/dports/net/gerbera/gerbera-1.9.2/src/content/ |
H A D | update_manager.cc | 60 threadRunner->waitForReady(); in run() 68 auto lock = threadRunner->uniqueLock(); in shutdown() 72 threadRunner->notify(); in shutdown() 75 threadRunner->join(); in shutdown() 81 auto lock = threadRunner->uniqueLock(); in containersChanged() 102 threadRunner->notify(); in containersChanged() 113 threadRunner->notify(); in containersChanged() 122 auto lock = threadRunner->lockGuard(); in containerChanged() 146 threadRunner->notify(); in containerChanged() 161 threadRunner->setReady(); in threadProc() [all …]
|
H A D | content_manager.cc | 110 threadRunner->waitForReady(); in run() 112 if (!threadRunner->isAlive()) { in run() 299 auto lock = threadRunner->uniqueLock(); in shutdown() 338 threadRunner->notify(); in shutdown() 342 threadRunner->join(); in shutdown() 363 auto lock = threadRunner->lockGuard("getCurrentTask"); in getCurrentTask() 370 auto lock = threadRunner->lockGuard("getTasklist"); in getTasklist() 1392 threadRunner->setReady(); in threadProc() 1410 threadRunner->wait(lock); in threadProc() 1446 auto lock = threadRunner->lockGuard("addTask"); in addTask() [all …]
|
H A D | update_manager.h | 69 std::unique_ptr<StdThreadRunner> threadRunner; variable
|
H A D | content_manager.h | 383 std::unique_ptr<ThreadRunner<std::condition_variable_any, std::recursive_mutex>> threadRunner; variable
|
/dports/net/gerbera/gerbera-1.9.2/src/util/ |
H A D | timer.cc | 47 threadRunner->waitForReady(); in run() 49 if (!threadRunner->isAlive()) in run() 73 auto lock = threadRunner->lockGuard(); in addTimerSubscriber() 84 threadRunner->notify(); in addTimerSubscriber() 90 auto lock = threadRunner->lockGuard(); in removeTimerSubscriber() 96 threadRunner->notify(); in removeTimerSubscriber() 112 threadRunner->setReady(); in triggerWait() 119 threadRunner->wait(lock); in triggerWait() 176 auto lock = threadRunner->lockGuard(); in getNextNotifyTime() 192 threadRunner->notifyAll(); in shutdown() [all …]
|
H A D | timer.h | 154 std::unique_ptr<StdThreadRunner> threadRunner; variable
|
/dports/net/gerbera/gerbera-1.9.2/src/content/onlineservice/ |
H A D | task_processor.cc | 43 threadRunner->waitForReady(); in run() 45 if (!threadRunner->isAlive()) in run() 53 threadRunner->notify(); in shutdown() 54 threadRunner->join(); in shutdown() 71 threadRunner->setReady(); in threadProc() 85 threadRunner->wait(lock); in threadProc() 110 auto lock = threadRunner->lockGuard(); in addTask() 115 threadRunner->notify(); in addTask() 120 auto lock = threadRunner->lockGuard(); in getCurrentTask() 126 auto lock = threadRunner->lockGuard(); in invalidateTask() [all …]
|
H A D | task_processor.h | 38 std::unique_ptr<StdThreadRunner> threadRunner; variable
|
/dports/net/gerbera/gerbera-1.9.2/src/iohandler/ |
H A D | io_handler_buffer_helper.cc | 73 auto lock = threadRunner->uniqueLock(); in read() 80 threadRunner->wait(lock); in read() 113 threadRunner->notify(); in read() 123 threadRunner->notify(); in read() 147 auto lock = threadRunner->uniqueLock(); in seek() 156 threadRunner->notify(); in seek() 159 threadRunner->wait(lock, [&]() { in seek() 183 auto lock = threadRunner->uniqueLock(); in stopBufferThread() 185 threadRunner->notify(); in stopBufferThread() 188 threadRunner->join(); in stopBufferThread() [all …]
|
H A D | buffered_io_handler.cc | 78 auto lock = threadRunner->uniqueLock(); in threadProc() 120 threadRunner->notify(); in threadProc() 140 threadRunner->notify(); in threadProc() 145 threadRunner->wait(lock); in threadProc() 158 threadRunner->notify(); in threadProc() 167 threadRunner->notify(); in threadProc() 172 threadRunner->notify(); in threadProc() 183 threadRunner->notify(); in threadProc()
|
H A D | curl_io_handler.cc | 107 auto lock = threadRunner->uniqueLock(std::defer_lock); in threadProc() 128 threadRunner->notify(); in threadProc() 139 threadRunner->notify(); in threadProc() 148 auto& threadRunner = ego->threadRunner; in curlCallback() local 152 auto lock = threadRunner->uniqueLock(); in curlCallback() 179 threadRunner->notify(); in curlCallback() 196 threadRunner->wait(lock); in curlCallback() 233 threadRunner->notify(); in curlCallback() 242 threadRunner->notify(); in curlCallback()
|
H A D | io_handler_buffer_helper.h | 96 std::unique_ptr<StdThreadRunner> threadRunner; variable
|
/dports/net/gerbera/gerbera-1.9.2/src/database/sqlite3/ |
H A D | sqlite_database.cc | 78 if (!threadRunner->isAlive()) { in init() 83 threadRunner->waitForReady(); in init() 283 StdThreadRunner::waitFor("Sqlite3Database", [this] { return threadRunner != nullptr; }); in threadProc() 284 auto lock = threadRunner->uniqueLockS("threadProc"); in threadProc() 286 threadRunner->setReady(); in threadProc() 308 threadRunner->wait(lock); in threadProc() 336 auto lock = threadRunner->lockGuard(fmt::format("addTask {}", task->taskType())); in addTask() 343 threadRunner->notify(); in addTask() 350 auto lock = threadRunner->uniqueLockS("shutdown"); in shutdownDriver() 357 threadRunner->notify(); in shutdownDriver() [all …]
|
H A D | sqlite_database.h | 190 std::unique_ptr<StdThreadRunner> threadRunner; variable
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/skia/tools/calmbench/ |
H A D | ab.py | 206 def run(args, threadRunner, name, nano, arg, i): argument 228 threadRunner.add(args, task) 232 threadRunner = ThreadRunner(args) 234 run(args, threadRunner, args.a, args.nano_a, args.arg_a, i) 235 run(args, threadRunner, args.b, args.nano_b, args.arg_b, i) 236 threadRunner.wait() 320 threadRunner = ThreadRunner(args) 322 run(args, threadRunner, args.a, args.nano_a, 324 run(args, threadRunner, args.b, args.nano_b, 327 threadRunner.wait()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/skia/tools/calmbench/ |
H A D | ab.py | 206 def run(args, threadRunner, name, nano, arg, i): argument 228 threadRunner.add(args, task) 232 threadRunner = ThreadRunner(args) 234 run(args, threadRunner, args.a, args.nano_a, args.arg_a, i) 235 run(args, threadRunner, args.b, args.nano_b, args.arg_b, i) 236 threadRunner.wait() 320 threadRunner = ThreadRunner(args) 322 run(args, threadRunner, args.a, args.nano_a, 324 run(args, threadRunner, args.b, args.nano_b, 327 threadRunner.wait()
|
/dports/x11/virtualgl/virtualgl-3.0/glxdemos/ |
H A D | sharedtex_mt.c | 380 static void *threadRunner (void *arg) in threadRunner() function 488 pthread_create(&t0, NULL, threadRunner, &tia0); in main() 490 pthread_create(&t1, NULL, threadRunner, &tia1); in main() 492 pthread_create(&t2, NULL, threadRunner, &tia2); in main() 494 pthread_create(&t3, NULL, threadRunner, &tia3); in main()
|
/dports/graphics/glx-utils/demos-5435fc7fbd332e171da9a71e33a9b190e9462cf0/src/xdemos/ |
H A D | sharedtex_mt.c | 380 static void *threadRunner (void *arg) in threadRunner() function 488 pthread_create(&t0, NULL, threadRunner, &tia0); in main() 490 pthread_create(&t1, NULL, threadRunner, &tia1); in main() 492 pthread_create(&t2, NULL, threadRunner, &tia2); in main() 494 pthread_create(&t3, NULL, threadRunner, &tia3); in main()
|
/dports/graphics/mesa-demos/mesa-demos-8.4.0/src/xdemos/ |
H A D | sharedtex_mt.c | 380 static void *threadRunner (void *arg) in threadRunner() function 488 pthread_create(&t0, NULL, threadRunner, &tia0); in main() 490 pthread_create(&t1, NULL, threadRunner, &tia1); in main() 492 pthread_create(&t2, NULL, threadRunner, &tia2); in main() 494 pthread_create(&t3, NULL, threadRunner, &tia3); in main()
|
/dports/devel/emscripten/emscripten-2.0.3/tests/nbody-java/ |
H A D | native_java_lang_Thread.c | 13 void threadRunner(JAVA_OBJECT me) in threadRunner() function 201 int rc = pthread_create(&pt, &attr, threadRunner, (void *)me); in java_lang_Thread_start0__()
|
/dports/graphics/glx-utils/demos-5435fc7fbd332e171da9a71e33a9b190e9462cf0/src/wgl/ |
H A D | sharedtex_mt.c | 403 threadRunner (void *arg) in threadRunner() function 533 threads[i] = CreateThread(NULL, 0, threadRunner, &tia[i], 0, &id); in main()
|
/dports/graphics/mesa-demos/mesa-demos-8.4.0/src/wgl/ |
H A D | sharedtex_mt.c | 403 threadRunner (void *arg) in threadRunner() function 533 threads[i] = CreateThread(NULL, 0, threadRunner, &tia[i], 0, &id); in main()
|
/dports/devel/hs-git-annex/git-annex-8.20210903/_cabal_deps/dbus-1.2.15.1/lib/DBus/ |
H A D | Client.hs | 436 let threadRunner = clientThreadRunner opts function 441 threadRunner (mainLoop client)
|