Home
last modified time | relevance | path

Searched refs:io_thread (Results 1 – 25 of 731) sorted by relevance

12345678910>>...30

/dports/devel/libxs/libxs-1.2.0/src/
H A Dio_object.cpp27 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 Dreaper.cpp33 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 Daudio_output_ipc_factory_unittest.cc36 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 Dweb_audio_output_ipc_factory_test.cc44 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 Dsimple.def6 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 Dsimple.def6 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 Dthread_util.h365 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 Dresource_message_filter_unittest.cc103 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 Dresource_message_filter_unittest.cc103 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 Dconnect_session.cpp49 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 Dconnect_session.cpp48 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 Dpth_cancel2.c74 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 Dpth_cancel2.c74 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 Dp2p_aggregation.c25 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 Dp2p_aggregation.c30 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 Dp2p_aggregation.c31 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 Dios_io_thread_unittest.mm5 #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 Dtransitional_url_loader_factory_owner_unittest.cc75 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 Dtransitional_url_loader_factory_owner_unittest.cc75 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 Dprocess_control.py472 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 Dprocess_control.py472 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 Dprocess_control.py472 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 Dprocess_control.py472 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 Dprocess_control.py472 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 Dprocess_control.py472 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,

12345678910>>...30