Home
last modified time | relevance | path

Searched full:posixeventengine (Results 1 – 13 of 13) sorted by relevance

/third_party/grpc/src/core/lib/event_engine/posix_engine/
Dposix_engine.cc159 reinterpret_cast<PosixEventEngine*>(engine_.get()) in OnWritable()
243 PosixEventEngine::CreateEndpointFromUnconnectedFdInternal( in CreateEndpointFromUnconnectedFdInternal()
308 void PosixEventEngine::OnConnectFinishInternal(int connection_handle) { in OnConnectFinishInternal()
364 PosixEventEngine::PosixEventEngine(std::shared_ptr<PosixEventPoller> poller) in PosixEventEngine() function in grpc_event_engine::experimental::PosixEventEngine
379 PosixEventEngine::PosixEventEngine() in PosixEventEngine() function in grpc_event_engine::experimental::PosixEventEngine
401 void PosixEventEngine::PollerWorkInternal( in PollerWorkInternal()
436 struct PosixEventEngine::ClosureData final : public EventEngine::Closure {
439 PosixEventEngine* engine;
444 << "PosixEventEngine:" << engine << " executing callback:" << handle; in Run()
454 PosixEventEngine::~PosixEventEngine() { in ~PosixEventEngine()
[all …]
Dposix_engine.h78 friend class PosixEventEngine;
135 class PosixEventEngine final : public PosixEventEngineWithFdSupport,
159 explicit PosixEventEngine(
162 PosixEventEngine();
164 PosixEventEngine();
167 ~PosixEventEngine() override;
218 static std::shared_ptr<PosixEventEngine> MakeTestOnlyPosixEventEngine( in MakeTestOnlyPosixEventEngine()
221 return std::make_shared<PosixEventEngine>(std::move(test_only_poller)); in MakeTestOnlyPosixEventEngine()
/third_party/grpc/test/core/event_engine/test_suite/tools/
Dposix_event_engine_factory.cc33 grpc_event_engine::experimental::PosixEventEngine>(); in CustomEventEngineFactory()
/third_party/grpc/src/core/lib/event_engine/
Ddefault_event_engine_factory.cc53 return std::make_unique<PosixEventEngine>(); in DefaultEventEngineFactory()
/third_party/grpc/test/core/event_engine/test_suite/
Dposix_event_engine_test.cc33 grpc_event_engine::experimental::PosixEventEngine>(); in main()
Dposix_event_engine_native_dns_test.cc34 grpc_event_engine::experimental::PosixEventEngine>(); in main()
Dthready_posix_event_engine_test.cc36 grpc_event_engine::experimental::PosixEventEngine>()); in main()
/third_party/grpc/test/core/event_engine/posix/
Dposix_event_engine_connect_test.cc148 std::shared_ptr<EventEngine> posix_ee = std::make_shared<PosixEventEngine>(); in TEST()
177 std::shared_ptr<EventEngine> posix_ee = std::make_shared<PosixEventEngine>(); in TEST()
Devent_poller_posix_test.cc377 std::make_unique<grpc_event_engine::experimental::PosixEventEngine>(); in SetUp()
384 engine_ = PosixEventEngine::MakeTestOnlyPosixEventEngine(g_event_poller); in SetUp()
402 std::shared_ptr<grpc_event_engine::experimental::PosixEventEngine> engine_;
Dposix_endpoint_test.cc202 posix_ee_ = PosixEventEngine::MakeTestOnlyPosixEventEngine(poller_); in SetUp()
/third_party/grpc/src/core/lib/experiments/
Dexperiments.cc88 "Prevent the PosixEventEngine from calling grpc_init & grpc_shutdown on "
306 "Prevent the PosixEventEngine from calling grpc_init & grpc_shutdown on "
524 "Prevent the PosixEventEngine from calling grpc_init & grpc_shutdown on "
Dexperiments.yaml137 Prevent the PosixEventEngine from calling grpc_init & grpc_shutdown on
/third_party/grpc/test/core/end2end/tests/
Dretry_transparent_max_concurrent_streams.cc106 // TODO(hork): hack to solve PosixEventEngine Listener's async shutdown issue. in CORE_END2END_TEST()