Home
last modified time | relevance | path

Searched refs:server_address_ (Results 1 – 25 of 35) sorted by relevance

12

/third_party/mindspore/mindspore/ccsrc/ps/core/communicator/
Dhttp_server.cc51 if (server_address_ == "") { in InitServer()
56 server_address_ = server_ip; in InitServer()
59 if (!CommUtil::CheckIp(server_address_)) { in InitServer()
60 MS_LOG(ERROR) << "The http server ip:" << server_address_ << " is illegal!"; in InitServer()
92 addr.sin_addr.s_addr = inet_addr(server_address_.c_str()); in InitServer()
97 MS_LOG(ERROR) << "Bind ip:" << server_address_ << " port:" << server_port_ << "failed!"; in InitServer()
103 MS_LOG(INFO) << "Bind ip:" << server_address_ << " port:" << server_port_ << " successful!"; in InitServer()
107 MS_LOG(ERROR) << "Listen ip:" << server_address_ << " port:" << server_port_ << "failed!"; in InitServer()
Dtcp_client.cc43 server_address_(std::move(address)), in TcpClient()
67 std::string TcpClient::GetServerAddress() const { return server_address_; } in GetServerAddress()
86 if (!CommUtil::CheckIp(server_address_)) { in Init()
87 MS_LOG(EXCEPTION) << "The tcp client ip:" << server_address_ << " is illegal!"; in Init()
105 sin.sin_addr.s_addr = inet_addr(server_address_.c_str()); in Init()
127 …MS_LOG(EXCEPTION) << "Connect server ip:" << server_address_ << " and port: " << server_port_ << "… in Init()
Dhttp_server.h52 : server_address_(address), in server_address_() function
73 std::string server_address_;
Dtcp_server.cc114 server_address_(std::move(address)), in TcpServer()
157 if (!CommUtil::CheckIp(server_address_)) { in Init()
158 MS_LOG(EXCEPTION) << "The tcp server ip:" << server_address_ << " is illegal!"; in Init()
173 sin.sin_addr.s_addr = inet_addr(server_address_.c_str()); in Init()
445 std::string TcpServer::BoundIp() const { return server_address_; } in BoundIp()
/third_party/grpc/test/cpp/end2end/
Dclient_interceptors_end2end_test.cc714 server_address_ = "localhost:" + std::to_string(port); in ParameterizedClientInterceptorsEnd2endTest()
715 builder.AddListeningPort(server_address_, InsecureServerCredentials()); in ParameterizedClientInterceptorsEnd2endTest()
751 std::string server_address_; member in grpc::testing::__anona127ce610111::ParameterizedClientInterceptorsEnd2endTest
770 server_address_, InsecureChannelCredentials(), args, std::move(creators)); in TEST_P()
788 server_address_ = "localhost:" + std::to_string(port); in ClientInterceptorsEnd2endTest()
789 builder.AddListeningPort(server_address_, InsecureServerCredentials()); in ClientInterceptorsEnd2endTest()
796 std::string server_address_; member in grpc::testing::__anona127ce610111::ClientInterceptorsEnd2endTest
809 server_address_, nullptr, args, std::move(creators)); in TEST_F()
832 server_address_, InsecureChannelCredentials(), args, std::move(creators)); in TEST_F()
847 server_address_, InsecureChannelCredentials(), args, std::move(creators)); in TEST_F()
[all …]
Ddelegating_channel_test.cc61 server_address_ = "localhost:" + std::to_string(port); in DelegatingChannelTest()
62 builder.AddListeningPort(server_address_, InsecureServerCredentials()); in DelegatingChannelTest()
69 std::string server_address_; member in grpc::testing::__anon4c45bcae0111::DelegatingChannelTest
75 auto channel = CreateChannel(server_address_, InsecureChannelCredentials()); in TEST_F()
Dserver_load_reporting_end2end_test.cc72 server_address_ = in SetUp()
76 .AddListeningPort(server_address_, InsecureServerCredentials()) in SetUp()
96 grpc::CreateChannel(server_address_, InsecureChannelCredentials())); in ClientMakeEchoCalls()
116 std::string server_address_; member in grpc::testing::__anonfbf825f00111::ServerLoadReportingEnd2endTest
126 grpc::CreateChannel(server_address_, InsecureChannelCredentials()); in TEST_F()
132 server_address_); in TEST_F()
Dstreaming_throughput_test.cc136 server_address_ << "localhost:" << port; in SetUp()
139 builder.AddListeningPort(server_address_.str(), in SetUp()
149 server_address_.str(), InsecureChannelCredentials()); in ResetStub()
155 std::ostringstream server_address_; member in grpc::testing::End2endTest
Dtime_change_test.cc135 server_address_ = addr_stream.str(); in SetUpTestCase()
138 "--address=" + server_address_, in SetUpTestCase()
143 grpc::CreateChannel(server_address_, InsecureChannelCredentials()); in SetUpTestCase()
153 grpc::CreateChannel(server_address_, InsecureChannelCredentials()); in SetUp()
170 static std::string server_address_; member in grpc::testing::__anond84822b60111::TimeChangeTest
175 std::string TimeChangeTest::server_address_; member in grpc::testing::__anond84822b60111::TimeChangeTest
Dnonblocking_test.cc74 server_address_ << "localhost:" << port_; in SetUp()
110 builder.AddListeningPort(server_address_.str(), in BuildAndStartServer()
120 server_address_.str(), grpc::InsecureChannelCredentials()); in ResetStub()
179 std::ostringstream server_address_; member in grpc::testing::__anon8ea606960211::NonblockingTest
Dserver_early_return_test.cc118 server_address_ << "127.0.0.1:" << port; in SetUp()
120 builder.AddListeningPort(server_address_.str(), in SetUp()
125 channel_ = grpc::CreateChannel(server_address_.str(), in SetUp()
210 std::ostringstream server_address_; member in grpc::testing::__anon86206e540111::ServerEarlyReturnTest
Dport_sharing_end2end_test.cc221 server_address_ << "localhost:" << port; in SetUp()
224 builder.AddListeningPort(server_address_.str(), creds); in SetUp()
226 server_address_.str().c_str()); in SetUp()
275 CreateCustomChannel(server_address_.str(), direct_creds, direct_args); in ResetStubs()
291 std::ostringstream server_address_; member in grpc::testing::__anon45a999d10111::PortSharingEnd2endTest
Dserver_interceptors_end2end_test.cc236 server_address_ = "localhost:" + std::to_string(port); in ServerInterceptorsEnd2endSyncUnaryTest()
237 builder.AddListeningPort(server_address_, InsecureServerCredentials()); in ServerInterceptorsEnd2endSyncUnaryTest()
262 std::string server_address_; member in grpc::testing::__anoneb859a790111::ServerInterceptorsEnd2endSyncUnaryTest
271 grpc::CreateChannel(server_address_, InsecureChannelCredentials()); in TEST_F()
283 server_address_ = "localhost:" + std::to_string(port); in ServerInterceptorsEnd2endSyncStreamingTest()
284 builder.AddListeningPort(server_address_, InsecureServerCredentials()); in ServerInterceptorsEnd2endSyncStreamingTest()
306 std::string server_address_; member in grpc::testing::__anoneb859a790111::ServerInterceptorsEnd2endSyncStreamingTest
315 grpc::CreateChannel(server_address_, InsecureChannelCredentials()); in TEST_F()
325 grpc::CreateChannel(server_address_, InsecureChannelCredentials()); in TEST_F()
335 grpc::CreateChannel(server_address_, InsecureChannelCredentials()); in TEST_F()
Dfilter_end2end_test.cc137 server_address_ << server_host_ << ":" << port; in SetUp()
140 builder.AddListeningPort(server_address_.str(), in SetUp()
161 server_address_.str(), InsecureChannelCredentials()); in ResetStub()
241 std::ostringstream server_address_; member in grpc::testing::__anonf13c4bc70111::FilterEnd2endTest
Dhealth_service_end2end_test.cc87 server_address_ << "localhost:" << port; in SetUpServer()
99 builder.AddListeningPort(server_address_.str(), in SetUpServer()
128 server_address_.str(), InsecureChannelCredentials()); in ResetStubs()
283 std::ostringstream server_address_; member in grpc::testing::__anond32763670111::HealthServiceEnd2endTest
Dmessage_allocator_end2end_test.cc121 server_address_ << "localhost:" << picked_port_; in CreateServer()
122 builder.AddListeningPort(server_address_.str(), server_creds); in CreateServer()
143 channel_ = ::grpc::CreateCustomChannel(server_address_.str(), in ResetStub()
199 std::ostringstream server_address_; member in grpc::testing::__anon6e7bb6e60111::MessageAllocatorEnd2endTestBase
Dthread_stress_test.cc106 server_address_.str(), InsecureChannelCredentials()); in ResetStub()
114 this->server_address_ << "localhost:" << port; in SetUpStart()
116 builder->AddListeningPort(server_address_.str(), in SetUpStart()
122 std::ostringstream server_address_; member in grpc::testing::CommonStressTestInsecure
Dgeneric_end2end_test.cc67 server_address_ << server_host_ << ":" << port; in SetUp()
70 builder.AddListeningPort(server_address_.str(), in SetUp()
99 server_address_.str(), InsecureChannelCredentials()); in ResetStub()
249 std::ostringstream server_address_; member in grpc::testing::__anon72e8887e0111::GenericEnd2endTest
Draw_end2end_test.cc105 server_address_ << "localhost:" << port_; in SetUp()
122 builder.AddListeningPort(server_address_.str(), in BuildAndStartServer()
134 server_address_.str(), grpc::InsecureChannelCredentials()); in ResetStub()
141 std::ostringstream server_address_; member in grpc::testing::__anon95f61f2b0111::RawEnd2EndTest
/third_party/grpc/test/cpp/util/
Dcli_call_test.cc65 server_address_ << "localhost:" << port; in SetUp()
68 builder.AddListeningPort(server_address_.str(), in SetUp()
77 channel_ = grpc::CreateChannel(server_address_.str(), in ResetStub()
85 std::ostringstream server_address_; member in grpc::testing::CliCallTest
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_opencensus_plugin.cc65 server_address_ = absl::StrCat("[::]:", port); in EchoServerThread()
74 const std::string& address() { return server_address_; } in address()
79 std::string server_address_; member in EchoServerThread
/third_party/grpc/src/php/tests/interop/
Dxds_client.php116 private $server_address_; variable in ClientThread
127 $this->server_address_ = $server_address;
183 $stub = new Grpc\Testing\TestServiceClient($this->server_address_, [
/third_party/grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc100 : server_address_(server_address) {} in Client()
106 grpc_blocking_resolve_address(server_address_, "80", &server_addresses); in Connect()
216 const char* server_address_; // Do not own. member in grpc_core::test::__anon11dfb1b00111::Client
/third_party/grpc/test/cpp/interop/
Dstress_interop_client.cc75 server_address_(server_address), in StressTestInteropClient()
86 server_address_.c_str()); in MainLoop()
/third_party/grpc/test/cpp/cocoapods/generic/
Dgeneric.mm99 std::ostringstream server_address_;
128 server_address_ << server_host_ << ":" << port;
131 builder.AddListeningPort(server_address_.str(), InsecureServerCredentials());
158 CreateChannel(server_address_.str(), InsecureChannelCredentials());

12