|
|
|
@ -22,7 +22,6 @@ |
|
|
|
|
#include <thread> |
|
|
|
|
#include <vector> |
|
|
|
|
|
|
|
|
|
#include "absl/memory/memory.h" |
|
|
|
|
#include "absl/status/statusor.h" |
|
|
|
|
#include "absl/strings/str_cat.h" |
|
|
|
|
#include "absl/strings/str_split.h" |
|
|
|
@ -85,7 +84,7 @@ std::list<Connection> CreateConnectedEndpoints( |
|
|
|
|
std::shared_ptr<EventEngine> posix_ee, |
|
|
|
|
std::shared_ptr<EventEngine> oracle_ee) { |
|
|
|
|
std::list<Connection> connections; |
|
|
|
|
auto memory_quota = absl::make_unique<grpc_core::MemoryQuota>("bar"); |
|
|
|
|
auto memory_quota = std::make_unique<grpc_core::MemoryQuota>("bar"); |
|
|
|
|
std::string target_addr = absl::StrCat( |
|
|
|
|
"ipv6:[::1]:", std::to_string(grpc_pick_unused_port_or_die())); |
|
|
|
|
EventEngine::ResolvedAddress resolved_addr = |
|
|
|
@ -112,7 +111,7 @@ std::list<Connection> CreateConnectedEndpoints( |
|
|
|
|
auto listener = oracle_ee->CreateListener( |
|
|
|
|
std::move(accept_cb), |
|
|
|
|
[](absl::Status status) { ASSERT_TRUE(status.ok()); }, config, |
|
|
|
|
absl::make_unique<grpc_core::MemoryQuota>("foo")); |
|
|
|
|
std::make_unique<grpc_core::MemoryQuota>("foo")); |
|
|
|
|
GPR_ASSERT(listener.ok()); |
|
|
|
|
|
|
|
|
|
EXPECT_TRUE((*listener)->Bind(resolved_addr).ok()); |
|
|
|
@ -199,7 +198,7 @@ class PosixEndpointTest : public ::testing::TestWithParam<bool> { |
|
|
|
|
oracle_ee_ = std::make_shared<PosixOracleEventEngine>(); |
|
|
|
|
posix_ee_ = std::make_shared<PosixEventEngine>(); |
|
|
|
|
scheduler_ = |
|
|
|
|
absl::make_unique<grpc_event_engine::posix_engine::TestScheduler>( |
|
|
|
|
std::make_unique<grpc_event_engine::posix_engine::TestScheduler>( |
|
|
|
|
posix_ee_.get()); |
|
|
|
|
EXPECT_NE(scheduler_, nullptr); |
|
|
|
|
poller_ = GetDefaultPoller(scheduler_.get()); |
|
|
|
|