Home
last modified time | relevance | path

Searched refs:mc_CMDQUEUE (Results 1 – 19 of 19) sorted by relevance

/dports/databases/libcouchbase/libcouchbase-2.10.7/src/mc/
H A Dmcreq.h462 } mc_CMDQUEUE; typedef
654 mcreq_map_key(mc_CMDQUEUE *queue,
683 mc_CMDQUEUE *queue, const lcb_CMDBASE *cmd,
736 mc_CMDQUEUE *queue, mc_PIPELINE * const *pipelines,
750 mcreq_queue_take_pipelines(mc_CMDQUEUE *queue, unsigned *count);
753 mcreq_queue_init(mc_CMDQUEUE *queue);
756 mcreq_queue_cleanup(mc_CMDQUEUE *queue);
841 (mc_CMDQUEUE *queue, mc_PIPELINE *srcpl, mc_PACKET *pkt, void *cbarg);
851 mcreq_iterwipe(mc_CMDQUEUE *queue, mc_PIPELINE *src,
952 typedef void (*mcreq_fallback_cb)(mc_CMDQUEUE *cq, mc_PACKET *pkt);
[all …]
H A Dmcreq.c432 mcreq_map_key(mc_CMDQUEUE *queue, in mcreq_map_key()
464 mc_CMDQUEUE *queue, const lcb_CMDBASE *cmd, in mcreq_basic_packet()
613 mcreq_queue_take_pipelines(mc_CMDQUEUE *queue, unsigned *count) in mcreq_queue_take_pipelines()
623 mcreq_queue_init(mc_CMDQUEUE *queue) in mcreq_queue_init()
634 mcreq_queue_cleanup(mc_CMDQUEUE *queue) in mcreq_queue_cleanup()
649 mcreq_sched_enter(mc_CMDQUEUE *queue) in mcreq_sched_enter()
657 queuectx_leave(mc_CMDQUEUE *queue, int success, int flush) in queuectx_leave()
704 mcreq_sched_leave(mc_CMDQUEUE *queue, int do_flush) in mcreq_sched_leave()
710 mcreq_sched_fail(mc_CMDQUEUE *queue) in mcreq_sched_fail()
718 mc_CMDQUEUE *cq = pipeline->parent; in mcreq_sched_add()
[all …]
H A Dforward.h84 mc_forward_packet(mc_CMDQUEUE *cq,
H A Dforward.c51 mc_forward_packet(mc_CMDQUEUE *cq,
/dports/databases/libcouchbase/libcouchbase-2.10.7/src/
H A Dretryq.h58 RetryQueue(mc_CMDQUEUE* cq_, lcbio_pTABLE, lcb_settings *);
162 mc_CMDQUEUE *cq;
H A Dnewconfig.cc196 iterwipe_cb(mc_CMDQUEUE *cq, mc_PIPELINE *oldpl, mc_PACKET *oldpkt, void *) in iterwipe_cb()
246 mc_CMDQUEUE *cq = &instance->cmdq; in replace_config()
320 mc_CMDQUEUE *q = &instance->cmdq; in lcb_update_vbconfig()
H A Dretryq.cc421 fallback_handler(mc_CMDQUEUE *cq, mc_PACKET *pkt) in fallback_handler()
443 RetryQueue::RetryQueue(mc_CMDQUEUE *cq_, lcbio_pTABLE table, lcb_settings *settings_) { in RetryQueue()
H A Dinternal.h115 mc_CMDQUEUE cmdq; /**< Base command queue object */
/dports/databases/libcouchbase/libcouchbase-2.10.7/tests/mc/
H A Dmctest.h7 struct CQWrap : mc_CMDQUEUE {
108 bool reservePacket(mc_CMDQUEUE *cq) { in reservePacket()
H A Dt_forward.cc24 lcb_error_t requestPacket(mc_CMDQUEUE *cq) {
H A Dt_alloc.cc5 mc_CMDQUEUE cQueue;
/dports/databases/libcouchbase/libcouchbase-2.10.7/src/operations/
H A Dget.cc28 mc_CMDQUEUE *q = &instance->cmdq; in lcb_get3()
119 mc_CMDQUEUE *cq = &instance->cmdq; in lcb_unlock3()
224 mc_CMDQUEUE *cq = &instance->cmdq; in rget_callback()
278 mc_CMDQUEUE *cq = &instance->cmdq; in lcb_rget3()
H A Dstats.cc94 mc_CMDQUEUE *cq = &instance->cmdq;
235 mc_CMDQUEUE *cq = &instance->cmdq;
310 mc_CMDQUEUE *cq = &instance->cmdq;
H A Dremove.cc25 mc_CMDQUEUE *cq = &instance->cmdq; in lcb_remove3()
H A Dobserve.cc161 mc_CMDQUEUE *cq = &instance->cmdq; in MCTX_addcmd()
228 mc_CMDQUEUE *cq = &instance->cmdq; in MCTX_done()
H A Dcounter.cc25 mc_CMDQUEUE *q = &instance->cmdq; in lcb_counter3()
H A Dstore.cc185 mc_CMDQUEUE *cq = &instance->cmdq; in do_store3()
H A Dping.cc307 mc_CMDQUEUE *cq = &instance->cmdq; in lcb_ping3()
/dports/databases/libcouchbase/libcouchbase-2.10.7/src/mcserver/
H A Dmcserver.cc881 mc_CMDQUEUE *cmdq = &this->instance->cmdq;