Searched defs:dss (Results 1 - 17 of 17) sorted by relevance

/ast/src/lib/libdss/
H A Ddssmagic.c22 * dss generic magic number support
33 dssmagic(Dss_t* dss, Sfio_t* sp, const char* name, const char* type, uint32_t version, size_t size) argument
41 name = dss->id;
53 if (dss->disc->errorf)
54 (*dss->disc->errorf)(dss, dss->disc, ERROR_SYSTEM|2, "magic header write error");
H A Ddss-scan.h27 "[-1ls5P?\n@(#)$Id: dss scan query (AT&T Research) 2011-06-15 $\n]"
40 Dss_t* dss = DSS(cx); local
101 if (ip = dssfopen(dss, file, NiL, DSS_FILE_READ, NiL))
103 if (dssbeg(dss, expr))
109 if (dsseval(dss, expr, record) < 0)
H A Ddssmisc.c22 * dss misc support
33 dsscomp(Dss_t* dss, const char* s, Sfio_t* sp) argument
44 if (dss->disc->errorf)
45 (*dss->disc->errorf)(dss, dss->disc, 2, "%s: cannot read expression file", s);
53 if (!(pop = cxpush(dss->cx, file, sp, s, -1, CX_INCLUDE)))
55 expr = cxcomp(dss->cx);
56 cxpop(dss->cx, pop);
65 dssbeg(Dss_t* dss, Dssexpr_ argument
75 dsseval(Dss_t* dss, Dssexpr_t* expr, Dssrecord_t* record) argument
90 dssend(Dss_t* dss, Dssexpr_t* expr) argument
100 dsslist(Dss_t* dss, Dssexpr_t* expr, Sfio_t* sp) argument
110 dssfree(Dss_t* dss, Dssexpr_t* expr) argument
137 dsstype(Dss_t* dss, const char* name) argument
147 dssvariable(Dss_t* dss, const char* name) argument
[all...]
H A Ddssfile.c22 * dss file support
72 dssfopen(Dss_t* dss, const char* path, Sfio_t* io, Dssflags_t flags, Dssformat_t* format) argument
90 n = top.disc == &dss->state->compress_preferred;
95 sfdczip(io, path, dss->meth->compress ? dss->meth->compress : "gzip", dss->disc->errorf);
99 if (dss->flags & DSS_APPEND)
129 if (dss->disc->errorf)
130 (*dss->disc->errorf)(NiL, dss
250 Dss_t* dss; local
[all...]
H A Ddssprintf.c22 * dss printf implementation
164 dssprintf(Dss_t* dss, Cx_t* cx, Sfio_t* sp, const char* format, Dssrecord_t* record) argument
182 cx = dss->cx;
183 for (fp = dss->print; fp && fp->oformat != (char*)format; fp = fp->next);
203 if (dss->disc->errorf)
204 (*dss->disc->errorf)(NiL, dss->disc, 2, "%s: format character omitted", f);
269 if (!(fp = vmnewof(dss->vm, 0, Format_t, 1, (n - 1) * sizeof(Arg_t) + strlen(format) + 2 * n + l + 2)))
271 if (dss->disc->errorf)
272 (*dss
[all...]
H A Ddss.h31 #define DSS_ID "dss"
97 Dssdisc_t* disc; /* dss disc */
130 Dss_t* dss; /* dss handle */ member in struct:Dssfile_s
159 Dss_t* dss; /* most recent dssopen() */ member in struct:Dssstate_s
167 struct Dss_s /* dss handle */
H A Ddssopen.c22 * dss open/close/library/method implementation
29 "[-1ls5P?\n@(#)$Id: dss library (AT&T Research) 2012-05-31 $\n]"
38 "\b../lib/dss\b sibling directory on \b$PATH\b. The supported tags are:]"
125 * dss identf
149 * dss openf
159 * dss readf
169 * dss writef
179 * dss seekf
189 * dss closef
222 * dss meth
555 register Dss_t* dss; local
638 dssclose(register Dss_t* dss) argument
804 dssrun(Dss_t* dss, const char* expression, const char* head, const char* tail, char** argv) argument
[all...]
/ast/src/cmd/dss/
H A Ddss.c34 "[-?\n@(#)$Id: dss (AT&T Research) 2011-09-11 $\n]"
36 "[+NAME?dss - scan a data stream and apply a select expression to each "
77 "files. The default \b../lib/dss\b directories on \b$PATH\b are added to "
81 "[m:map?Numeric field value map XML file. \b--method=dss,man\b describes "
109 "[0xf000?dss library specific tests]"
121 "[+dss -x dss '{stats --man}'?List the \bstats\b query manpage.]"
122 "[+dss -x bgp '{write --man}'?List the formats supported by the "
124 "[+dss -x netflow \"{stats --group=prot bytes packets}\" *.gz?List "
127 "[+dss
192 Dss_t* dss; local
[all...]
/ast/src/cmd/dsslib/netflow/
H A Dnetflow.c159 Netflow_method_t* gp = (Netflow_method_t*)(((Dssrecord_t*)(data))->file)->dss->data;
786 netflowopen(Dss_t* dss, Dssdisc_t* disc) argument
790 if (!(flow = vmnewof(dss->vm, 0, Netflow_method_t, 1, 0)) ||
791 !(flow->type_ipv4addr = cxtype(dss->cx, "ipv4addr_t", disc)) ||
792 !(flow->type_ipv4prefix = cxtype(dss->cx, "ipv4prefix_t", disc)) ||
793 !(flow->type_ipv6addr = cxtype(dss->cx, "ipv6addr_t", disc)) ||
794 !(flow->type_ipv6prefix = cxtype(dss->cx, "ipv6prefix_t", disc)) ||
798 vmfree(dss->vm, flow);
804 dss->data = flow;
826 "[-1ls5Pp0?\n@(#)$Id: dss netflo
[all...]
/ast/src/cmd/dsslib/merge/
H A Dmerge.c60 Dss_t* dss; member in struct:State_s
107 enter(Dss_t* dss, register State_t* state, register File_t* file) argument
134 Dss_t* dss = DSS(cx); local
250 if (!(state->files[n].file = dssfopen(dss, path, NiL, DSS_FILE_READ, NiL)))
252 enter(dss, state, &state->files[n]);
265 if (dssbeg(dss, expr))
269 if (dsseval(dss, expr, file->record) < 0)
271 enter(dss, state, file);
305 "[-1lms5P?\n@(#)$Id: dss merge query (AT&T Research) 2003-02-14 $\n]"
/ast/src/cmd/dsslib/text/
H A Dtext.c36 " [+dss -x text::::\b\"%(name)s::%(passwd::Encrypted\\ password.)s::%(uid)d::%(gid)d::%(comment)s::%(home)s::%(shell)s\"\\ 'passwd==\"\"&&uid==0'\\ "
81 if (!(file->data = vmnewof(file->dss->vm, 0, Cxvalue_t, ((Text_t*)file->dss->meth->data)->vars, 0)))
99 vmfree(file->dss->vm, file->data);
194 register Text_t* text = (Text_t*)file->dss->meth->data;
333 register Text_t* text = (Text_t*)file->dss->meth->data;
651 textopen(Dss_t* dss, Dssdisc_t* disc) argument
653 return dss->meth->data ? 0 : -1;
673 "[-1ls5Pp0?\n@(#)$Id: dss text method (AT&T Research) 2002-12-17 $\n]"
/ast/src/cmd/dsslib/bgp/
H A Dbgp.c622 bgpopen(Dss_t* dss, Dssdisc_t* disc) argument
626 if (!(bgp = vmnewof(dss->vm, 0, Bgp_t, 1, 0)) ||
627 !(bgp->type_as16path = cxtype(dss->cx, "as16path_t", disc)) ||
628 !(bgp->type_as32path = cxtype(dss->cx, "as32path_t", disc)) ||
629 !(bgp->type_cluster = cxtype(dss->cx, "cluster_t", disc)) ||
630 !(bgp->type_community = cxtype(dss->cx, "community_t", disc)) ||
631 !(bgp->type_extended = cxtype(dss->cx, "extended_t", disc)) ||
632 !(bgp->type_ipv4addr = cxtype(dss->cx, "ipv4addr_t", disc)) ||
633 !(bgp->type_ipv4prefix = cxtype(dss->cx, "ipv4prefix_t", disc)) ||
634 !(bgp->type_ipv6addr = cxtype(dss
653 bgpclose(Dss_t* dss, Dssdisc_t* disc) argument
[all...]
/ast/src/cmd/sortlib/sum/
H A Dsortsum.c67 "[+dlls --base dss | grep '_t$'?Lists the \bdss\b(1) type "
69 "[+dss --plugin=man num_t?Lists the \bdss\b(1) \bnum_t\b type "
79 #include <dss.h>
126 Dss_t* dss; member in struct:State_s
146 if (!(b->buf = vmnewof(state->dss->vm, b->buf, unsigned char, b->siz, 0)))
158 Cx_t* cx = state->dss->cx;
402 dssclose(state->dss);
428 Dss_t* dss; local
441 if (!(dss = dssopen(0, 0, &disc, dssmeth("dss",
[all...]
/ast/src/cmd/dsslib/xml/
H A Dxml.c335 if (v = dtmatch(file->dss->cx->variables, f->part[f->prefix] + 1))
407 if (v = dtmatch(file->dss->cx->variables, f->part[f->prefix] + 1))
484 register Xml_t* xml = (Xml_t*)file->dss->meth->data;
502 xml->image = !!(file->dss->flags & DSS_WRITE);
754 if (v = dtmatch(file->dss->cx->variables, f->part[f->prefix] + 1))
774 if (v = dtmatch(file->dss->cx->variables, f->part[f->prefix] + 1))
1270 xmlopen(Dss_t* dss, Dssdisc_t* disc) argument
1272 Xml_t* xml = (Xml_t*)dss->meth->data;
1280 dss->cx->ctype['.'] |= CX_CTYPE_ALPHA;
1282 if (cxaddcallout(dss
[all...]
/ast/src/cmd/kshlib/dss/
H A Ddss.c22 * dss type library
49 Dssoptdisc_t dss; member in struct:Optdisc
121 Dss_t *dss; member in struct:parent
135 Dss_t *dss = dp->dss; local
138 Cx_t *cx = dss->cx;
230 sfprintf(stkstd,"dss.%s",name);
237 /* create reference variable name to NV_CLASS.dss.name */
241 sfprintf(stkstd,NV_CLASS".dss.%s",name);
417 if(!pp->dss || v
1150 Dss_t *dss=0; local
[all...]
/ast/src/cmd/dsslib/ip_t/
H A Dip_t.c24 * dss ip type library
718 Dss_t* dss; local
750 else if ((meth = dssmeth("bgp", disc)) && (dss = dssopen(0, 0, disc, meth)))
752 if (ip = dssfopen(dss, s + 1, NiL, DSS_FILE_READ, NiL))
763 dssclose(dss);
779 Dss_t* dss; local
810 else if ((meth = dssmeth("bgp", disc)) && (dss = dssopen(0, 0, disc, meth)))
812 if (ip = dssfopen(dss, s + 1, NiL, DSS_FILE_READ, NiL))
823 dssclose(dss);
1001 "[-?\n@(#)$Id: dss i
[all...]
/ast/src/cmd/dsslib/flat/
H A Dflat.c31 "schemas are usually placed in a \b../lib/dss\b sibling directory on "
90 Dss_t* dss; /* output method stream */ member in struct:Flatten_s
92 Cx_t* cx; /* dss->cx */
93 Flat_t* flat; /* dss->meth->data */
95 Cxcallout_f getf; /* dss->cx->getf */
156 Dss_t* dss; /* dss handle */ member in struct:Record_s
158 Dssrecord_t* record; /* dss record handle */
385 if (r->dss->disc->errorf)
386 (*r->dss
3368 flatopen(Dss_t* dss, Dssdisc_t* disc) argument
[all...]

Completed in 768 milliseconds