aboutsummaryrefslogtreecommitdiff
path: root/src/core/lib/event_engine/posix_engine/grpc_polled_fd_posix.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/lib/event_engine/posix_engine/grpc_polled_fd_posix.h')
-rw-r--r--src/core/lib/event_engine/posix_engine/grpc_polled_fd_posix.h16
1 files changed, 12 insertions, 4 deletions
diff --git a/src/core/lib/event_engine/posix_engine/grpc_polled_fd_posix.h b/src/core/lib/event_engine/posix_engine/grpc_polled_fd_posix.h
index c6eed18323..3feea096e8 100644
--- a/src/core/lib/event_engine/posix_engine/grpc_polled_fd_posix.h
+++ b/src/core/lib/event_engine/posix_engine/grpc_polled_fd_posix.h
@@ -17,6 +17,11 @@
#include <grpc/support/port_platform.h>
+#include <memory>
+
+#include <grpc/event_engine/event_engine.h>
+
+#include "src/core/lib/gprpp/sync.h"
#include "src/core/lib/iomgr/port.h"
#if GRPC_ARES == 1 && defined(GRPC_POSIX_SOCKET_ARES_EV_DRIVER)
@@ -42,7 +47,6 @@
#include "src/core/lib/event_engine/posix_engine/event_poller.h"
#include "src/core/lib/event_engine/posix_engine/posix_engine_closure.h"
#include "src/core/lib/event_engine/posix_engine/tcp_socket_utils.h"
-#include "src/core/lib/iomgr/error.h"
namespace grpc_event_engine {
namespace experimental {
@@ -80,8 +84,9 @@ class GrpcPolledFdPosix : public GrpcPolledFd {
bytes_available > 0;
}
- void ShutdownLocked(grpc_error_handle error) override {
+ bool ShutdownLocked(absl::Status error) override {
handle_->ShutdownHandle(error);
+ return true;
}
ares_socket_t GetWrappedAresSocketLocked() override { return as_; }
@@ -105,9 +110,12 @@ class GrpcPolledFdFactoryPosix : public GrpcPolledFdFactory {
}
}
- GrpcPolledFd* NewGrpcPolledFdLocked(ares_socket_t as) override {
+ void Initialize(grpc_core::Mutex*, EventEngine*) override {}
+
+ std::unique_ptr<GrpcPolledFd> NewGrpcPolledFdLocked(
+ ares_socket_t as) override {
owned_fds_.insert(as);
- return new GrpcPolledFdPosix(
+ return std::make_unique<GrpcPolledFdPosix>(
as,
poller_->CreateHandle(as, "c-ares socket", poller_->CanTrackErrors()));
}