/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
|