Home
last modified time | relevance | path

Searched refs:lock_required (Results 1 – 15 of 15) sorted by relevance

/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/bgq/src/
H A Dfi_bgq_rma.c69 int lock_required; in fi_bgq_rma_read() local
77 lock_required = 0; in fi_bgq_rma_read()
79 lock_required = 1; in fi_bgq_rma_read()
89 int lock_required; in fi_bgq_rma_readmsg() local
97 lock_required = 0; in fi_bgq_rma_readmsg()
103 lock_required); in fi_bgq_rma_readmsg()
110 int lock_required; in fi_bgq_rma_inject_write() local
132 int lock_required; in fi_bgq_rma_write() local
154 int lock_required; in fi_bgq_rma_writev() local
174 int lock_required; in fi_bgq_rma_writemsg() local
[all …]
H A Dfi_bgq_cq.c107 int lock_required; in fi_bgq_cq_read() local
114 lock_required = 0; in fi_bgq_cq_read()
116 lock_required = 1; in fi_bgq_cq_read()
126 int lock_required; in fi_bgq_cq_readfrom() local
133 lock_required = 0; in fi_bgq_cq_readfrom()
136 lock_required = 1; in fi_bgq_cq_readfrom()
228 int lock_required; in fi_bgq_cq_sread() local
234 lock_required = 0; in fi_bgq_cq_sread()
236 lock_required = 1; in fi_bgq_cq_sread()
255 int lock_required; in fi_bgq_cq_sreadfrom() local
[all …]
H A Dfi_bgq_atomic.c488 int lock_required = 0; in fi_bgq_atomic() local
497 lock_required = 0; in fi_bgq_atomic()
502 lock_required = 1; in fi_bgq_atomic()
510 lock_required); in fi_bgq_atomic()
522 int lock_required = 0; in fi_bgq_fetch_atomic() local
531 lock_required = 0; in fi_bgq_fetch_atomic()
546 lock_required); in fi_bgq_fetch_atomic()
557 int lock_required = 0; in fi_bgq_compare_atomic() local
582 lock_required); in fi_bgq_compare_atomic()
590 int lock_required = 0; in fi_bgq_inject_atomic() local
[all …]
H A Dfi_bgq_tagged.c41 const int lock_required = in fi_bgq_trecvmsg() local
46 return fi_bgq_trecvmsg_generic(ep, msg, flags, lock_required); in fi_bgq_trecvmsg()
H A Dfi_bgq_ep.c1641 const int lock_required = in fi_bgq_cancel() local
1647 ret = fi_bgq_lock_if_required(&bgq_ep->lock, lock_required); in fi_bgq_cancel()
1652 ret = fi_bgq_unlock_if_required(&bgq_ep->lock, lock_required); in fi_bgq_cancel()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/bgq/include/rdma/
H A Dfi_direct_rma.h222 lock_required); in fi_bgq_readv_internal()
239 lock_required); in fi_bgq_readv_internal()
294 lock_required); in fi_bgq_readv_internal()
310 int lock_required) in fi_bgq_inject_write_generic() argument
405 lock_required); in fi_bgq_write_fence()
601 int lock_required) in fi_bgq_write_generic() argument
658 lock_required); in fi_bgq_writev_generic()
737 lock_required); in fi_bgq_writemsg_generic()
813 lock_required); in fi_bgq_readv_generic()
820 lock_required); in fi_bgq_readv_generic()
[all …]
H A Dfi_direct_atomic.h223 const int lock_required) in fi_bgq_atomic_fence() argument
454 const int lock_required) in fi_bgq_atomic_generic() argument
546 lock_required); in fi_bgq_atomic_writemsg_generic()
683 lock_required); in fi_bgq_atomic_readwritemsg_generic()
793 lock_required); in fi_bgq_atomic_compwritemsg_generic()
813 int lock_required) in fi_bgq_fetch_compare_atomic_generic() argument
847 int lock_required) in fi_bgq_fetch_atomic_generic() argument
856 lock_required); in fi_bgq_fetch_atomic_generic()
866 int lock_required) in fi_bgq_compare_atomic_generic() argument
872 lock_required); in fi_bgq_compare_atomic_generic()
[all …]
H A Dfi_direct_eq.h181 const int lock_required);
186 const int lock_required) in fi_bgq_cq_enqueue_pending() argument
191 ret = fi_bgq_lock_if_required(&bgq_cq->lock, lock_required); in fi_bgq_cq_enqueue_pending()
203 ret = fi_bgq_unlock_if_required(&bgq_cq->lock, lock_required); in fi_bgq_cq_enqueue_pending()
220 const int lock_required) in fi_bgq_cq_enqueue_completed() argument
227 ret = fi_bgq_lock_if_required(&bgq_cq->lock, lock_required); in fi_bgq_cq_enqueue_completed()
245 ret = fi_bgq_unlock_if_required(&bgq_cq->lock, lock_required); in fi_bgq_cq_enqueue_completed()
435 const int lock_required) in fi_bgq_cq_poll_inline() argument
442 ret = fi_bgq_lock_if_required(&bgq_cq->lock, lock_required); in fi_bgq_cq_poll_inline()
505 const enum fi_cq_format format, const int lock_required) in fi_bgq_cq_read_generic() argument
[all …]
H A Dfi_direct_endpoint.h455 int lock_required, in fi_bgq_inject_generic() argument
525 const uint32_t data, int lock_required, in fi_bgq_send_generic_flags() argument
787 int lock_required, in fi_bgq_send_generic() argument
792 tag, context, 0, lock_required, is_msg, in fi_bgq_send_generic()
808 const int lock_required, in fi_bgq_recv_generic() argument
879 int lock_required) in fi_bgq_recvmsg_generic() argument
1018 int lock_required, in fi_bgq_injectdata_generic() argument
1022 lock_required, is_msg); in fi_bgq_injectdata_generic()
1030 int lock_required, in fi_bgq_senddata_generic() argument
1048 int lock_required) in fi_bgq_inject() argument
[all …]
H A Dfi_direct_tagged.h55 int lock_required) in fi_bgq_tinject() argument
58 lock_required, 0); in fi_bgq_tinject()
81 const int lock_required) in fi_bgq_trecvmsg_generic() argument
144 ret = fi_bgq_lock_if_required(&bgq_ep->lock, lock_required); in fi_bgq_trecvmsg_generic()
156 ret = fi_bgq_unlock_if_required(&bgq_ep->lock, lock_required); in fi_bgq_trecvmsg_generic()
166 ret = fi_bgq_lock_if_required(&bgq_ep->lock, lock_required); in fi_bgq_trecvmsg_generic()
178 ret = fi_bgq_unlock_if_required(&bgq_ep->lock, lock_required); in fi_bgq_trecvmsg_generic()
/dports/net/openmpi3/openmpi-3.1.6/oshmem/mca/atomic/basic/
H A Datomic_basic_module.c116 char lock_required = ATOMIC_LOCK_WAITING; in atomic_basic_lock() local
123 …MCA_SPML_CALL(put((void*)(atomic_lock_sync + me), sizeof(lock_required), (void*)&lock_required, ro… in atomic_basic_lock()
125 } while (local_lock_sync[me] != lock_required); in atomic_basic_lock()
/dports/www/p5-Tenjin/Tenjin-0.070001/lib/Tenjin/
H A DTemplate.pm496 my ($self, $filename, $lock_required) = @_;
500 flock(IN, LOCK_SH) if $lock_required;
519 my ($self, $filename, $content, $lock_required) = @_;
525 flock(OUT, LOCK_EX) if $lock_required;
/dports/net/openmpi/openmpi-4.1.1/oshmem/mca/atomic/basic/
H A Datomic_basic_module.c236 char lock_required = ATOMIC_LOCK_WAITING; in atomic_basic_lock() local
243 …SPML_CALL(put(ctx, (void*)(atomic_lock_sync + me), sizeof(lock_required), (void*)&lock_required, r… in atomic_basic_lock()
245 } while (local_lock_sync[me] != lock_required); in atomic_basic_lock()
/dports/audio/ardour6/Ardour-6.8.0/libs/ardour/ardour/
H A Dcontrol_protocol_manager.h105 int teardown (ControlProtocolInfo&, bool lock_required);
/dports/audio/ardour6/Ardour-6.8.0/libs/ardour/
H A Dcontrol_protocol_manager.cc243 ControlProtocolManager::teardown (ControlProtocolInfo& cpi, bool lock_required) in teardown() argument
277 if (lock_required) { in teardown()