| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 412 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 423 int error = (CS_CONNECTING == state_) ? ECONNREFUSED : 0; | 423 int error = (CS_CONNECTING == state_) ? ECONNREFUSED : 0; |
| 424 state_ = CS_CLOSED; | 424 state_ = CS_CLOSED; |
| 425 remote_addr_.Clear(); | 425 remote_addr_.Clear(); |
| 426 if (async_) { | 426 if (async_) { |
| 427 SignalCloseEvent(this, error); | 427 SignalCloseEvent(this, error); |
| 428 } | 428 } |
| 429 } | 429 } |
| 430 } else if (pmsg->message_id == MSG_ID_ADDRESS_BOUND) { | 430 } else if (pmsg->message_id == MSG_ID_ADDRESS_BOUND) { |
| 431 SignalAddressReady(this, GetLocalAddress()); | 431 SignalAddressReady(this, GetLocalAddress()); |
| 432 } else { | 432 } else { |
| 433 RTC_DCHECK(false); | 433 RTC_NOTREACHED(); |
| 434 } | 434 } |
| 435 } | 435 } |
| 436 | 436 |
| 437 int VirtualSocket::InitiateConnect(const SocketAddress& addr, bool use_delay) { | 437 int VirtualSocket::InitiateConnect(const SocketAddress& addr, bool use_delay) { |
| 438 if (!remote_addr_.IsNil()) { | 438 if (!remote_addr_.IsNil()) { |
| 439 error_ = (CS_CONNECTED == state_) ? EISCONN : EINPROGRESS; | 439 error_ = (CS_CONNECTED == state_) ? EISCONN : EINPROGRESS; |
| 440 return -1; | 440 return -1; |
| 441 } | 441 } |
| 442 if (local_addr_.IsNil()) { | 442 if (local_addr_.IsNil()) { |
| 443 // If there's no local address set, grab a random one in the correct AF. | 443 // If there's no local address set, grab a random one in the correct AF. |
| (...skipping 238 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 682 AddressMap::value_type entry(normalized, socket); | 682 AddressMap::value_type entry(normalized, socket); |
| 683 return bindings_->insert(entry).second ? 0 : -1; | 683 return bindings_->insert(entry).second ? 0 : -1; |
| 684 } | 684 } |
| 685 | 685 |
| 686 int VirtualSocketServer::Bind(VirtualSocket* socket, SocketAddress* addr) { | 686 int VirtualSocketServer::Bind(VirtualSocket* socket, SocketAddress* addr) { |
| 687 RTC_DCHECK(NULL != socket); | 687 RTC_DCHECK(NULL != socket); |
| 688 | 688 |
| 689 if (!IPIsUnspec(addr->ipaddr())) { | 689 if (!IPIsUnspec(addr->ipaddr())) { |
| 690 addr->SetIP(addr->ipaddr().Normalized()); | 690 addr->SetIP(addr->ipaddr().Normalized()); |
| 691 } else { | 691 } else { |
| 692 RTC_DCHECK(false); | 692 RTC_NOTREACHED(); |
| 693 } | 693 } |
| 694 | 694 |
| 695 if (addr->port() == 0) { | 695 if (addr->port() == 0) { |
| 696 for (int i = 0; i < kEphemeralPortCount; ++i) { | 696 for (int i = 0; i < kEphemeralPortCount; ++i) { |
| 697 addr->SetPort(GetNextPort()); | 697 addr->SetPort(GetNextPort()); |
| 698 if (bindings_->find(*addr) == bindings_->end()) { | 698 if (bindings_->find(*addr) == bindings_->end()) { |
| 699 break; | 699 break; |
| 700 } | 700 } |
| 701 } | 701 } |
| 702 } | 702 } |
| (...skipping 488 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1191 void VirtualSocketServer::SetDefaultRoute(const IPAddress& from_addr) { | 1191 void VirtualSocketServer::SetDefaultRoute(const IPAddress& from_addr) { |
| 1192 RTC_DCHECK(!IPIsAny(from_addr)); | 1192 RTC_DCHECK(!IPIsAny(from_addr)); |
| 1193 if (from_addr.family() == AF_INET) { | 1193 if (from_addr.family() == AF_INET) { |
| 1194 default_route_v4_ = from_addr; | 1194 default_route_v4_ = from_addr; |
| 1195 } else if (from_addr.family() == AF_INET6) { | 1195 } else if (from_addr.family() == AF_INET6) { |
| 1196 default_route_v6_ = from_addr; | 1196 default_route_v6_ = from_addr; |
| 1197 } | 1197 } |
| 1198 } | 1198 } |
| 1199 | 1199 |
| 1200 } // namespace rtc | 1200 } // namespace rtc |
| OLD | NEW |