Searched refs:mc_CMDQUEUE (Results 1 – 19 of 19) sorted by relevance
/dports/databases/libcouchbase/libcouchbase-2.10.7/src/mc/ |
H A D | mcreq.h | 462 } 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 D | mcreq.c | 432 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 D | forward.h | 84 mc_forward_packet(mc_CMDQUEUE *cq,
|
H A D | forward.c | 51 mc_forward_packet(mc_CMDQUEUE *cq,
|
/dports/databases/libcouchbase/libcouchbase-2.10.7/src/ |
H A D | retryq.h | 58 RetryQueue(mc_CMDQUEUE* cq_, lcbio_pTABLE, lcb_settings *); 162 mc_CMDQUEUE *cq;
|
H A D | newconfig.cc | 196 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 D | retryq.cc | 421 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 D | internal.h | 115 mc_CMDQUEUE cmdq; /**< Base command queue object */
|
/dports/databases/libcouchbase/libcouchbase-2.10.7/tests/mc/ |
H A D | mctest.h | 7 struct CQWrap : mc_CMDQUEUE { 108 bool reservePacket(mc_CMDQUEUE *cq) { in reservePacket()
|
H A D | t_forward.cc | 24 lcb_error_t requestPacket(mc_CMDQUEUE *cq) {
|
H A D | t_alloc.cc | 5 mc_CMDQUEUE cQueue;
|
/dports/databases/libcouchbase/libcouchbase-2.10.7/src/operations/ |
H A D | get.cc | 28 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 D | stats.cc | 94 mc_CMDQUEUE *cq = &instance->cmdq; 235 mc_CMDQUEUE *cq = &instance->cmdq; 310 mc_CMDQUEUE *cq = &instance->cmdq;
|
H A D | remove.cc | 25 mc_CMDQUEUE *cq = &instance->cmdq; in lcb_remove3()
|
H A D | observe.cc | 161 mc_CMDQUEUE *cq = &instance->cmdq; in MCTX_addcmd() 228 mc_CMDQUEUE *cq = &instance->cmdq; in MCTX_done()
|
H A D | counter.cc | 25 mc_CMDQUEUE *q = &instance->cmdq; in lcb_counter3()
|
H A D | store.cc | 185 mc_CMDQUEUE *cq = &instance->cmdq; in do_store3()
|
H A D | ping.cc | 307 mc_CMDQUEUE *cq = &instance->cmdq; in lcb_ping3()
|
/dports/databases/libcouchbase/libcouchbase-2.10.7/src/mcserver/ |
H A D | mcserver.cc | 881 mc_CMDQUEUE *cmdq = &this->instance->cmdq;
|