/ast/src/cmd/dsslib/netflow/ |
H A D | flow-fixed.c | 115 fixedread(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 125 (*disc->errorf)(NiL, disc, 2, "%slast record incomplete", cxlocation(file->dss->cx, record)); 133 record->data = rp; 134 record->size = sizeof(*rp); 143 fixedwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 145 if (sfwrite(file->io, record->data, sizeof(Netflow_t)) != sizeof(Netflow_t)) 148 (*disc->errorf)(NiL, disc, 2, "%swrite error", cxlocation(file->dss->cx, record));
|
H A D | flow-flat.c | 32 Netflow_t record; member in struct:State_s 85 flatread(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 87 register Netflow_t* rp = &((State_t*)file->data)->record; 97 (*disc->errorf)(NiL, disc, 2, "%slast record incomplete", cxlocation(file->dss->cx, record)); 161 record->data = rp; 162 record->size = sizeof(*rp); 169 (*disc->errorf)(NiL, disc, 2, "%s%-.*s<<<: invalid %s record field", cxlocation(file->dss->cx, record), a - s, s, file->format->name); 181 flatwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_ argument [all...] |
H A D | flow-dumpv9.c | 75 dumpv9fread(register Dssfile_t* file, register Dssrecord_t* record, Dssdisc_t* disc) argument 79 register Netflow_t* rp = &pp->record; 123 sfprintf(sfstderr, "record %d flowset %d\n", file->count, rp->count - pp->count); 139 (*disc->errorf)(NiL, disc, 1, "%s%d: undefined template -- flowset ignored", cxlocation(file->dss->cx, record), n); 145 /* HERE: add an options indicator to the record schema instead of discarding? */ 268 (*disc->errorf)(NiL, disc, 1, "%s%d: template index %d definition ignored", cxlocation(file->dss->cx, record), n); 274 record->size = sizeof(*rp); 275 record->data = rp; 279 (*disc->errorf)(NiL, disc, ERROR_SYSTEM|2, "%sheader corrupt", cxlocation(file->dss->cx, record)); 283 (*disc->errorf)(NiL, disc, 2, "%slast packet incomplete", cxlocation(file->dss->cx, record)); 292 dumpv9fwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument [all...] |
H A D | flowlib.h | 73 Netflow_t record; member in struct:Netflow_file_s
|
H A D | flow-dump.c | 148 Netflow_t record; member in struct:State_s 212 dumpfread(register Dssfile_t* file, register Dssrecord_t* record, Dssdisc_t* disc) argument 215 register Netflow_t* rp = &state->record; 226 (*disc->errorf)(NiL, disc, 2, "%slast packet incomplete", cxlocation(file->dss->cx, record)); 275 (*disc->errorf)(NiL, disc, ERROR_SYSTEM|2, "%sheader corrupted", cxlocation(file->dss->cx, record)); 340 record->size = sizeof(*rp); 341 record->data = rp; 350 dumpfwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 353 register Netflow_t* rp = (Netflow_t*)record->data; 407 (*disc->errorf)(NiL, disc, 2, "%s%d: record versio [all...] |
H A D | flow-tool.c | 187 Netflow_t record; member in struct:State_s 319 state->record.version = state->version; 328 ftfread(register Dssfile_t* file, register Dssrecord_t* record, Dssdisc_t* disc) argument 331 register Netflow_t* rp = &state->record; 348 (*disc->errorf)(NiL, disc, 2, "%slast packet incomplete", cxlocation(file->dss->cx, record)); 504 record->size = sizeof(*rp); 505 record->data = rp; 514 ftfwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 517 register Netflow_t* rp = (Netflow_t*)record->data;
|
/ast/src/cmd/dsslib/opaque/ |
H A D | opaque.c | 29 "[+DESCRIPTION?The \bdss\b opaque method handles anonymous fixed record " 32 "[s:size?The fixed record size; must be specified.]#[size]" 114 opaqueread(register Dssfile_t* file, register Dssrecord_t* record, Dssdisc_t* disc) argument 116 record->data = sfreserve(file->io, *((size_t*)file->data), 0); 117 record->size = sfvalue(file->io); 118 if (record->data) 120 if (record->size && disc->errorf) 121 (*disc->errorf)(NiL, disc, 2, "%slast record truncated -- record ignored", cxlocation(file->dss->cx, record)); 130 opaquewrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument [all...] |
/ast/src/lib/libdss/ |
H A D | dssmisc.c | 75 dsseval(Dss_t* dss, Dssexpr_t* expr, Dssrecord_t* record) argument 81 return cxeval(dss->cx, expr, record, &cv); 122 dssget(Dssrecord_t* record, Dssvariable_t* variable, Dsstype_t* type, const char* details, Dssvalue_t* value) argument 126 if (cxcast(record->file->dss->cx, &ret, variable, type, record, details))
|
H A D | dssfile.c | 38 noreadf(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 50 nullreadf(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 60 nowritef(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 233 file->record.file = file; 286 if ((r = (*file->readf)(file, &file->record, file->dss->disc)) <= 0) 294 return &file->record; 302 dssfwrite(Dssfile_t* file, Dssrecord_t* record) argument 304 return (*file->writef)(file, record, file->dss->disc); 328 * save record state 332 dsssave(Dssrecord_t* record) argument 342 dssdrop(Dssrecord_t* record) argument 352 dss_no_fread(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 360 dss_no_fwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument [all...] |
H A D | dss-scan.h | 46 Dssrecord_t* record; local 108 while (record = dssfread(ip)) 109 if (dsseval(dss, expr, record) < 0)
|
H A D | dsslib.h | 50 Dssrecord_t record; \
|
/ast/src/cmd/pax/ |
H A D | pax-slt.c | 127 error(2, "%s: %-*.*s: variable length label record too short", f->name, c, c, slt->buf); 165 sfsprintf(slt->buf, sizeof(slt->buf), "%s1%-17.17s000001%04d%04d000100 %02d%03d 00000 %06d%-6.6sD%-7.7s ", type, f->id, slt->section, slt->sequence, tm->tm_year, tm->tm_yday, f->record.blocks, slt->format, slt->implementation); 167 sfsprintf(slt->buf, sizeof(slt->buf), "%s2%c%05d%05d%010d%s%c 00 ", type, state.record.format, state.blocksize, state.record.size, f->st->st_size, type, '2'); 309 f->record.section = getlabnum(slt->buf, 28, 4, 10); 334 switch (f->record.format = slt->buf[4]) 343 error(2, "%s record format %c not supported", ap->format->name, f->record.format); 347 state.record.size = getlabnum(slt->buf, 11, 5, 10); 349 state.record [all...] |
H A D | pax-vdb.c | 203 complete(ap, f, state.record.header ? state.record.headerlen : f->namesize); 204 if (state.record.header) 205 paxwrite(pax, ap, state.record.header, state.record.headerlen); 212 if (!(c = state.record.delimiter)) 267 if (state.record.trailer) 268 paxwrite(pax, ap, state.record.trailer, state.record.trailerlen); 277 if (state.record [all...] |
H A D | pax.c | 1128 state.record.charset = y; 1132 state.record.delimiter = 0; 1134 state.record.delimiter = *v; 1137 state.record.format = y ? *v : 0; 1142 state.record.header = 0; 1143 state.record.headerlen = 0; 1145 else if (!(state.record.headerlen = stresc(state.record.header = strdup(v)))) 1146 state.record.headerlen = 1; 1149 state.record [all...] |
/ast/src/lib/libast/regex/ |
H A D | regrexec.c | 25 * posix regex record executor 26 * multiple record sized-buffer interface 36 regrexec(const regex_t* p, const char* s, size_t len, size_t nmatch, regmatch_t* match, regflags_t flags, int sep, void* handle, regrecord_t record) argument 119 if (n = (*record)(handle, (char*)beg, x - beg)) 124 else if (n = (*record)(handle, (char*)l, r - l)) 128 n = (inv && (++r - buf) < len) ? (*record)(handle, (char*)r, (buf + len) - r): 0; 161 regrexec(const regex_t* p, const char* s, size_t len, size_t nmatch, oldregmatch_t* oldmatch, regflags_t flags, int sep, void* handle, regrecord_t record) argument 171 if (!(r = regrexec_20120528(p, s, len, nmatch, match, flags, sep, handle, record))) 180 return regrexec_20120528(p, s, len, 0, NiL, flags, sep, handle, record);
|
/ast/src/cmd/dsslib/bgp/ |
H A D | bgp-fixed.c | 114 fixedread(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 124 (*disc->errorf)(NiL, disc, 2, "%s: last record incomplete", file->format->name); 143 record->data = rp; 144 record->size = rp->size; 153 fixedwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 155 if (sfwrite(file->io, record->data, sizeof(Bgproute_t)) != sizeof(Bgproute_t))
|
H A D | bgp-ciscov6.c | 121 ciscov6read(register Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 184 record->data = rp; 185 record->size = rp->size = (char*)(rp->data + o) - (char*)rp; 196 ciscov6write(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 200 register Bgproute_t* rp = (Bgproute_t*)record->data;
|
H A D | bgp-table.c | 109 tableread(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 189 record->data = rp; 190 record->size = BGP_FIXED; 201 tablewrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 203 register Bgproute_t* rp = (Bgproute_t*)record->data;
|
H A D | bgp-ipma.c | 215 ipmaread(register Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 327 record->data = rp; 328 record->size = rp->size = (char*)(rp->data + i) - (char*)rp; 339 ipmawrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 342 register Bgproute_t* rp = (Bgproute_t*)record->data;
|
H A D | bgp-cisco.c | 112 ciscoread(register Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 283 record->data = rp; 284 record->size = rp->size = (char*)(rp->data + o) - (char*)rp; 296 ciscowrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 299 register Bgproute_t* rp = (Bgproute_t*)record->data;
|
/ast/src/cmd/dsslib/xml/ |
H A D | xml.c | 60 struct Value_s /* value in current record */ 62 uintmax_t record; /* record number for value */ member in struct:Value_s 71 uintmax_t record; /* current record number */ member in struct:File_s 73 unsigned char* rec; /* input record position */ 78 char* value; /* current record tag values */ 79 int image; /* keep current record image */ 266 * xml readf -- consume 1 xml record and retain field values of interest 270 xmlread(Dssfile_t* file, Dssrecord_t* record, Dssdisc_ argument 455 xmlwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument 648 jsonread(register Dssfile_t* file, register Dssrecord_t* record, Dssdisc_t* disc) argument 934 jsonwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc) argument [all...] |
/ast/src/cmd/tests/sfio/ |
H A D | tmwrite.c | 39 char record[N_WRITER][128], *s; local 44 /* create random record sizes */ 52 record[i][r] = '0'+i; 69 memcpy(s,record[i],r-1); 85 terror("Wrong record type"); 89 terror("Bad record%d, count=%d", i, count[i]);
|
H A D | tmprocess.c | 48 terror("Not writing a whole record"); 54 terror("Bad record"); 73 char record[N_PROC][128], *s, *file; local 80 /* create pseudo-random record sizes */ 91 record[i][r] = '0' + 2*i; 124 memcpy(s,record[i],n-1); 149 terror("%d: Wrong record type", n);
|
/ast/src/cmd/dsslib/merge/ |
H A D | merge.c | 45 Dssrecord_t* record; member in struct:File_s 113 if (file->record) 115 if (file->record = dssfread(file->file)) 120 if ((*state->getf)(state->cx, &x, file->data + k, NiL, NiL, file->record, state->cx->disc)) 269 if (dsseval(dss, expr, file->record) < 0)
|
/ast/src/lib/libjcl/ |
H A D | jcllib.h | 131 char* record; \
|