Searched refs:num_pending_sends (Results 1 – 10 of 10) sorted by relevance
43 OPAL_THREAD_ADD_FETCH32(&mca_btl_smcuda_component.num_pending_sends, +1); in add_pending()
163 int num_pending_sends; /**< total number on all of my pending-send queues */ member
986 OPAL_THREAD_ADD_FETCH32(&mca_btl_smcuda_component.num_pending_sends, -1); in btl_smcuda_process_pending_sends()1011 if ( 0 < mca_btl_smcuda_component.num_pending_sends ) { in mca_btl_smcuda_component_progress()
477 mca_btl_smcuda_component.num_pending_sends = 0; in smcuda_btl_first_time_init()
43 OPAL_THREAD_ADD32(&mca_btl_smcuda_component.num_pending_sends, +1); in add_pending()
983 OPAL_THREAD_ADD32(&mca_btl_smcuda_component.num_pending_sends, -1); in btl_smcuda_process_pending_sends()1008 if ( 0 < mca_btl_smcuda_component.num_pending_sends ) { in mca_btl_smcuda_component_progress()
473 mca_btl_smcuda_component.num_pending_sends = 0; in smcuda_btl_first_time_init()
443 size_t num_pending_sends = pending_sends_.size(); in OnMsgSendTo() local444 if (num_pending_sends == UDPSocketResourceConstants::kPluginSendBufferSlots) { in OnMsgSendTo()470 if (num_pending_sends == 0) in OnMsgSendTo()
444 size_t num_pending_sends = pending_sends_.size(); in OnMsgSendTo() local445 if (num_pending_sends == UDPSocketResourceConstants::kPluginSendBufferSlots) { in OnMsgSendTo()471 if (num_pending_sends == 0) in OnMsgSendTo()