Home
last modified time | relevance | path

Searched refs:wpos (Results 1 – 21 of 21) sorted by relevance

/openbsd/usr.sbin/lpd/
H A Diobuf.c93 left -= q->wpos - q->rpos; in iobuf_drain()
128 return io->size - io->wpos; in iobuf_left()
140 return io->wpos - io->rpos; in iobuf_len()
153 io->rpos = io->wpos = 0; in iobuf_drop()
196 io->rpos = io->wpos = 0; in iobuf_normalize()
201 io->wpos -= io->rpos; in iobuf_normalize()
220 io->wpos += n; in iobuf_read()
237 q->wpos = 0; in ioqbuf_alloc()
271 r = q->buf + q->wpos; in iobuf_reserve()
272 q->wpos += len; in iobuf_reserve()
[all …]
H A Diobuf.h23 size_t wpos; member
31 size_t wpos; member
/openbsd/usr.sbin/smtpd/
H A Diobuf.c88 left -= q->wpos - q->rpos; in iobuf_drain()
123 return io->size - io->wpos; in iobuf_left()
135 return io->wpos - io->rpos; in iobuf_len()
148 io->rpos = io->wpos = 0; in iobuf_drop()
190 io->rpos = io->wpos = 0; in iobuf_normalize()
195 io->wpos -= io->rpos; in iobuf_normalize()
214 io->wpos += n; in iobuf_read()
231 q->wpos = 0; in ioqbuf_alloc()
265 r = q->buf + q->wpos; in iobuf_reserve()
266 q->wpos += len; in iobuf_reserve()
[all …]
H A Denqueue.c121 size_t wpos; member
676 pstate.wpos = 0; in parse_addr()
686 pstate.wpos = 0; in parse_addr()
694 if (pstate.wpos >= sizeof(pstate.buf)) in parse_addr()
696 pstate.buf[pstate.wpos++] = s[pos]; in parse_addr()
723 if (pstate.wpos) { in parse_addr_terminal()
724 if (pstate.wpos >= sizeof(pstate.buf)) in parse_addr_terminal()
726 pstate.buf[pstate.wpos] = '\0'; in parse_addr_terminal()
731 pstate.wpos = 0; in parse_addr_terminal()
H A Diobuf.h22 size_t wpos; member
30 size_t wpos; member
H A Dmproc.c210 buf = ibuf->r.buf + ibuf->r.wpos; in imsg_read_nofd()
211 len = sizeof(ibuf->r.buf) - ibuf->r.wpos; in imsg_read_nofd()
218 ibuf->r.wpos += n; in imsg_read_nofd()
/openbsd/usr.sbin/rpki-client/
H A Dio.c154 if (buf->wpos + len > buf->max) { in ibuf_realloc()
159 b = recallocarray(buf->buf, buf->size, buf->wpos + len, 1); in ibuf_realloc()
163 buf->size = buf->wpos + len; in ibuf_realloc()
189 while ((n = read(fd, b->buf + b->wpos, b->size - b->wpos)) == -1) { in io_buf_read()
199 b->wpos += n; in io_buf_read()
202 if (b->wpos == b->size) { in io_buf_read()
204 if (b->wpos == sizeof(sz)) { in io_buf_read()
285 b->wpos += n; in io_buf_recvfd()
288 if (b->wpos == b->size) { in io_buf_recvfd()
290 if (b->wpos == sizeof(sz)) { in io_buf_recvfd()
/openbsd/usr.sbin/iscsid/
H A Dpdu.c237 iov[0].iov_base = c->prbuf.buf + c->prbuf.wpos; in pdu_read()
238 if (c->prbuf.wpos < c->prbuf.rpos) in pdu_read()
255 c->prbuf.wpos += n; in pdu_read()
256 if (c->prbuf.wpos >= c->prbuf.size) in pdu_read()
257 c->prbuf.wpos -= c->prbuf.size; in pdu_read()
409 if (rb->rpos == rb->wpos) { in pdu_readbuf_read()
411 } else if (rb->rpos < rb->wpos) { in pdu_readbuf_read()
412 l = PDU_MIN(rb->wpos - rb->rpos, len); in pdu_readbuf_read()
432 if (rb->rpos <= rb->wpos) in pdu_readbuf_len()
433 return rb->wpos - rb->rpos; in pdu_readbuf_len()
[all …]
H A Discsid.h144 size_t wpos; member
/openbsd/lib/libutil/
H A Dimsg-buffer.c92 if (len > SIZE_MAX - buf->wpos || buf->wpos + len > buf->max) { in ibuf_realloc()
97 b = recallocarray(buf->buf, buf->size, buf->wpos + len, 1); in ibuf_realloc()
101 buf->size = buf->wpos + len; in ibuf_realloc()
111 if (len > SIZE_MAX - buf->wpos || buf->max == 0) { in ibuf_reserve()
116 if (buf->wpos + len > buf->size) in ibuf_reserve()
120 b = buf->buf + buf->wpos; in ibuf_reserve()
121 buf->wpos += len; in ibuf_reserve()
351 return (buf->wpos - buf->rpos); in ibuf_size()
359 return (buf->max - buf->wpos); in ibuf_left()
366 buf->wpos = buf->rpos + len; in ibuf_truncate()
[all …]
H A Dimsg.c69 iov.iov_base = imsgbuf->r.buf + imsgbuf->r.wpos; in imsg_read()
70 iov.iov_len = sizeof(imsgbuf->r.buf) - imsgbuf->r.wpos; in imsg_read()
94 imsgbuf->r.wpos += n; in imsg_read()
135 av = imsgbuf->r.wpos; in imsg_get()
172 imsgbuf->r.wpos = left; in imsg_get()
174 imsgbuf->r.wpos = 0; in imsg_get()
H A Dimsg.h36 size_t wpos; member
50 size_t wpos; member
/openbsd/gnu/llvm/llvm/utils/TableGen/
H A DCodeGenInstruction.cpp306 StringRef::size_type wpos = CStr.find_first_of(" \t"); in ParseConstraint() local
308 StringRef Tok = CStr.substr(start, wpos - start); in ParseConstraint()
310 StringRef Name = CStr.substr(wpos+1); in ParseConstraint()
311 wpos = Name.find_first_not_of(" \t"); in ParseConstraint()
312 if (wpos == StringRef::npos) in ParseConstraint()
316 Name = Name.substr(wpos); in ParseConstraint()
338 wpos = CStr.find_first_of(" \t", start); in ParseConstraint()
339 if (wpos == StringRef::npos || wpos > pos) in ParseConstraint()
346 wpos = CStr.find_first_not_of(" \t", pos + 1); in ParseConstraint()
347 if (wpos == StringRef::npos) in ParseConstraint()
[all …]
/openbsd/lib/libsndio/
H A Dsio.c462 long long wpos, wdiff; in _sio_printpos() local
473 wpos = (hdl->mode & SIO_PLAY) ? in _sio_printpos()
488 wdiff = wpos % wround; in _sio_printpos()
489 wpos = wpos / wround; in _sio_printpos()
491 wpos++; in _sio_printpos()
497 cpos, cdiff, wpos, wdiff, rpos, rdiff); in _sio_printpos()
/openbsd/usr.sbin/bgpd/
H A Drde_attr.c773 int l, overflow = 0, shift = 0, size, wpos = 0; in aspath_prepend() local
819 p[wpos++] = AS_SEQUENCE; in aspath_prepend()
820 p[wpos++] = overflow; in aspath_prepend()
823 memcpy(p + wpos, &as, sizeof(uint32_t)); in aspath_prepend()
824 wpos += sizeof(uint32_t); in aspath_prepend()
829 p[wpos++] = AS_SEQUENCE; in aspath_prepend()
830 p[wpos++] = quantum + size; in aspath_prepend()
833 memcpy(p + wpos, &as, sizeof(uint32_t)); in aspath_prepend()
834 wpos += sizeof(uint32_t); in aspath_prepend()
837 memcpy(p + wpos, asp->data + shift, asp->len - shift); in aspath_prepend()
H A Dcontrol.c599 buf = imsgbuf->r.buf + imsgbuf->r.wpos; in imsg_read_nofd()
600 len = sizeof(imsgbuf->r.buf) - imsgbuf->r.wpos; in imsg_read_nofd()
607 imsgbuf->r.wpos += n; in imsg_read_nofd()
H A Drtr_proto.c1014 ibuf_from_buffer(&rbuf, rs->r.buf, rs->r.wpos); in rtr_process_msg()
1077 rs->r.wpos = ibuf_size(&rbuf); in rtr_process_msg()
1115 rs->r.wpos = 0; in rtr_fsm()
1221 rs->r.wpos = 0; in rtr_fsm()
1265 if ((n = read(rs->fd, rs->r.buf + rs->r.wpos, in rtr_dispatch_msg()
1266 sizeof(rs->r.buf) - rs->r.wpos)) == -1) { in rtr_dispatch_msg()
1277 rs->r.wpos += n; in rtr_dispatch_msg()
H A Dsession.c416 if (p->rpending && p->rbuf && p->rbuf->wpos) in session_main()
504 if (p->rbuf && p->rbuf->wpos) in session_main()
1955 if ((n = read(p->fd, p->rbuf->buf + p->rbuf->wpos, in session_dispatch_msg()
1956 sizeof(p->rbuf->buf) - p->rbuf->wpos)) == -1) { in session_dispatch_msg()
1968 p->rbuf->wpos += n; in session_dispatch_msg()
1985 av = p->rbuf->wpos; in session_process_msg()
2056 p->rbuf->wpos = left; in session_process_msg()
2058 p->rbuf->wpos = 0; in session_process_msg()
/openbsd/usr.sbin/ldpd/
H A Dpacket.c436 if ((n = read(fd, tcp->rbuf->buf + tcp->rbuf->wpos, in session_read()
437 sizeof(tcp->rbuf->buf) - tcp->rbuf->wpos)) == -1) { in session_read()
452 tcp->rbuf->wpos += n; in session_read()
659 av = r->wpos; in session_get_pdu()
675 r->wpos = left; in session_get_pdu()
677 r->wpos = 0; in session_get_pdu()
/openbsd/sbin/iked/
H A Dimsg_util.c120 buf->wpos = len; in ibuf_setsize()
/openbsd/usr.sbin/radiusd/
H A Dradiusd.c1088 if (evmask & EV_READ || module->ibuf.r.wpos > IMSG_HEADER_SIZE) { in radiusd_module_on_imsg_io()
1127 } else if (module->ibuf.r.wpos > IMSG_HEADER_SIZE) in radiusd_module_reset_ev_handler()