Lines Matching refs:message
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()
298 rsp->message.body.value = htonll(strtoull(tmpbuf, NULL, 10)); in complete_incr_bin()
302 write_bin_response(c, &rsp->message.body, 0, 0, in complete_incr_bin()
303 sizeof(rsp->message.body.value)); 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()
330 … write_bin_response(c, &rsp->message.body, 0, 0, sizeof(rsp->message.body.value)); in complete_incr_bin()
478 time_t exptime = ntohl(t->message.body.expiration); in process_bin_get_or_touch()
488 uint32_t bodylen = sizeof(rsp->message.body) + (it->nbytes - 2); in process_bin_get_or_touch()
515 add_bin_header(c, 0, sizeof(rsp->message.body), keylen, bodylen); in process_bin_get_or_touch()
516 rsp->message.header.response.cas = htonll(ITEM_get_cas(it)); in process_bin_get_or_touch()
519 FLAGS_CONV(it, rsp->message.body.flags); in process_bin_get_or_touch()
520 rsp->message.body.flags = htonl(rsp->message.body.flags); in process_bin_get_or_touch()
521 resp_add_iov(c->resp, &rsp->message.body, sizeof(rsp->message.body)); in process_bin_get_or_touch()
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()
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()