Home
last modified time | relevance | path

Searched refs:port_ (Results 1 – 25 of 54) sorted by relevance

123

/third_party/grpc/test/cpp/end2end/
Dgrpclb_end2end_test.cc589 addresses.emplace_back(AddressData{balancers_[i]->port_, ""}); in SetNextResolutionAllBalancers()
619 backend_ports.push_back(backends_[i]->port_); in GetBackendPorts()
670 : port_(grpc_pick_unused_port_or_die()), in ServerThread()
675 gpr_log(GPR_INFO, "starting %s server on port %d", type_.c_str(), port_); in Start()
696 server_address << server_host << ":" << port_; in Serve()
716 const int port_; member
907 ports.push_back(backends_[0]->port_); in TEST_F()
908 ports.push_back(backends_[0]->port_); in TEST_F()
926 SetNextResolution({AddressData{balancers_[0]->port_, "lb"}}); in TEST_F()
958 SetNextResolution({AddressData{balancers_[0]->port_, "woops"}}); in TEST_F()
[all …]
Dshutdown_test.cc66 port_ = grpc_pick_unused_port_or_die(); in SetUp()
67 server_ = SetUpServer(port_); in SetUp()
85 string target = "dns:localhost:" + to_string(port_); in ResetStub()
114 int port_; member in grpc::testing::ShutdownTest
Dproto_server_reflection_test.cc46 port_ = grpc_pick_unused_port_or_die(); in SetUp()
50 std::string server_address = "localhost:" + to_string(port_); in SetUp()
56 string target = "dns:localhost:" + to_string(port_); in ResetStub()
126 int port_; member in grpc::testing::ProtoServerReflectionTest
Dclient_lb_end2end_test.cc264 ports.push_back(servers_[i]->port_); in GetServersPorts()
334 int port_; member
342 port_ = port > 0 ? port : grpc_pick_unused_port_or_die(); in ServerData()
346 gpr_log(GPR_INFO, "starting server on port %d", port_); in Start()
361 server_address << server_host << ":" << port_; in Serve()
516 response_generator.SetNextResolution({servers_[0]->port_}); in TEST_F()
526 second_response_generator.SetNextResolution({servers_[0]->port_}); in TEST_F()
703 ports.emplace_back(servers_[0]->port_); in TEST_F()
722 ports.emplace_back(servers_[1]->port_); in TEST_F()
730 ports.emplace_back(servers_[2]->port_); in TEST_F()
[all …]
Dcfstream_test.cc128 port_ = grpc_pick_unused_port_or_die(); in StartServer()
129 server_.reset(new ServerData(port_, GetParam().credentials_type)); in StartServer()
141 server_address << server_host_ << ":" << port_; in BuildChannel()
246 int port_; member
254 : port_(port), creds_(creds) {} in ServerData()
257 gpr_log(GPR_INFO, "starting server on port %d", port_); in Start()
271 server_address << server_host << ":" << port_; in Serve()
294 int port_; member in grpc::testing::__anon6b05a8f50111::CFStreamTest
Dnonblocking_test.cc73 port_ = grpc_pick_unused_port_or_die(); in SetUp()
74 server_address_ << "localhost:" << port_; in SetUp()
105 grpc_recycle_unused_port(port_); in TearDown()
180 int port_; member in grpc::testing::__anonb00edf140211::NonblockingTest
Dflaky_network_test.cc181 port_ = SERVER_PORT; in StartServer()
183 server_.reset(new ServerData(port_, GetParam().credentials_type)); in StartServer()
202 server_address << server_host_ << ":" << port_; in BuildChannel()
245 int port_; member
253 : port_(port), creds_(creds) {} in ServerData()
256 gpr_log(GPR_INFO, "starting server on port %d", port_); in Start()
270 server_address << server_host << ":" << port_; in Serve()
318 int port_; member in grpc::testing::__anondeb12ea00111::FlakyNetworkTest
Dserver_builder_plugin_test.cc140 port_ = grpc_pick_unused_port_or_die(); in SetUp()
171 std::string server_address = "localhost:" + to_string(port_); in StartServer()
182 string target = "dns:localhost:" + to_string(port_); in ResetStub()
212 int port_; member in grpc::testing::ServerBuilderPluginTest
Dport_sharing_end2end_test.cc95 port_(grpc_pick_unused_port_or_die()) { in TestTcpServer()
97 server_address << "localhost:" << port_; in TestTcpServer()
107 grpc_recycle_unused_port(port_); in ~TestTcpServer()
114 test_tcp_server_start(&tcp_server_, port_); in Start()
197 int port_ = -1; member in grpc::testing::__anon63b8e00f0111::TestTcpServer
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_admin_arg.cc45 port_(kCfgDefaultCachePort), in CacheAdminArgHandler()
54 port_ = static_cast<int32_t>(strtol(env_cache_port.c_str(), &end, kDecimal)); in CacheAdminArgHandler()
57 … port_ = 0; // cause the port range validation to generate an error during the validation checks in CacheAdminArgHandler()
293 RETURN_IF_NOT_OK(AssignArg(tok, &port_, arg_stream)); in ParseArgStream()
391 if (port_ < kMinLegalPort || port_ > kMaxLegalPort) { in Validate()
413 CacheClientGreeter comm(hostname_, port_, 1); in RunCommand()
418 …std::cout << "Session created for server on port " << std::to_string(port_) << ": " << rq->GetSess… in RunCommand()
423 CacheClientGreeter comm(hostname_, port_, 1); in RunCommand()
431 …"Drop session " << id << " successfully for server on port " << std::to_string(port_) << std::endl; in RunCommand()
436 CacheClientGreeter comm(hostname_, port_, 1); in RunCommand()
[all …]
Dcache_grpc_server.cc26 CacheServerGreeterImpl::CacheServerGreeterImpl(int32_t port) : port_(port) { in CacheServerGreeterImpl()
54 std::string server_address = host + ":" + std::to_string(port_); in Run()
72 if (port_tcpip != port_) { in Run()
73 errMsg += "Unable to bind to tcpip port " + std::to_string(port_) + "."; in Run()
188 RETURN_IF_NOT_OK(PortToFtok(port_, &key)); in MonitorUnixSocket()
Dcache_grpc_client.cc23 …: num_connections_(num_connections), request_cnt_(0), hostname_(std::move(hostname)), port_(port) { in CacheClientGreeter()
28 MS_LOG(INFO) << "Hostname: " << hostname_ << ", port: " << std::to_string(port_); in CacheClientGreeter()
49 RETURN_IF_NOT_OK(PortToFtok(port_, &shm_key)); in AttachToSharedMemory()
122 err_msg = "Cache server with port " + std::to_string(port_) + in WorkerEntry()
Dcache_server.h72 int32_t GetPort() const { return port_; } in GetPort()
86 port_ = p; in SetPort()
145 … RETURN_IF_NOT_OK(CacheServer::CreateInstance(top_, num_workers_, port_, shared_memory_sz_in_gb_, in Build()
153 int32_t port_; variable
291 int32_t port_; variable
Dcache_grpc_client.h92 int32_t GetPort() const { return port_; } in GetPort()
105 int32_t port_; variable
/third_party/mindspore/mindspore/ccsrc/ps/core/communicator/
Dhttp_communicator.h36 : task_executor_(task_executor), http_server_(nullptr), ip_(ip), port_(port) { in HttpCommunicator()
37 http_server_ = std::make_shared<HttpServer>(ip_, port_, kThreadNum); in HttpCommunicator()
52 uint16_t port_; variable
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/ir/cache/
Ddataset_cache_impl.cc36 if (port_) { in Build()
37 (void)builder.SetPort(port_.value()); in Build()
88 if (port_) args["port"] = port_.value(); in to_json()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/
Dgrpc_async_server.cc25 GrpcAsyncServer::GrpcAsyncServer(const std::string &host, int32_t port) : host_(host), port_(port) … in GrpcAsyncServer()
30 std::string server_address = host_ + ":" + std::to_string(port_); in Run()
44 if (port_tcpip != port_) { in Run()
/third_party/grpc/test/cpp/qps/
Dserver.h47 port_ = config.port(); in Server()
49 port_ = grpc_pick_unused_port_or_die(); in Server()
95 int port() const { return port_; } in port()
147 int port_;
/third_party/node/src/
Dnode_options.h19 : host_name_(host_name), port_(port) {} in HostPort()
27 void set_port(int port) { port_ = port; } in set_port()
33 CHECK_GE(port_, 0); in port()
34 return port_; in port()
39 if (other.port_ >= 0) port_ = other.port_; in Update()
44 int port_; variable
Dinspector_socket_server.cc213 int port() const { return port_; } in port()
230 int port_ = -1; member in node::inspector::ServerSocket
262 port_(port), in InspectorSocketServer()
397 const std::string port_string = std::to_string(port_); in Start()
421 host_.c_str(), port_, uv_strerror(err)); in Start()
462 return port_; in Port()
533 port_ = ntohs(port); in DetectPort()
558 server_socket->server_->Accept(server_socket->port_, tcp_socket); in SocketConnectedCallback()
/third_party/grpc/test/cpp/microbenchmarks/
Dfullstack_fixtures.h116 : FullstackFixture(service, fixture_configuration, MakeAddress(&port_)) {} in FullstackFixture() argument
118 ~TCP() { grpc_recycle_unused_port(port_); } in ~TCP()
121 int port_;
135 : FullstackFixture(service, fixture_configuration, MakeAddress(&port_)) {} in FullstackFixture() argument
137 ~UDS() { grpc_recycle_unused_port(port_); } in ~UDS()
140 int port_;
/third_party/cef/libcef/browser/devtools/
Ddevtools_manager_delegate.cc44 : address_(address), port_(port) {} in TCPServerSocketFactory()
54 if (socket->ListenWithAddressAndPort(address_, port_, kBackLog) != net::OK) in CreateForHttpServer()
65 uint16_t port_; member in __anon69b31cfd0111::TCPServerSocketFactory
/third_party/mindspore/mindspore/ccsrc/ps/core/
Dnode_info.h39 …NodeInfo() : ip_(""), port_(0), node_role_(NodeRole::SCHEDULER), rank_id_(UINT32_MAX), is_alive(fa… in NodeInfo()
43 uint16_t port_; member
/third_party/grpc/test/cpp/client/
Dclient_channel_stress_test.cc157 addresses.emplace_back(AddressData{balancer_server.port_, ""}); in Run()
179 port_ = grpc_pick_unused_port_or_die(); in ServerThread()
180 gpr_log(GPR_INFO, "starting %s server on port %d", type_.c_str(), port_); in ServerThread()
194 server_address << server_host << ":" << port_; in Start()
210 int port_; member
297 backend_ports.push_back(backend_servers_.back().port_); in Start()
/third_party/grpc/test/core/tsi/alts/handshaker/
Dalts_concurrent_connectivity_test.cc340 port_ = grpc_pick_unused_port_or_die(); in FakeTcpServer()
342 address_ = absl::StrCat("[::]:", port_); in FakeTcpServer()
353 port_, errno); in FakeTcpServer()
363 addr.sin6_port = htons(port_); in FakeTcpServer()
366 gpr_log(GPR_ERROR, "Failed to bind socket to [::1]:%d : %d", port_, in FakeTcpServer()
372 port_, errno); in FakeTcpServer()
480 int port_; member in __anon047530350111::FakeTcpServer

123