Lines Matching defs:pz
25 * sync outstanding data in a pz stream
29 pzsync(register Pz_t* pz)
43 op = pz->ws.io ? pz->ws.io : pz->io;
44 if (pz->ws.bp)
50 pz->ws.bp = 0;
51 pp = pz->part;
52 if (pz->flags & PZ_SORT)
54 pz->flags &= ~PZ_SORT;
55 elt = (Pzelt_t*)dtfirst(pz->sort.order);
57 while (elt && pzwrite(pz, op, elt->buf, n) == n)
60 elt = (Pzelt_t*)dtnext(pz->sort.order, elt);
61 dtdelete(pz->sort.order, old);
62 dtinsert(pz->sort.free, old);
64 r = pzsync(pz);
65 pz->flags |= PZ_SORT;
66 pz->ws.bp = pz->buf;
69 tmp = pz->tmp;
70 n = pz->ws.row;
71 if (pz->flags & PZ_SECTION)
72 pz->count.sections++;
74 pz->count.windows++;
75 pz->count.records += pz->ws.rep;
76 sfputu(tmp, pz->ws.rep);
86 pp->mix[0] = buf = pz->wrk;
93 buf = pz->buf;
102 buf = pz->wrk;
108 if (pz->disc->errorf)
109 (*pz->disc->errorf)(pz, pz->disc, ERROR_SYSTEM|2, "hi frequency write error");
130 m = pz->ws.vp - pz->val;
132 if (sfwrite(op, pz->val, m) != m || sfsync(op))
134 if (pz->disc->errorf)
135 (*pz->disc->errorf)(pz, pz->disc, ERROR_SYSTEM|2, "lo frequency value write error");
141 if (pz->disc->errorf)
142 (*pz->disc->errorf)(pz, pz->disc, ERROR_SYSTEM|2, "lo frequency code write error");
146 else if ((pz->flags & PZ_WRITE) && sfsync(op))
148 if (pz->disc->errorf)
149 (*pz->disc->errorf)(pz, pz->disc, ERROR_SYSTEM|2, "write error");