Home
last modified time | relevance | path

Searched refs:mqe (Results 1 – 25 of 224) sorted by relevance

123456789

/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Ddistributedenginecomm.cpp519 mqe = map_tok->second; in read()
558 mqe = map_tok->second; in read()
595 mqe = map_tok->second; in read_all()
598 mqe->queue.pop_all(v); in read_all()
600 if (mqe->sendACKs) in read_all()
623 mqe = map_tok->second; in read_some()
631 if (mqe->sendACKs) in read_some()
654 if (!mqe->throttled || queueSize >= mqe->targetQueueSize) in sendAcks()
908 mqe = it->second; in write()
950 if (mqe->sendACKs) in addDataToOutput()
[all …]
H A Ddistributedenginecomm.h291 boost::shared_ptr<MQE> mqe, size_t qSize);
292 void nextPMToACK(boost::shared_ptr<MQE> mqe, uint32_t maxAck, uint32_t* sockIndex,
294 void setFlowControl(bool enable, uint32_t uniqueID, boost::shared_ptr<MQE> mqe);
295 void doHasBigMsgs(boost::shared_ptr<MQE> mqe, uint64_t targetSize);
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/
H A Ddistributedenginecomm.cpp519 mqe = map_tok->second; in read()
558 mqe = map_tok->second; in read()
595 mqe = map_tok->second; in read_all()
598 mqe->queue.pop_all(v); in read_all()
600 if (mqe->sendACKs) in read_all()
623 mqe = map_tok->second; in read_some()
631 if (mqe->sendACKs) in read_some()
654 if (!mqe->throttled || queueSize >= mqe->targetQueueSize) in sendAcks()
908 mqe = it->second; in write()
950 if (mqe->sendACKs) in addDataToOutput()
[all …]
H A Ddistributedenginecomm.h291 boost::shared_ptr<MQE> mqe, size_t qSize);
292 void nextPMToACK(boost::shared_ptr<MQE> mqe, uint32_t maxAck, uint32_t* sockIndex,
294 void setFlowControl(bool enable, uint32_t uniqueID, boost::shared_ptr<MQE> mqe);
295 void doHasBigMsgs(boost::shared_ptr<MQE> mqe, uint64_t targetSize);
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/scsi/lpfc/
H A Dlpfc_mbox.c1043 struct lpfc_mqe *mqe; in lpfc_sli4_swap_str() local
1047 mqe = &pmb->u.mqe; in lpfc_sli4_swap_str()
1049 mqe->un.read_rev.fw_name, 16); in lpfc_sli4_swap_str()
1051 mqe->un.read_rev.ulp_fw_name, 16); in lpfc_sli4_swap_str()
1691 &mbox->u.mqe.un.nembed_cmd; in lpfc_sli4_mbx_sge_set()
1713 &mbox->u.mqe.un.nembed_cmd; in lpfc_sli4_mbx_sge_get()
1734 sli4_cfg = &mbox->u.mqe.un.sli4_config; in lpfc_sli4_mbox_cmd_free()
1964 sli4_cfg = &mbox->u.mqe.un.sli4_config; in lpfc_sli_config_mbox_subsys_get()
2124 init_vfi = &mbox->u.mqe.un.init_vfi; in lpfc_init_vfi()
2156 reg_vfi = &mbox->u.mqe.un.reg_vfi; in lpfc_reg_vfi()
[all …]
H A Dlpfc_sli.c5476 mqe = &mboxq->u.mqe; in lpfc_sli4_read_fcoe_params()
5493 mqe->un.mb_words[0], mqe->un.mb_words[1], in lpfc_sli4_read_fcoe_params()
5494 mqe->un.mb_words[2], mqe->un.mb_words[3], in lpfc_sli4_read_fcoe_params()
5495 mqe->un.mb_words[4], mqe->un.mb_words[5], in lpfc_sli4_read_fcoe_params()
5496 mqe->un.mb_words[6], mqe->un.mb_words[7], in lpfc_sli4_read_fcoe_params()
5497 mqe->un.mb_words[8], mqe->un.mb_words[9], in lpfc_sli4_read_fcoe_params()
5576 mqe = &mboxq->u.mqe; in lpfc_sli4_read_rev()
7555 mqe = &mboxq->u.mqe; in lpfc_sli4_hba_setup()
9213 mqe = &mboxq->u.mqe; in lpfc_sli4_post_async_mbox()
13596 mqe = &pmb->u.mqe; in lpfc_sli4_sp_handle_mbox_event()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/scsi/lpfc/
H A Dlpfc_mbox.c1043 struct lpfc_mqe *mqe; in lpfc_sli4_swap_str() local
1047 mqe = &pmb->u.mqe; in lpfc_sli4_swap_str()
1049 mqe->un.read_rev.fw_name, 16); in lpfc_sli4_swap_str()
1051 mqe->un.read_rev.ulp_fw_name, 16); in lpfc_sli4_swap_str()
1691 &mbox->u.mqe.un.nembed_cmd; in lpfc_sli4_mbx_sge_set()
1713 &mbox->u.mqe.un.nembed_cmd; in lpfc_sli4_mbx_sge_get()
1734 sli4_cfg = &mbox->u.mqe.un.sli4_config; in lpfc_sli4_mbox_cmd_free()
1964 sli4_cfg = &mbox->u.mqe.un.sli4_config; in lpfc_sli_config_mbox_subsys_get()
2124 init_vfi = &mbox->u.mqe.un.init_vfi; in lpfc_init_vfi()
2156 reg_vfi = &mbox->u.mqe.un.reg_vfi; in lpfc_reg_vfi()
[all …]
H A Dlpfc_sli.c5476 mqe = &mboxq->u.mqe; in lpfc_sli4_read_fcoe_params()
5493 mqe->un.mb_words[0], mqe->un.mb_words[1], in lpfc_sli4_read_fcoe_params()
5494 mqe->un.mb_words[2], mqe->un.mb_words[3], in lpfc_sli4_read_fcoe_params()
5495 mqe->un.mb_words[4], mqe->un.mb_words[5], in lpfc_sli4_read_fcoe_params()
5496 mqe->un.mb_words[6], mqe->un.mb_words[7], in lpfc_sli4_read_fcoe_params()
5497 mqe->un.mb_words[8], mqe->un.mb_words[9], in lpfc_sli4_read_fcoe_params()
5576 mqe = &mboxq->u.mqe; in lpfc_sli4_read_rev()
7555 mqe = &mboxq->u.mqe; in lpfc_sli4_hba_setup()
9213 mqe = &mboxq->u.mqe; in lpfc_sli4_post_async_mbox()
13596 mqe = &pmb->u.mqe; in lpfc_sli4_sp_handle_mbox_event()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/scsi/lpfc/
H A Dlpfc_mbox.c1043 struct lpfc_mqe *mqe; in lpfc_sli4_swap_str() local
1047 mqe = &pmb->u.mqe; in lpfc_sli4_swap_str()
1049 mqe->un.read_rev.fw_name, 16); in lpfc_sli4_swap_str()
1051 mqe->un.read_rev.ulp_fw_name, 16); in lpfc_sli4_swap_str()
1691 &mbox->u.mqe.un.nembed_cmd; in lpfc_sli4_mbx_sge_set()
1713 &mbox->u.mqe.un.nembed_cmd; in lpfc_sli4_mbx_sge_get()
1734 sli4_cfg = &mbox->u.mqe.un.sli4_config; in lpfc_sli4_mbox_cmd_free()
1964 sli4_cfg = &mbox->u.mqe.un.sli4_config; in lpfc_sli_config_mbox_subsys_get()
2124 init_vfi = &mbox->u.mqe.un.init_vfi; in lpfc_init_vfi()
2156 reg_vfi = &mbox->u.mqe.un.reg_vfi; in lpfc_reg_vfi()
[all …]
H A Dlpfc_sli.c5476 mqe = &mboxq->u.mqe; in lpfc_sli4_read_fcoe_params()
5493 mqe->un.mb_words[0], mqe->un.mb_words[1], in lpfc_sli4_read_fcoe_params()
5494 mqe->un.mb_words[2], mqe->un.mb_words[3], in lpfc_sli4_read_fcoe_params()
5495 mqe->un.mb_words[4], mqe->un.mb_words[5], in lpfc_sli4_read_fcoe_params()
5496 mqe->un.mb_words[6], mqe->un.mb_words[7], in lpfc_sli4_read_fcoe_params()
5497 mqe->un.mb_words[8], mqe->un.mb_words[9], in lpfc_sli4_read_fcoe_params()
5576 mqe = &mboxq->u.mqe; in lpfc_sli4_read_rev()
7555 mqe = &mboxq->u.mqe; in lpfc_sli4_hba_setup()
9213 mqe = &mboxq->u.mqe; in lpfc_sli4_post_async_mbox()
13596 mqe = &pmb->u.mqe; in lpfc_sli4_sp_handle_mbox_event()
[all …]
/dports/devel/ORBit2/ORBit2-2.14.19/src/orb/orb-core/
H A Dorbit-small.c295 GIOPMessageQueueEntry *mqe, in orbit_small_marshal() argument
591 GIOPMessageQueueEntry mqe; in ORBit_small_invoke_stub() local
1084 GIOPMessageQueueEntry mqe; member
1100 switch (orbit_small_demarshal (aqe->obj, &aqe->mqe.cnx, aqe->mqe.buffer, ev, in ORBit_small_demarshal_async()
1105 aqe->mqe.request_id); in ORBit_small_demarshal_async()
1110 aqe->mqe.request_id); in ORBit_small_demarshal_async()
1115 aqe->mqe.request_id); in ORBit_small_demarshal_async()
1124 aqe->mqe.request_id); in ORBit_small_demarshal_async()
1147 aqe->mqe.async_cb = NULL; in async_recv_cb()
1149 if (!aqe->mqe.cnx || in async_recv_cb()
[all …]
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/client/
H A Dwe_clients.cpp433 boost::shared_ptr<MQE> mqe(new MQE(pmCount)); in addQueue() local
435 mqe->queue = WESMsgQueue(lock, cond); in addQueue()
438 b = fSessionMessages.insert(pair<uint32_t, boost::shared_ptr<MQE> >(key, mqe)).second; in addQueue()
475 boost::shared_ptr<MQE> mqe; in read() local
489 mqe = map_tok->second; in read()
493 (void)mqe->queue.pop(&bs); in read()
556 boost::shared_ptr<MQE> mqe; in addDataToOutput() local
566 mqe = map_tok->second; in addDataToOutput()
571 atomicops::atomicInc(&mqe->unackedWork[connIndex % pmCount]); in addDataToOutput()
574 (void)mqe->queue.push(sbs); in addDataToOutput()
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/client/
H A Dwe_clients.cpp433 boost::shared_ptr<MQE> mqe(new MQE(pmCount)); in addQueue() local
435 mqe->queue = WESMsgQueue(lock, cond); in addQueue()
438 b = fSessionMessages.insert(pair<uint32_t, boost::shared_ptr<MQE> >(key, mqe)).second; in addQueue()
475 boost::shared_ptr<MQE> mqe; in read() local
489 mqe = map_tok->second; in read()
493 (void)mqe->queue.pop(&bs); in read()
556 boost::shared_ptr<MQE> mqe; in addDataToOutput() local
566 mqe = map_tok->second; in addDataToOutput()
571 atomicops::atomicInc(&mqe->unackedWork[connIndex % pmCount]); in addDataToOutput()
574 (void)mqe->queue.push(sbs); in addDataToOutput()
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/hw/ocrdma/
H A Docrdma_hw.c356 struct ocrdma_mqe *mqe; in ocrdma_init_emb_mqe() local
359 if (!mqe) in ocrdma_init_emb_mqe()
367 mqe->hdr.pyld_len); in ocrdma_init_emb_mqe()
368 return mqe; in ocrdma_init_emb_mqe()
1047 ocrdma_copy_cpu_to_le32(mqe, cmd, sizeof(*mqe)); in ocrdma_post_mqe()
1089 ocrdma_copy_le32_to_cpu(mqe, rsp_mqe, (sizeof(*mqe))); in ocrdma_mbx_cmd()
1092 rsp = &mqe->u.rsp; in ocrdma_mbx_cmd()
1288 struct ocrdma_mqe *mqe = &dev->stats_mem.mqe; in ocrdma_mbx_rdma_stats() local
1296 memset(mqe, 0, sizeof(*mqe)); in ocrdma_mbx_rdma_stats()
1336 if (!mqe) in ocrdma_mbx_get_ctrl_attribs()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/hw/ocrdma/
H A Docrdma_hw.c356 struct ocrdma_mqe *mqe; in ocrdma_init_emb_mqe() local
359 if (!mqe) in ocrdma_init_emb_mqe()
367 mqe->hdr.pyld_len); in ocrdma_init_emb_mqe()
368 return mqe; in ocrdma_init_emb_mqe()
1047 ocrdma_copy_cpu_to_le32(mqe, cmd, sizeof(*mqe)); in ocrdma_post_mqe()
1089 ocrdma_copy_le32_to_cpu(mqe, rsp_mqe, (sizeof(*mqe))); in ocrdma_mbx_cmd()
1092 rsp = &mqe->u.rsp; in ocrdma_mbx_cmd()
1288 struct ocrdma_mqe *mqe = &dev->stats_mem.mqe; in ocrdma_mbx_rdma_stats() local
1296 memset(mqe, 0, sizeof(*mqe)); in ocrdma_mbx_rdma_stats()
1336 if (!mqe) in ocrdma_mbx_get_ctrl_attribs()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/hw/ocrdma/
H A Docrdma_hw.c356 struct ocrdma_mqe *mqe; in ocrdma_init_emb_mqe() local
359 if (!mqe) in ocrdma_init_emb_mqe()
367 mqe->hdr.pyld_len); in ocrdma_init_emb_mqe()
368 return mqe; in ocrdma_init_emb_mqe()
1047 ocrdma_copy_cpu_to_le32(mqe, cmd, sizeof(*mqe)); in ocrdma_post_mqe()
1089 ocrdma_copy_le32_to_cpu(mqe, rsp_mqe, (sizeof(*mqe))); in ocrdma_mbx_cmd()
1092 rsp = &mqe->u.rsp; in ocrdma_mbx_cmd()
1288 struct ocrdma_mqe *mqe = &dev->stats_mem.mqe; in ocrdma_mbx_rdma_stats() local
1296 memset(mqe, 0, sizeof(*mqe)); in ocrdma_mbx_rdma_stats()
1336 if (!mqe) in ocrdma_mbx_get_ctrl_attribs()
[all …]
/dports/www/py-libsass/libsass-0.21.0/libsass/src/
H A Dinspect.cpp822 void Inspect::operator()(Media_Query_Expression* mqe) in operator ()() argument
824 if (mqe->is_interpolated()) { in operator ()()
825 mqe->feature()->perform(this); in operator ()()
829 mqe->feature()->perform(this); in operator ()()
830 if (mqe->value()) { in operator ()()
832 mqe->value()->perform(this); in operator ()()
/dports/www/gohugo/hugo-0.91.2/vendor/github.com/bep/golibsass/libsass_src/src/
H A Dinspect.cpp822 void Inspect::operator()(Media_Query_Expression* mqe) in operator ()() argument
824 if (mqe->is_interpolated()) { in operator ()()
825 mqe->feature()->perform(this); in operator ()()
829 mqe->feature()->perform(this); in operator ()()
830 if (mqe->value()) { in operator ()()
832 mqe->value()->perform(this); in operator ()()
/dports/textproc/libsass/libsass-3.6.4/src/
H A Dinspect.cpp822 void Inspect::operator()(Media_Query_Expression* mqe) in operator ()() argument
824 if (mqe->is_interpolated()) { in operator ()()
825 mqe->feature()->perform(this); in operator ()()
829 mqe->feature()->perform(this); in operator ()()
830 if (mqe->value()) { in operator ()()
832 mqe->value()->perform(this); in operator ()()
/dports/textproc/p5-CSS-Sass/CSS-Sass-3.6.4/libsass/src/
H A Dinspect.cpp822 void Inspect::operator()(Media_Query_Expression* mqe) in operator ()() argument
824 if (mqe->is_interpolated()) { in operator ()()
825 mqe->feature()->perform(this); in operator ()()
829 mqe->feature()->perform(this); in operator ()()
830 if (mqe->value()) { in operator ()()
832 mqe->value()->perform(this); in operator ()()
/dports/www/zola/zola-0.15.2/cargo-crates/sass-sys-0.4.22/libsass/src/
H A Dinspect.cpp822 void Inspect::operator()(Media_Query_Expression* mqe) in operator ()() argument
824 if (mqe->is_interpolated()) { in operator ()()
825 mqe->feature()->perform(this); in operator ()()
829 mqe->feature()->perform(this); in operator ()()
830 if (mqe->value()) { in operator ()()
832 mqe->value()->perform(this); in operator ()()
/dports/textproc/R-cran-sass/sass/src/libsass/src/
H A Dinspect.cpp822 void Inspect::operator()(Media_Query_Expression* mqe) in operator ()() argument
824 if (mqe->is_interpolated()) { in operator ()()
825 mqe->feature()->perform(this); in operator ()()
829 mqe->feature()->perform(this); in operator ()()
830 if (mqe->value()) { in operator ()()
832 mqe->value()->perform(this); in operator ()()
/dports/biology/canu/canu-2.2/src/utility/src/utility/
H A Dalign-ksw2-extz.C118 if (en == qlen - 1 && eh[qlen].h > ez->mqe) in ksw_extz()
119 ez->mqe = eh[qlen].h, ez->mqe_t = i; in ksw_extz()
H A Dalign-ksw2.H26 int mqe, mqe_t; // max score when reaching the end of query member
156 ez->max = 0, ez->score = ez->mqe = ez->mte = KSW_NEG_INF; in ksw_reset_extz()
/dports/biology/mmseqs2/MMseqs2-13-45111/lib/ksw2/
H A Dksw2.h53 int mqe, mqe_t; // max score when reaching the end of query member
182 ez->max = 0, ez->score = ez->mqe = ez->mte = KSW_NEG_INF; in ksw_reset_extz()

123456789