Lines Matching refs:res
1306 int res = strlen(tmpbuf); in complete_incr_bin() local
1308 res + 2); in complete_incr_bin()
1311 memcpy(ITEM_data(it), tmpbuf, res); in complete_incr_bin()
1312 memcpy(ITEM_data(it) + res, "\r\n", 2); in complete_incr_bin()
3537 int res; in do_add_delta() local
3584 res = strlen(buf); in do_add_delta()
3588 if (res + 2 <= it->nbytes && it->refcount == 2) { /* replace in-place */ in do_add_delta()
3597 memcpy(ITEM_data(it), buf, res); in do_add_delta()
3598 memset(ITEM_data(it) + res, ' ', it->nbytes - res - 2); in do_add_delta()
3603 new_it = do_item_alloc(ITEM_key(it), it->nkey, flags, it->exptime, res + 2); in do_add_delta()
3608 memcpy(ITEM_data(new_it), buf, res); in do_add_delta()
3609 memcpy(ITEM_data(new_it) + res, "\r\n", 2); in do_add_delta()
4175 int res; in try_read_udp() local
4180 res = recvfrom(c->sfd, c->rbuf, c->rsize, in try_read_udp()
4183 if (res > 8) { in try_read_udp()
4186 c->thread->stats.bytes_read += res; in try_read_udp()
4199 res -= 8; in try_read_udp()
4200 memmove(c->rbuf, c->rbuf + 8, res); in try_read_udp()
4202 c->rbytes = res; in try_read_udp()
4223 int res; in try_read_network() local
4257 res = read(c->sfd, c->rbuf + c->rbytes, avail); in try_read_network()
4258 if (res > 0) { in try_read_network()
4260 c->thread->stats.bytes_read += res; in try_read_network()
4263 c->rbytes += res; in try_read_network()
4264 if (res == avail) { in try_read_network()
4270 if (res == 0) { in try_read_network()
4273 if (res == -1) { in try_read_network()
4358 ssize_t res; in transmit() local
4361 res = sendmsg(c->sfd, m, 0); in transmit()
4362 if (res > 0) { in transmit()
4364 c->thread->stats.bytes_written += res; in transmit()
4369 while (m->msg_iovlen > 0 && res >= m->msg_iov->iov_len) { in transmit()
4370 res -= m->msg_iov->iov_len; in transmit()
4377 if (res > 0) { in transmit()
4378 m->msg_iov->iov_base = (caddr_t)m->msg_iov->iov_base + res; in transmit()
4379 m->msg_iov->iov_len -= res; in transmit()
4383 if (res == -1 && (errno == EAGAIN || errno == EWOULDBLOCK)) { in transmit()
4413 int res; in read_into_chunked_item() local
4437 res = read(c->sfd, ch->data + ch->used, in read_into_chunked_item()
4439 if (res > 0) { in read_into_chunked_item()
4441 c->thread->stats.bytes_read += res; in read_into_chunked_item()
4443 ch->used += res; in read_into_chunked_item()
4444 total += res; in read_into_chunked_item()
4445 c->rlbytes -= res; in read_into_chunked_item()
4448 total = res; in read_into_chunked_item()
4473 int res; in drive_machine() local
4528 res = write(sfd, str, strlen(str)); in drive_machine()
4554 res = IS_UDP(c->transport) ? try_read_udp(c) : try_read_network(c); in drive_machine()
4556 switch (res) { in drive_machine()
4641 res = read(c->sfd, c->ritem, c->rlbytes); in drive_machine()
4642 if (res > 0) { in drive_machine()
4644 c->thread->stats.bytes_read += res; in drive_machine()
4647 c->rcurr += res; in drive_machine()
4649 c->ritem += res; in drive_machine()
4650 c->rlbytes -= res; in drive_machine()
4654 res = read_into_chunked_item(c); in drive_machine()
4655 if (res > 0) in drive_machine()
4659 if (res == 0) { /* end of stream */ in drive_machine()
4664 if (res == -1 && (errno == EAGAIN || errno == EWOULDBLOCK)) { in drive_machine()
4703 res = read(c->sfd, c->rbuf, c->rsize > c->sbytes ? c->sbytes : c->rsize); in drive_machine()
4704 if (res > 0) { in drive_machine()
4706 c->thread->stats.bytes_read += res; in drive_machine()
4708 c->sbytes -= res; in drive_machine()
4711 if (res == 0) { /* end of stream */ in drive_machine()
4715 if (res == -1 && (errno == EAGAIN || errno == EWOULDBLOCK)) { in drive_machine()
6223 int res = mlockall(MCL_CURRENT | MCL_FUTURE); in main() local
6224 if (res != 0) { in main()