| 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 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 extern const char SSLTCP_PROTOCOL_NAME[]; | 45 extern const char SSLTCP_PROTOCOL_NAME[]; |
| 46 | 46 |
| 47 // RFC 6544, TCP candidate encoding rules. | 47 // RFC 6544, TCP candidate encoding rules. |
| 48 extern const int DISCARD_PORT; | 48 extern const int DISCARD_PORT; |
| 49 extern const char TCPTYPE_ACTIVE_STR[]; | 49 extern const char TCPTYPE_ACTIVE_STR[]; |
| 50 extern const char TCPTYPE_PASSIVE_STR[]; | 50 extern const char TCPTYPE_PASSIVE_STR[]; |
| 51 extern const char TCPTYPE_SIMOPEN_STR[]; | 51 extern const char TCPTYPE_SIMOPEN_STR[]; |
| 52 | 52 |
| 53 // The minimum time we will wait before destroying a connection after creating | 53 // The minimum time we will wait before destroying a connection after creating |
| 54 // it. | 54 // it. |
| 55 const uint32 MIN_CONNECTION_LIFETIME = 10 * 1000; // 10 seconds. | 55 const uint32_t MIN_CONNECTION_LIFETIME = 10 * 1000; // 10 seconds. |
| 56 | 56 |
| 57 // The timeout duration when a connection does not receive anything. | 57 // The timeout duration when a connection does not receive anything. |
| 58 const uint32 WEAK_CONNECTION_RECEIVE_TIMEOUT = 2500; // 2.5 seconds | 58 const uint32_t WEAK_CONNECTION_RECEIVE_TIMEOUT = 2500; // 2.5 seconds |
| 59 | 59 |
| 60 // The length of time we wait before timing out writability on a connection. | 60 // The length of time we wait before timing out writability on a connection. |
| 61 const uint32 CONNECTION_WRITE_TIMEOUT = 15 * 1000; // 15 seconds | 61 const uint32_t CONNECTION_WRITE_TIMEOUT = 15 * 1000; // 15 seconds |
| 62 | 62 |
| 63 // The length of time we wait before we become unwritable. | 63 // The length of time we wait before we become unwritable. |
| 64 const uint32 CONNECTION_WRITE_CONNECT_TIMEOUT = 5 * 1000; // 5 seconds | 64 const uint32_t CONNECTION_WRITE_CONNECT_TIMEOUT = 5 * 1000; // 5 seconds |
| 65 | 65 |
| 66 // The number of pings that must fail to respond before we become unwritable. | 66 // The number of pings that must fail to respond before we become unwritable. |
| 67 const uint32 CONNECTION_WRITE_CONNECT_FAILURES = 5; | 67 const uint32_t CONNECTION_WRITE_CONNECT_FAILURES = 5; |
| 68 | 68 |
| 69 // This is the length of time that we wait for a ping response to come back. | 69 // This is the length of time that we wait for a ping response to come back. |
| 70 const int CONNECTION_RESPONSE_TIMEOUT = 5 * 1000; // 5 seconds | 70 const int CONNECTION_RESPONSE_TIMEOUT = 5 * 1000; // 5 seconds |
| 71 | 71 |
| 72 enum RelayType { | 72 enum RelayType { |
| 73 RELAY_GTURN, // Legacy google relay service. | 73 RELAY_GTURN, // Legacy google relay service. |
| 74 RELAY_TURN // Standard (TURN) relay service. | 74 RELAY_TURN // Standard (TURN) relay service. |
| 75 }; | 75 }; |
| 76 | 76 |
| 77 enum IcePriorityValue { | 77 enum IcePriorityValue { |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 115 rtc::PacketSocketFactory* factory, | 115 rtc::PacketSocketFactory* factory, |
| 116 rtc::Network* network, | 116 rtc::Network* network, |
| 117 const rtc::IPAddress& ip, | 117 const rtc::IPAddress& ip, |
| 118 const std::string& username_fragment, | 118 const std::string& username_fragment, |
| 119 const std::string& password); | 119 const std::string& password); |
| 120 Port(rtc::Thread* thread, | 120 Port(rtc::Thread* thread, |
| 121 const std::string& type, | 121 const std::string& type, |
| 122 rtc::PacketSocketFactory* factory, | 122 rtc::PacketSocketFactory* factory, |
| 123 rtc::Network* network, | 123 rtc::Network* network, |
| 124 const rtc::IPAddress& ip, | 124 const rtc::IPAddress& ip, |
| 125 uint16 min_port, | 125 uint16_t min_port, |
| 126 uint16 max_port, | 126 uint16_t max_port, |
| 127 const std::string& username_fragment, | 127 const std::string& username_fragment, |
| 128 const std::string& password); | 128 const std::string& password); |
| 129 virtual ~Port(); | 129 virtual ~Port(); |
| 130 | 130 |
| 131 virtual const std::string& Type() const { return type_; } | 131 virtual const std::string& Type() const { return type_; } |
| 132 virtual rtc::Network* Network() const { return network_; } | 132 virtual rtc::Network* Network() const { return network_; } |
| 133 | 133 |
| 134 // Methods to set/get ICE role and tiebreaker values. | 134 // Methods to set/get ICE role and tiebreaker values. |
| 135 IceRole GetIceRole() const { return ice_role_; } | 135 IceRole GetIceRole() const { return ice_role_; } |
| 136 void SetIceRole(IceRole role) { ice_role_ = role; } | 136 void SetIceRole(IceRole role) { ice_role_ = role; } |
| 137 | 137 |
| 138 void SetIceTiebreaker(uint64 tiebreaker) { tiebreaker_ = tiebreaker; } | 138 void SetIceTiebreaker(uint64_t tiebreaker) { tiebreaker_ = tiebreaker; } |
| 139 uint64 IceTiebreaker() const { return tiebreaker_; } | 139 uint64_t IceTiebreaker() const { return tiebreaker_; } |
| 140 | 140 |
| 141 virtual bool SharedSocket() const { return shared_socket_; } | 141 virtual bool SharedSocket() const { return shared_socket_; } |
| 142 void ResetSharedSocket() { shared_socket_ = false; } | 142 void ResetSharedSocket() { shared_socket_ = false; } |
| 143 | 143 |
| 144 // The thread on which this port performs its I/O. | 144 // The thread on which this port performs its I/O. |
| 145 rtc::Thread* thread() { return thread_; } | 145 rtc::Thread* thread() { return thread_; } |
| 146 | 146 |
| 147 // The factory used to create the sockets of this port. | 147 // The factory used to create the sockets of this port. |
| 148 rtc::PacketSocketFactory* socket_factory() const { return factory_; } | 148 rtc::PacketSocketFactory* socket_factory() const { return factory_; } |
| 149 void set_socket_factory(rtc::PacketSocketFactory* factory) { | 149 void set_socket_factory(rtc::PacketSocketFactory* factory) { |
| (...skipping 10 matching lines...) Expand all Loading... |
| 160 void set_component(int component) { component_ = component; } | 160 void set_component(int component) { component_ = component; } |
| 161 | 161 |
| 162 bool send_retransmit_count_attribute() const { | 162 bool send_retransmit_count_attribute() const { |
| 163 return send_retransmit_count_attribute_; | 163 return send_retransmit_count_attribute_; |
| 164 } | 164 } |
| 165 void set_send_retransmit_count_attribute(bool enable) { | 165 void set_send_retransmit_count_attribute(bool enable) { |
| 166 send_retransmit_count_attribute_ = enable; | 166 send_retransmit_count_attribute_ = enable; |
| 167 } | 167 } |
| 168 | 168 |
| 169 // Identifies the generation that this port was created in. | 169 // Identifies the generation that this port was created in. |
| 170 uint32 generation() { return generation_; } | 170 uint32_t generation() { return generation_; } |
| 171 void set_generation(uint32 generation) { generation_ = generation; } | 171 void set_generation(uint32_t generation) { generation_ = generation; } |
| 172 | 172 |
| 173 // ICE requires a single username/password per content/media line. So the | 173 // ICE requires a single username/password per content/media line. So the |
| 174 // |ice_username_fragment_| of the ports that belongs to the same content will | 174 // |ice_username_fragment_| of the ports that belongs to the same content will |
| 175 // be the same. However this causes a small complication with our relay | 175 // be the same. However this causes a small complication with our relay |
| 176 // server, which expects different username for RTP and RTCP. | 176 // server, which expects different username for RTP and RTCP. |
| 177 // | 177 // |
| 178 // To resolve this problem, we implemented the username_fragment(), | 178 // To resolve this problem, we implemented the username_fragment(), |
| 179 // which returns a different username (calculated from | 179 // which returns a different username (calculated from |
| 180 // |ice_username_fragment_|) for RTCP in the case of ICEPROTO_GOOGLE. And the | 180 // |ice_username_fragment_|) for RTCP in the case of ICEPROTO_GOOGLE. And the |
| 181 // username_fragment() simply returns |ice_username_fragment_| when running | 181 // username_fragment() simply returns |ice_username_fragment_| when running |
| (...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 250 virtual void EnablePortPackets(); | 250 virtual void EnablePortPackets(); |
| 251 | 251 |
| 252 // Called if the port has no connections and is no longer useful. | 252 // Called if the port has no connections and is no longer useful. |
| 253 void Destroy(); | 253 void Destroy(); |
| 254 | 254 |
| 255 virtual void OnMessage(rtc::Message *pmsg); | 255 virtual void OnMessage(rtc::Message *pmsg); |
| 256 | 256 |
| 257 // Debugging description of this port | 257 // Debugging description of this port |
| 258 virtual std::string ToString() const; | 258 virtual std::string ToString() const; |
| 259 const rtc::IPAddress& ip() const { return ip_; } | 259 const rtc::IPAddress& ip() const { return ip_; } |
| 260 uint16 min_port() { return min_port_; } | 260 uint16_t min_port() { return min_port_; } |
| 261 uint16 max_port() { return max_port_; } | 261 uint16_t max_port() { return max_port_; } |
| 262 | 262 |
| 263 // Timeout shortening function to speed up unit tests. | 263 // Timeout shortening function to speed up unit tests. |
| 264 void set_timeout_delay(int delay) { timeout_delay_ = delay; } | 264 void set_timeout_delay(int delay) { timeout_delay_ = delay; } |
| 265 | 265 |
| 266 // This method will return local and remote username fragements from the | 266 // This method will return local and remote username fragements from the |
| 267 // stun username attribute if present. | 267 // stun username attribute if present. |
| 268 bool ParseStunUsername(const StunMessage* stun_msg, | 268 bool ParseStunUsername(const StunMessage* stun_msg, |
| 269 std::string* local_username, | 269 std::string* local_username, |
| 270 std::string* remote_username) const; | 270 std::string* remote_username) const; |
| 271 void CreateStunUsername(const std::string& remote_username, | 271 void CreateStunUsername(const std::string& remote_username, |
| 272 std::string* stun_username_attr_str) const; | 272 std::string* stun_username_attr_str) const; |
| 273 | 273 |
| 274 bool MaybeIceRoleConflict(const rtc::SocketAddress& addr, | 274 bool MaybeIceRoleConflict(const rtc::SocketAddress& addr, |
| 275 IceMessage* stun_msg, | 275 IceMessage* stun_msg, |
| 276 const std::string& remote_ufrag); | 276 const std::string& remote_ufrag); |
| 277 | 277 |
| 278 // Called when the socket is currently able to send. | 278 // Called when the socket is currently able to send. |
| 279 void OnReadyToSend(); | 279 void OnReadyToSend(); |
| 280 | 280 |
| 281 // Called when the Connection discovers a local peer reflexive candidate. | 281 // Called when the Connection discovers a local peer reflexive candidate. |
| 282 // Returns the index of the new local candidate. | 282 // Returns the index of the new local candidate. |
| 283 size_t AddPrflxCandidate(const Candidate& local); | 283 size_t AddPrflxCandidate(const Candidate& local); |
| 284 | 284 |
| 285 void set_candidate_filter(uint32 candidate_filter) { | 285 void set_candidate_filter(uint32_t candidate_filter) { |
| 286 candidate_filter_ = candidate_filter; | 286 candidate_filter_ = candidate_filter; |
| 287 } | 287 } |
| 288 | 288 |
| 289 protected: | 289 protected: |
| 290 enum { | 290 enum { |
| 291 MSG_DEAD = 0, | 291 MSG_DEAD = 0, |
| 292 MSG_FIRST_AVAILABLE | 292 MSG_FIRST_AVAILABLE |
| 293 }; | 293 }; |
| 294 | 294 |
| 295 void set_type(const std::string& type) { type_ = type; } | 295 void set_type(const std::string& type) { type_ = type; } |
| 296 | 296 |
| 297 void AddAddress(const rtc::SocketAddress& address, | 297 void AddAddress(const rtc::SocketAddress& address, |
| 298 const rtc::SocketAddress& base_address, | 298 const rtc::SocketAddress& base_address, |
| 299 const rtc::SocketAddress& related_address, | 299 const rtc::SocketAddress& related_address, |
| 300 const std::string& protocol, | 300 const std::string& protocol, |
| 301 const std::string& relay_protocol, | 301 const std::string& relay_protocol, |
| 302 const std::string& tcptype, | 302 const std::string& tcptype, |
| 303 const std::string& type, | 303 const std::string& type, |
| 304 uint32 type_preference, | 304 uint32_t type_preference, |
| 305 uint32 relay_preference, | 305 uint32_t relay_preference, |
| 306 bool final); | 306 bool final); |
| 307 | 307 |
| 308 // Adds the given connection to the list. (Deleting removes them.) | 308 // Adds the given connection to the list. (Deleting removes them.) |
| 309 void AddConnection(Connection* conn); | 309 void AddConnection(Connection* conn); |
| 310 | 310 |
| 311 // Called when a packet is received from an unknown address that is not | 311 // Called when a packet is received from an unknown address that is not |
| 312 // currently a connection. If this is an authenticated STUN binding request, | 312 // currently a connection. If this is an authenticated STUN binding request, |
| 313 // then we will signal the client. | 313 // then we will signal the client. |
| 314 void OnReadPacket(const char* data, size_t size, | 314 void OnReadPacket(const char* data, size_t size, |
| 315 const rtc::SocketAddress& addr, | 315 const rtc::SocketAddress& addr, |
| (...skipping 10 matching lines...) Expand all Loading... |
| 326 | 326 |
| 327 // Checks if the address in addr is compatible with the port's ip. | 327 // Checks if the address in addr is compatible with the port's ip. |
| 328 bool IsCompatibleAddress(const rtc::SocketAddress& addr); | 328 bool IsCompatibleAddress(const rtc::SocketAddress& addr); |
| 329 | 329 |
| 330 // Returns default DSCP value. | 330 // Returns default DSCP value. |
| 331 rtc::DiffServCodePoint DefaultDscpValue() const { | 331 rtc::DiffServCodePoint DefaultDscpValue() const { |
| 332 // No change from what MediaChannel set. | 332 // No change from what MediaChannel set. |
| 333 return rtc::DSCP_NO_CHANGE; | 333 return rtc::DSCP_NO_CHANGE; |
| 334 } | 334 } |
| 335 | 335 |
| 336 uint32 candidate_filter() { return candidate_filter_; } | 336 uint32_t candidate_filter() { return candidate_filter_; } |
| 337 | 337 |
| 338 private: | 338 private: |
| 339 void Construct(); | 339 void Construct(); |
| 340 // Called when one of our connections deletes itself. | 340 // Called when one of our connections deletes itself. |
| 341 void OnConnectionDestroyed(Connection* conn); | 341 void OnConnectionDestroyed(Connection* conn); |
| 342 | 342 |
| 343 // Whether this port is dead, and hence, should be destroyed on the controlled | 343 // Whether this port is dead, and hence, should be destroyed on the controlled |
| 344 // side. | 344 // side. |
| 345 bool dead() const { | 345 bool dead() const { |
| 346 return ice_role_ == ICEROLE_CONTROLLED && connections_.empty(); | 346 return ice_role_ == ICEROLE_CONTROLLED && connections_.empty(); |
| 347 } | 347 } |
| 348 | 348 |
| 349 rtc::Thread* thread_; | 349 rtc::Thread* thread_; |
| 350 rtc::PacketSocketFactory* factory_; | 350 rtc::PacketSocketFactory* factory_; |
| 351 std::string type_; | 351 std::string type_; |
| 352 bool send_retransmit_count_attribute_; | 352 bool send_retransmit_count_attribute_; |
| 353 rtc::Network* network_; | 353 rtc::Network* network_; |
| 354 rtc::IPAddress ip_; | 354 rtc::IPAddress ip_; |
| 355 uint16 min_port_; | 355 uint16_t min_port_; |
| 356 uint16 max_port_; | 356 uint16_t max_port_; |
| 357 std::string content_name_; | 357 std::string content_name_; |
| 358 int component_; | 358 int component_; |
| 359 uint32 generation_; | 359 uint32_t generation_; |
| 360 // In order to establish a connection to this Port (so that real data can be | 360 // In order to establish a connection to this Port (so that real data can be |
| 361 // sent through), the other side must send us a STUN binding request that is | 361 // sent through), the other side must send us a STUN binding request that is |
| 362 // authenticated with this username_fragment and password. | 362 // authenticated with this username_fragment and password. |
| 363 // PortAllocatorSession will provide these username_fragment and password. | 363 // PortAllocatorSession will provide these username_fragment and password. |
| 364 // | 364 // |
| 365 // Note: we should always use username_fragment() instead of using | 365 // Note: we should always use username_fragment() instead of using |
| 366 // |ice_username_fragment_| directly. For the details see the comment on | 366 // |ice_username_fragment_| directly. For the details see the comment on |
| 367 // username_fragment(). | 367 // username_fragment(). |
| 368 std::string ice_username_fragment_; | 368 std::string ice_username_fragment_; |
| 369 std::string password_; | 369 std::string password_; |
| 370 std::vector<Candidate> candidates_; | 370 std::vector<Candidate> candidates_; |
| 371 AddressMap connections_; | 371 AddressMap connections_; |
| 372 int timeout_delay_; | 372 int timeout_delay_; |
| 373 bool enable_port_packets_; | 373 bool enable_port_packets_; |
| 374 IceRole ice_role_; | 374 IceRole ice_role_; |
| 375 uint64 tiebreaker_; | 375 uint64_t tiebreaker_; |
| 376 bool shared_socket_; | 376 bool shared_socket_; |
| 377 // Information to use when going through a proxy. | 377 // Information to use when going through a proxy. |
| 378 std::string user_agent_; | 378 std::string user_agent_; |
| 379 rtc::ProxyInfo proxy_; | 379 rtc::ProxyInfo proxy_; |
| 380 | 380 |
| 381 // Candidate filter is pushed down to Port such that each Port could | 381 // Candidate filter is pushed down to Port such that each Port could |
| 382 // make its own decision on how to create candidates. For example, | 382 // make its own decision on how to create candidates. For example, |
| 383 // when IceTransportsType is set to relay, both RelayPort and | 383 // when IceTransportsType is set to relay, both RelayPort and |
| 384 // TurnPort will hide raddr to avoid local address leakage. | 384 // TurnPort will hide raddr to avoid local address leakage. |
| 385 uint32 candidate_filter_; | 385 uint32_t candidate_filter_; |
| 386 | 386 |
| 387 friend class Connection; | 387 friend class Connection; |
| 388 }; | 388 }; |
| 389 | 389 |
| 390 // Represents a communication link between a port on the local client and a | 390 // Represents a communication link between a port on the local client and a |
| 391 // port on the remote client. | 391 // port on the remote client. |
| 392 class Connection : public rtc::MessageHandler, | 392 class Connection : public rtc::MessageHandler, |
| 393 public sigslot::has_slots<> { | 393 public sigslot::has_slots<> { |
| 394 public: | 394 public: |
| 395 struct SentPing { | 395 struct SentPing { |
| 396 SentPing(const std::string id, uint32 sent_time) | 396 SentPing(const std::string id, uint32_t sent_time) |
| 397 : id(id), | 397 : id(id), sent_time(sent_time) {} |
| 398 sent_time(sent_time) {} | |
| 399 | 398 |
| 400 std::string id; | 399 std::string id; |
| 401 uint32 sent_time; | 400 uint32_t sent_time; |
| 402 }; | 401 }; |
| 403 | 402 |
| 404 // States are from RFC 5245. http://tools.ietf.org/html/rfc5245#section-5.7.4 | 403 // States are from RFC 5245. http://tools.ietf.org/html/rfc5245#section-5.7.4 |
| 405 enum State { | 404 enum State { |
| 406 STATE_WAITING = 0, // Check has not been performed, Waiting pair on CL. | 405 STATE_WAITING = 0, // Check has not been performed, Waiting pair on CL. |
| 407 STATE_INPROGRESS, // Check has been sent, transaction is in progress. | 406 STATE_INPROGRESS, // Check has been sent, transaction is in progress. |
| 408 STATE_SUCCEEDED, // Check already done, produced a successful result. | 407 STATE_SUCCEEDED, // Check already done, produced a successful result. |
| 409 STATE_FAILED // Check for this connection failed. | 408 STATE_FAILED // Check for this connection failed. |
| 410 }; | 409 }; |
| 411 | 410 |
| 412 virtual ~Connection(); | 411 virtual ~Connection(); |
| 413 | 412 |
| 414 // The local port where this connection sends and receives packets. | 413 // The local port where this connection sends and receives packets. |
| 415 Port* port() { return port_; } | 414 Port* port() { return port_; } |
| 416 const Port* port() const { return port_; } | 415 const Port* port() const { return port_; } |
| 417 | 416 |
| 418 // Returns the description of the local port | 417 // Returns the description of the local port |
| 419 virtual const Candidate& local_candidate() const; | 418 virtual const Candidate& local_candidate() const; |
| 420 | 419 |
| 421 // Returns the description of the remote port to which we communicate. | 420 // Returns the description of the remote port to which we communicate. |
| 422 const Candidate& remote_candidate() const { return remote_candidate_; } | 421 const Candidate& remote_candidate() const { return remote_candidate_; } |
| 423 | 422 |
| 424 // Returns the pair priority. | 423 // Returns the pair priority. |
| 425 uint64 priority() const; | 424 uint64_t priority() const; |
| 426 | 425 |
| 427 enum WriteState { | 426 enum WriteState { |
| 428 STATE_WRITABLE = 0, // we have received ping responses recently | 427 STATE_WRITABLE = 0, // we have received ping responses recently |
| 429 STATE_WRITE_UNRELIABLE = 1, // we have had a few ping failures | 428 STATE_WRITE_UNRELIABLE = 1, // we have had a few ping failures |
| 430 STATE_WRITE_INIT = 2, // we have yet to receive a ping response | 429 STATE_WRITE_INIT = 2, // we have yet to receive a ping response |
| 431 STATE_WRITE_TIMEOUT = 3, // we have had a large number of ping failures | 430 STATE_WRITE_TIMEOUT = 3, // we have had a large number of ping failures |
| 432 }; | 431 }; |
| 433 | 432 |
| 434 WriteState write_state() const { return write_state_; } | 433 WriteState write_state() const { return write_state_; } |
| 435 bool writable() const { return write_state_ == STATE_WRITABLE; } | 434 bool writable() const { return write_state_ == STATE_WRITABLE; } |
| 436 bool receiving() const { return receiving_; } | 435 bool receiving() const { return receiving_; } |
| 437 | 436 |
| 438 // Determines whether the connection has finished connecting. This can only | 437 // Determines whether the connection has finished connecting. This can only |
| 439 // be false for TCP connections. | 438 // be false for TCP connections. |
| 440 bool connected() const { return connected_; } | 439 bool connected() const { return connected_; } |
| 441 bool weak() const { return !(writable() && receiving() && connected()); } | 440 bool weak() const { return !(writable() && receiving() && connected()); } |
| 442 bool active() const { | 441 bool active() const { |
| 443 // TODO(honghaiz): Move from using |write_state_| to using |pruned_|. | 442 // TODO(honghaiz): Move from using |write_state_| to using |pruned_|. |
| 444 return write_state_ != STATE_WRITE_TIMEOUT; | 443 return write_state_ != STATE_WRITE_TIMEOUT; |
| 445 } | 444 } |
| 446 // A connection is dead if it can be safely deleted. | 445 // A connection is dead if it can be safely deleted. |
| 447 bool dead(uint32 now) const; | 446 bool dead(uint32_t now) const; |
| 448 | 447 |
| 449 // Estimate of the round-trip time over this connection. | 448 // Estimate of the round-trip time over this connection. |
| 450 uint32 rtt() const { return rtt_; } | 449 uint32_t rtt() const { return rtt_; } |
| 451 | 450 |
| 452 size_t sent_total_bytes(); | 451 size_t sent_total_bytes(); |
| 453 size_t sent_bytes_second(); | 452 size_t sent_bytes_second(); |
| 454 // Used to track how many packets are discarded in the application socket due | 453 // Used to track how many packets are discarded in the application socket due |
| 455 // to errors. | 454 // to errors. |
| 456 size_t sent_discarded_packets(); | 455 size_t sent_discarded_packets(); |
| 457 size_t sent_total_packets(); | 456 size_t sent_total_packets(); |
| 458 size_t recv_total_bytes(); | 457 size_t recv_total_bytes(); |
| 459 size_t recv_bytes_second(); | 458 size_t recv_bytes_second(); |
| 460 sigslot::signal1<Connection*> SignalStateChange; | 459 sigslot::signal1<Connection*> SignalStateChange; |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 494 bool use_candidate_attr() const { return use_candidate_attr_; } | 493 bool use_candidate_attr() const { return use_candidate_attr_; } |
| 495 void set_use_candidate_attr(bool enable); | 494 void set_use_candidate_attr(bool enable); |
| 496 | 495 |
| 497 bool nominated() const { return nominated_; } | 496 bool nominated() const { return nominated_; } |
| 498 void set_nominated(bool nominated) { nominated_ = nominated; } | 497 void set_nominated(bool nominated) { nominated_ = nominated; } |
| 499 | 498 |
| 500 void set_remote_ice_mode(IceMode mode) { | 499 void set_remote_ice_mode(IceMode mode) { |
| 501 remote_ice_mode_ = mode; | 500 remote_ice_mode_ = mode; |
| 502 } | 501 } |
| 503 | 502 |
| 504 void set_receiving_timeout(uint32 receiving_timeout_ms) { | 503 void set_receiving_timeout(uint32_t receiving_timeout_ms) { |
| 505 receiving_timeout_ = receiving_timeout_ms; | 504 receiving_timeout_ = receiving_timeout_ms; |
| 506 } | 505 } |
| 507 | 506 |
| 508 // Makes the connection go away. | 507 // Makes the connection go away. |
| 509 void Destroy(); | 508 void Destroy(); |
| 510 | 509 |
| 511 // Checks that the state of this connection is up-to-date. The argument is | 510 // Checks that the state of this connection is up-to-date. The argument is |
| 512 // the current time, which is compared against various timeouts. | 511 // the current time, which is compared against various timeouts. |
| 513 void UpdateState(uint32 now); | 512 void UpdateState(uint32_t now); |
| 514 | 513 |
| 515 // Called when this connection should try checking writability again. | 514 // Called when this connection should try checking writability again. |
| 516 uint32 last_ping_sent() const { return last_ping_sent_; } | 515 uint32_t last_ping_sent() const { return last_ping_sent_; } |
| 517 void Ping(uint32 now); | 516 void Ping(uint32_t now); |
| 518 void ReceivedPingResponse(); | 517 void ReceivedPingResponse(); |
| 519 | 518 |
| 520 // Called whenever a valid ping is received on this connection. This is | 519 // Called whenever a valid ping is received on this connection. This is |
| 521 // public because the connection intercepts the first ping for us. | 520 // public because the connection intercepts the first ping for us. |
| 522 uint32 last_ping_received() const { return last_ping_received_; } | 521 uint32_t last_ping_received() const { return last_ping_received_; } |
| 523 void ReceivedPing(); | 522 void ReceivedPing(); |
| 524 | 523 |
| 525 // Debugging description of this connection | 524 // Debugging description of this connection |
| 526 std::string ToDebugId() const; | 525 std::string ToDebugId() const; |
| 527 std::string ToString() const; | 526 std::string ToString() const; |
| 528 std::string ToSensitiveString() const; | 527 std::string ToSensitiveString() const; |
| 529 // Prints pings_since_last_response_ into a string. | 528 // Prints pings_since_last_response_ into a string. |
| 530 void PrintPingsSinceLastResponse(std::string* pings, size_t max); | 529 void PrintPingsSinceLastResponse(std::string* pings, size_t max); |
| 531 | 530 |
| 532 bool reported() const { return reported_; } | 531 bool reported() const { return reported_; } |
| (...skipping 15 matching lines...) Expand all Loading... |
| 548 void MaybeSetRemoteIceCredentials(const std::string& ice_ufrag, | 547 void MaybeSetRemoteIceCredentials(const std::string& ice_ufrag, |
| 549 const std::string& ice_pwd); | 548 const std::string& ice_pwd); |
| 550 | 549 |
| 551 // If |remote_candidate_| is peer reflexive and is equivalent to | 550 // If |remote_candidate_| is peer reflexive and is equivalent to |
| 552 // |new_candidate| except the type, update |remote_candidate_| to | 551 // |new_candidate| except the type, update |remote_candidate_| to |
| 553 // |new_candidate|. | 552 // |new_candidate|. |
| 554 void MaybeUpdatePeerReflexiveCandidate(const Candidate& new_candidate); | 553 void MaybeUpdatePeerReflexiveCandidate(const Candidate& new_candidate); |
| 555 | 554 |
| 556 // Returns the last received time of any data, stun request, or stun | 555 // Returns the last received time of any data, stun request, or stun |
| 557 // response in milliseconds | 556 // response in milliseconds |
| 558 uint32 last_received(); | 557 uint32_t last_received(); |
| 559 | 558 |
| 560 protected: | 559 protected: |
| 561 enum { MSG_DELETE = 0, MSG_FIRST_AVAILABLE }; | 560 enum { MSG_DELETE = 0, MSG_FIRST_AVAILABLE }; |
| 562 | 561 |
| 563 // Constructs a new connection to the given remote port. | 562 // Constructs a new connection to the given remote port. |
| 564 Connection(Port* port, size_t index, const Candidate& candidate); | 563 Connection(Port* port, size_t index, const Candidate& candidate); |
| 565 | 564 |
| 566 // Called back when StunRequestManager has a stun packet to send | 565 // Called back when StunRequestManager has a stun packet to send |
| 567 void OnSendStunPacket(const void* data, size_t size, StunRequest* req); | 566 void OnSendStunPacket(const void* data, size_t size, StunRequest* req); |
| 568 | 567 |
| (...skipping 23 matching lines...) Expand all Loading... |
| 592 // By default |use_candidate_attr_| flag will be true, | 591 // By default |use_candidate_attr_| flag will be true, |
| 593 // as we will be using aggressive nomination. | 592 // as we will be using aggressive nomination. |
| 594 // But when peer is ice-lite, this flag "must" be initialized to false and | 593 // But when peer is ice-lite, this flag "must" be initialized to false and |
| 595 // turn on when connection becomes "best connection". | 594 // turn on when connection becomes "best connection". |
| 596 bool use_candidate_attr_; | 595 bool use_candidate_attr_; |
| 597 // Whether this connection has been nominated by the controlling side via | 596 // Whether this connection has been nominated by the controlling side via |
| 598 // the use_candidate attribute. | 597 // the use_candidate attribute. |
| 599 bool nominated_; | 598 bool nominated_; |
| 600 IceMode remote_ice_mode_; | 599 IceMode remote_ice_mode_; |
| 601 StunRequestManager requests_; | 600 StunRequestManager requests_; |
| 602 uint32 rtt_; | 601 uint32_t rtt_; |
| 603 uint32 last_ping_sent_; // last time we sent a ping to the other side | 602 uint32_t last_ping_sent_; // last time we sent a ping to the other side |
| 604 uint32 last_ping_received_; // last time we received a ping from the other | 603 uint32_t last_ping_received_; // last time we received a ping from the other |
| 605 // side | 604 // side |
| 606 uint32 last_data_received_; | 605 uint32_t last_data_received_; |
| 607 uint32 last_ping_response_received_; | 606 uint32_t last_ping_response_received_; |
| 608 std::vector<SentPing> pings_since_last_response_; | 607 std::vector<SentPing> pings_since_last_response_; |
| 609 | 608 |
| 610 rtc::RateTracker recv_rate_tracker_; | 609 rtc::RateTracker recv_rate_tracker_; |
| 611 rtc::RateTracker send_rate_tracker_; | 610 rtc::RateTracker send_rate_tracker_; |
| 612 uint32 sent_packets_discarded_; | 611 uint32_t sent_packets_discarded_; |
| 613 uint32 sent_packets_total_; | 612 uint32_t sent_packets_total_; |
| 614 | 613 |
| 615 private: | 614 private: |
| 616 void MaybeAddPrflxCandidate(ConnectionRequest* request, | 615 void MaybeAddPrflxCandidate(ConnectionRequest* request, |
| 617 StunMessage* response); | 616 StunMessage* response); |
| 618 | 617 |
| 619 bool reported_; | 618 bool reported_; |
| 620 State state_; | 619 State state_; |
| 621 // Time duration to switch from receiving to not receiving. | 620 // Time duration to switch from receiving to not receiving. |
| 622 uint32 receiving_timeout_; | 621 uint32_t receiving_timeout_; |
| 623 uint32 time_created_ms_; | 622 uint32_t time_created_ms_; |
| 624 | 623 |
| 625 friend class Port; | 624 friend class Port; |
| 626 friend class ConnectionRequest; | 625 friend class ConnectionRequest; |
| 627 }; | 626 }; |
| 628 | 627 |
| 629 // ProxyConnection defers all the interesting work to the port | 628 // ProxyConnection defers all the interesting work to the port |
| 630 class ProxyConnection : public Connection { | 629 class ProxyConnection : public Connection { |
| 631 public: | 630 public: |
| 632 ProxyConnection(Port* port, size_t index, const Candidate& candidate); | 631 ProxyConnection(Port* port, size_t index, const Candidate& candidate); |
| 633 | 632 |
| 634 virtual int Send(const void* data, size_t size, | 633 virtual int Send(const void* data, size_t size, |
| 635 const rtc::PacketOptions& options); | 634 const rtc::PacketOptions& options); |
| 636 virtual int GetError() { return error_; } | 635 virtual int GetError() { return error_; } |
| 637 | 636 |
| 638 private: | 637 private: |
| 639 int error_; | 638 int error_; |
| 640 }; | 639 }; |
| 641 | 640 |
| 642 } // namespace cricket | 641 } // namespace cricket |
| 643 | 642 |
| 644 #endif // WEBRTC_P2P_BASE_PORT_H_ | 643 #endif // WEBRTC_P2P_BASE_PORT_H_ |
| OLD | NEW |