OLD | NEW |
(Empty) | |
| 1 /* |
| 2 * Copyright 2016 The WebRTC project authors. All Rights Reserved. |
| 3 * |
| 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 |
| 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ |
| 10 |
| 11 #include "webrtc/p2p/base/udptransport.h" |
| 12 |
| 13 #include <string> |
| 14 #include <utility> // For std::move. |
| 15 |
| 16 #include "webrtc/base/asyncudpsocket.h" |
| 17 #include "webrtc/base/asyncpacketsocket.h" |
| 18 #include "webrtc/base/logging.h" |
| 19 #include "webrtc/base/socketaddress.h" |
| 20 #include "webrtc/base/thread.h" |
| 21 #include "webrtc/base/thread_checker.h" |
| 22 |
| 23 namespace cricket { |
| 24 |
| 25 UdpTransport::UdpTransport(const std::string& transport_name, |
| 26 std::unique_ptr<rtc::AsyncPacketSocket> socket) |
| 27 : transport_name_(transport_name), socket_(std::move(socket)) { |
| 28 RTC_DCHECK(socket_); |
| 29 socket_->SignalReadPacket.connect(this, &UdpTransport::OnSocketReadPacket); |
| 30 socket_->SignalSentPacket.connect(this, &UdpTransport::OnSocketSentPacket); |
| 31 } |
| 32 |
| 33 UdpTransport::~UdpTransport() { |
| 34 RTC_DCHECK_RUN_ON(&network_thread_checker_); |
| 35 } |
| 36 |
| 37 rtc::SocketAddress UdpTransport::GetLocalAddress() const { |
| 38 RTC_DCHECK_RUN_ON(&network_thread_checker_); |
| 39 return socket_->GetLocalAddress(); |
| 40 } |
| 41 |
| 42 bool UdpTransport::SetRemoteAddress(const rtc::SocketAddress& addr) { |
| 43 RTC_DCHECK_RUN_ON(&network_thread_checker_); |
| 44 if (!addr.IsComplete()) { |
| 45 LOG(LS_WARNING) << "Remote address not complete."; |
| 46 return false; |
| 47 } |
| 48 // TODO(johan): check for ipv4, other settings. |
| 49 bool prev_destination_nil = remote_address_.IsNil(); |
| 50 remote_address_ = addr; |
| 51 // Going from "didn't have destination" to "have destination" or vice versa. |
| 52 if (prev_destination_nil != remote_address_.IsNil()) { |
| 53 SignalWritableState(this); |
| 54 if (prev_destination_nil) { |
| 55 SignalReadyToSend(this); |
| 56 } |
| 57 } |
| 58 return true; |
| 59 } |
| 60 |
| 61 rtc::SocketAddress UdpTransport::GetRemoteAddress() const { |
| 62 RTC_DCHECK_RUN_ON(&network_thread_checker_); |
| 63 return remote_address_; |
| 64 } |
| 65 |
| 66 bool UdpTransport::writable() const { |
| 67 RTC_DCHECK_RUN_ON(&network_thread_checker_); |
| 68 return !remote_address_.IsNil(); |
| 69 } |
| 70 |
| 71 int UdpTransport::SendPacket(const char* data, |
| 72 size_t len, |
| 73 const rtc::PacketOptions& options, |
| 74 int flags) { |
| 75 // No thread_checker in high frequency network function. |
| 76 if (remote_address_.IsNil()) { |
| 77 LOG(LS_WARNING) << "Remote address not set."; |
| 78 send_error_ = ENOTCONN; |
| 79 return -1; |
| 80 } |
| 81 int result = |
| 82 socket_->SendTo((const void*)data, len, remote_address_, options); |
| 83 if (result <= 0) { |
| 84 LOG(LS_VERBOSE) << "SendPacket() " << result; |
| 85 } |
| 86 return result; |
| 87 } |
| 88 |
| 89 void UdpTransport::OnSocketReadPacket(rtc::AsyncPacketSocket* socket, |
| 90 const char* data, |
| 91 size_t len, |
| 92 const rtc::SocketAddress& remote_addr, |
| 93 const rtc::PacketTime& packet_time) { |
| 94 // No thread_checker in high frequency network function. |
| 95 SignalReadPacket(this, data, len, packet_time, 0); |
| 96 } |
| 97 |
| 98 void UdpTransport::OnSocketSentPacket(rtc::AsyncPacketSocket* socket, |
| 99 const rtc::SentPacket& packet) { |
| 100 RTC_DCHECK_EQ(socket_.get(), socket); |
| 101 SignalSentPacket(this, packet); |
| 102 } |
| 103 |
| 104 } // namespace cricket |
OLD | NEW |