| /dports/www/chromium-legacy/chromium-88.0.4324.182/storage/browser/quota/ |
| H A D | quota_manager_proxy.cc | 48 io_thread_->PostTask( in RegisterClient()
65 io_thread_->PostTask( in NotifyStorageAccessed()
80 io_thread_->PostTask( in NotifyStorageModified()
92 io_thread_->PostTask( in NotifyOriginInUse()
104 io_thread_->PostTask( in NotifyOriginNoLongerInUse()
115 io_thread_->PostTask( in NotifyWriteFailed()
129 io_thread_->PostTask( in SetUsageCacheEnabled()
144 io_thread_->PostTask( in GetUsageAndQuota()
173 io_thread_->PostTaskAndReply( in OverrideQuotaForOrigin()
182 io_thread_->PostTask(FROM_HERE, in WithdrawOverridesForHandle()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/storage/browser/quota/ |
| H A D | quota_manager_proxy.cc | 40 if (!io_thread_->BelongsToCurrentThread() && in RegisterClient()
41 io_thread_->PostTask( in RegisterClient()
55 if (!io_thread_->BelongsToCurrentThread()) { in NotifyStorageAccessed()
56 io_thread_->PostTask( in NotifyStorageAccessed()
71 io_thread_->PostTask( in NotifyStorageModified()
83 io_thread_->PostTask( in NotifyOriginInUse()
95 io_thread_->PostTask( in NotifyOriginNoLongerInUse()
106 io_thread_->PostTask( in NotifyWriteFailed()
120 io_thread_->PostTask( in SetUsageCacheEnabled()
135 io_thread_->PostTask( in GetUsageAndQuota()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/chrome_cleaner/ipc/ |
| H A D | mojo_task_runner.cc | 32 DCHECK(io_thread_); in PostDelayedTask()
33 return io_thread_->task_runner()->PostDelayedTask(from_here, std::move(task), in PostDelayedTask()
38 DCHECK(io_thread_); in RunsTasksInCurrentSequence()
39 return io_thread_->task_runner()->RunsTasksInCurrentSequence(); in RunsTasksInCurrentSequence()
45 return io_thread_->task_runner()->PostNonNestableDelayedTask( in PostNonNestableDelayedTask()
55 io_thread_.reset(); in ~MojoTaskRunner()
59 io_thread_ = std::make_unique<base::Thread>("MojoThread"); in Initialize()
60 if (!io_thread_->StartWithOptions( in Initialize()
62 io_thread_.reset(); in Initialize()
67 io_thread_->task_runner(), in Initialize()
|
| /dports/devel/libxs/libxs-1.2.0/src/ |
| H A D | session_base.cpp | 57 s = new (std::nothrow) req_session_t (io_thread_, connect_, in create()
61 s = new (std::nothrow) xreq_session_t (io_thread_, connect_, in create()
65 s = new (std::nothrow) rep_session_t (io_thread_, connect_, in create()
69 s = new (std::nothrow) xrep_session_t (io_thread_, connect_, in create()
73 s = new (std::nothrow) pub_session_t (io_thread_, connect_, in create()
77 s = new (std::nothrow) xpub_session_t (io_thread_, connect_, in create()
81 s = new (std::nothrow) sub_session_t (io_thread_, connect_, in create()
124 xs::session_base_t::session_base_t (class io_thread_t *io_thread_, in session_base_t() argument
127 own_t (io_thread_, options_), in session_base_t()
128 io_object_t (io_thread_), in session_base_t()
[all …]
|
| H A D | io_object.cpp | 26 xs::io_object_t::io_object_t (io_thread_t *io_thread_) : in io_object_t() argument
29 if (io_thread_) in io_object_t()
30 plug (io_thread_); in io_object_t()
37 void xs::io_object_t::plug (io_thread_t *io_thread_) in plug() argument
39 xs_assert (io_thread_); in plug()
43 io_thread = io_thread_; in plug()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/gcm_driver/ |
| H A D | gcm_driver_desktop.cc | 552 io_thread_->PostTask( in GCMDriverDesktop()
702 io_thread_->PostTask( in DoRegister()
726 io_thread_->PostTask( in DoUnregister()
749 io_thread_->PostTask( in DoSend()
758 io_thread_->PostTask( in RecordDecryptionFailure()
783 io_thread_->PostTask( in GetGCMStatistics()
795 io_thread_->PostTask( in SetGCMRecording()
805 io_thread_->PostTask( in UpdateAccountMapping()
814 io_thread_->PostTask( in RemoveAccountMapping()
829 io_thread_->PostTask( in SetLastTokenFetchTime()
[all …]
|
| H A D | gcm_driver_unittest.cc | 98 base::Thread io_thread_; member in gcm::GCMDriverBaseTest
116 GCMDriverBaseTest::GCMDriverBaseTest() : io_thread_("IOThread") {} in GCMDriverBaseTest()
121 io_thread_.Start(); in SetUp()
137 io_thread_.Stop(); in TearDown()
144 io_thread_.task_runner()->PostTaskAndReply( in PumpIOLoop()
151 new net::TestURLRequestContextGetter(io_thread_.task_runner()); in CreateDriver()
156 base::ThreadTaskRunnerHandle::Get(), io_thread_.task_runner()), in CreateDriver()
162 base::ThreadTaskRunnerHandle::Get(), io_thread_.task_runner(), in CreateDriver()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/browser/api/sockets_udp/ |
| H A D | test_udp_echo_server.cc | 101 if (io_thread_) { in ~TestUdpEchoServer()
102 io_thread_->task_runner()->DeleteSoon(FROM_HERE, std::move(core_)); in ~TestUdpEchoServer()
104 io_thread_->task_runner()->PostTask(FROM_HERE, run_loop.QuitClosure()); in ~TestUdpEchoServer()
106 io_thread_.reset(); in ~TestUdpEchoServer()
111 DCHECK(!io_thread_); in Start()
117 io_thread_ = std::make_unique<base::Thread>("EmbeddedTestServer IO Thread"); in Start()
118 CHECK(io_thread_->StartWithOptions(thread_options)); in Start()
119 CHECK(io_thread_->WaitUntilThreadStarted()); in Start()
123 io_thread_->task_runner()->PostTaskAndReply( in Start()
|
| /dports/net/libzmq4/zeromq-4.3.4/src/ |
| H A D | io_object.cpp | 35 zmq::io_object_t::io_object_t (io_thread_t *io_thread_) : _poller (NULL) in io_object_t() argument
37 if (io_thread_) in io_object_t()
38 plug (io_thread_); in io_object_t()
45 void zmq::io_object_t::plug (io_thread_t *io_thread_) in plug() argument
47 zmq_assert (io_thread_); in plug()
51 _poller = io_thread_->get_poller (); in plug()
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/ |
| H A D | io_object.cpp | 35 zmq::io_object_t::io_object_t (io_thread_t *io_thread_) : _poller (NULL) in io_object_t() argument
37 if (io_thread_) in io_object_t()
38 plug (io_thread_); in io_object_t()
45 void zmq::io_object_t::plug (io_thread_t *io_thread_) in plug() argument
47 zmq_assert (io_thread_); in plug()
51 _poller = io_thread_->get_poller (); in plug()
|
| /dports/net/libzmq2/zeromq-2.2.0/src/ |
| H A D | io_object.cpp | 25 zmq::io_object_t::io_object_t (io_thread_t *io_thread_) : in io_object_t() argument
28 if (io_thread_) in io_object_t()
29 plug (io_thread_); in io_object_t()
36 void zmq::io_object_t::plug (io_thread_t *io_thread_) in plug() argument
38 zmq_assert (io_thread_); in plug()
42 poller = io_thread_->get_poller (); in plug()
|
| /dports/devel/upp/upp/bazaar/ZMQ/lib/src/ |
| H A D | io_object.cpp | 24 zmq::io_object_t::io_object_t (io_thread_t *io_thread_) : in io_object_t() argument
27 if (io_thread_) in io_object_t()
28 plug (io_thread_); in io_object_t()
35 void zmq::io_object_t::plug (io_thread_t *io_thread_) in plug() argument
37 zmq_assert (io_thread_); in plug()
41 poller = io_thread_->get_poller (); in plug()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/test/embedded_test_server/ |
| H A D | embedded_test_server.cc | 99 io_thread_.reset(); in ~EmbeddedTestServer()
113 DCHECK(!io_thread_.get()) in SetConnectionListener()
293 if (io_thread_.get()) in GenerateCertAndKey()
314 DCHECK(!io_thread_.get()) in StartAcceptingConnections()
323 CHECK(io_thread_->StartWithOptions(thread_options)); in StartAcceptingConnections()
324 CHECK(io_thread_->WaitUntilThreadStarted()); in StartAcceptingConnections()
326 io_thread_->task_runner()->PostTask( in StartAcceptingConnections()
522 DCHECK(!io_thread_.get()) in RegisterRequestHandler()
529 DCHECK(!io_thread_.get()) in RegisterRequestMonitor()
536 DCHECK(!io_thread_.get()) in RegisterDefaultHandler()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/browser/loader/ |
| H A D | quic_transport_browsertest.cc | 49 io_thread_->task_runner()->PostTask( in ~QuicTransportSimpleServerWithThread()
56 io_thread_.reset(); in ~QuicTransportSimpleServerWithThread()
60 CHECK(!io_thread_); in Start()
62 io_thread_ = std::make_unique<base::Thread>("QuicTransport server"); in Start()
65 CHECK(io_thread_->StartWithOptions(thread_options)); in Start()
66 CHECK(io_thread_->WaitUntilThreadStarted()); in Start()
70 io_thread_->task_runner()->PostTask( in Start()
91 std::unique_ptr<base::Thread> io_thread_; member in content::__anondb7b58380111::QuicTransportSimpleServerWithThread
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/test/spawned_test_server/ |
| H A D | remote_test_server.cc | 59 : BaseTestServer(type), io_thread_("RemoteTestServer IO Thread") { in RemoteTestServer()
68 io_thread_("RemoteTestServer IO Thread") { in RemoteTestServer()
100 ocsp_proxy_ = std::make_unique<TcpSocketProxy>(io_thread_.task_runner()); in StartInBackground()
114 io_thread_.task_runner(), config_.GetSpawnerUrl("start"), in StartInBackground()
140 std::make_unique<TcpSocketProxy>(io_thread_.task_runner()); in BlockUntilStarted()
168 io_thread_.task_runner(), in Stop()
200 bool thread_started = io_thread_.StartWithOptions( in Init()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/test/chromedriver/net/ |
| H A D | net_util_unittest.cc | 40 : io_thread_("io"), in FetchUrlTest()
44 CHECK(io_thread_.StartWithOptions(options)); in FetchUrlTest()
48 io_thread_.task_runner()->PostTask( in FetchUrlTest()
58 io_thread_.task_runner()->PostTask( in ~FetchUrlTest()
68 new URLRequestContextGetter(io_thread_.task_runner()); in InitOnIO()
113 SetIOCapableTaskRunnerForTest(io_thread_.task_runner()); in DoFetchURL()
129 base::Thread io_thread_; member in __anon28fabc470111::FetchUrlTest
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/ios/web/test/ |
| H A D | web_task_environment.cc | 30 io_thread_->Stop(); in ~WebTaskEnvironment()
53 io_thread_ = std::make_unique<TestWebThread>(WebThread::IO); in Init()
54 io_thread_->StartIOThread(); in Init()
56 io_thread_ = std::make_unique<TestWebThread>(WebThread::IO, in Init()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/service/ |
| H A D | service_ipc_server_unittest.cc | 86 base::Thread io_thread_; member in ServiceIPCServerTest
95 : io_thread_("ServiceIPCServerTest IO"), in ServiceIPCServerTest()
103 ASSERT_TRUE(io_thread_.StartWithOptions(options)); in SetUp()
106 io_thread_.task_runner(), in SetUp()
118 io_thread_.Stop(); in TearDown()
123 io_thread_.task_runner()->PostTaskAndReply( in PumpLoops()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/viz/service/gl/ |
| H A D | gpu_service_impl_unittest.cc | 44 : io_thread_("TestIOThread"), in GpuServiceTest()
65 return io_thread_.task_runner(); in io_runner()
70 ASSERT_TRUE(io_thread_.Start()); in SetUp()
74 gpu_info, /*watchdog_thread=*/nullptr, io_thread_.task_runner(), in SetUp()
85 io_thread_.Stop(); in TearDown()
89 base::Thread io_thread_; member in viz::GpuServiceTest
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/viz/service/gl/ |
| H A D | gpu_service_impl_unittest.cc | 43 : io_thread_("TestIOThread"), in GpuServiceTest()
64 return io_thread_.task_runner(); in io_runner()
69 ASSERT_TRUE(io_thread_.Start()); in SetUp()
73 gpu_info, /*watchdog_thread=*/nullptr, io_thread_.task_runner(), in SetUp()
85 io_thread_.Stop(); in TearDown()
89 base::Thread io_thread_; member in viz::GpuServiceTest
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/content/browser/loader/ |
| H A D | quic_transport_browsertest.cc | 51 io_thread_->task_runner()->PostTask( in ~QuicTransportSimpleServerWithThread()
58 io_thread_.reset(); in ~QuicTransportSimpleServerWithThread()
62 CHECK(!io_thread_); in Start()
64 io_thread_ = std::make_unique<base::Thread>("QuicTransport server"); in Start()
67 CHECK(io_thread_->StartWithOptions(thread_options)); in Start()
68 CHECK(io_thread_->WaitUntilThreadStarted()); in Start()
72 io_thread_->task_runner()->PostTask( in Start()
93 std::unique_ptr<base::Thread> io_thread_; member in content::__anonad867add0111::QuicTransportSimpleServerWithThread
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/content/app/ |
| H A D | service_manager_environment.cc | 24 : io_thread_(std::move(io_thread)) { in ServiceManagerEnvironment()
26 io_thread_->task_runner(); in ServiceManagerEnvironment()
40 std::make_unique<ServiceManagerContext>(io_thread_->task_runner()); in ServiceManagerEnvironment()
49 startup_data->io_thread = std::move(io_thread_); in CreateBrowserStartupData()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/nacl/loader/nonsfi/ |
| H A D | nonsfi_listener.cc | 40 : io_thread_("NaCl_IOThread"), in NonSfiListener()
44 io_thread_.StartWithOptions( in NonSfiListener()
52 NaClService service(io_thread_.task_runner()); in Listen()
56 io_thread_.task_runner(), base::ThreadTaskRunnerHandle::Get(), in Listen()
113 io_thread_.task_runner().get()); in OnStart()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/test/embedded_test_server/ |
| H A D | embedded_test_server.cc | 298 io_thread_.reset(); in ~EmbeddedTestServer()
312 DCHECK(!io_thread_) in SetConnectionListener()
565 if (io_thread_) in GenerateCertAndKey()
599 CHECK(io_thread_->StartWithOptions(thread_options)); in StartAcceptingConnections()
600 CHECK(io_thread_->WaitUntilThreadStarted()); in StartAcceptingConnections()
602 io_thread_->task_runner()->PostTask( in StartAcceptingConnections()
630 DCHECK(io_thread_->task_runner()->BelongsToCurrentThread()); in ShutdownOnIOThread()
843 DCHECK(!io_thread_) in RegisterRequestHandler()
850 DCHECK(!io_thread_) in RegisterRequestMonitor()
857 DCHECK(!io_thread_) in RegisterDefaultHandler()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/tools/ipc_fuzzer/message_replay/ |
| H A D | replay_process.cc | 100 : io_thread_("Chrome_ChildIOThread"), in ReplayProcess()
111 io_thread_.Stop(); in ~ReplayProcess()
134 io_thread_.StartWithOptions( in Initialize()
145 io_thread_.task_runner(), in Initialize()
163 bootstrap_receiver.PassPipe(), io_thread_.task_runner(), in OpenChannel()
165 this, io_thread_.task_runner(), base::ThreadTaskRunnerHandle::Get()); in OpenChannel()
|