Searched refs:record (Results 1 - 25 of 45) sorted by relevance

12

/ast/src/cmd/dsslib/netflow/
H A Dflow-fixed.c115 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 Dflow-flat.c32 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 Dflow-dumpv9.c75 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 Dflowlib.h73 Netflow_t record; member in struct:Netflow_file_s
H A Dflow-dump.c148 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 Dflow-tool.c187 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 Dopaque.c29 "[+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 Ddssmisc.c75 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 Ddssfile.c38 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 Ddss-scan.h46 Dssrecord_t* record; local
108 while (record = dssfread(ip))
109 if (dsseval(dss, expr, record) < 0)
H A Ddsslib.h50 Dssrecord_t record; \
/ast/src/cmd/pax/
H A Dpax-slt.c127 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 Dpax-vdb.c203 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 Dpax.c1128 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 Dregrexec.c25 * 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 Dbgp-fixed.c114 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 Dbgp-ciscov6.c121 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 Dbgp-table.c109 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 Dbgp-ipma.c215 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 Dbgp-cisco.c112 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 Dxml.c60 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 Dtmwrite.c39 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 Dtmprocess.c48 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 Dmerge.c45 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 Djcllib.h131 char* record; \

Completed in 748 milliseconds

12