Home
last modified time | relevance | path

Searched refs:threadRunner (Results 1 – 23 of 23) sorted by relevance

/dports/net/gerbera/gerbera-1.9.2/src/content/
H A Dupdate_manager.cc60 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 Dcontent_manager.cc110 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 Dupdate_manager.h69 std::unique_ptr<StdThreadRunner> threadRunner; variable
H A Dcontent_manager.h383 std::unique_ptr<ThreadRunner<std::condition_variable_any, std::recursive_mutex>> threadRunner; variable
/dports/net/gerbera/gerbera-1.9.2/src/util/
H A Dtimer.cc47 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 Dtimer.h154 std::unique_ptr<StdThreadRunner> threadRunner; variable
/dports/net/gerbera/gerbera-1.9.2/src/content/onlineservice/
H A Dtask_processor.cc43 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 Dtask_processor.h38 std::unique_ptr<StdThreadRunner> threadRunner; variable
/dports/net/gerbera/gerbera-1.9.2/src/iohandler/
H A Dio_handler_buffer_helper.cc73 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 Dbuffered_io_handler.cc78 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 Dcurl_io_handler.cc107 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 Dio_handler_buffer_helper.h96 std::unique_ptr<StdThreadRunner> threadRunner; variable
/dports/net/gerbera/gerbera-1.9.2/src/database/sqlite3/
H A Dsqlite_database.cc78 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 Dsqlite_database.h190 std::unique_ptr<StdThreadRunner> threadRunner; variable
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/skia/tools/calmbench/
H A Dab.py206 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 Dab.py206 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 Dsharedtex_mt.c380 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 Dsharedtex_mt.c380 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 Dsharedtex_mt.c380 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 Dnative_java_lang_Thread.c13 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 Dsharedtex_mt.c403 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 Dsharedtex_mt.c403 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 DClient.hs436 let threadRunner = clientThreadRunner opts function
441 threadRunner (mainLoop client)