| /external/webrtc/webrtc/p2p/base/ |
| D | turnport.cc | 74 TurnPort* port_; member in cricket::TurnAllocateRequest
88 TurnPort* port_; member in cricket::TurnRefreshRequest
106 TurnPort* port_; member in cricket::TurnCreatePermissionRequest
125 TurnPort* port_; member in cricket::TurnChannelBindRequest
139 TurnPort* port() { return port_; } in port()
171 TurnPort* port_; member in cricket::TurnEntry
1027 port_(port) { in TurnAllocateRequest()
1037 if (!port_->hash().empty()) { in Prepare()
1038 port_->AddRequestAuthInfo(request); in Prepare()
1043 LOG_J(LS_INFO, port_) << "TURN allocate request sent" in OnSent()
[all …]
|
| D | relayport.cc | 82 RelayPort* port() { return port_; } in port()
130 RelayPort* port_; member in cricket::RelayEntry
453 : port_(port), ext_addr_(ext_addr), in RelayEntry()
490 socket = port_->socket_factory()->CreateUdpSocket( in Connect()
491 rtc::SocketAddress(port_->ip(), 0), in Connect()
492 port_->min_port(), port_->max_port()); in Connect()
496 socket = port_->socket_factory()->CreateClientTcpSocket( in Connect()
497 rtc::SocketAddress(port_->ip(), 0), ra->address, in Connect()
498 port_->proxy(), port_->user_agent(), opts); in Connect()
518 for (size_t i = 0; i < port_->options().size(); ++i) { in Connect()
[all …]
|
| D | stunport.cc | 39 : port_(port), server_addr_(addr), deadline_(deadline) { in StunBindingRequest()
62 port_->OnStunBindingRequestSucceeded(server_addr_, addr); in OnResponse()
68 port_->requests_.SendDelayed( in OnResponse()
69 new StunBindingRequest(port_, server_addr_, deadline_), in OnResponse()
70 port_->stun_keepalive_delay()); in OnResponse()
85 port_->OnStunBindingOrResolveRequestFailed(server_addr_); in OnErrorResponse()
89 port_->requests_.SendDelayed( in OnErrorResponse()
90 new StunBindingRequest(port_, server_addr_, deadline_), in OnErrorResponse()
91 port_->stun_keepalive_delay()); in OnErrorResponse()
97 << port_->GetLocalAddress().ToSensitiveString() in OnTimeout()
[all …]
|
| D | port.cc | 767 : port_(port), in Connection()
802 ASSERT(local_candidate_index_ < port_->Candidates().size()); in local_candidate()
803 return port_->Candidates()[local_candidate_index_]; in local_candidate()
813 IceRole role = port_->GetIceRole(); in priority()
872 rtc::PacketOptions options(port_->DefaultDscpValue()); in OnSendStunPacket()
873 auto err = port_->SendTo( in OnSendStunPacket()
887 if (!port_->GetStunMessage(data, size, addr, msg.accept(), &remote_ufrag)) { in OnReadPacket()
923 port_->SendBindingErrorResponse(msg.get(), addr, in OnReadPacket()
963 if (!port_->MaybeIceRoleConflict(remote_addr, msg, remote_ufrag)) { in HandleBindingRequest()
970 port_->SendBindingResponse(msg, remote_addr); in HandleBindingRequest()
[all …]
|
| /external/libchrome/mojo/core/ |
| D | message_pipe_dispatcher.cc | 91 port_(port), in MessagePipeDispatcher()
99 port_, base::MakeRefCounted<PortObserverThunk>(this)); in MessagePipeDispatcher()
103 node_controller_->SetPortObserver(port_, nullptr); in Fuse()
104 node_controller_->SetPortObserver(other->port_, nullptr); in Fuse()
109 port0 = port_; in Fuse()
117 port1 = other->port_; in Fuse()
134 << " [port=" << port_.name() << "]"; in Close()
143 int rv = node_controller_->SendUserMessage(port_, std::move(message)); in WriteMessage()
146 << " [port=" << port_.name() << "; rv=" << rv << "]"; in WriteMessage()
170 int rv = node_controller_->node()->GetMessage(port_, message, nullptr); in ReadMessage()
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | socketaddress.cc | 68 port_ = 0; in Clear()
73 return hostname_.empty() && IPIsUnspec(ip_) && 0 == port_; in IsNil()
77 return (!IPIsAny(ip_)) && (0 != port_); in IsComplete()
83 port_ = addr.port_; in operator =()
124 port_ = static_cast<uint16_t>(port); in SetPort()
136 return port_; in port()
165 ost << port_; in PortAsString()
238 return port_ < addr.port_; in operator <()
247 return (port_ == addr.port_); in EqualPorts()
253 h ^= port_ | (port_ << 16); in Hash()
[all …]
|
| D | httpcommon-inl.h | 56 port_ = static_cast<uint16_t>(::strtoul(colon + 1, NULL, 10)); in do_set_address()
60 port_ = HttpDefaultPort(secure_); in do_set_address()
93 if (port_ != HttpDefaultPort(secure_)) { in do_get_address()
96 sprintfn(port, arraysize(port), format, port_); in do_get_address()
|
| D | httprequest.h | 49 int port() { return port_; } in port()
50 void set_port(int port) { port_ = port; } in set_port()
78 int port_; variable
|
| D | httprequest.cc | 53 port_(80), in HttpRequest()
81 bool transparent_proxy = (port_ == 80) && ((proxy_.type == PROXY_HTTPS) || in Send()
89 SocketAddress server(host_, port_); in Send()
|
| D | httpcommon.h | 210 : host_(host), port_(port), secure_(HTTP_SECURE_PORT == port) { in host_()
217 port_ = HTTP_DEFAULT_PORT; in clear()
247 void set_port(uint16_t val) { port_ = val; } in set_port()
248 uint16_t port() const { return port_; } in port()
281 uint16_t port_; variable
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | client_lb_end2end_test.cc | 192 for (const auto& server : servers_) ports.push_back(server->port_); in GetServersPorts()
250 int port_; member
257 port_ = port > 0 ? port : grpc_pick_unused_port_or_die(); in ServerData()
261 gpr_log(GPR_INFO, "starting server on port %d", port_); in Start()
275 server_address << server_host << ":" << port_; in Serve()
362 ports.emplace_back(servers_[i]->port_); in TEST_F()
387 SetNextResolution({servers_[0]->port_}); in TEST_F()
396 SetNextResolution({servers_[0]->port_}); in TEST_F()
495 ports.emplace_back(servers_[0]->port_); in TEST_F()
514 ports.emplace_back(servers_[1]->port_); in TEST_F()
[all …]
|
| D | grpclb_end2end_test.cc | 390 addresses.emplace_back(AddressData{balancer_servers_[i].port_, true, ""}); in SetNextResolutionAllBalancers()
531 backend_ports.push_back(backend_servers_[i].port_); in GetBackendPorts()
578 port_ = grpc_pick_unused_port_or_die(); in ServerThread()
579 gpr_log(GPR_INFO, "starting %s server on port %d", type_.c_str(), port_); in ServerThread()
593 server_address << server_host << ":" << port_; in Start()
610 int port_; member
668 SetNextResolution({AddressData{balancer_servers_[0].port_, true, "lb"}}); in TEST_F()
702 {AddressData{balancer_servers_[0].port_, true, "woops"}}); in TEST_F()
764 addresses.emplace_back(AddressData{balancer_servers_[0].port_, true, ""}); in TEST_F()
766 addresses.emplace_back(AddressData{backend_servers_[i].port_, false, ""}); in TEST_F()
[all …]
|
| D | shutdown_test.cc | 66 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
|
| D | nonblocking_test.cc | 69 port_ = grpc_pick_unused_port_or_die(); in SetUp()
70 server_address_ << "localhost:" << port_; in SetUp()
95 grpc_recycle_unused_port(port_); in TearDown()
170 int port_; member in grpc::testing::__anon0a5f04670211::NonblockingTest
|
| D | proto_server_reflection_test.cc | 46 port_ = grpc_pick_unused_port_or_die(); in SetUp()
50 grpc::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
|
| D | server_builder_plugin_test.cc | 145 port_ = grpc_pick_unused_port_or_die(); in SetUp()
176 grpc::string server_address = "localhost:" + to_string(port_); in StartServer()
187 string target = "dns:localhost:" + to_string(port_); in ResetStub()
217 int port_; member in grpc::testing::ServerBuilderPluginTest
|
| /external/google-breakpad/src/common/mac/ |
| D | MachIPC.mm | 172 &port_);
178 port_,
179 port_,
194 port_);
204 &port_);
210 port_,
211 port_,
219 : port_(receive_port),
226 mach_port_deallocate(mach_task_self(), port_);
241 out_message->head.msgh_local_port = port_;
[all …]
|
| /external/libchrome/mojo/core/ports/ |
| D | port_ref.h | 34 bool is_valid() const { return !!port_; } in COMPONENT_EXPORT()
39 Port* port() const { return port_.get(); } in COMPONENT_EXPORT()
42 scoped_refptr<Port> port_; in COMPONENT_EXPORT() local
|
| /external/grpc-grpc-java/grpclb/src/generated/main/java/io/grpc/lb/v1/ |
| D | Server.java | 25 port_ = 0; in Server()
68 port_ = input.readInt32(); in Server()
121 private int port_; field in Server
130 return port_; in getPort()
215 if (port_ != 0) { in writeTo()
216 output.writeInt32(2, port_); in writeTo()
236 if (port_ != 0) { in getSerializedSize()
238 .computeInt32Size(2, port_); in getSerializedSize()
427 port_ = 0; in clear()
456 result.port_ = port_; in buildPartial()
[all …]
|
| /external/webrtc/webrtc/p2p/client/ |
| D | fakeportallocator.h | 97 port_(), running_(false), in FakePortAllocatorSession()
103 if (!port_) { in StartGettingPorts()
104 port_.reset(TestUDPPort::Create(worker_thread_, factory_, &network_, in StartGettingPorts()
107 AddPort(port_.get()); in StartGettingPorts()
136 rtc::scoped_ptr<cricket::Port> port_; variable
|
| D | basicportallocator.h | 127 PortData() : port_(NULL), sequence_(NULL), state_(STATE_INIT) {} in PortData()
129 : port_(port), sequence_(seq), state_(STATE_INIT) { in PortData()
132 Port* port() { return port_; } in port()
156 Port* port_; variable
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server.h | 46 port_ = config.port(); in Server()
48 port_ = grpc_pick_unused_port_or_die(); in Server()
94 int port() const { return port_; } in port()
146 int port_;
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 129 : FullstackFixture(service, fixture_configuration, MakeAddress(&port_)) {} in FullstackFixture() argument
131 ~TCP() { grpc_recycle_unused_port(port_); } in ~TCP()
134 int port_;
148 : FullstackFixture(service, fixture_configuration, MakeAddress(&port_)) {} in FullstackFixture() argument
150 ~UDS() { grpc_recycle_unused_port(port_); } in ~UDS()
153 int port_;
|
| /external/grpc-grpc/test/cpp/client/ |
| D | client_channel_stress_test.cc | 151 addresses.emplace_back(AddressData{balancer_server.port_, true, ""}); in Run()
173 port_ = grpc_pick_unused_port_or_die(); in ServerThread()
174 gpr_log(GPR_INFO, "starting %s server on port %d", type_.c_str(), port_); in ServerThread()
188 server_address << server_host << ":" << port_; in Start()
204 int port_; member
274 backend_ports.push_back(backend_servers_.back().port_); in Start()
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| D | main_wnd.cc | 133 port_ = buffer; in GtkMainWnd()
250 gtk_entry_set_text(GTK_ENTRY(port_edit_), port_.c_str()); in SwitchToConnectUI()
339 port_ = gtk_entry_get_text(GTK_ENTRY(port_edit_)); in OnClicked()
340 int port = port_.length() ? atoi(port_.c_str()) : 0; in OnClicked()
|