Home
last modified time | relevance | path

Searched refs:io (Results 1 – 9 of 9) sorted by relevance

/memcached-1.6.32/
Dextstore.c550 e->io_stack = io; in _wbuf_cb()
569 io->next = NULL; in _submit_wbuf()
571 io->page_id = p->id; in _submit_wbuf()
572 io->data = w; in _submit_wbuf()
574 io->len = w->size; in _submit_wbuf()
575 io->buf = w->buf; in _submit_wbuf()
576 io->cb = _wbuf_cb; in _submit_wbuf()
678 obj_io *tio = io; in _extstore_submit()
690 t->queue = io; in _extstore_submit()
819 memcpy(io->buf, wbuf->buf + (io->offset - wbuf->offset), io->len); in _read_from_wbuf()
[all …]
Dstorage.c167 crc2 = crc32c(crc2, (char *)io->iov[x].iov_base, io->iov[x].iov_len); in _storage_get_item_cb()
399 assert(io != NULL); in recache_or_free()
481 if (io->iov) { in storage_finalize_cb()
482 free(io->iov); in storage_finalize_cb()
483 io->iov = NULL; in storage_finalize_cb()
503 obj_io io; in storage_write() local
895 obj_io io; member
957 obj_io io; in storage_compact_readback() local
962 memcpy(io.buf, it, io.len); in storage_compact_readback()
1083 wrap.io.data = &wrap; in storage_compact_thread()
[all …]
Dproxy_network.c155 io->flushed = false; in _proxy_event_handler_dequeue()
928 io = be->io_next; in _prep_pending_write()
930 assert(io != NULL); in _prep_pending_write()
931 for (; io; io = STAILQ_NEXT(io, io_next)) { in _prep_pending_write()
933 if (io->flushed) in _prep_pending_write()
941 memcpy(&iovs[iovused], io->iov, sizeof(struct iovec)*io->iovcnt); in _prep_pending_write()
950 if (io == NULL) { in _post_pending_write()
954 for (; io; io = STAILQ_NEXT(io, io_next)) { in _post_pending_write()
956 if (io->flushed) in _post_pending_write()
990 if (io != NULL) { in _post_pending_write()
[all …]
Dextstore.h72 typedef void (*obj_io_cb)(void *e, obj_io *io, int ret);
106 int extstore_write_request(void *ptr, unsigned int bucket, unsigned int free_bucket, obj_io *io);
107 void extstore_write(void *ptr, obj_io *io);
108 int extstore_submit(void *ptr, obj_io *io);
109 int extstore_submit_bg(void *ptr, obj_io *io);
Dproxy_internal.c89 mc_resp *resp = io->tresp; in _storage_get_item_cb()
130 io->miss = miss; in _storage_get_item_cb()
131 io->active = false; in _storage_get_item_cb()
154 io->active = true; in proxy_storage_get()
156 io->hdr_it = it; in proxy_storage_get()
160 io->gettype = type; in proxy_storage_get()
161 io->thread = t; in proxy_storage_get()
164 obj_io *eio = &io->eio; in proxy_storage_get()
179 eio->data = (void *)io; in proxy_storage_get()
1774 io->rctx = rctx; in mcplib_internal_run()
[all …]
Dthread.c53 io_pending_t *io; // IO when used for deferred IO handling. member
577 io_pending_t *io = STAILQ_FIRST(&head); in thread_libevent_ionotify() local
579 conn_io_queue_return(io); in thread_libevent_ionotify()
822 void return_io_pending(io_pending_t *io) { in return_io_pending() argument
824 LIBEVENT_THREAD *t = io->thread; in return_io_pending()
829 STAILQ_INSERT_TAIL(&t->ion_head, io, iop_next); in return_io_pending()
Dmemcached.h960 void conn_io_queue_return(io_pending_t *io);
991 void return_io_pending(io_pending_t *io);
Dmemcached.c623 void conn_io_queue_return(io_pending_t *io) { in conn_io_queue_return() argument
624 io->return_cb(io); in conn_io_queue_return()
1223 io_pending_t *io = resp->io_pending; in resp_finish() local
1226 io->finalize_cb(io); in resp_finish()
1227 do_cache_free(c->thread->io_cache, io); in resp_finish()
/memcached-1.6.32/scripts/
Ddamemtop76 my $read_keys = AnyEvent->io (