| Index: webrtc/p2p/base/port.h
|
| diff --git a/webrtc/p2p/base/port.h b/webrtc/p2p/base/port.h
|
| index 8e7a2592d991661c59bc745e901d523c5b1dd9a8..fbda9cea0104a9078ede4af028dc4e55d9083848 100644
|
| --- a/webrtc/p2p/base/port.h
|
| +++ b/webrtc/p2p/base/port.h
|
| @@ -50,12 +50,8 @@
|
| extern const char TCPTYPE_PASSIVE_STR[];
|
| extern const char TCPTYPE_SIMOPEN_STR[];
|
|
|
| -// If a connection does not receive anything for this long, it is considered
|
| -// dead.
|
| -const uint32 DEAD_CONNECTION_RECEIVE_TIMEOUT = 30 * 1000; // 30 seconds.
|
| -
|
| -// The timeout duration when a connection does not receive anything.
|
| -const uint32 WEAK_CONNECTION_RECEIVE_TIMEOUT = 2500; // 2.5 seconds
|
| +// The length of time we wait before timing out readability on a connection.
|
| +const uint32 CONNECTION_READ_TIMEOUT = 30 * 1000; // 30 seconds
|
|
|
| // The length of time we wait before timing out writability on a connection.
|
| const uint32 CONNECTION_WRITE_TIMEOUT = 15 * 1000; // 15 seconds
|
| @@ -421,6 +417,15 @@
|
| // Returns the pair priority.
|
| uint64 priority() const;
|
|
|
| + enum ReadState {
|
| + STATE_READ_INIT = 0, // we have yet to receive a ping
|
| + STATE_READABLE = 1, // we have received pings recently
|
| + STATE_READ_TIMEOUT = 2, // we haven't received pings in a while
|
| + };
|
| +
|
| + ReadState read_state() const { return read_state_; }
|
| + bool readable() const { return read_state_ == STATE_READABLE; }
|
| +
|
| enum WriteState {
|
| STATE_WRITABLE = 0, // we have received ping responses recently
|
| STATE_WRITE_UNRELIABLE = 1, // we have had a few ping failures
|
| @@ -430,7 +435,6 @@
|
|
|
| WriteState write_state() const { return write_state_; }
|
| bool writable() const { return write_state_ == STATE_WRITABLE; }
|
| - bool receiving() const { return receiving_; }
|
|
|
| // Determines whether the connection has finished connecting. This can only
|
| // be false for TCP connections.
|
| @@ -462,8 +466,8 @@
|
| // Error if Send() returns < 0
|
| virtual int GetError() = 0;
|
|
|
| - sigslot::signal4<Connection*, const char*, size_t, const rtc::PacketTime&>
|
| - SignalReadPacket;
|
| + sigslot::signal4<Connection*, const char*, size_t,
|
| + const rtc::PacketTime&> SignalReadPacket;
|
|
|
| sigslot::signal1<Connection*> SignalReadyToSend;
|
|
|
| @@ -489,10 +493,6 @@
|
|
|
| void set_remote_ice_mode(IceMode mode) {
|
| remote_ice_mode_ = mode;
|
| - }
|
| -
|
| - void set_receiving_timeout(uint32 receiving_timeout_ms) {
|
| - receiving_timeout_ = receiving_timeout_ms;
|
| }
|
|
|
| // Makes the connection go away.
|
| @@ -565,8 +565,8 @@
|
| void OnConnectionRequestSent(ConnectionRequest* req);
|
|
|
| // Changes the state and signals if necessary.
|
| + void set_read_state(ReadState value);
|
| void set_write_state(WriteState value);
|
| - void set_receiving(bool value);
|
| void set_state(State state);
|
| void set_connected(bool value);
|
|
|
| @@ -578,8 +578,8 @@
|
| Port* port_;
|
| size_t local_candidate_index_;
|
| Candidate remote_candidate_;
|
| + ReadState read_state_;
|
| WriteState write_state_;
|
| - bool receiving_;
|
| bool connected_;
|
| bool pruned_;
|
| // By default |use_candidate_attr_| flag will be true,
|
| @@ -611,8 +611,6 @@
|
|
|
| bool reported_;
|
| State state_;
|
| - // Time duration to switch from receiving to not receiving.
|
| - uint32 receiving_timeout_;
|
|
|
| friend class Port;
|
| friend class ConnectionRequest;
|
|
|