| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/concurrency/ |
| H A D | lock_stats_test.cpp | 68 ASSERT_EQUALS(LOCK_WAITING, lockerConflict.lockBegin(resId, MODE_S)); in TEST()
83 ASSERT_EQUALS(1, stats.get(resId, MODE_S).numAcquisitions); in TEST()
84 ASSERT_EQUALS(1, stats.get(resId, MODE_S).numWaits); in TEST()
85 ASSERT_GREATER_THAN(stats.get(resId, MODE_S).combinedWaitTimeMicros, 0); in TEST()
122 ASSERT_EQUALS(1, stats.get(resId, MODE_S).numAcquisitions); in TEST()
123 ASSERT_EQUALS(1, stats.get(resId, MODE_S).numWaits); in TEST()
124 ASSERT_GREATER_THAN(stats.get(resId, MODE_S).combinedWaitTimeMicros, 0); in TEST()
135 ASSERT_EQUALS(2, stats2.get(resId, MODE_S).numAcquisitions); in TEST()
136 ASSERT_EQUALS(2, stats2.get(resId, MODE_S).numWaits); in TEST()
140 ASSERT_EQUALS(1, stats2.get(resId, MODE_S).numAcquisitions); in TEST()
[all …]
|
| H A D | lock_manager_test.cpp | 96 ASSERT(request.mode == MODE_S); in TEST()
178 ASSERT(request.mode == MODE_S); in TEST()
184 ASSERT(request.mode == MODE_S); in TEST()
190 ASSERT(request.mode == MODE_S); in TEST()
212 ASSERT(request.mode == MODE_S); in TEST()
218 ASSERT(request.mode == MODE_S); in TEST()
234 ASSERT(request.mode == MODE_S); in TEST()
380 ASSERT(request1.mode == MODE_S); in TEST()
475 ASSERT(request2.mode == MODE_S); in TEST()
481 ASSERT(request2.mode == MODE_S); in TEST()
[all …]
|
| H A D | d_concurrency_test.cpp | 469 Lock::GlobalLock globalRead(opCtx, MODE_S, 0); in TEST_F()
500 { Lock::DBLock dbRead(opCtx, "db", MODE_S); } in TEST_F()
589 Lock::DBLock dbRead(opCtx.get(), "db", MODE_S); in TEST_F()
615 Lock::DBLock dbRead(opCtx.get(), "admin", MODE_S); in TEST_F()
650 Lock::DBLock r2(opCtx.get(), "db1", MODE_S); in TEST_F()
662 Lock::DBLock dbLock(opCtx.get(), dbName, MODE_S); in TEST_F()
807 "foo", MODE_S)); in TEST_F()
811 "foo", MODE_S)); in TEST_F()
815 "foo", MODE_S)); in TEST_F()
817 "local", MODE_S)); in TEST_F()
[all …]
|
| H A D | lock_state_test.cpp | 57 ASSERT(locker.isLockHeldForMode(resId, MODE_S)); in TEST()
72 ASSERT(LOCK_OK == locker.lock(resId, MODE_S)); in TEST()
93 ASSERT(LOCK_TIMEOUT == locker2.lock(resId, MODE_S, Milliseconds(0))); in TEST()
108 ASSERT(LOCK_OK == locker1.lock(resId, MODE_S)); in TEST()
112 ASSERT(LOCK_OK == locker2.lock(resId, MODE_S)); in TEST()
267 ASSERT(LOCK_OK == locker1.lock(db1, MODE_S)); in TEST()
278 ASSERT(LOCK_WAITING == locker3.lockBegin(db1, MODE_S)); in TEST()
285 ASSERT(LOCK_OK == locker3.lockComplete(db1, MODE_S, Milliseconds(1), /*checkDeadlock*/ false)); in TEST()
291 ASSERT(locker1.getLockMode(db1) == MODE_S); in TEST()
293 ASSERT(locker3.getLockMode(db1) == MODE_S); in TEST()
|
| H A D | deadlock_detection_test.cpp | 42 ASSERT_EQUALS(LOCK_OK, locker1.lockBegin(resId, MODE_S)); in TEST()
43 ASSERT_EQUALS(LOCK_OK, locker2.lockBegin(resId, MODE_S)); in TEST()
154 ASSERT_EQUALS(LOCK_WAITING, reader.lockBegin(resIdDb, MODE_S)); in TEST()
158 ASSERT_EQUALS(LOCK_WAITING, flush.lockBegin(resIdFlush, MODE_S)); in TEST()
|
| H A D | lock_state.cpp | 160 case MODE_S: in shouldDelayUnlock()
178 return getLockMode(resourceIdGlobal) == MODE_S; in isR()
253 ticketHolders[MODE_S] = reading; in setGlobalThrottling()
370 globalStats.recordAcquisition(_id, resourceIdGlobal, MODE_S); in downgradeGlobalXtoSForMMAPV1()
371 _stats.recordAcquisition(resourceIdGlobal, MODE_S); in downgradeGlobalXtoSForMMAPV1()
373 globalLockManager.downgrade(globalLockRequest, MODE_S); in downgradeGlobalXtoSForMMAPV1()
518 case MODE_S: in isCollectionLockedForMode()
698 if (mode == MODE_S || mode == MODE_X) { in lockBegin()
847 case MODE_S: in _getModeForMMAPV1FlushLock()
901 LockResult result = _locker->lock(resourceIdMMAPV1Flush, MODE_S, Milliseconds::max(), true); in AutoAcquireFlushLockForMMAPV1Commit()
|
| H A D | lock_manager_defs.h | 65 MODE_S = 3, enumerator
94 return (mode == MODE_IS || mode == MODE_S); in isSharedLockMode()
|
| /dports/comms/hylafax/hylafax-6.0.7/util/ |
| H A D | faxfetch.c++ | 71 u_int mode = MODE_S; in run()
83 mode = MODE_S; in run()
100 if (mode == MODE_S) in run()
|
| /dports/comms/hylafax/hylafax-6.0.7/hfaxd/ |
| H A D | FileTransfer.c++ | 335 case PACK(TYPE_I,MODE_S): in sendTIFFData()
336 case PACK(TYPE_L,MODE_S): in sendTIFFData()
634 case PACK(TYPE_I,MODE_S): in sendData()
635 case PACK(TYPE_L,MODE_S): in sendData()
648 case PACK(TYPE_A,MODE_S): in sendData()
792 case PACK(TYPE_I,MODE_S): in recvData()
793 case PACK(TYPE_L,MODE_S): in recvData()
806 case PACK(TYPE_A,MODE_S): in recvData()
1044 mode = MODE_S; in modeCmd()
|
| H A D | manifest.h | 83 #define MODE_S 0 // stream macro
|
| /dports/games/flightgear/flightgear-2020.3.11/src/Instrumentation/ |
| H A D | transponder.cxx | 189 case MODE_S: in update()
224 if (_mode == MODE_S && _knob >= KNOB_GROUND) { in update()
236 if (_mode == MODE_S && _knob >= KNOB_GROUND && _airspeedIndicator_node->hasValue()) { in update()
|
| /dports/lang/zig-devel/zig-0.9.0/lib/libc/wasi/libc-top-half/musl/include/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/lang/zig-devel/zig-0.9.0/lib/libc/musl/include/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/devel/wasi-libc/wasi-libc-ad5133410f66b93a2381db5b542aad5e0964db96/libc-top-half/musl/include/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/lang/zig/zig-0.9.0/lib/libc/include/wasm-wasi-musl/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/lang/zig/zig-0.9.0/lib/libc/include/generic-musl/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/lang/zig/zig-0.9.0/lib/libc/wasi/libc-top-half/musl/include/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/lang/zig/zig-0.9.0/lib/libc/musl/include/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/lang/zig-devel/zig-0.9.0/lib/libc/include/generic-musl/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/lang/zig-devel/zig-0.9.0/lib/libc/include/wasm-wasi-musl/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/devel/emscripten/emscripten-2.0.3/system/include/libc/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/devel/tinygo/tinygo-0.14.1/lib/wasi-libc/libc-top-half/musl/include/arpa/ |
| H A D | ftp.h | 18 #define MODE_S 1 macro
|
| /dports/net/rpki-client/rpki-client-portable-7.6/openbsd/src/include/arpa/ |
| H A D | ftp.h | 84 #define MODE_S 1 /* stream */ macro
|
| /dports/devel/zpu-binutils/zpu-toolchain-1.0/toolchain/gcc/newlib/libc/sys/linux/include/arpa/ |
| H A D | ftp.h | 85 #define MODE_S 1 /* stream */ macro
|
| /dports/misc/rump/buildrump.sh-b914579/src/include/arpa/ |
| H A D | ftp.h | 83 #define MODE_S 1 /* stream */ macro
|