/dports/devel/libxs/libxs-1.2.0/src/ |
H A D | io_object.cpp | 27 io_thread (NULL) in io_object_t() 40 xs_assert (!io_thread); in plug() 43 io_thread = io_thread_; in plug() 48 xs_assert (io_thread); in unplug() 49 io_thread = NULL; in unplug() 59 io_thread->rm_fd (handle_); in rm_fd() 64 io_thread->set_pollin (handle_); in set_pollin() 69 io_thread->reset_pollin (handle_); in reset_pollin() 74 io_thread->set_pollout (handle_); in set_pollout() 79 io_thread->reset_pollout (handle_); in reset_pollout() [all …]
|
H A D | reaper.cpp | 33 io_thread = io_thread_t::create (ctx_, tid_); in reaper_t() 34 xs_assert (io_thread); in reaper_t() 36 mailbox_handle = io_thread->add_fd (mailbox_fd (&mailbox), this); in reaper_t() 37 io_thread->set_pollin (mailbox_handle); in reaper_t() 42 delete io_thread; in ~reaper_t() 54 io_thread->start (); in start() 97 io_thread->rm_fd (mailbox_handle); in process_stop() 98 io_thread->stop (); in process_stop() 105 socket_->start_reaping (io_thread); in process_reap() 118 io_thread->rm_fd (mailbox_handle); in process_reaped() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/renderer/media/audio/ |
H A D | audio_output_ipc_factory_unittest.cc | 36 CHECK(io_thread->StartWithOptions(thread_options)); in MakeIOThread() 37 return io_thread; in MakeIOThread() 109 auto io_thread = MakeIOThread(); in TEST_F() local 128 io_thread->task_runner()->PostTask( in TEST_F() 142 io_thread.reset(); in TEST_F() 149 auto io_thread = MakeIOThread(); in TEST_F() local 174 io_thread->task_runner()->PostTask( in TEST_F() 186 io_thread->task_runner()->PostTask( in TEST_F() 202 io_thread.reset(); in TEST_F() 210 auto io_thread = MakeIOThread(); in TEST_F() local [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/modules/media/audio/ |
H A D | web_audio_output_ipc_factory_test.cc | 44 CHECK(io_thread->StartWithOptions(thread_options)); in MakeIOThread() 45 return io_thread; in MakeIOThread() 121 auto io_thread = MakeIOThread(); in TEST_F() local 141 io_thread->task_runner()->PostTask( in TEST_F() 156 io_thread.reset(); in TEST_F() 163 auto io_thread = MakeIOThread(); in TEST_F() local 189 io_thread->task_runner()->PostTask( in TEST_F() 202 io_thread->task_runner()->PostTask( in TEST_F() 219 io_thread.reset(); in TEST_F() 228 auto io_thread = MakeIOThread(); in TEST_F() local [all …]
|
/dports/math/stanmath/math-4.2.0/lib/cpplint_1.4.5/samples/chromium-sample/ |
H A D | simple.def | 6 Done processing src/io_thread.cc 7 Done processing src/io_thread.h 18 src/io_thread.cc:1148: Closing ) should be moved to the previous line [whitespace/parens] [2] 19 src/io_thread.cc:1547: Missing space around colon in range-based for loop [whitespace/forcolon] [… 20 src/io_thread.cc:5: samples/chromium-sample/src/io_thread.cc should include its header file sample… 21 src/io_thread.h:5: #ifndef header guard has wrong style, please use: SAMPLES_CHROMIUM_SAMPLE_SRC_I… 22 src/io_thread.h:565: #endif line should be "#endif // SAMPLES_CHROMIUM_SAMPLE_SRC_IO_THREAD_H_" …
|
/dports/devel/cpplint/cpplint-1.5.5/samples/chromium-sample/ |
H A D | simple.def | 6 Done processing src/io_thread.cc 7 Done processing src/io_thread.h 18 src/io_thread.cc:1148: Closing ) should be moved to the previous line [whitespace/parens] [2] 19 src/io_thread.cc:1547: Missing space around colon in range-based for loop [whitespace/forcolon] [… 20 src/io_thread.cc:5: samples/chromium-sample/src/io_thread.cc should include its header file sample… 21 src/io_thread.h:5: #ifndef header guard has wrong style, please use: SAMPLES_CHROMIUM_SAMPLE_SRC_I… 22 src/io_thread.h:565: #endif line should be "#endif // SAMPLES_CHROMIUM_SAMPLE_SRC_IO_THREAD_H_" …
|
/dports/x11/xscreensaver/xscreensaver-5.44/utils/ |
H A D | thread_util.h | 365 struct io_thread struct 380 void *io_thread_create(struct io_thread *self, void *parent, void *(*start_routine)(void *), Displa… argument 399 int io_thread_return(struct io_thread *self); 403 int io_thread_is_done(struct io_thread *self); 406 int io_thread_cancel(struct io_thread *self); 411 void io_thread_finish(struct io_thread *self);
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/ppapi/host/ |
H A D | resource_message_filter_unittest.cc | 103 MyResourceFilter(const base::Thread& io_thread, in MyResourceFilter() argument 107 : ResourceMessageFilter(io_thread.task_runner()), in MyResourceFilter() 151 base::Thread io_thread("test_io_thread"); in TestHandleMessageImpl() local 152 ASSERT_TRUE(io_thread.Start()); in TestHandleMessageImpl() 157 new MyResourceFilter(io_thread, bg_thread1, MSG1_TYPE, REPLY_MSG1_TYPE); in TestHandleMessageImpl() 162 new MyResourceFilter(io_thread, bg_thread2, MSG2_TYPE, REPLY_MSG2_TYPE); in TestHandleMessageImpl() 185 EXPECT_EQ(host.last_reply_task_runner(), io_thread.task_runner()); in TestHandleMessageImpl() 195 EXPECT_EQ(host.last_reply_task_runner(), io_thread.task_runner()); in TestHandleMessageImpl() 204 io_thread.Stop(); in TestHandleMessageImpl()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/ppapi/host/ |
H A D | resource_message_filter_unittest.cc | 103 MyResourceFilter(const base::Thread& io_thread, in MyResourceFilter() argument 107 : ResourceMessageFilter(io_thread.task_runner()), in MyResourceFilter() 151 base::Thread io_thread("test_io_thread"); in TestHandleMessageImpl() local 152 ASSERT_TRUE(io_thread.Start()); in TestHandleMessageImpl() 157 new MyResourceFilter(io_thread, bg_thread1, MSG1_TYPE, REPLY_MSG1_TYPE); in TestHandleMessageImpl() 162 new MyResourceFilter(io_thread, bg_thread2, MSG2_TYPE, REPLY_MSG2_TYPE); in TestHandleMessageImpl() 185 EXPECT_EQ(host.last_reply_task_runner(), io_thread.task_runner()); in TestHandleMessageImpl() 195 EXPECT_EQ(host.last_reply_task_runner(), io_thread.task_runner()); in TestHandleMessageImpl() 204 io_thread.Stop(); in TestHandleMessageImpl()
|
/dports/net/libzmq2/zeromq-2.2.0/src/ |
H A D | connect_session.cpp | 49 io_thread_t *io_thread = choose_io_thread (options.affinity); in start_connecting() local 50 zmq_assert (io_thread); in start_connecting() 58 io_thread, this, options, protocol.c_str (), address.c_str (), in start_connecting() 80 io_thread, options); in start_connecting() 92 io_thread, options); in start_connecting()
|
/dports/devel/upp/upp/bazaar/ZMQ/lib/src/ |
H A D | connect_session.cpp | 48 io_thread_t *io_thread = choose_io_thread (options.affinity); in start_connecting() local 49 zmq_assert (io_thread); in start_connecting() 57 io_thread, this, options, protocol.c_str (), address.c_str (), in start_connecting() 79 io_thread, options); in start_connecting() 91 io_thread, options); in start_connecting()
|
/dports/devel/valgrind/valgrind-dragonfly-dragonfly/none/tests/ |
H A D | pth_cancel2.c | 74 pthread_t io_thread, killer_thread; in main() local 82 pthread_create(&io_thread, in main() 89 (void *)&io_thread); in main() 91 pthread_join(io_thread, NULL); in main()
|
/dports/devel/valgrind-lts/valgrind-dragonfly-dragonfly/none/tests/ |
H A D | pth_cancel2.c | 74 pthread_t io_thread, killer_thread; in main() local 82 pthread_create(&io_thread, in main() 89 (void *)&io_thread); in main() 91 pthread_join(io_thread, NULL); in main()
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/io/romio314/romio/adio/common/ |
H A D | p2p_aggregation.c | 25 pthread_t io_thread; in ADIOI_P2PContigWriteAggregation() local 154 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 400 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 422 if ( (pthread_create(&io_thread, NULL, in ADIOI_P2PContigWriteAggregation() 424 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 496 pthread_t io_thread; in ADIOI_P2PContigReadAggregation() local 635 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() 696 pthread_join(io_thread, &thread_ret); in ADIOI_P2PContigReadAggregation() 699 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() 723 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/common/ |
H A D | p2p_aggregation.c | 30 pthread_t io_thread; in ADIOI_P2PContigWriteAggregation() local 39 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 464 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 487 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 509 pthread_join(io_thread, &thread_ret); in ADIOI_P2PContigWriteAggregation() 557 pthread_t io_thread; in ADIOI_P2PContigReadAggregation() local 570 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() 769 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() 792 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() 801 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() [all …]
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/io/romio321/romio/adio/common/ |
H A D | p2p_aggregation.c | 31 pthread_t io_thread; in ADIOI_P2PContigWriteAggregation() local 160 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 406 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 428 if ( (pthread_create(&io_thread, NULL, in ADIOI_P2PContigWriteAggregation() 430 io_thread = pthread_self(); in ADIOI_P2PContigWriteAggregation() 502 pthread_t io_thread; in ADIOI_P2PContigReadAggregation() local 641 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() 702 pthread_join(io_thread, &thread_ret); in ADIOI_P2PContigReadAggregation() 705 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() 729 io_thread = pthread_self(); in ADIOI_P2PContigReadAggregation() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/ios/components/io_thread/ |
H A D | ios_io_thread_unittest.mm | 5 #include "ios/components/io_thread/ios_io_thread.h" 28 class TestIOThread : public io_thread::IOSIOThread { 70 std::unique_ptr<web::TestWebThread> io_thread( 72 io_thread->StartIOThreadUnregistered(); 77 io_thread->RegisterAsWebThread(); 83 io_thread.reset();
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/ |
H A D | transitional_url_loader_factory_owner_unittest.cc | 75 base::Thread io_thread("IO"); in TEST_F() local 78 ASSERT_TRUE(io_thread.StartWithOptions(options)); in TEST_F() 80 TestOnTaskRunner(io_thread.task_runner(), base::BindLambdaForTesting([&]() { in TEST_F() 81 io_thread.FlushForTesting(); in TEST_F()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/services/network/ |
H A D | transitional_url_loader_factory_owner_unittest.cc | 75 base::Thread io_thread("IO"); in TEST_F() local 78 ASSERT_TRUE(io_thread.StartWithOptions(options)); in TEST_F() 80 TestOnTaskRunner(io_thread.task_runner(), base::BindLambdaForTesting([&]() { in TEST_F() 81 io_thread.FlushForTesting(); in TEST_F()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/llvm/lldb/packages/Python/lldbsuite/test/test_runner/ |
H A D | process_control.py | 472 self.io_thread = None 526 self.io_thread.join() 537 self.io_thread.output, 566 self.io_thread = CommunicatorThread( 568 self.io_thread.start() 583 self.io_thread.join(self.soft_terminate_timeout) 584 if not self.io_thread.is_alive(): 615 self.io_thread.join(self.hard_terminate_timeout) 616 if self.io_thread.is_alive(): 690 self.io_thread.output,
|
/dports/devel/wasi-libcxx/llvm-project-13.0.1.src/lldb/packages/Python/lldbsuite/test/test_runner/ |
H A D | process_control.py | 472 self.io_thread = None 526 self.io_thread.join() 537 self.io_thread.output, 566 self.io_thread = CommunicatorThread( 568 self.io_thread.start() 583 self.io_thread.join(self.soft_terminate_timeout) 584 if not self.io_thread.is_alive(): 615 self.io_thread.join(self.hard_terminate_timeout) 616 if self.io_thread.is_alive(): 690 self.io_thread.output,
|
/dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/lldb/packages/Python/lldbsuite/test/test_runner/ |
H A D | process_control.py | 472 self.io_thread = None 526 self.io_thread.join() 537 self.io_thread.output, 566 self.io_thread = CommunicatorThread( 568 self.io_thread.start() 583 self.io_thread.join(self.soft_terminate_timeout) 584 if not self.io_thread.is_alive(): 615 self.io_thread.join(self.hard_terminate_timeout) 616 if self.io_thread.is_alive(): 690 self.io_thread.output,
|
/dports/devel/llvm12/llvm-project-12.0.1.src/lldb/packages/Python/lldbsuite/test/test_runner/ |
H A D | process_control.py | 472 self.io_thread = None 526 self.io_thread.join() 537 self.io_thread.output, 566 self.io_thread = CommunicatorThread( 568 self.io_thread.start() 583 self.io_thread.join(self.soft_terminate_timeout) 584 if not self.io_thread.is_alive(): 615 self.io_thread.join(self.hard_terminate_timeout) 616 if self.io_thread.is_alive(): 690 self.io_thread.output,
|
/dports/lang/rust/rustc-1.58.1-src/src/llvm-project/lldb/packages/Python/lldbsuite/test/test_runner/ |
H A D | process_control.py | 472 self.io_thread = None 526 self.io_thread.join() 537 self.io_thread.output, 566 self.io_thread = CommunicatorThread( 568 self.io_thread.start() 583 self.io_thread.join(self.soft_terminate_timeout) 584 if not self.io_thread.is_alive(): 615 self.io_thread.join(self.hard_terminate_timeout) 616 if self.io_thread.is_alive(): 690 self.io_thread.output,
|
/dports/devel/llvm-devel/llvm-project-f05c95f10fc1d8171071735af8ad3a9e87633120/lldb/packages/Python/lldbsuite/test/test_runner/ |
H A D | process_control.py | 472 self.io_thread = None 526 self.io_thread.join() 537 self.io_thread.output, 566 self.io_thread = CommunicatorThread( 568 self.io_thread.start() 583 self.io_thread.join(self.soft_terminate_timeout) 584 if not self.io_thread.is_alive(): 615 self.io_thread.join(self.hard_terminate_timeout) 616 if self.io_thread.is_alive(): 690 self.io_thread.output,
|