/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
H A D | distributedenginecomm.cpp | 519 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 D | distributedenginecomm.h | 291 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 D | distributedenginecomm.cpp | 519 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 D | distributedenginecomm.h | 291 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 D | lpfc_mbox.c | 1043 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 D | lpfc_sli.c | 5476 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 D | lpfc_mbox.c | 1043 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 D | lpfc_sli.c | 5476 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 D | lpfc_mbox.c | 1043 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 D | lpfc_sli.c | 5476 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 D | orbit-small.c | 295 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 D | we_clients.cpp | 433 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 D | we_clients.cpp | 433 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 D | ocrdma_hw.c | 356 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 D | ocrdma_hw.c | 356 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 D | ocrdma_hw.c | 356 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 D | inspect.cpp | 822 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 D | inspect.cpp | 822 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 D | inspect.cpp | 822 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 D | inspect.cpp | 822 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 D | inspect.cpp | 822 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 D | inspect.cpp | 822 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 D | align-ksw2-extz.C | 118 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 D | align-ksw2.H | 26 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 D | ksw2.h | 53 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()
|