| /third_party/nghttp2/src/ |
| H A D | shrpx_quic_connection_handler.cc | 50 : worker_{worker}, in QUICConnectionHandler()
58 ev_timer_stop(worker_->get_loop(), &stateless_reset_bucket_regen_timer_); in ~QUICConnectionHandler()
87 auto conn_handler = worker_->get_connection_handler(); in handle_packet()
143 worker_->get_cid_prefix())) { in handle_packet()
161 if (worker_->get_worker_stat()->num_connections >= in handle_packet()
195 worker_->get_cid_prefix())) { in handle_packet()
200 if (worker_->get_graceful_shutdown()) { in handle_packet()
330 worker_->get_cid_prefix())) { in handle_packet()
384 auto ssl_ctx = worker_->get_quic_sv_ssl_ctx(); in handle_new_connection()
412 if (!worker_ in handle_new_connection()
[all...] |
| H A D | shrpx_quic_listener.cc | 40 : faddr_{faddr}, worker_{worker} { in QUICListener()
43 ev_io_start(worker_->get_loop(), &rev_);
47 ev_io_stop(worker_->get_loop(), &rev_); in ~QUICListener()
66 auto quic_conn_handler = worker_->get_quic_connection_handler(); in on_read()
|
| H A D | shrpx_client_handler.cc | 456 worker_(worker), in ClientHandler()
462 ++worker_->get_worker_stat()->num_connections; in ClientHandler()
498 worker_->get_randgen()); in ClientHandler()
567 auto worker_stat = worker_->get_worker_stat(); in ~ClientHandler()
571 worker_->schedule_clear_mcpool(); in ~ClientHandler()
578 if (worker_->get_graceful_shutdown() && worker_stat->num_connections == 0 && in ~ClientHandler()
795 auto session = new Http2Session(conn_.loop, worker_->get_cl_ssl_ctx(), in get_http2_session()
796 worker_, group, addr); in get_http2_session()
815 auto rh = d(worker_->get_randgen()); in get_affinity_cookie()
976 auto rh = d(worker_ in get_downstream_addr_strict_affinity()
[all...] |
| H A D | shrpx_live_check.cc | 114 worker_(worker),
140 auto dns_tracker = worker_->get_dns_tracker(); in disconnect()
197 auto worker_blocker = worker_->get_connect_blocker(); in initiate_connection()
242 auto dns_tracker = worker_->get_dns_tracker(); in initiate_connection()
|
| H A D | shrpx_quic_listener.h | 45 Worker *worker_; member in shrpx::QUICListener
|
| H A D | shrpx_http_downstream_connection.cc | 215 worker_(worker),
232 auto dns_tracker = worker_->get_dns_tracker(); in ~HttpDownstreamConnection()
295 auto worker_blocker = worker_->get_connect_blocker(); in initiate_connection()
304 auto &downstreamconf = *worker_->get_downstream_config(); in initiate_connection()
345 auto dns_tracker = worker_->get_dns_tracker(); in initiate_connection()
873 auto &downstreamconf = *worker_->get_downstream_config(); in detach_downstream()
893 auto &downstreamconf = *worker_->get_downstream_config(); in resume_read()
|
| H A D | shrpx_api_downstream_connection.h | 103 Worker *worker_; member in shrpx::APIDownstreamConnection
|
| H A D | shrpx_live_check.h | 100 Worker *worker_; member in shrpx::LiveCheck
|
| H A D | shrpx_http_downstream_connection.h | 99 Worker *worker_; member in shrpx::HttpDownstreamConnection
|
| H A D | shrpx_client_handler.h | 224 Worker *worker_; member in shrpx::ClientHandler
|
| H A D | shrpx_quic_connection_handler.h | 133 Worker *worker_; member in shrpx::QUICConnectionHandler
|
| H A D | shrpx_http2_session.h | 269 Worker *worker_; member in shrpx::Http2Session
|
| H A D | shrpx_api_downstream_connection.cc | 73 : worker_(worker), api_(nullptr), fd_(-1), shutdown_read_(false) {} in APIDownstreamConnection()
426 auto conn_handler = worker_->get_connection_handler(); in handle_backendconfig()
|
| H A D | shrpx_http2_session.cc | 193 worker_(worker),
244 auto dns_tracker = worker_->get_dns_tracker(); in disconnect()
322 auto dns_tracker = worker_->get_dns_tracker(); in resolve_name()
374 auto worker_blocker = worker_->get_connect_blocker(); in initiate_connection()
2376 auto worker_blocker = worker_->get_connect_blocker(); in on_timeout()
|
| /third_party/node/test/parallel/ |
| H A D | test-cluster-message.js | 106 cluster.on('message', function(worker_, message) {
107 assert.strictEqual(worker_, worker);
|
| /third_party/skia/third_party/externals/libwebp/src/dec/ |
| H A D | vp8_dec.c | 61 WebPGetWorkerInterface()->Init(&dec->worker_); in VP8New()
663 if (!WebPGetWorkerInterface()->Sync(&dec->worker_)) return 0; in ParseFrame()
713 WebPGetWorkerInterface()->End(&dec->worker_); in VP8Clear()
|
| H A D | vp8i_dec.h | 197 WebPWorker worker_; member
|
| H A D | frame_dec.c | 514 WebPWorker* const worker = &dec->worker_; in VP8ProcessRow()
604 ok = WebPGetWorkerInterface()->Sync(&dec->worker_); in VP8ExitCritical()
644 WebPWorker* const worker = &dec->worker_; in InitThreadContext()
|
| H A D | idec_dec.c | 483 if (!WebPGetWorkerInterface()->Sync(&dec->worker_)) { in DecodeRemaining()
|
| /third_party/node/deps/v8/src/d8/ |
| H A D | d8.h | 234 worker_(std::move(worker)) {} in WorkerThread()
239 std::shared_ptr<Worker> worker_; member in v8::Worker::WorkerThread
|
| H A D | d8.cc | 4139 // We must clear the worker_ field of the thread, but we keep the in Run()
4143 auto worker = std::move(worker_); in Run()
4144 worker_ = nullptr; in Run()
4155 worker_(worker), in ProcessMessageTask()
4158 void RunInternal() override { worker_->ProcessMessage(std::move(data_)); }
4161 std::shared_ptr<Worker> worker_; member in v8::ProcessMessageTask
4177 : i::CancelableTask(task_manager), worker_(worker) {} in TerminateTask()
4181 CHECK(worker_->state_.compare_exchange_strong(expected,
4186 std::shared_ptr<Worker> worker_; member in v8::TerminateTask
|