Lines Matching refs:message

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()
1286 rsp->message.body.value = htonll(strtoull(tmpbuf, NULL, 10)); in complete_incr_bin()
1290 write_bin_response(c, &rsp->message.body, 0, 0, in complete_incr_bin()
1291 sizeof(rsp->message.body.value)); 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()
1316 … write_bin_response(c, &rsp->message.body, 0, 0, sizeof(rsp->message.body.value)); in complete_incr_bin()
1455 time_t exptime = ntohl(t->message.body.expiration); in process_bin_get_or_touch()
1465 uint32_t bodylen = sizeof(rsp->message.body) + (it->nbytes - 2); in process_bin_get_or_touch()
1493 add_bin_header(c, 0, sizeof(rsp->message.body), keylen, bodylen); in process_bin_get_or_touch()
1494 rsp->message.header.response.cas = htonll(ITEM_get_cas(it)); in process_bin_get_or_touch()
1497 rsp->message.body.flags = htonl(strtoul(ITEM_suffix(it), NULL, 10)); in process_bin_get_or_touch()
1498 add_iov(c, &rsp->message.body, sizeof(rsp->message.body)); in process_bin_get_or_touch()
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()
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()
2385 uint64_t cas = ntohll(req->message.header.request.cas); in process_bin_delete()