Lines Matching refs:req
56 protocol_binary_request_header* req; in try_read_command_binary() local
57 req = &c->binary_header; in try_read_command_binary()
63 for (ii = 0; ii < sizeof(req->bytes); ++ii) { in try_read_command_binary()
67 fprintf(stderr, " 0x%02x", req->bytes[ii]); in try_read_command_binary()
72 c->binary_header = *req; in try_read_command_binary()
73 c->binary_header.request.keylen = ntohs(req->request.keylen); in try_read_command_binary()
74 c->binary_header.request.bodylen = ntohl(req->request.bodylen); in try_read_command_binary()
75 c->binary_header.request.cas = ntohll(req->request.cas); in try_read_command_binary()
267 protocol_binary_request_incr* req = (void *)extbuf; in complete_incr_bin() local
272 req->message.body.delta = ntohll(req->message.body.delta); in complete_incr_bin()
273 req->message.body.initial = ntohll(req->message.body.initial); in complete_incr_bin()
274 req->message.body.expiration = ntohl(req->message.body.expiration); in complete_incr_bin()
286 (long long)req->message.body.delta, in complete_incr_bin()
287 (long long)req->message.body.initial, in complete_incr_bin()
288 req->message.body.expiration); in complete_incr_bin()
295 req->message.body.delta, tmpbuf, in complete_incr_bin()
312 if (req->message.body.expiration != 0xffffffff) { in complete_incr_bin()
314 rsp->message.body.value = htonll(req->message.body.initial); in complete_incr_bin()
317 (unsigned long long)req->message.body.initial); in complete_incr_bin()
319 it = item_alloc(key, nkey, 0, realtime(req->message.body.expiration), in complete_incr_bin()
1085 protocol_binary_request_set* req = (void *)extbuf; in process_bin_update() local
1093 req->message.body.flags = ntohl(req->message.body.flags); in process_bin_update()
1094 req->message.body.expiration = ntohl(req->message.body.expiration); in process_bin_update()
1119 it = item_alloc(key, nkey, req->message.body.flags, in process_bin_update()
1120 realtime(req->message.body.expiration), vlen+2); in process_bin_update()
1124 if (! item_size_ok(nkey, req->message.body.flags, vlen + 2)) { in process_bin_update()
1135 NULL, status, 0, key, nkey, req->message.body.expiration, in process_bin_update()
1254 protocol_binary_request_flush* req = (void *)extbuf; in process_bin_flush() local
1263 if (c->binary_header.request.extlen == sizeof(req->message.body)) { in process_bin_flush()
1264 exptime = ntohl(req->message.body.expiration); in process_bin_flush()