Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "remoting/jingle_glue/chromium_socket_factory.h" | 5 #include "remoting/jingle_glue/chromium_socket_factory.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
| 10 #include "jingle/glue/utils.h" | 10 #include "jingle/glue/utils.h" |
| (...skipping 27 matching lines...) Expand all Loading... | |
| 38 public: | 38 public: |
| 39 UdpPacketSocket(); | 39 UdpPacketSocket(); |
| 40 virtual ~UdpPacketSocket(); | 40 virtual ~UdpPacketSocket(); |
| 41 | 41 |
| 42 bool Init(const talk_base::SocketAddress& local_address, | 42 bool Init(const talk_base::SocketAddress& local_address, |
| 43 int min_port, int max_port); | 43 int min_port, int max_port); |
| 44 | 44 |
| 45 // talk_base::AsyncPacketSocket interface. | 45 // talk_base::AsyncPacketSocket interface. |
| 46 virtual talk_base::SocketAddress GetLocalAddress() const OVERRIDE; | 46 virtual talk_base::SocketAddress GetLocalAddress() const OVERRIDE; |
| 47 virtual talk_base::SocketAddress GetRemoteAddress() const OVERRIDE; | 47 virtual talk_base::SocketAddress GetRemoteAddress() const OVERRIDE; |
| 48 virtual int Send(const void* data, size_t data_size) OVERRIDE; | 48 virtual int Send(const void* data, size_t data_size, |
| 49 talk_base::DiffServCodePoint dscp) OVERRIDE; | |
| 49 virtual int SendTo(const void* data, size_t data_size, | 50 virtual int SendTo(const void* data, size_t data_size, |
| 50 const talk_base::SocketAddress& address) OVERRIDE; | 51 const talk_base::SocketAddress& address, |
| 52 talk_base::DiffServCodePoint dscp) OVERRIDE; | |
| 51 virtual int Close() OVERRIDE; | 53 virtual int Close() OVERRIDE; |
| 52 virtual State GetState() const OVERRIDE; | 54 virtual State GetState() const OVERRIDE; |
| 53 virtual int GetOption(talk_base::Socket::Option option, int* value) OVERRIDE; | 55 virtual int GetOption(talk_base::Socket::Option option, int* value) OVERRIDE; |
| 54 virtual int SetOption(talk_base::Socket::Option option, int value) OVERRIDE; | 56 virtual int SetOption(talk_base::Socket::Option option, int value) OVERRIDE; |
| 55 virtual int GetError() const OVERRIDE; | 57 virtual int GetError() const OVERRIDE; |
| 56 virtual void SetError(int error) OVERRIDE; | 58 virtual void SetError(int error) OVERRIDE; |
| 57 | 59 |
| 58 private: | 60 private: |
| 59 struct PendingPacket { | 61 struct PendingPacket { |
| 60 PendingPacket(const void* buffer, | 62 PendingPacket(const void* buffer, |
| (...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 152 DCHECK_EQ(state_, STATE_BOUND); | 154 DCHECK_EQ(state_, STATE_BOUND); |
| 153 return local_address_; | 155 return local_address_; |
| 154 } | 156 } |
| 155 | 157 |
| 156 talk_base::SocketAddress UdpPacketSocket::GetRemoteAddress() const { | 158 talk_base::SocketAddress UdpPacketSocket::GetRemoteAddress() const { |
| 157 // UDP sockets are not connected - this method should never be called. | 159 // UDP sockets are not connected - this method should never be called. |
| 158 NOTREACHED(); | 160 NOTREACHED(); |
| 159 return talk_base::SocketAddress(); | 161 return talk_base::SocketAddress(); |
| 160 } | 162 } |
| 161 | 163 |
| 162 int UdpPacketSocket::Send(const void* data, size_t data_size) { | 164 int UdpPacketSocket::Send(const void* data, size_t data_size, |
| 165 talk_base::DiffServCodePoint dscp) { | |
| 163 // UDP sockets are not connected - this method should never be called. | 166 // UDP sockets are not connected - this method should never be called. |
| 164 NOTREACHED(); | 167 NOTREACHED(); |
| 165 return EWOULDBLOCK; | 168 return EWOULDBLOCK; |
| 166 } | 169 } |
| 167 | 170 |
| 168 int UdpPacketSocket::SendTo(const void* data, size_t data_size, | 171 int UdpPacketSocket::SendTo(const void* data, size_t data_size, |
| 169 const talk_base::SocketAddress& address) { | 172 const talk_base::SocketAddress& address, |
| 173 talk_base::DiffServCodePoint /*dscp*/) { | |
|
Sergey Ulanov
2013/09/23 22:32:36
ditto
Mallinath (Gone from Chromium)
2013/09/23 22:38:14
Done.
| |
| 170 if (state_ != STATE_BOUND) { | 174 if (state_ != STATE_BOUND) { |
| 171 NOTREACHED(); | 175 NOTREACHED(); |
| 172 return EINVAL; | 176 return EINVAL; |
| 173 } | 177 } |
| 174 | 178 |
| 175 if (error_ != 0) { | 179 if (error_ != 0) { |
| 176 return error_; | 180 return error_; |
| 177 } | 181 } |
| 178 | 182 |
| 179 net::IPEndPoint endpoint; | 183 net::IPEndPoint endpoint; |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 230 } | 234 } |
| 231 | 235 |
| 232 case talk_base::Socket::OPT_NODELAY: | 236 case talk_base::Socket::OPT_NODELAY: |
| 233 // OPT_NODELAY is only for TCP sockets. | 237 // OPT_NODELAY is only for TCP sockets. |
| 234 NOTREACHED(); | 238 NOTREACHED(); |
| 235 return -1; | 239 return -1; |
| 236 | 240 |
| 237 case talk_base::Socket::OPT_IPV6_V6ONLY: | 241 case talk_base::Socket::OPT_IPV6_V6ONLY: |
| 238 NOTIMPLEMENTED(); | 242 NOTIMPLEMENTED(); |
| 239 return -1; | 243 return -1; |
| 244 | |
| 245 case talk_base::Socket::OPT_DSCP: | |
| 246 NOTIMPLEMENTED(); | |
| 247 return -1; | |
| 240 } | 248 } |
| 241 | 249 |
| 242 NOTREACHED(); | 250 NOTREACHED(); |
| 243 return -1; | 251 return -1; |
| 244 } | 252 } |
| 245 | 253 |
| 246 int UdpPacketSocket::GetError() const { | 254 int UdpPacketSocket::GetError() const { |
| 247 return error_; | 255 return error_; |
| 248 } | 256 } |
| 249 | 257 |
| (...skipping 107 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 357 const talk_base::SocketAddress& remote_address, | 365 const talk_base::SocketAddress& remote_address, |
| 358 const talk_base::ProxyInfo& proxy_info, | 366 const talk_base::ProxyInfo& proxy_info, |
| 359 const std::string& user_agent, | 367 const std::string& user_agent, |
| 360 int opts) { | 368 int opts) { |
| 361 // We don't use TCP sockets for remoting connections. | 369 // We don't use TCP sockets for remoting connections. |
| 362 NOTREACHED(); | 370 NOTREACHED(); |
| 363 return NULL; | 371 return NULL; |
| 364 } | 372 } |
| 365 | 373 |
| 366 } // namespace remoting | 374 } // namespace remoting |
| OLD | NEW |