Lines Matching refs:p

146     io_pending_storage_t *p = (io_pending_storage_t *)io->data;  in _storage_get_item_cb()  local
147 mc_resp *resp = p->resp; in _storage_get_item_cb()
148 conn *c = p->c; in _storage_get_item_cb()
149 assert(p->active == true); in _storage_get_item_cb()
175 p->badcrc = true; in _storage_get_item_cb()
180 if (p->noreply) { 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()
222 for (i = 0; i <= p->iovec_data; i++) { in _storage_get_item_cb()
232 p->miss = true; in _storage_get_item_cb()
238 resp->iov[p->iovec_data].iov_base = ITEM_data(read_it); in _storage_get_item_cb()
240 p->miss = false; in _storage_get_item_cb()
243 p->active = false; in _storage_get_item_cb()
246 return_io_pending((io_pending_t *)p); in _storage_get_item_cb()
276 io_pending_storage_t *p = do_cache_alloc(c->thread->io_cache); in storage_get_item() local
279 memset(p, 0, sizeof(io_pending_storage_t)); in storage_get_item()
280 p->active = true; in storage_get_item()
281 p->miss = false; in storage_get_item()
282 p->badcrc = false; in storage_get_item()
283 p->noreply = c->noreply; in storage_get_item()
284 p->thread = c->thread; in storage_get_item()
285 p->return_cb = storage_return_cb; in storage_get_item()
286 p->finalize_cb = storage_finalize_cb; in storage_get_item()
288 p->hdr_it = it; in storage_get_item()
289 p->resp = resp; in storage_get_item()
290 p->io_queue_type = IO_QUEUE_EXTSTORE; in storage_get_item()
291 obj_io *eio = &p->io_ctx; in storage_get_item()
305 do_cache_free(c->thread->io_cache, p); in storage_get_item()
322 do_cache_free(c->thread->io_cache, p); in storage_get_item()
336 p->iovec_data = resp->iovcnt; in storage_get_item()
345 resp->io_pending = (io_pending_t *)p; in storage_get_item()
348 p->c = c; in storage_get_item()
358 eio->data = (void *)p; in storage_get_item()
395 io_pending_storage_t *p = (io_pending_storage_t *)pending; in recache_or_free() local
397 conn *c = p->c; in recache_or_free()
398 obj_io *io = &p->io_ctx; in recache_or_free()
403 if (p->active) { in recache_or_free()
407 size_t ntotal = ITEM_ntotal(p->hdr_it); in recache_or_free()
410 io_queue_t *q = conn_io_queue_get(c, p->io_queue_type); in recache_or_free()
416 } else if (p->miss) { in recache_or_free()
419 size_t ntotal = ITEM_ntotal(p->hdr_it); in recache_or_free()
420 item_unlink(p->hdr_it); in recache_or_free()
424 if (p->badcrc) in recache_or_free()
433 item *h_it = p->hdr_it; in recache_or_free()
458 p->io_ctx.buf = NULL; in recache_or_free()
459 p->io_ctx.next = NULL; in recache_or_free()
460 p->active = false; in recache_or_free()
463 item_remove(p->hdr_it); in recache_or_free()
478 io_pending_storage_t *p = (io_pending_storage_t *)pending; in storage_finalize_cb() local
479 obj_io *io = &p->io_ctx; in storage_finalize_cb()
1193 char *p = strtok_r(arg, ":", &b); in storage_conf_parse() local
1197 if (p == NULL) in storage_conf_parse()
1201 cf->file = strdup(p); in storage_conf_parse()
1203 p = strtok_r(NULL, ":", &b); in storage_conf_parse()
1204 if (p == NULL) { in storage_conf_parse()
1208 unit = tolower(p[strlen(p)-1]); in storage_conf_parse()
1209 p[strlen(p)-1] = '\0'; in storage_conf_parse()
1230 base_size = atoi(p); in storage_conf_parse()
1241 p = strtok_r(NULL, ":", &b); in storage_conf_parse()
1244 if (p != NULL) { in storage_conf_parse()
1245 if (strcmp(p, "compact") == 0) { in storage_conf_parse()
1247 } else if (strcmp(p, "lowttl") == 0) { in storage_conf_parse()
1249 } else if (strcmp(p, "chunked") == 0) { in storage_conf_parse()
1251 } else if (strcmp(p, "default") == 0) { in storage_conf_parse()
1253 } else if (strcmp(p, "coldcompact") == 0) { in storage_conf_parse()
1255 } else if (strcmp(p, "old") == 0) { in storage_conf_parse()
1258 fprintf(stderr, "Unknown extstore bucket: %s\n", p); in storage_conf_parse()