Lines Matching refs:file
53 fixedident(Dssfile_t* file, void* buf, size_t n, Dssdisc_t* disc)
65 file->skip = sizeof(Netflow_t);
66 file->ident = swap;
77 fixedopen(Dssfile_t* file, Dssdisc_t* disc)
79 if (file->flags & DSS_FILE_READ)
81 if (!sfreserve(file->io, file->skip, 0))
87 if (!(file->data = (void*)vmnewof(file->dss->vm, 0, State_t, 1, 0)))
93 ((State_t*)file->data)->swap = file->ident;
95 else if (!(file->flags & DSS_FILE_APPEND))
105 sfwrite(file->io, &hdr, sizeof(hdr));
115 fixedread(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc)
117 register State_t* state = (State_t*)file->data;
120 if (!(rp = (Netflow_t*)sfreserve(file->io, sizeof(*rp), 0)))
122 if (sfvalue(file->io))
125 (*disc->errorf)(NiL, disc, 2, "%slast record incomplete", cxlocation(file->dss->cx, record));
143 fixedwrite(Dssfile_t* file, Dssrecord_t* record, Dssdisc_t* disc)
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));
159 fixedclose(Dssfile_t* file, Dssdisc_t* disc)
161 if (file->data)
162 vmfree(file->dss->vm, file->data);