Lines Matching refs:resp
35 mc_resp *resp; member
147 mc_resp *resp = p->resp; in _storage_get_item_cb() local
182 resp->skip = true; in _storage_get_item_cb()
191 (protocol_binary_response_header *)resp->wbuf; in _storage_get_item_cb()
196 body_len -= resp->iov[p->iovec_data].iov_len + hdr_len; in _storage_get_item_cb()
197 resp->tosend -= resp->iov[p->iovec_data].iov_len + hdr_len; in _storage_get_item_cb()
203 resp->iov[p->iovec_data].iov_len = 0; in _storage_get_item_cb()
205 resp->iov[p->iovec_data-1].iov_len = 0; in _storage_get_item_cb()
206 resp->chunked_data_iov = 0; in _storage_get_item_cb()
211 if (resp->iov[0].iov_len >= 3 in _storage_get_item_cb()
212 && memcmp(resp->iov[0].iov_base, "VA ", 3) == 0) { in _storage_get_item_cb()
215 resp->iovcnt = 1; in _storage_get_item_cb()
216 resp->iov[0].iov_len = 4; in _storage_get_item_cb()
217 resp->iov[0].iov_base = "EN\r\n"; in _storage_get_item_cb()
218 resp->tosend = 4; in _storage_get_item_cb()
223 resp->tosend -= resp->iov[i].iov_len; in _storage_get_item_cb()
224 resp->iov[i].iov_len = 0; in _storage_get_item_cb()
225 resp->iov[i].iov_base = NULL; in _storage_get_item_cb()
228 resp->chunked_total = 0; in _storage_get_item_cb()
229 resp->chunked_data_iov = 0; in _storage_get_item_cb()
238 resp->iov[p->iovec_data].iov_base = ITEM_data(read_it); in _storage_get_item_cb()
249 int storage_get_item(conn *c, item *it, mc_resp *resp) { in storage_get_item() argument
289 p->resp = resp; in storage_get_item()
336 p->iovec_data = resp->iovcnt; in storage_get_item()
339 resp_add_chunked_iov(resp, new_it, iovtotal); in storage_get_item()
341 resp_add_iov(resp, "", iovtotal); in storage_get_item()
345 resp->io_pending = (io_pending_t *)p; in storage_get_item()