Lines Matching refs:binary_header
1108 ret -= (sizeof(c->binary_header) + c->binary_header.request.keylen + in binary_get_request()
1109 c->binary_header.request.extlen); in binary_get_request()
1119 return c->rcurr - (c->binary_header.request.keylen); in binary_get_key()
1141 header->response.opcode = c->binary_header.request.opcode; in add_bin_header()
1264 nkey = c->binary_header.request.keylen; in complete_incr_bin()
1279 if (c->binary_header.request.cas != 0) { in complete_incr_bin()
1280 cas = c->binary_header.request.cas; in complete_incr_bin()
1439 size_t nkey = c->binary_header.request.keylen; in process_bin_get_or_touch()
1668 size_t nkey = c->binary_header.request.keylen; in process_bin_stat()
1789 c->binary_header.request.opcode, c->sfd); in handle_binary_protocol_error()
1821 c->binary_header.request.bodylen in bin_list_sasl_mechs()
1822 - c->binary_header.request.keylen); in bin_list_sasl_mechs()
1850 c->binary_header.request.bodylen in process_bin_sasl_auth()
1851 - c->binary_header.request.keylen); in process_bin_sasl_auth()
1855 assert(c->binary_header.request.extlen == 0); in process_bin_sasl_auth()
1857 int nkey = c->binary_header.request.keylen; in process_bin_sasl_auth()
1858 int vlen = c->binary_header.request.bodylen - nkey; in process_bin_sasl_auth()
1893 int nkey = c->binary_header.request.keylen; in process_bin_complete_sasl_auth()
1894 int vlen = c->binary_header.request.bodylen - nkey; in process_bin_complete_sasl_auth()
1988 int extlen = c->binary_header.request.extlen; in dispatch_bin_command()
1989 int keylen = c->binary_header.request.keylen; in dispatch_bin_command()
1990 uint32_t bodylen = c->binary_header.request.bodylen; in dispatch_bin_command()
2181 nkey = c->binary_header.request.keylen; in process_bin_update()
2187 vlen = c->binary_header.request.bodylen - (nkey + c->binary_header.request.extlen); in process_bin_update()
2243 ITEM_set_cas(it, c->binary_header.request.cas); in process_bin_update()
2279 nkey = c->binary_header.request.keylen; in process_bin_append_prepend()
2280 vlen = c->binary_header.request.bodylen - nkey; in process_bin_append_prepend()
2305 ITEM_set_cas(it, c->binary_header.request.cas); in process_bin_append_prepend()
2336 if (c->binary_header.request.extlen == sizeof(req->message.body)) { in process_bin_flush()
2366 size_t nkey = c->binary_header.request.keylen; in process_bin_delete()
4059 if (c->rbytes < sizeof(c->binary_header)) { in try_read_command()
4089 c->binary_header = *req; in try_read_command()
4090 c->binary_header.request.keylen = ntohs(req->request.keylen); in try_read_command()
4091 c->binary_header.request.bodylen = ntohl(req->request.bodylen); in try_read_command()
4092 c->binary_header.request.cas = ntohll(req->request.cas); in try_read_command()
4094 if (c->binary_header.request.magic != PROTOCOL_BINARY_REQ) { in try_read_command()
4097 c->binary_header.request.magic); in try_read_command()
4112 c->cmd = c->binary_header.request.opcode; in try_read_command()
4113 c->keylen = c->binary_header.request.keylen; in try_read_command()
4114 c->opaque = c->binary_header.request.opaque; in try_read_command()
4120 c->rbytes -= sizeof(c->binary_header); in try_read_command()
4121 c->rcurr += sizeof(c->binary_header); in try_read_command()