| Index: webrtc/p2p/base/pseudotcp.cc
|
| diff --git a/webrtc/p2p/base/pseudotcp.cc b/webrtc/p2p/base/pseudotcp.cc
|
| index a54127bbb4fff4bc68e0a8be4114ad6426488d01..5f035ca65233b60ab51332f512366cfaf2a5107f 100644
|
| --- a/webrtc/p2p/base/pseudotcp.cc
|
| +++ b/webrtc/p2p/base/pseudotcp.cc
|
| @@ -39,40 +39,40 @@ namespace cricket {
|
| //////////////////////////////////////////////////////////////////////
|
|
|
| // Standard MTUs
|
| -const uint16 PACKET_MAXIMUMS[] = {
|
| - 65535, // Theoretical maximum, Hyperchannel
|
| - 32000, // Nothing
|
| - 17914, // 16Mb IBM Token Ring
|
| - 8166, // IEEE 802.4
|
| - //4464, // IEEE 802.5 (4Mb max)
|
| - 4352, // FDDI
|
| - //2048, // Wideband Network
|
| - 2002, // IEEE 802.5 (4Mb recommended)
|
| - //1536, // Expermental Ethernet Networks
|
| - //1500, // Ethernet, Point-to-Point (default)
|
| - 1492, // IEEE 802.3
|
| - 1006, // SLIP, ARPANET
|
| - //576, // X.25 Networks
|
| - //544, // DEC IP Portal
|
| - //512, // NETBIOS
|
| - 508, // IEEE 802/Source-Rt Bridge, ARCNET
|
| - 296, // Point-to-Point (low delay)
|
| - //68, // Official minimum
|
| - 0, // End of list marker
|
| +const uint16_t PACKET_MAXIMUMS[] = {
|
| + 65535, // Theoretical maximum, Hyperchannel
|
| + 32000, // Nothing
|
| + 17914, // 16Mb IBM Token Ring
|
| + 8166, // IEEE 802.4
|
| + // 4464, // IEEE 802.5 (4Mb max)
|
| + 4352, // FDDI
|
| + // 2048, // Wideband Network
|
| + 2002, // IEEE 802.5 (4Mb recommended)
|
| + // 1536, // Expermental Ethernet Networks
|
| + // 1500, // Ethernet, Point-to-Point (default)
|
| + 1492, // IEEE 802.3
|
| + 1006, // SLIP, ARPANET
|
| + // 576, // X.25 Networks
|
| + // 544, // DEC IP Portal
|
| + // 512, // NETBIOS
|
| + 508, // IEEE 802/Source-Rt Bridge, ARCNET
|
| + 296, // Point-to-Point (low delay)
|
| + // 68, // Official minimum
|
| + 0, // End of list marker
|
| };
|
|
|
| -const uint32 MAX_PACKET = 65535;
|
| +const uint32_t MAX_PACKET = 65535;
|
| // Note: we removed lowest level because packet overhead was larger!
|
| -const uint32 MIN_PACKET = 296;
|
| +const uint32_t MIN_PACKET = 296;
|
|
|
| -const uint32 IP_HEADER_SIZE = 20; // (+ up to 40 bytes of options?)
|
| -const uint32 UDP_HEADER_SIZE = 8;
|
| +const uint32_t IP_HEADER_SIZE = 20; // (+ up to 40 bytes of options?)
|
| +const uint32_t UDP_HEADER_SIZE = 8;
|
| // TODO: Make JINGLE_HEADER_SIZE transparent to this code?
|
| -const uint32 JINGLE_HEADER_SIZE = 64; // when relay framing is in use
|
| +const uint32_t JINGLE_HEADER_SIZE = 64; // when relay framing is in use
|
|
|
| // Default size for receive and send buffer.
|
| -const uint32 DEFAULT_RCV_BUF_SIZE = 60 * 1024;
|
| -const uint32 DEFAULT_SND_BUF_SIZE = 90 * 1024;
|
| +const uint32_t DEFAULT_RCV_BUF_SIZE = 60 * 1024;
|
| +const uint32_t DEFAULT_SND_BUF_SIZE = 90 * 1024;
|
|
|
| //////////////////////////////////////////////////////////////////////
|
| // Global Constants and Functions
|
| @@ -102,55 +102,59 @@ const uint32 DEFAULT_SND_BUF_SIZE = 90 * 1024;
|
|
|
| #define PSEUDO_KEEPALIVE 0
|
|
|
| -const uint32 HEADER_SIZE = 24;
|
| -const uint32 PACKET_OVERHEAD = HEADER_SIZE + UDP_HEADER_SIZE + IP_HEADER_SIZE + JINGLE_HEADER_SIZE;
|
| +const uint32_t HEADER_SIZE = 24;
|
| +const uint32_t PACKET_OVERHEAD =
|
| + HEADER_SIZE + UDP_HEADER_SIZE + IP_HEADER_SIZE + JINGLE_HEADER_SIZE;
|
|
|
| -const uint32 MIN_RTO = 250; // 250 ms (RFC1122, Sec 4.2.3.1 "fractions of a second")
|
| -const uint32 DEF_RTO = 3000; // 3 seconds (RFC1122, Sec 4.2.3.1)
|
| -const uint32 MAX_RTO = 60000; // 60 seconds
|
| -const uint32 DEF_ACK_DELAY = 100; // 100 milliseconds
|
| +const uint32_t MIN_RTO =
|
| + 250; // 250 ms (RFC1122, Sec 4.2.3.1 "fractions of a second")
|
| +const uint32_t DEF_RTO = 3000; // 3 seconds (RFC1122, Sec 4.2.3.1)
|
| +const uint32_t MAX_RTO = 60000; // 60 seconds
|
| +const uint32_t DEF_ACK_DELAY = 100; // 100 milliseconds
|
|
|
| -const uint8 FLAG_CTL = 0x02;
|
| -const uint8 FLAG_RST = 0x04;
|
| +const uint8_t FLAG_CTL = 0x02;
|
| +const uint8_t FLAG_RST = 0x04;
|
|
|
| -const uint8 CTL_CONNECT = 0;
|
| +const uint8_t CTL_CONNECT = 0;
|
|
|
| // TCP options.
|
| -const uint8 TCP_OPT_EOL = 0; // End of list.
|
| -const uint8 TCP_OPT_NOOP = 1; // No-op.
|
| -const uint8 TCP_OPT_MSS = 2; // Maximum segment size.
|
| -const uint8 TCP_OPT_WND_SCALE = 3; // Window scale factor.
|
| +const uint8_t TCP_OPT_EOL = 0; // End of list.
|
| +const uint8_t TCP_OPT_NOOP = 1; // No-op.
|
| +const uint8_t TCP_OPT_MSS = 2; // Maximum segment size.
|
| +const uint8_t TCP_OPT_WND_SCALE = 3; // Window scale factor.
|
|
|
| const long DEFAULT_TIMEOUT = 4000; // If there are no pending clocks, wake up every 4 seconds
|
| const long CLOSED_TIMEOUT = 60 * 1000; // If the connection is closed, once per minute
|
|
|
| #if PSEUDO_KEEPALIVE
|
| // !?! Rethink these times
|
| -const uint32 IDLE_PING = 20 * 1000; // 20 seconds (note: WinXP SP2 firewall udp timeout is 90 seconds)
|
| -const uint32 IDLE_TIMEOUT = 90 * 1000; // 90 seconds;
|
| +const uint32_t IDLE_PING =
|
| + 20 *
|
| + 1000; // 20 seconds (note: WinXP SP2 firewall udp timeout is 90 seconds)
|
| +const uint32_t IDLE_TIMEOUT = 90 * 1000; // 90 seconds;
|
| #endif // PSEUDO_KEEPALIVE
|
|
|
| //////////////////////////////////////////////////////////////////////
|
| // Helper Functions
|
| //////////////////////////////////////////////////////////////////////
|
|
|
| -inline void long_to_bytes(uint32 val, void* buf) {
|
| - *static_cast<uint32*>(buf) = rtc::HostToNetwork32(val);
|
| +inline void long_to_bytes(uint32_t val, void* buf) {
|
| + *static_cast<uint32_t*>(buf) = rtc::HostToNetwork32(val);
|
| }
|
|
|
| -inline void short_to_bytes(uint16 val, void* buf) {
|
| - *static_cast<uint16*>(buf) = rtc::HostToNetwork16(val);
|
| +inline void short_to_bytes(uint16_t val, void* buf) {
|
| + *static_cast<uint16_t*>(buf) = rtc::HostToNetwork16(val);
|
| }
|
|
|
| -inline uint32 bytes_to_long(const void* buf) {
|
| - return rtc::NetworkToHost32(*static_cast<const uint32*>(buf));
|
| +inline uint32_t bytes_to_long(const void* buf) {
|
| + return rtc::NetworkToHost32(*static_cast<const uint32_t*>(buf));
|
| }
|
|
|
| -inline uint16 bytes_to_short(const void* buf) {
|
| - return rtc::NetworkToHost16(*static_cast<const uint16*>(buf));
|
| +inline uint16_t bytes_to_short(const void* buf) {
|
| + return rtc::NetworkToHost16(*static_cast<const uint16_t*>(buf));
|
| }
|
|
|
| -uint32 bound(uint32 lower, uint32 middle, uint32 upper) {
|
| +uint32_t bound(uint32_t lower, uint32_t middle, uint32_t upper) {
|
| return std::min(std::max(lower, middle), upper);
|
| }
|
|
|
| @@ -196,7 +200,7 @@ void ReportStats() {
|
| // PseudoTcp
|
| //////////////////////////////////////////////////////////////////////
|
|
|
| -uint32 PseudoTcp::Now() {
|
| +uint32_t PseudoTcp::Now() {
|
| #if 0 // Use this to synchronize timers with logging timestamps (easier debug)
|
| return rtc::TimeSince(StartTime());
|
| #else
|
| @@ -204,7 +208,7 @@ uint32 PseudoTcp::Now() {
|
| #endif
|
| }
|
|
|
| -PseudoTcp::PseudoTcp(IPseudoTcpNotify* notify, uint32 conv)
|
| +PseudoTcp::PseudoTcp(IPseudoTcpNotify* notify, uint32_t conv)
|
| : m_notify(notify),
|
| m_shutdown(SD_NONE),
|
| m_error(0),
|
| @@ -212,11 +216,10 @@ PseudoTcp::PseudoTcp(IPseudoTcpNotify* notify, uint32 conv)
|
| m_rbuf(m_rbuf_len),
|
| m_sbuf_len(DEFAULT_SND_BUF_SIZE),
|
| m_sbuf(m_sbuf_len) {
|
| -
|
| // Sanity check on buffer sizes (needed for OnTcpWriteable notification logic)
|
| ASSERT(m_rbuf_len + MIN_PACKET < m_sbuf_len);
|
|
|
| - uint32 now = Now();
|
| + uint32_t now = Now();
|
|
|
| m_state = TCP_LISTEN;
|
| m_conv = conv;
|
| @@ -273,14 +276,14 @@ int PseudoTcp::Connect() {
|
| return 0;
|
| }
|
|
|
| -void PseudoTcp::NotifyMTU(uint16 mtu) {
|
| +void PseudoTcp::NotifyMTU(uint16_t mtu) {
|
| m_mtu_advise = mtu;
|
| if (m_state == TCP_ESTABLISHED) {
|
| adjustMTU();
|
| }
|
| }
|
|
|
| -void PseudoTcp::NotifyClock(uint32 now) {
|
| +void PseudoTcp::NotifyClock(uint32_t now) {
|
| if (m_state == TCP_CLOSED)
|
| return;
|
|
|
| @@ -303,13 +306,13 @@ void PseudoTcp::NotifyClock(uint32 now) {
|
| return;
|
| }
|
|
|
| - uint32 nInFlight = m_snd_nxt - m_snd_una;
|
| + uint32_t nInFlight = m_snd_nxt - m_snd_una;
|
| m_ssthresh = std::max(nInFlight / 2, 2 * m_mss);
|
| //LOG(LS_INFO) << "m_ssthresh: " << m_ssthresh << " nInFlight: " << nInFlight << " m_mss: " << m_mss;
|
| m_cwnd = m_mss;
|
|
|
| // Back off retransmit timer. Note: the limit is lower when connecting.
|
| - uint32 rto_limit = (m_state < TCP_ESTABLISHED) ? DEF_RTO : MAX_RTO;
|
| + uint32_t rto_limit = (m_state < TCP_ESTABLISHED) ? DEF_RTO : MAX_RTO;
|
| m_rx_rto = std::min(rto_limit, m_rx_rto * 2);
|
| m_rto_base = now;
|
| }
|
| @@ -355,10 +358,10 @@ bool PseudoTcp::NotifyPacket(const char* buffer, size_t len) {
|
| LOG_F(WARNING) << "packet too large";
|
| return false;
|
| }
|
| - return parse(reinterpret_cast<const uint8 *>(buffer), uint32(len));
|
| + return parse(reinterpret_cast<const uint8_t*>(buffer), uint32_t(len));
|
| }
|
|
|
| -bool PseudoTcp::GetNextClock(uint32 now, long& timeout) {
|
| +bool PseudoTcp::GetNextClock(uint32_t now, long& timeout) {
|
| return clock_check(now, timeout);
|
| }
|
|
|
| @@ -391,21 +394,21 @@ void PseudoTcp::SetOption(Option opt, int value) {
|
| }
|
| }
|
|
|
| -uint32 PseudoTcp::GetCongestionWindow() const {
|
| +uint32_t PseudoTcp::GetCongestionWindow() const {
|
| return m_cwnd;
|
| }
|
|
|
| -uint32 PseudoTcp::GetBytesInFlight() const {
|
| +uint32_t PseudoTcp::GetBytesInFlight() const {
|
| return m_snd_nxt - m_snd_una;
|
| }
|
|
|
| -uint32 PseudoTcp::GetBytesBufferedNotSent() const {
|
| +uint32_t PseudoTcp::GetBytesBufferedNotSent() const {
|
| size_t buffered_bytes = 0;
|
| m_sbuf.GetBuffered(&buffered_bytes);
|
| - return static_cast<uint32>(m_snd_una + buffered_bytes - m_snd_nxt);
|
| + return static_cast<uint32_t>(m_snd_una + buffered_bytes - m_snd_nxt);
|
| }
|
|
|
| -uint32 PseudoTcp::GetRoundTripTimeEstimateMs() const {
|
| +uint32_t PseudoTcp::GetRoundTripTimeEstimateMs() const {
|
| return m_rx_srtt;
|
| }
|
|
|
| @@ -433,11 +436,11 @@ int PseudoTcp::Recv(char* buffer, size_t len) {
|
| size_t available_space = 0;
|
| m_rbuf.GetWriteRemaining(&available_space);
|
|
|
| - if (uint32(available_space) - m_rcv_wnd >=
|
| - std::min<uint32>(m_rbuf_len / 2, m_mss)) {
|
| + if (uint32_t(available_space) - m_rcv_wnd >=
|
| + std::min<uint32_t>(m_rbuf_len / 2, m_mss)) {
|
| // TODO(jbeda): !?! Not sure about this was closed business
|
| bool bWasClosed = (m_rcv_wnd == 0);
|
| - m_rcv_wnd = static_cast<uint32>(available_space);
|
| + m_rcv_wnd = static_cast<uint32_t>(available_space);
|
|
|
| if (bWasClosed) {
|
| attemptSend(sfImmediateAck);
|
| @@ -462,7 +465,7 @@ int PseudoTcp::Send(const char* buffer, size_t len) {
|
| return SOCKET_ERROR;
|
| }
|
|
|
| - int written = queue(buffer, uint32(len), false);
|
| + int written = queue(buffer, uint32_t(len), false);
|
| attemptSend();
|
| return written;
|
| }
|
| @@ -480,13 +483,13 @@ int PseudoTcp::GetError() {
|
| // Internal Implementation
|
| //
|
|
|
| -uint32 PseudoTcp::queue(const char* data, uint32 len, bool bCtrl) {
|
| +uint32_t PseudoTcp::queue(const char* data, uint32_t len, bool bCtrl) {
|
| size_t available_space = 0;
|
| m_sbuf.GetWriteRemaining(&available_space);
|
|
|
| - if (len > static_cast<uint32>(available_space)) {
|
| + if (len > static_cast<uint32_t>(available_space)) {
|
| ASSERT(!bCtrl);
|
| - len = static_cast<uint32>(available_space);
|
| + len = static_cast<uint32_t>(available_space);
|
| }
|
|
|
| // We can concatenate data if the last segment is the same type
|
| @@ -497,29 +500,31 @@ uint32 PseudoTcp::queue(const char* data, uint32 len, bool bCtrl) {
|
| } else {
|
| size_t snd_buffered = 0;
|
| m_sbuf.GetBuffered(&snd_buffered);
|
| - SSegment sseg(static_cast<uint32>(m_snd_una + snd_buffered), len, bCtrl);
|
| + SSegment sseg(static_cast<uint32_t>(m_snd_una + snd_buffered), len, bCtrl);
|
| m_slist.push_back(sseg);
|
| }
|
|
|
| size_t written = 0;
|
| m_sbuf.Write(data, len, &written, NULL);
|
| - return static_cast<uint32>(written);
|
| + return static_cast<uint32_t>(written);
|
| }
|
|
|
| -IPseudoTcpNotify::WriteResult PseudoTcp::packet(uint32 seq, uint8 flags,
|
| - uint32 offset, uint32 len) {
|
| +IPseudoTcpNotify::WriteResult PseudoTcp::packet(uint32_t seq,
|
| + uint8_t flags,
|
| + uint32_t offset,
|
| + uint32_t len) {
|
| ASSERT(HEADER_SIZE + len <= MAX_PACKET);
|
|
|
| - uint32 now = Now();
|
| + uint32_t now = Now();
|
|
|
| - rtc::scoped_ptr<uint8[]> buffer(new uint8[MAX_PACKET]);
|
| + rtc::scoped_ptr<uint8_t[]> buffer(new uint8_t[MAX_PACKET]);
|
| long_to_bytes(m_conv, buffer.get());
|
| long_to_bytes(seq, buffer.get() + 4);
|
| long_to_bytes(m_rcv_nxt, buffer.get() + 8);
|
| buffer[12] = 0;
|
| buffer[13] = flags;
|
| - short_to_bytes(
|
| - static_cast<uint16>(m_rcv_wnd >> m_rwnd_scale), buffer.get() + 14);
|
| + short_to_bytes(static_cast<uint16_t>(m_rcv_wnd >> m_rwnd_scale),
|
| + buffer.get() + 14);
|
|
|
| // Timestamp computations
|
| long_to_bytes(now, buffer.get() + 16);
|
| @@ -532,7 +537,7 @@ IPseudoTcpNotify::WriteResult PseudoTcp::packet(uint32 seq, uint8 flags,
|
| buffer.get() + HEADER_SIZE, len, offset, &bytes_read);
|
| RTC_UNUSED(result);
|
| ASSERT(result == rtc::SR_SUCCESS);
|
| - ASSERT(static_cast<uint32>(bytes_read) == len);
|
| + ASSERT(static_cast<uint32_t>(bytes_read) == len);
|
| }
|
|
|
| #if _DEBUGMSG >= _DBG_VERBOSE
|
| @@ -564,7 +569,7 @@ IPseudoTcpNotify::WriteResult PseudoTcp::packet(uint32 seq, uint8 flags,
|
| return IPseudoTcpNotify::WR_SUCCESS;
|
| }
|
|
|
| -bool PseudoTcp::parse(const uint8* buffer, uint32 size) {
|
| +bool PseudoTcp::parse(const uint8_t* buffer, uint32_t size) {
|
| if (size < 12)
|
| return false;
|
|
|
| @@ -595,7 +600,7 @@ bool PseudoTcp::parse(const uint8* buffer, uint32 size) {
|
| return process(seg);
|
| }
|
|
|
| -bool PseudoTcp::clock_check(uint32 now, long& nTimeout) {
|
| +bool PseudoTcp::clock_check(uint32_t now, long& nTimeout) {
|
| if (m_shutdown == SD_FORCEFUL)
|
| return false;
|
|
|
| @@ -616,19 +621,19 @@ bool PseudoTcp::clock_check(uint32 now, long& nTimeout) {
|
|
|
| if (m_t_ack) {
|
| nTimeout =
|
| - std::min<int32>(nTimeout, rtc::TimeDiff(m_t_ack + m_ack_delay, now));
|
| + std::min<int32_t>(nTimeout, rtc::TimeDiff(m_t_ack + m_ack_delay, now));
|
| }
|
| if (m_rto_base) {
|
| nTimeout =
|
| - std::min<int32>(nTimeout, rtc::TimeDiff(m_rto_base + m_rx_rto, now));
|
| + std::min<int32_t>(nTimeout, rtc::TimeDiff(m_rto_base + m_rx_rto, now));
|
| }
|
| if (m_snd_wnd == 0) {
|
| nTimeout =
|
| - std::min<int32>(nTimeout, rtc::TimeDiff(m_lastsend + m_rx_rto, now));
|
| + std::min<int32_t>(nTimeout, rtc::TimeDiff(m_lastsend + m_rx_rto, now));
|
| }
|
| #if PSEUDO_KEEPALIVE
|
| if (m_state == TCP_ESTABLISHED) {
|
| - nTimeout = std::min<int32>(
|
| + nTimeout = std::min<int32_t>(
|
| nTimeout, rtc::TimeDiff(m_lasttraffic + (m_bOutgoing ? IDLE_PING * 3 / 2
|
| : IDLE_PING),
|
| now));
|
| @@ -647,7 +652,7 @@ bool PseudoTcp::process(Segment& seg) {
|
| return false;
|
| }
|
|
|
| - uint32 now = Now();
|
| + uint32_t now = Now();
|
| m_lasttraffic = m_lastrecv = now;
|
| m_bOutgoing = false;
|
|
|
| @@ -704,20 +709,22 @@ bool PseudoTcp::process(Segment& seg) {
|
| if ((seg.ack > m_snd_una) && (seg.ack <= m_snd_nxt)) {
|
| // Calculate round-trip time
|
| if (seg.tsecr) {
|
| - int32 rtt = rtc::TimeDiff(now, seg.tsecr);
|
| + int32_t rtt = rtc::TimeDiff(now, seg.tsecr);
|
| if (rtt >= 0) {
|
| if (m_rx_srtt == 0) {
|
| m_rx_srtt = rtt;
|
| m_rx_rttvar = rtt / 2;
|
| } else {
|
| - uint32 unsigned_rtt = static_cast<uint32>(rtt);
|
| - uint32 abs_err = unsigned_rtt > m_rx_srtt ? unsigned_rtt - m_rx_srtt
|
| - : m_rx_srtt - unsigned_rtt;
|
| + uint32_t unsigned_rtt = static_cast<uint32_t>(rtt);
|
| + uint32_t abs_err = unsigned_rtt > m_rx_srtt
|
| + ? unsigned_rtt - m_rx_srtt
|
| + : m_rx_srtt - unsigned_rtt;
|
| m_rx_rttvar = (3 * m_rx_rttvar + abs_err) / 4;
|
| m_rx_srtt = (7 * m_rx_srtt + rtt) / 8;
|
| }
|
| - m_rx_rto = bound(
|
| - MIN_RTO, m_rx_srtt + std::max<uint32>(1, 4 * m_rx_rttvar), MAX_RTO);
|
| + m_rx_rto =
|
| + bound(MIN_RTO, m_rx_srtt + std::max<uint32_t>(1, 4 * m_rx_rttvar),
|
| + MAX_RTO);
|
| #if _DEBUGMSG >= _DBG_VERBOSE
|
| LOG(LS_INFO) << "rtt: " << rtt
|
| << " srtt: " << m_rx_srtt
|
| @@ -728,16 +735,16 @@ bool PseudoTcp::process(Segment& seg) {
|
| }
|
| }
|
|
|
| - m_snd_wnd = static_cast<uint32>(seg.wnd) << m_swnd_scale;
|
| + m_snd_wnd = static_cast<uint32_t>(seg.wnd) << m_swnd_scale;
|
|
|
| - uint32 nAcked = seg.ack - m_snd_una;
|
| + uint32_t nAcked = seg.ack - m_snd_una;
|
| m_snd_una = seg.ack;
|
|
|
| m_rto_base = (m_snd_una == m_snd_nxt) ? 0 : now;
|
|
|
| m_sbuf.ConsumeReadData(nAcked);
|
|
|
| - for (uint32 nFree = nAcked; nFree > 0; ) {
|
| + for (uint32_t nFree = nAcked; nFree > 0;) {
|
| ASSERT(!m_slist.empty());
|
| if (nFree < m_slist.front().len) {
|
| m_slist.front().len -= nFree;
|
| @@ -753,7 +760,7 @@ bool PseudoTcp::process(Segment& seg) {
|
|
|
| if (m_dup_acks >= 3) {
|
| if (m_snd_una >= m_recover) { // NewReno
|
| - uint32 nInFlight = m_snd_nxt - m_snd_una;
|
| + uint32_t nInFlight = m_snd_nxt - m_snd_una;
|
| m_cwnd = std::min(m_ssthresh, nInFlight + m_mss); // (Fast Retransmit)
|
| #if _DEBUGMSG >= _DBG_NORMAL
|
| LOG(LS_INFO) << "exit recovery";
|
| @@ -775,12 +782,12 @@ bool PseudoTcp::process(Segment& seg) {
|
| if (m_cwnd < m_ssthresh) {
|
| m_cwnd += m_mss;
|
| } else {
|
| - m_cwnd += std::max<uint32>(1, m_mss * m_mss / m_cwnd);
|
| + m_cwnd += std::max<uint32_t>(1, m_mss * m_mss / m_cwnd);
|
| }
|
| }
|
| } else if (seg.ack == m_snd_una) {
|
| // !?! Note, tcp says don't do this... but otherwise how does a closed window become open?
|
| - m_snd_wnd = static_cast<uint32>(seg.wnd) << m_swnd_scale;
|
| + m_snd_wnd = static_cast<uint32_t>(seg.wnd) << m_swnd_scale;
|
|
|
| // Check duplicate acks
|
| if (seg.len > 0) {
|
| @@ -797,7 +804,7 @@ bool PseudoTcp::process(Segment& seg) {
|
| return false;
|
| }
|
| m_recover = m_snd_nxt;
|
| - uint32 nInFlight = m_snd_nxt - m_snd_una;
|
| + uint32_t nInFlight = m_snd_nxt - m_snd_una;
|
| m_ssthresh = std::max(nInFlight / 2, 2 * m_mss);
|
| //LOG(LS_INFO) << "m_ssthresh: " << m_ssthresh << " nInFlight: " << nInFlight << " m_mss: " << m_mss;
|
| m_cwnd = m_ssthresh + 3 * m_mss;
|
| @@ -823,10 +830,11 @@ bool PseudoTcp::process(Segment& seg) {
|
| // If we make room in the send queue, notify the user
|
| // The goal it to make sure we always have at least enough data to fill the
|
| // window. We'd like to notify the app when we are halfway to that point.
|
| - const uint32 kIdealRefillSize = (m_sbuf_len + m_rbuf_len) / 2;
|
| + const uint32_t kIdealRefillSize = (m_sbuf_len + m_rbuf_len) / 2;
|
| size_t snd_buffered = 0;
|
| m_sbuf.GetBuffered(&snd_buffered);
|
| - if (m_bWriteEnable && static_cast<uint32>(snd_buffered) < kIdealRefillSize) {
|
| + if (m_bWriteEnable &&
|
| + static_cast<uint32_t>(snd_buffered) < kIdealRefillSize) {
|
| m_bWriteEnable = false;
|
| if (m_notify) {
|
| m_notify->OnTcpWriteable(this);
|
| @@ -862,7 +870,7 @@ bool PseudoTcp::process(Segment& seg) {
|
|
|
| // Adjust the incoming segment to fit our receive buffer
|
| if (seg.seq < m_rcv_nxt) {
|
| - uint32 nAdjust = m_rcv_nxt - seg.seq;
|
| + uint32_t nAdjust = m_rcv_nxt - seg.seq;
|
| if (nAdjust < seg.len) {
|
| seg.seq += nAdjust;
|
| seg.data += nAdjust;
|
| @@ -875,8 +883,10 @@ bool PseudoTcp::process(Segment& seg) {
|
| size_t available_space = 0;
|
| m_rbuf.GetWriteRemaining(&available_space);
|
|
|
| - if ((seg.seq + seg.len - m_rcv_nxt) > static_cast<uint32>(available_space)) {
|
| - uint32 nAdjust = seg.seq + seg.len - m_rcv_nxt - static_cast<uint32>(available_space);
|
| + if ((seg.seq + seg.len - m_rcv_nxt) >
|
| + static_cast<uint32_t>(available_space)) {
|
| + uint32_t nAdjust =
|
| + seg.seq + seg.len - m_rcv_nxt - static_cast<uint32_t>(available_space);
|
| if (nAdjust < seg.len) {
|
| seg.len -= nAdjust;
|
| } else {
|
| @@ -893,7 +903,7 @@ bool PseudoTcp::process(Segment& seg) {
|
| m_rcv_nxt += seg.len;
|
| }
|
| } else {
|
| - uint32 nOffset = seg.seq - m_rcv_nxt;
|
| + uint32_t nOffset = seg.seq - m_rcv_nxt;
|
|
|
| rtc::StreamResult result = m_rbuf.WriteOffset(seg.data, seg.len,
|
| nOffset, NULL);
|
| @@ -910,7 +920,7 @@ bool PseudoTcp::process(Segment& seg) {
|
| while ((it != m_rlist.end()) && (it->seq <= m_rcv_nxt)) {
|
| if (it->seq + it->len > m_rcv_nxt) {
|
| sflags = sfImmediateAck; // (Fast Recovery)
|
| - uint32 nAdjust = (it->seq + it->len) - m_rcv_nxt;
|
| + uint32_t nAdjust = (it->seq + it->len) - m_rcv_nxt;
|
| #if _DEBUGMSG >= _DBG_NORMAL
|
| LOG(LS_INFO) << "Recovered " << nAdjust << " bytes (" << m_rcv_nxt << " -> " << m_rcv_nxt + nAdjust << ")";
|
| #endif // _DEBUGMSG
|
| @@ -950,17 +960,17 @@ bool PseudoTcp::process(Segment& seg) {
|
| return true;
|
| }
|
|
|
| -bool PseudoTcp::transmit(const SList::iterator& seg, uint32 now) {
|
| +bool PseudoTcp::transmit(const SList::iterator& seg, uint32_t now) {
|
| if (seg->xmit >= ((m_state == TCP_ESTABLISHED) ? 15 : 30)) {
|
| LOG_F(LS_VERBOSE) << "too many retransmits";
|
| return false;
|
| }
|
|
|
| - uint32 nTransmit = std::min(seg->len, m_mss);
|
| + uint32_t nTransmit = std::min(seg->len, m_mss);
|
|
|
| while (true) {
|
| - uint32 seq = seg->seq;
|
| - uint8 flags = (seg->bCtrl ? FLAG_CTL : 0);
|
| + uint32_t seq = seg->seq;
|
| + uint8_t flags = (seg->bCtrl ? FLAG_CTL : 0);
|
| IPseudoTcpNotify::WriteResult wres = packet(seq,
|
| flags,
|
| seg->seq - m_snd_una,
|
| @@ -1020,7 +1030,7 @@ bool PseudoTcp::transmit(const SList::iterator& seg, uint32 now) {
|
| }
|
|
|
| void PseudoTcp::attemptSend(SendFlags sflags) {
|
| - uint32 now = Now();
|
| + uint32_t now = Now();
|
|
|
| if (rtc::TimeDiff(now, m_lastsend) > static_cast<long>(m_rx_rto)) {
|
| m_cwnd = m_mss;
|
| @@ -1032,18 +1042,18 @@ void PseudoTcp::attemptSend(SendFlags sflags) {
|
| #endif // _DEBUGMSG
|
|
|
| while (true) {
|
| - uint32 cwnd = m_cwnd;
|
| + uint32_t cwnd = m_cwnd;
|
| if ((m_dup_acks == 1) || (m_dup_acks == 2)) { // Limited Transmit
|
| cwnd += m_dup_acks * m_mss;
|
| }
|
| - uint32 nWindow = std::min(m_snd_wnd, cwnd);
|
| - uint32 nInFlight = m_snd_nxt - m_snd_una;
|
| - uint32 nUseable = (nInFlight < nWindow) ? (nWindow - nInFlight) : 0;
|
| + uint32_t nWindow = std::min(m_snd_wnd, cwnd);
|
| + uint32_t nInFlight = m_snd_nxt - m_snd_una;
|
| + uint32_t nUseable = (nInFlight < nWindow) ? (nWindow - nInFlight) : 0;
|
|
|
| size_t snd_buffered = 0;
|
| m_sbuf.GetBuffered(&snd_buffered);
|
| - uint32 nAvailable =
|
| - std::min(static_cast<uint32>(snd_buffered) - nInFlight, m_mss);
|
| + uint32_t nAvailable =
|
| + std::min(static_cast<uint32_t>(snd_buffered) - nInFlight, m_mss);
|
|
|
| if (nAvailable > nUseable) {
|
| if (nUseable * 4 < nWindow) {
|
| @@ -1116,8 +1126,7 @@ void PseudoTcp::attemptSend(SendFlags sflags) {
|
| }
|
| }
|
|
|
| -void
|
| -PseudoTcp::closedown(uint32 err) {
|
| +void PseudoTcp::closedown(uint32_t err) {
|
| LOG(LS_INFO) << "State: TCP_CLOSED";
|
| m_state = TCP_CLOSED;
|
| if (m_notify) {
|
| @@ -1130,7 +1139,7 @@ void
|
| PseudoTcp::adjustMTU() {
|
| // Determine our current mss level, so that we can adjust appropriately later
|
| for (m_msslevel = 0; PACKET_MAXIMUMS[m_msslevel + 1] > 0; ++m_msslevel) {
|
| - if (static_cast<uint16>(PACKET_MAXIMUMS[m_msslevel]) <= m_mtu_advise) {
|
| + if (static_cast<uint16_t>(PACKET_MAXIMUMS[m_msslevel]) <= m_mtu_advise) {
|
| break;
|
| }
|
| }
|
| @@ -1166,19 +1175,18 @@ PseudoTcp::queueConnectMessage() {
|
| buf.WriteUInt8(1);
|
| buf.WriteUInt8(m_rwnd_scale);
|
| }
|
| - m_snd_wnd = static_cast<uint32>(buf.Length());
|
| - queue(buf.Data(), static_cast<uint32>(buf.Length()), true);
|
| + m_snd_wnd = static_cast<uint32_t>(buf.Length());
|
| + queue(buf.Data(), static_cast<uint32_t>(buf.Length()), true);
|
| }
|
|
|
| -void
|
| -PseudoTcp::parseOptions(const char* data, uint32 len) {
|
| - std::set<uint8> options_specified;
|
| +void PseudoTcp::parseOptions(const char* data, uint32_t len) {
|
| + std::set<uint8_t> options_specified;
|
|
|
| // See http://www.freesoft.org/CIE/Course/Section4/8.htm for
|
| // parsing the options list.
|
| rtc::ByteBuffer buf(data, len);
|
| while (buf.Length()) {
|
| - uint8 kind = TCP_OPT_EOL;
|
| + uint8_t kind = TCP_OPT_EOL;
|
| buf.ReadUInt8(&kind);
|
|
|
| if (kind == TCP_OPT_EOL) {
|
| @@ -1192,7 +1200,7 @@ PseudoTcp::parseOptions(const char* data, uint32 len) {
|
| // Length of this option.
|
| ASSERT(len != 0);
|
| RTC_UNUSED(len);
|
| - uint8 opt_len = 0;
|
| + uint8_t opt_len = 0;
|
| buf.ReadUInt8(&opt_len);
|
|
|
| // Content of this option.
|
| @@ -1218,8 +1226,7 @@ PseudoTcp::parseOptions(const char* data, uint32 len) {
|
| }
|
| }
|
|
|
| -void
|
| -PseudoTcp::applyOption(char kind, const char* data, uint32 len) {
|
| +void PseudoTcp::applyOption(char kind, const char* data, uint32_t len) {
|
| if (kind == TCP_OPT_MSS) {
|
| LOG(LS_WARNING) << "Peer specified MSS option which is not supported.";
|
| // TODO: Implement.
|
| @@ -1234,20 +1241,17 @@ PseudoTcp::applyOption(char kind, const char* data, uint32 len) {
|
| }
|
| }
|
|
|
| -void
|
| -PseudoTcp::applyWindowScaleOption(uint8 scale_factor) {
|
| +void PseudoTcp::applyWindowScaleOption(uint8_t scale_factor) {
|
| m_swnd_scale = scale_factor;
|
| }
|
|
|
| -void
|
| -PseudoTcp::resizeSendBuffer(uint32 new_size) {
|
| +void PseudoTcp::resizeSendBuffer(uint32_t new_size) {
|
| m_sbuf_len = new_size;
|
| m_sbuf.SetCapacity(new_size);
|
| }
|
|
|
| -void
|
| -PseudoTcp::resizeReceiveBuffer(uint32 new_size) {
|
| - uint8 scale_factor = 0;
|
| +void PseudoTcp::resizeReceiveBuffer(uint32_t new_size) {
|
| + uint8_t scale_factor = 0;
|
|
|
| // Determine the scale factor such that the scaled window size can fit
|
| // in a 16-bit unsigned integer.
|
| @@ -1272,7 +1276,7 @@ PseudoTcp::resizeReceiveBuffer(uint32 new_size) {
|
|
|
| size_t available_space = 0;
|
| m_rbuf.GetWriteRemaining(&available_space);
|
| - m_rcv_wnd = static_cast<uint32>(available_space);
|
| + m_rcv_wnd = static_cast<uint32_t>(available_space);
|
| }
|
|
|
| } // namespace cricket
|
|
|