Lines Matching refs:recvbuf
256 } recvbuf;
744 INSIST(sock->recvbuf.remaining == 0);
747 iov[0].len = sock->recvbuf.len;
748 iov[0].buf = sock->recvbuf.base;
759 sock->recvbuf.from_addr_len = sizeof(sock->recvbuf.from_addr);
764 (SOCKADDR *)&sock->recvbuf.from_addr,
765 &sock->recvbuf.from_addr_len,
1213 INSIST(sock->recvbuf.remaining > 0);
1217 dev->address.length = sock->recvbuf.from_addr_len;
1218 memmove(&dev->address.type, &sock->recvbuf.from_addr,
1219 sock->recvbuf.from_addr_len);
1227 sock->recvbuf.remaining = 0;
1241 while (buffer != NULL && sock->recvbuf.remaining > 0) {
1246 sock->recvbuf.remaining);
1247 memmove(r.base, sock->recvbuf.consume_position,
1249 sock->recvbuf.consume_position += copylen;
1250 sock->recvbuf.remaining -= copylen;
1257 copylen = min(dev->region.length - dev->n, sock->recvbuf.remaining);
1259 sock->recvbuf.consume_position, copylen);
1260 sock->recvbuf.consume_position += copylen;
1261 sock->recvbuf.remaining -= copylen;
1272 sock->recvbuf.remaining = 0;
1291 while (sock->recvbuf.remaining > 0 && !ISC_LIST_EMPTY(sock->recv_list)) {
1482 sock->recvbuf.len = 65536;
1483 sock->recvbuf.consume_position = sock->recvbuf.base;
1484 sock->recvbuf.remaining = 0;
1485 sock->recvbuf.base = isc_mem_get(manager->mctx, sock->recvbuf.len); // max buffer size
1486 if (sock->recvbuf.base == NULL) {
1507 if (sock->recvbuf.base != NULL)
1508 isc_mem_put(manager->mctx, sock->recvbuf.base, sock->recvbuf.len);
1619 if (sock->recvbuf.base != NULL)
1620 isc_mem_put(manager->mctx, sock->recvbuf.base,
1621 sock->recvbuf.len);
2212 sock->recvbuf.remaining = nbytes;
2213 sock->recvbuf.consume_position = sock->recvbuf.base;