Home
last modified time | relevance | path

Searched refs:READERS (Results 1 – 25 of 158) sorted by relevance

1234567

/dports/net/py-h11/h11-0.12.0/h11/tests/
H A Dtest_io.py10 READERS,
151 READERS[CLIENT, IDLE],
163 READERS[CLIENT, IDLE],
257 READERS[CLIENT, IDLE],
281 READERS[CLIENT, IDLE],
288 READERS[CLIENT, IDLE],
294 READERS[CLIENT, IDLE],
300 READERS[CLIENT, IDLE],
496 READERS[CLIENT, IDLE],
505 READERS[CLIENT, IDLE],
[all …]
/dports/devel/onetbb/oneTBB-2021.4.0/include/oneapi/tbb/
H A Drw_mutex.h90 state_type curr_state = (m_state &= READERS | WRITER_PENDING); // Returns current state in unlock()
109 …__TBB_ASSERT(m_state.load(std::memory_order_relaxed) & READERS, "invalid state of a read lock: no … in lock_shared()
132 …__TBB_ASSERT(m_state.load(std::memory_order_relaxed) & READERS, "invalid state of a read lock: no … in unlock_shared()
154 __TBB_ASSERT(s & READERS, "invalid state before upgrade: no readers "); in upgrade()
158 while ((s & READERS) == ONE_READER || !(s & WRITER_PENDING)) { in upgrade()
160 …keup_condition = [&] { return (m_state.load(std::memory_order_relaxed) & READERS) == ONE_READER; }; in upgrade()
161 while ((m_state.load(std::memory_order_relaxed) & READERS) != ONE_READER) { in upgrade()
188 …__TBB_ASSERT(m_state.load(std::memory_order_relaxed) & READERS, "invalid state after downgrade: no… in downgrade()
194 static constexpr state_type READERS = ~(WRITER | WRITER_PENDING); variable
196 static constexpr state_type BUSY = WRITER | READERS;
H A Dspin_rw_mutex.h97 m_state &= READERS; in unlock()
115 __TBB_ASSERT(m_state & READERS, "invalid state of a read lock: no readers"); in lock_shared()
136 __TBB_ASSERT(m_state & READERS, "invalid state of a read lock: no readers"); in unlock_shared()
149 __TBB_ASSERT(s & READERS, "invalid state before upgrade: no readers "); in upgrade()
153 while ((s & READERS) == ONE_READER || !(s & WRITER_PENDING)) { in upgrade()
156 … while ((m_state.load(std::memory_order_relaxed) & READERS) != ONE_READER) backoff.pause(); in upgrade()
173 __TBB_ASSERT(m_state & READERS, "invalid state after downgrade: no readers"); in downgrade()
179 static constexpr state_type READERS = ~(WRITER | WRITER_PENDING); variable
181 static constexpr state_type BUSY = WRITER | READERS;
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/tbb/
H A Dspin_rw_mutex.cpp58 __TBB_AtomicAND( &state, READERS ); in internal_release_writer()
77 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_acquire_reader()
85 __TBB_ASSERT( s & READERS, "invalid state before upgrade: no readers " ); in internal_upgrade()
89 while( (s & READERS)==ONE_READER || !(s & WRITER_PENDING) ) { in internal_upgrade()
94 while( (state & READERS) != ONE_READER ) backoff.pause(); in internal_upgrade()
111 __TBB_ASSERT( state & READERS, "invalid state after downgrade: no readers" ); in internal_downgrade()
117 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_release_reader()
/dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/tbb-2018_U2/src/tbb/
H A Dspin_rw_mutex.cpp62 __TBB_AtomicAND( &state, READERS ); in internal_release_writer()
81 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_acquire_reader()
89 __TBB_ASSERT( s & READERS, "invalid state before upgrade: no readers " ); in internal_upgrade()
93 while( (s & READERS)==ONE_READER || !(s & WRITER_PENDING) ) { in internal_upgrade()
98 while( (state & READERS) != ONE_READER ) backoff.pause(); in internal_upgrade()
115 __TBB_ASSERT( state & READERS, "invalid state after downgrade: no readers" ); in internal_downgrade()
121 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_release_reader()
/dports/devel/concurrentqueue/concurrentqueue-1.0.3-15-g0753496/benchmarks/tbb/
H A Dspin_rw_mutex.cpp62 __TBB_AtomicAND( &state, READERS ); in internal_release_writer()
81 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_acquire_reader()
89 __TBB_ASSERT( s & READERS, "invalid state before upgrade: no readers " ); in internal_upgrade()
93 while( (s & READERS)==ONE_READER || !(s & WRITER_PENDING) ) { in internal_upgrade()
98 while( (state & READERS) != ONE_READER ) backoff.pause(); in internal_upgrade()
115 __TBB_ASSERT( state & READERS, "invalid state after downgrade: no readers" ); in internal_downgrade()
121 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_release_reader()
H A Dspin_rw_mutex.h139 if( is_writer ) __TBB_AtomicAND( &m->state, READERS ); in release()
199 if( state&WRITER ) __TBB_AtomicAND( &state, READERS ); in unlock()
217 static const state_t READERS = ~(WRITER | WRITER_PENDING); variable
219 static const state_t BUSY = WRITER | READERS;
/dports/devel/tbb/oneTBB-2020.3/src/tbb/
H A Dspin_rw_mutex.cpp58 __TBB_AtomicAND( &state, READERS ); in internal_release_writer()
77 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_acquire_reader()
85 __TBB_ASSERT( s & READERS, "invalid state before upgrade: no readers " ); in internal_upgrade()
89 while( (s & READERS)==ONE_READER || !(s & WRITER_PENDING) ) { in internal_upgrade()
94 while( (state & READERS) != ONE_READER ) backoff.pause(); in internal_upgrade()
111 __TBB_ASSERT( state & READERS, "invalid state after downgrade: no readers" ); in internal_downgrade()
117 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_release_reader()
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/tbb/
H A Dspin_rw_mutex.cpp58 __TBB_AtomicAND( &state, READERS ); in internal_release_writer()
77 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_acquire_reader()
85 __TBB_ASSERT( s & READERS, "invalid state before upgrade: no readers " ); in internal_upgrade()
89 while( (s & READERS)==ONE_READER || !(s & WRITER_PENDING) ) { in internal_upgrade()
94 while( (state & READERS) != ONE_READER ) backoff.pause(); in internal_upgrade()
111 __TBB_ASSERT( state & READERS, "invalid state after downgrade: no readers" ); in internal_downgrade()
117 __TBB_ASSERT( state & READERS, "invalid state of a read lock: no readers" ); in internal_release_reader()
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/old/
H A Dspin_rw_mutex_v2.cpp74 __TBB_ASSERT( mutex->state & READERS, "invalid state of a read lock: no readers" ); in internal_acquire_reader()
82 __TBB_ASSERT( s & READERS, "invalid state before upgrade: no readers " ); in internal_upgrade()
87 while( (s & READERS)==ONE_READER || !(s & WRITER_PENDING) ) { in internal_upgrade()
92 while( (mutex->state & READERS) != ONE_READER ) backoff.pause(); in internal_upgrade()
113 __TBB_ASSERT( mutex->state & READERS, "invalid state after downgrade: no readers" ); in internal_downgrade()
120 __TBB_ASSERT( mutex->state & READERS, "invalid state of a read lock: no readers" ); in internal_release_reader()
/dports/devel/tbb/oneTBB-2020.3/src/old/
H A Dspin_rw_mutex_v2.cpp74 __TBB_ASSERT( mutex->state & READERS, "invalid state of a read lock: no readers" ); in internal_acquire_reader()
82 __TBB_ASSERT( s & READERS, "invalid state before upgrade: no readers " ); in internal_upgrade()
87 while( (s & READERS)==ONE_READER || !(s & WRITER_PENDING) ) { in internal_upgrade()
92 while( (mutex->state & READERS) != ONE_READER ) backoff.pause(); in internal_upgrade()
113 __TBB_ASSERT( mutex->state & READERS, "invalid state after downgrade: no readers" ); in internal_downgrade()
120 __TBB_ASSERT( mutex->state & READERS, "invalid state of a read lock: no readers" ); in internal_release_reader()
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/old/
H A Dspin_rw_mutex_v2.cpp74 __TBB_ASSERT( mutex->state & READERS, "invalid state of a read lock: no readers" ); in internal_acquire_reader()
82 __TBB_ASSERT( s & READERS, "invalid state before upgrade: no readers " ); in internal_upgrade()
87 while( (s & READERS)==ONE_READER || !(s & WRITER_PENDING) ) { in internal_upgrade()
92 while( (mutex->state & READERS) != ONE_READER ) backoff.pause(); in internal_upgrade()
113 __TBB_ASSERT( mutex->state & READERS, "invalid state after downgrade: no readers" ); in internal_downgrade()
120 __TBB_ASSERT( mutex->state & READERS, "invalid state of a read lock: no readers" ); in internal_release_reader()
/dports/net-p2p/deluge-cli/deluge-2.0.3/deluge/plugins/Blocklist/deluge_blocklist/
H A Ddetect.py19 READERS = { variable
38 for reader in READERS:
46 reader = READERS.get(file_format)
/dports/lang/abcl/abcl-src-1.8.0/src/org/armedbear/lisp/
H A DSlotDefinition.java65 setInstanceSlotValue(Symbol.READERS, NIL); in SlotDefinition()
80 setInstanceSlotValue(Symbol.READERS, readers); in SlotDefinition()
94 setInstanceSlotValue(Symbol.READERS, readers); in SlotDefinition()
108 setInstanceSlotValue(Symbol.READERS, readers); in SlotDefinition()
121 setInstanceSlotValue(Symbol.READERS, readers); in SlotDefinition()
/dports/net/p5-Net-Proxy/Net-Proxy-0.13/lib/Net/
H A DProxy.pm14 my $READERS;
170 $READERS->remove($sock);
183 $READERS->add(@socks);
216 $READERS = IO::Select->new();
237 while ( $continue and my @ready = IO::Select->select( $READERS, $WRITERS ) ) {
308 Net::Proxy->close_sockets( $READERS->handles(), $WRITERS->handles() );
/dports/databases/mariadb104-server/mariadb-10.4.24/tests/
H A Dconsistent_snapshot.pl12 my $READERS= 5;
101 for (1 .. $READERS) {
105 waitpid(-1, 0) for (1 .. ($UPDATERS + $READERS));
/dports/databases/mariadb104-client/mariadb-10.4.24/tests/
H A Dconsistent_snapshot.pl12 my $READERS= 5;
101 for (1 .. $READERS) {
105 waitpid(-1, 0) for (1 .. ($UPDATERS + $READERS));
/dports/databases/mariadb105-client/mariadb-10.5.15/tests/
H A Dconsistent_snapshot.pl12 my $READERS= 5;
101 for (1 .. $READERS) {
105 waitpid(-1, 0) for (1 .. ($UPDATERS + $READERS));
/dports/databases/mariadb103-server/mariadb-10.3.34/tests/
H A Dconsistent_snapshot.pl12 my $READERS= 5;
101 for (1 .. $READERS) {
105 waitpid(-1, 0) for (1 .. ($UPDATERS + $READERS));
/dports/databases/mariadb103-client/mariadb-10.3.34/tests/
H A Dconsistent_snapshot.pl12 my $READERS= 5;
101 for (1 .. $READERS) {
105 waitpid(-1, 0) for (1 .. ($UPDATERS + $READERS));
/dports/databases/mariadb105-server/mariadb-10.5.15/tests/
H A Dconsistent_snapshot.pl12 my $READERS= 5;
101 for (1 .. $READERS) {
105 waitpid(-1, 0) for (1 .. ($UPDATERS + $READERS));
/dports/devel/gitolite2/gitolite-2.3.1/t/
H A Dt63-perm-cats23 R = READERS
101 name "change u2 to READERS"
102 echo READERS u2 | runlocal ssh u1 setperms foo/u1/u1r1
104 expect "READERS u2"
109 name "READERS cannot push at all"
116 ( echo READERS u6\; echo MANAGERS u2 ) | ssh u1 setperms foo/u1/u1r1;
121 echo "\$GL_WILDREPOS_PERM_CATS = 'READERS WRITERS MANAGERS';" | addrc
123 ( echo READERS u6\; echo MANAGERS u2 ) | ssh u1 setperms foo/u1/u1r1;
126 /READERS u6/
159 echo "\$GL_WILDREPOS_PERM_CATS = 'READERS WRITERS TESTERS';" | addrc
[all …]
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/include/tbb/
H A Dspin_rw_mutex.h132 if( is_writer ) __TBB_AtomicAND( &m->state, READERS ); in release()
192 if( state&WRITER ) __TBB_AtomicAND( &state, READERS ); in unlock()
210 static const state_t READERS = ~(WRITER | WRITER_PENDING); variable
212 static const state_t BUSY = WRITER | READERS;
/dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/tbb-2018_U2/include/tbb/
H A Dspin_rw_mutex.h139 if( is_writer ) __TBB_AtomicAND( &m->state, READERS ); in release()
199 if( state&WRITER ) __TBB_AtomicAND( &state, READERS ); in unlock()
217 static const state_t READERS = ~(WRITER | WRITER_PENDING); variable
219 static const state_t BUSY = WRITER | READERS;
/dports/devel/tbb/oneTBB-2020.3/include/tbb/
H A Dspin_rw_mutex.h132 if( is_writer ) __TBB_AtomicAND( &m->state, READERS ); in release()
192 if( state&WRITER ) __TBB_AtomicAND( &state, READERS ); in unlock()
210 static const state_t READERS = ~(WRITER | WRITER_PENDING); variable
212 static const state_t BUSY = WRITER | READERS;

1234567