Lines Matching refs:req
1254 protocol_binary_request_incr* req = binary_get_request(c); in complete_incr_bin() local
1260 req->message.body.delta = ntohll(req->message.body.delta); in complete_incr_bin()
1261 req->message.body.initial = ntohll(req->message.body.initial); in complete_incr_bin()
1262 req->message.body.expiration = ntohl(req->message.body.expiration); in complete_incr_bin()
1274 (long long)req->message.body.delta, in complete_incr_bin()
1275 (long long)req->message.body.initial, in complete_incr_bin()
1276 req->message.body.expiration); in complete_incr_bin()
1283 req->message.body.delta, tmpbuf, in complete_incr_bin()
1300 if (req->message.body.expiration != 0xffffffff) { in complete_incr_bin()
1302 rsp->message.body.value = htonll(req->message.body.initial); in complete_incr_bin()
1305 (unsigned long long)req->message.body.initial); in complete_incr_bin()
1307 it = item_alloc(key, nkey, 0, realtime(req->message.body.expiration), in complete_incr_bin()
2176 protocol_binary_request_set* req = binary_get_request(c); in process_bin_update() local
2184 req->message.body.flags = ntohl(req->message.body.flags); in process_bin_update()
2185 req->message.body.expiration = ntohl(req->message.body.expiration); in process_bin_update()
2210 it = item_alloc(key, nkey, req->message.body.flags, in process_bin_update()
2211 realtime(req->message.body.expiration), vlen+2); in process_bin_update()
2215 if (! item_size_ok(nkey, req->message.body.flags, vlen + 2)) { in process_bin_update()
2327 protocol_binary_request_flush* req = binary_get_request(c); in process_bin_flush() local
2336 if (c->binary_header.request.extlen == sizeof(req->message.body)) { in process_bin_flush()
2337 exptime = ntohl(req->message.body.expiration); in process_bin_flush()
2363 protocol_binary_request_delete* req = binary_get_request(c); in process_bin_delete() local
2385 uint64_t cas = ntohll(req->message.header.request.cas); in process_bin_delete()
4073 protocol_binary_request_header* req; in try_read_command() local
4074 req = (protocol_binary_request_header*)c->rcurr; in try_read_command()
4080 for (ii = 0; ii < sizeof(req->bytes); ++ii) { in try_read_command()
4084 fprintf(stderr, " 0x%02x", req->bytes[ii]); 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()