| /external/webrtc/p2p/base/ |
| D | turn_port.cc | 113 TurnPort* port_; member in cricket::TurnAllocateRequest
125 TurnPort* port_; member in cricket::TurnRefreshRequest
140 TurnPort* port_; member in cricket::TurnCreatePermissionRequest
158 TurnPort* port_; member in cricket::TurnChannelBindRequest
172 TurnPort* port() { return port_; } in port()
216 TurnPort* port_; member in cricket::TurnEntry
1326 port_(port) { in TurnAllocateRequest()
1334 if (!port_->hash().empty()) { in TurnAllocateRequest()
1335 port_->AddRequestAuthInfo(message); in TurnAllocateRequest()
1337 port_->MaybeAddTurnLoggingId(message); in TurnAllocateRequest()
[all …]
|
| D | connection.cc | 217 port_(std::move(port)), in Connection()
218 local_candidate_(port_->Candidates()[index]), in Connection()
227 requests_(port_->thread(), in Connection()
242 RTC_DCHECK(port_);
248 RTC_DCHECK(!port_); in ~Connection()
273 if (!port_) in priority()
282 IceRole role = port_->GetIceRole(); in priority()
432 rtc::PacketOptions options(port_->StunDscpValue()); in OnSendStunPacket()
436 port_->SendTo(data, size, remote_candidate_.address(), options, false); in OnSendStunPacket()
452 if (!port_->GetStunMessage(data, size, addr, &msg, &remote_ufrag)) { in OnReadPacket()
[all …]
|
| D | fake_port_allocator.h | 105 port_(), in FakePortAllocatorSession()
120 if (!port_) { in StartGettingPorts()
125 port_.reset(TestUDPPort::Create(network_thread_, factory_, &network, 0, 0, in StartGettingPorts()
128 RTC_DCHECK(port_); in StartGettingPorts()
129 port_->SetIceTiebreaker(ice_tiebreaker()); in StartGettingPorts()
130 port_->SubscribePortDestroyed( in StartGettingPorts()
132 AddPort(port_.get()); in StartGettingPorts()
153 void PruneAllPorts() override { port_->Prune(); } in PruneAllPorts()
198 port_.release(); in OnPortDestroyed()
205 std::unique_ptr<cricket::Port> port_; variable
|
| D | stun_port.cc | 67 port_(port), in StunBindingRequest()
83 port_->OnStunBindingRequestSucceeded(this->Elapsed(), server_addr_, addr); in OnResponse()
88 port_->request_manager_.SendDelayed( in OnResponse()
89 new StunBindingRequest(port_, server_addr_, start_time_), in OnResponse()
90 port_->stun_keepalive_delay()); in OnResponse()
105 port_->OnStunBindingOrResolveRequestFailed( in OnErrorResponse()
113 port_->request_manager_.SendDelayed( in OnErrorResponse()
114 new StunBindingRequest(port_, server_addr_, start_time_), in OnErrorResponse()
115 port_->stun_keepalive_delay()); in OnErrorResponse()
120 << port_->GetLocalAddress().ToSensitiveString() << " (" in OnTimeout()
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/platform/api/ |
| D | quic_socket_address.cc | 36 : host_(address), port_(port) {} in QuicSocketAddress()
43 port_ = ntohs(v4->sin_port); in QuicSocketAddress()
49 port_ = ntohs(v6->sin6_port); in QuicSocketAddress()
77 return lhs.host_ == rhs.host_ && lhs.port_ == rhs.port_; in operator ==()
89 return absl::StrCat(host_.ToString(), ":", port_); in ToString()
91 return absl::StrCat("[", host_.ToString(), "]:", port_); in ToString()
112 return QuicSocketAddress(host_.Normalized(), port_); in Normalized()
117 uint16_t QuicSocketAddress::port() const { return port_; } in port()
131 result.v4.sin_port = htons(port_); in generic_address()
136 result.v6.sin6_port = htons(port_); in generic_address()
[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/cronet/net/base/ |
| D | host_port_pair.h | 53 return std::tie(port_, host_) < std::tie(other.port_, other.host_);
60 return host_ == other.host_ && port_ == other.port_; in Equals()
64 return host_.empty() && port_ == 0; in IsEmpty()
71 uint16_t port() const { return port_; } in port()
77 void set_port(uint16_t in_port) { port_ = in_port; } in set_port()
92 uint16_t port_; variable
|
| D | ip_endpoint.cc | 72 : address_(address), port_(port) {} in IPEndPoint()
80 return port_; in port()
124 addr->sin_port = base::HostToNet16(port_); in ToSockAddr()
137 addr6->sin6_port = base::HostToNet16(port_); in ToSockAddr()
196 return IPAddressToStringWithPort(address_, port_); in ToString()
211 return std::tie(address_, port_) < std::tie(other.address_, other.port_); in operator <()
215 return address_ == other.address_ && port_ == other.port_; in operator ==()
227 dict.Set(kValuePortKey, port_); in ToValue()
|
| D | host_port_pair.cc | 32 HostPortPair::HostPortPair() : port_(0) {} in HostPortPair()
34 : host_(in_host), port_(in_port) {} in HostPortPair()
109 ret += base::NumberToString(port_); in ToString()
135 dict.Set(kValuePortKey, port_); in ToValue()
|
| /external/webrtc/rtc_base/ |
| D | socket_address.cc | 70 port_ = 0; in Clear()
75 return hostname_.empty() && IPIsUnspec(ip_) && 0 == port_; in IsNil()
79 return (!IPIsAny(ip_)) && (0 != port_); in IsComplete()
85 port_ = addr.port_; in operator =()
125 port_ = rtc::dchecked_cast<uint16_t>(port); in SetPort()
137 return port_; in port()
165 return std::to_string(port_); in PortAsString()
245 return port_ < addr.port_; in operator <()
254 return (port_ == addr.port_); in EqualPorts()
260 h ^= port_ | (port_ << 16); in Hash()
[all …]
|
| /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::__anona41b0d210211::NonblockingTest
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_server_id.cc | 68 port_(port), in QuicServerId()
74 return std::tie(port_, host_, privacy_mode_enabled_) < in operator <()
75 std::tie(other.port_, other.host_, other.privacy_mode_enabled_); in operator <()
80 host_ == other.host_ && port_ == other.port_; in operator ==()
88 return absl::StrCat(GetHostWithIpv6Brackets(), ":", port_); in ToHostPortString()
|
| /external/cronet/url/ |
| D | scheme_host_port.cc | 156 port_ = port; in SchemeHostPort()
190 port_ = port; in SchemeHostPort()
199 DCHECK(!scheme_.empty() || port_ == 0); in IsValid()
233 return std::tie(port_, scheme_, host_) < in operator <()
234 std::tie(other.port_, other.scheme_, other.host_); in operator <()
263 if (port_ != default_port) { in SerializeInternal()
265 std::string port(base::NumberToString(port_)); in SerializeInternal()
|
| D | scheme_host_port.h | 124 uint16_t port() const { return port_; } in COMPONENT_EXPORT()
149 return port_ == other.port() && scheme_ == other.scheme() && in COMPONENT_EXPORT()
164 uint16_t port_ = 0; in COMPONENT_EXPORT() local
|
| /external/openscreen/util/ |
| D | url.cc | 60 port_ = parse_result; in Url()
87 port_(other.port_), in Url()
105 port_ = other.port_; in operator =()
|
| /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/tensorflow/tensorflow/core/data/service/ |
| D | url.h | 39 bool has_port() const { return !port_.empty(); } in has_port()
40 absl::string_view port() const { return port_; } in port()
46 std::string port_; variable
|
| /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/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/openscreen/discovery/dnssd/public/ |
| D | dns_sd_instance.cc | 66 port_(port), in DnsSdInstance()
188 if (lhs.port_ != rhs.port_) { in operator <()
189 return lhs.port_ < rhs.port_; in operator <()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/tools/ |
| D | quic_server.cc | 59 : port_(0), in QuicServer()
134 port_ = address.port(); in CreateUDPSocketAndListen()
135 if (port_ == 0) { in CreateUDPSocketAndListen()
141 port_ = address.port(); in CreateUDPSocketAndListen()
206 fd_, port_, *QuicDefaultClock::Get(), dispatcher_.get(), in OnSocketEvent()
|
| /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_;
|