1f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch/* 2f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * libjingle 3f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * Copyright 2004--2005, Google Inc. 4f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * 53345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick * Redistribution and use in source and binary forms, with or without 6f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * modification, are permitted provided that the following conditions are met: 7f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * 83345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick * 1. Redistributions of source code must retain the above copyright notice, 9f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * this list of conditions and the following disclaimer. 10f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * 2. Redistributions in binary form must reproduce the above copyright notice, 11f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * this list of conditions and the following disclaimer in the documentation 12f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * and/or other materials provided with the distribution. 133345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick * 3. The name of the author may not be used to endorse or promote products 14f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * derived from this software without specific prior written permission. 15f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * 16f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 173345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 18f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 193345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 20f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 21f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 22f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 233345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 243345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 25f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 26f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch */ 27f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 28f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include "talk/p2p/base/pseudotcp.h" 29f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 30f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include <cstdio> 31f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include <cstdlib> 32f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 33f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include "talk/base/basictypes.h" 34f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include "talk/base/byteorder.h" 35f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include "talk/base/common.h" 36f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include "talk/base/logging.h" 37f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include "talk/base/socket.h" 38f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include "talk/base/stringutils.h" 39f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#include "talk/base/time.h" 40f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 413345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick// The following logging is for detailed (packet-level) analysis only. 42f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#define _DBG_NONE 0 43f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#define _DBG_NORMAL 1 44f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#define _DBG_VERBOSE 2 45f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#define _DEBUGMSG _DBG_NONE 46f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 47f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochnamespace cricket { 48f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 49f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 50f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// Network Constants 51f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 52f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 53f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// Standard MTUs 54f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint16 PACKET_MAXIMUMS[] = { 55f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 65535, // Theoretical maximum, Hyperchannel 56f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 32000, // Nothing 57f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 17914, // 16Mb IBM Token Ring 58f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 8166, // IEEE 802.4 59f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //4464, // IEEE 802.5 (4Mb max) 60f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 4352, // FDDI 61f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //2048, // Wideband Network 62f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 2002, // IEEE 802.5 (4Mb recommended) 63f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //1536, // Expermental Ethernet Networks 64f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //1500, // Ethernet, Point-to-Point (default) 65f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1492, // IEEE 802.3 66f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1006, // SLIP, ARPANET 67f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //576, // X.25 Networks 68f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //544, // DEC IP Portal 69f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //512, // NETBIOS 70f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 508, // IEEE 802/Source-Rt Bridge, ARCNET 71f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 296, // Point-to-Point (low delay) 72f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //68, // Official minimum 73f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 0, // End of list marker 74f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch}; 75f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 76f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 MAX_PACKET = 65535; 77f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// Note: we removed lowest level because packet overhead was larger! 78f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 MIN_PACKET = 296; 79f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 80f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 IP_HEADER_SIZE = 20; // (+ up to 40 bytes of options?) 81f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 ICMP_HEADER_SIZE = 8; 82f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 UDP_HEADER_SIZE = 8; 83f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// TODO: Make JINGLE_HEADER_SIZE transparent to this code? 84f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 JINGLE_HEADER_SIZE = 64; // when relay framing is in use 85f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 86f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 87f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// Global Constants and Functions 88f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 89f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 903345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick// 0 1 2 3 913345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick// 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 92f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 93f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 0 | Conversation Number | 94f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 95f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 4 | Sequence Number | 96f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 97f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 8 | Acknowledgment Number | 98f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 99f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// | | |U|A|P|R|S|F| | 100f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 12 | Control | |R|C|S|S|Y|I| Window | 101f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// | | |G|K|H|T|N|N| | 102f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 103f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 16 | Timestamp sending | 104f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 105f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 20 | Timestamp receiving | 106f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 107f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 24 | data | 108f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 109f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 110f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 111f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 112f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#define PSEUDO_KEEPALIVE 0 113f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 114f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 MAX_SEQ = 0xFFFFFFFF; 115f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 HEADER_SIZE = 24; 116f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 PACKET_OVERHEAD = HEADER_SIZE + UDP_HEADER_SIZE + IP_HEADER_SIZE + JINGLE_HEADER_SIZE; 117f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 118f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 MIN_RTO = 250; // 250 ms (RFC1122, Sec 4.2.3.1 "fractions of a second") 119f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 DEF_RTO = 3000; // 3 seconds (RFC1122, Sec 4.2.3.1) 120f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 MAX_RTO = 60000; // 60 seconds 121dc0f95d653279beabeb9817299e2902918ba123eKristian Monsenconst uint32 DEF_ACK_DELAY = 100; // 100 milliseconds 122f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 123f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint8 FLAG_CTL = 0x02; 124f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint8 FLAG_RST = 0x04; 125f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 126f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint8 CTL_CONNECT = 0; 127f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch//const uint8 CTL_REDIRECT = 1; 128f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint8 CTL_EXTRA = 255; 129f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 130f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch/* 131f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint8 FLAG_FIN = 0x01; 132f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint8 FLAG_SYN = 0x02; 133f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint8 FLAG_ACK = 0x10; 134f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch*/ 135f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 136f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 CTRL_BOUND = 0x80000000; 137f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 138f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst long DEFAULT_TIMEOUT = 4000; // If there are no pending clocks, wake up every 4 seconds 139f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst long CLOSED_TIMEOUT = 60 * 1000; // If the connection is closed, once per minute 140f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 141f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if PSEUDO_KEEPALIVE 142f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// !?! Rethink these times 143f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 IDLE_PING = 20 * 1000; // 20 seconds (note: WinXP SP2 firewall udp timeout is 90 seconds) 144f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst uint32 IDLE_TIMEOUT = 90 * 1000; // 90 seconds; 145f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // PSEUDO_KEEPALIVE 146f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 147f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 148f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// Helper Functions 149f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 150f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 151f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochinline void long_to_bytes(uint32 val, void* buf) { 152f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch *static_cast<uint32*>(buf) = talk_base::HostToNetwork32(val); 153f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 154f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 155f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochinline void short_to_bytes(uint16 val, void* buf) { 156f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch *static_cast<uint16*>(buf) = talk_base::HostToNetwork16(val); 157f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 158f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 159f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochinline uint32 bytes_to_long(const void* buf) { 160f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return talk_base::NetworkToHost32(*static_cast<const uint32*>(buf)); 161f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 162f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 163f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochinline uint16 bytes_to_short(const void* buf) { 164f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return talk_base::NetworkToHost16(*static_cast<const uint16*>(buf)); 165f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 166f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 167f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochuint32 bound(uint32 lower, uint32 middle, uint32 upper) { 168f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return talk_base::_min(talk_base::_max(lower, middle), upper); 169f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 170f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 171f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 172f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// Debugging Statistics 173f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 174f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 175f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if 0 // Not used yet 176f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 177f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochenum Stat { 178f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch S_SENT_PACKET, // All packet sends 179f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch S_RESENT_PACKET, // All packet sends that are retransmits 180f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch S_RECV_PACKET, // All packet receives 181f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch S_RECV_NEW, // All packet receives that are too new 182f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch S_RECV_OLD, // All packet receives that are too old 183f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch S_NUM_STATS 184f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch}; 185f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 186f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochconst char* const STAT_NAMES[S_NUM_STATS] = { 187f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch "snt", 188f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch "snt-r", 189f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch "rcv" 190f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch "rcv-n", 191f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch "rcv-o" 192f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch}; 193f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 194f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochint g_stats[S_NUM_STATS]; 195f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochinline void Incr(Stat s) { ++g_stats[s]; } 196f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochvoid ReportStats() { 197f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch char buffer[256]; 198f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch size_t len = 0; 1993345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick for (int i = 0; i < S_NUM_STATS; ++i) { 200f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch len += talk_base::sprintfn(buffer, ARRAY_SIZE(buffer), "%s%s:%d", 201f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch (i == 0) ? "" : ",", STAT_NAMES[i], g_stats[i]); 202f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch g_stats[i] = 0; 203f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 204f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "Stats[" << buffer << "]"; 205f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 206f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 207f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif 208f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 209f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 210f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// PseudoTcp 211f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch////////////////////////////////////////////////////////////////////// 212f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 213f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochuint32 PseudoTcp::Now() { 214f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if 0 // Use this to synchronize timers with logging timestamps (easier debug) 215f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return talk_base::TimeSince(StartTime()); 216f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#else 217f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return talk_base::Time(); 218f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif 219f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 220f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 2213345a6884c488ff3a535c2c9acdd33d74b37e311Iain MerrickPseudoTcp::PseudoTcp(IPseudoTcpNotify* notify, uint32 conv) 222f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch : m_notify(notify), m_shutdown(SD_NONE), m_error(0) { 223f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 224f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Sanity check on buffer sizes (needed for OnTcpWriteable notification logic) 225f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(sizeof(m_rbuf) + MIN_PACKET < sizeof(m_sbuf)); 226f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 227f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 now = Now(); 228f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 229f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_state = TCP_LISTEN; 230f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_conv = conv; 231f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rcv_wnd = sizeof(m_rbuf); 232f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_snd_nxt = m_slen = 0; 233f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_snd_wnd = 1; 234f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_snd_una = m_rcv_nxt = m_rlen = 0; 235f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bReadEnable = true; 236f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bWriteEnable = false; 237f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_t_ack = 0; 238f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 239f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_msslevel = 0; 240f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_largest = 0; 241f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(MIN_PACKET > PACKET_OVERHEAD); 242f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_mss = MIN_PACKET - PACKET_OVERHEAD; 243f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_mtu_advise = MAX_PACKET; 244f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 245f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rto_base = 0; 246f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 247f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd = 2 * m_mss; 248f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_ssthresh = sizeof(m_rbuf); 249f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_lastrecv = m_lastsend = m_lasttraffic = now; 250f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bOutgoing = false; 251f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 252f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_dup_acks = 0; 253f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_recover = 0; 254f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 255f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_ts_recent = m_ts_lastack = 0; 256f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 257f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_rto = DEF_RTO; 258f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_srtt = m_rx_rttvar = 0; 259dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen 260dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen m_use_nagling = true; 261dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen m_ack_delay = DEF_ACK_DELAY; 262f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 263f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 264f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen MurdochPseudoTcp::~PseudoTcp() { 265f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 266f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 2673345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickint PseudoTcp::Connect() { 268f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state != TCP_LISTEN) { 269f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_error = EINVAL; 270f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return -1; 271f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 272f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 273f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_state = TCP_SYN_SENT; 274f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "State: TCP_SYN_SENT"; 275f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 276f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch char buffer[1]; 277f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch buffer[0] = CTL_CONNECT; 278f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch queue(buffer, 1, true); 279f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch attemptSend(); 280f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 281f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return 0; 282f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 283f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 2843345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickvoid PseudoTcp::NotifyMTU(uint16 mtu) { 285f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_mtu_advise = mtu; 286f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state == TCP_ESTABLISHED) { 287f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch adjustMTU(); 288f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 289f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 290f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 2913345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickvoid PseudoTcp::NotifyClock(uint32 now) { 292f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state == TCP_CLOSED) 293f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return; 294f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 295f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check if it's time to retransmit a segment 296f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_rto_base && (talk_base::TimeDiff(m_rto_base + m_rx_rto, now) <= 0)) { 297f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_slist.empty()) { 298f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(false); 299f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 300f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Note: (m_slist.front().xmit == 0)) { 301f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // retransmit segments 302f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 303f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "timeout retransmit (rto: " << m_rx_rto 304f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << ") (rto_base: " << m_rto_base 305f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << ") (now: " << now 306f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << ") (dup_acks: " << static_cast<unsigned>(m_dup_acks) 307f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << ")"; 308f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 309f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (!transmit(m_slist.begin(), now)) { 310f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch closedown(ECONNABORTED); 311f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return; 312f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 313f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 314f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nInFlight = m_snd_nxt - m_snd_una; 315f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_ssthresh = talk_base::_max(nInFlight / 2, 2 * m_mss); 316f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //LOG(LS_INFO) << "m_ssthresh: " << m_ssthresh << " nInFlight: " << nInFlight << " m_mss: " << m_mss; 317f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd = m_mss; 318f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 319f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Back off retransmit timer. Note: the limit is lower when connecting. 320f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 rto_limit = (m_state < TCP_ESTABLISHED) ? DEF_RTO : MAX_RTO; 321f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_rto = talk_base::_min(rto_limit, m_rx_rto * 2); 322f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rto_base = now; 323f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 324f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 3253345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick 326f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check if it's time to probe closed windows 3273345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick if ((m_snd_wnd == 0) 328f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch && (talk_base::TimeDiff(m_lastsend + m_rx_rto, now) <= 0)) { 329f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (talk_base::TimeDiff(now, m_lastrecv) >= 15000) { 330f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch closedown(ECONNABORTED); 331f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return; 332f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 333f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 334f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // probe the window 335f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch packet(m_snd_nxt - 1, 0, 0, 0); 336f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_lastsend = now; 337f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 338f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // back off retransmit timer 339f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_rto = talk_base::_min(MAX_RTO, m_rx_rto * 2); 340f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 341f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 342f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check if it's time to send delayed acks 343dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen if (m_t_ack && (talk_base::TimeDiff(m_t_ack + m_ack_delay, now) <= 0)) { 344f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch packet(m_snd_nxt, 0, 0, 0); 345f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 346f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 347f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if PSEUDO_KEEPALIVE 348f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check for idle timeout 349f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((m_state == TCP_ESTABLISHED) && (TimeDiff(m_lastrecv + IDLE_TIMEOUT, now) <= 0)) { 350f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch closedown(ECONNABORTED); 351f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return; 352f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 353f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 354f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check for ping timeout (to keep udp mapping open) 355f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((m_state == TCP_ESTABLISHED) && (TimeDiff(m_lasttraffic + (m_bOutgoing ? IDLE_PING * 3/2 : IDLE_PING), now) <= 0)) { 356f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch packet(m_snd_nxt, 0, 0, 0); 357f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 358f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // PSEUDO_KEEPALIVE 359f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 360f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 3613345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickbool PseudoTcp::NotifyPacket(const char* buffer, size_t len) { 362f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (len > MAX_PACKET) { 363f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(WARNING) << "packet too large"; 364f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 365f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 366f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return parse(reinterpret_cast<const uint8 *>(buffer), uint32(len)); 367f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 368f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 3693345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickbool PseudoTcp::GetNextClock(uint32 now, long& timeout) { 370f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return clock_check(now, timeout); 371f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 372f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 373dc0f95d653279beabeb9817299e2902918ba123eKristian Monsenvoid PseudoTcp::GetOption(Option opt, int* value) { 374dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen if (opt == OPT_NODELAY) { 375dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen *value = m_use_nagling ? 0 : 1; 376dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen } else if (opt == OPT_ACKDELAY) { 377dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen *value = m_ack_delay; 378dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen } else { 379dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen ASSERT(false); 380dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen } 381dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen} 382dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen 383dc0f95d653279beabeb9817299e2902918ba123eKristian Monsenvoid PseudoTcp::SetOption(Option opt, int value) { 384dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen if (opt == OPT_NODELAY) { 385dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen m_use_nagling = value == 0; 386dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen } else if (opt == OPT_ACKDELAY) { 387dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen m_ack_delay = value; 388dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen } else { 389dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen ASSERT(false); 390dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen } 391dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen} 392dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen 3933345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick// 394f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// IPStream Implementation 395f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 396f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 3973345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickint PseudoTcp::Recv(char* buffer, size_t len) { 398f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state != TCP_ESTABLISHED) { 399f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_error = ENOTCONN; 400f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return SOCKET_ERROR; 401f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 402f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 403f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_rlen == 0) { 404f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bReadEnable = true; 405f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_error = EWOULDBLOCK; 406f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return SOCKET_ERROR; 407f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 408f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 409f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 read = talk_base::_min(uint32(len), m_rlen); 410f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch memcpy(buffer, m_rbuf, read); 411f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rlen -= read; 412f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 413f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // !?! until we create a circular buffer, we need to move all of the rest of the buffer up! 414f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch memmove(m_rbuf, m_rbuf + read, sizeof(m_rbuf) - read/*m_rlen*/); 415f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 4163345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick if ((sizeof(m_rbuf) - m_rlen - m_rcv_wnd) 417f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch >= talk_base::_min<uint32>(sizeof(m_rbuf) / 2, m_mss)) { 418f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch bool bWasClosed = (m_rcv_wnd == 0); // !?! Not sure about this was closed business 419f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 420f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rcv_wnd = sizeof(m_rbuf) - m_rlen; 421f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 422f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (bWasClosed) { 423f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch attemptSend(sfImmediateAck); 424f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 425f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 426f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 427f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return read; 428f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 429f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 4303345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickint PseudoTcp::Send(const char* buffer, size_t len) { 431f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state != TCP_ESTABLISHED) { 432f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_error = ENOTCONN; 433f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return SOCKET_ERROR; 434f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 435f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 436f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_slen == sizeof(m_sbuf)) { 437f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bWriteEnable = true; 438f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_error = EWOULDBLOCK; 439f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return SOCKET_ERROR; 440f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 441f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 442f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch int written = queue(buffer, uint32(len), false); 443f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch attemptSend(); 444f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return written; 445f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 446f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 4473345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickvoid PseudoTcp::Close(bool force) { 448f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_VERBOSE) << "(" << (force ? "true" : "false") << ")"; 449f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_shutdown = force ? SD_FORCEFUL : SD_GRACEFUL; 450f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 451f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 452f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochint PseudoTcp::GetError() { 453f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return m_error; 454f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 455f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 456f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 457f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// Internal Implementation 458f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch// 459f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 4603345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickuint32 PseudoTcp::queue(const char* data, uint32 len, bool bCtrl) { 461f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (len > sizeof(m_sbuf) - m_slen) { 462f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(!bCtrl); 463f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch len = sizeof(m_sbuf) - m_slen; 464f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 465f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 466f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // We can concatenate data if the last segment is the same type 467f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // (control v. regular data), and has not been transmitted yet 468f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (!m_slist.empty() && (m_slist.back().bCtrl == bCtrl) && (m_slist.back().xmit == 0)) { 469f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slist.back().len += len; 470f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 471f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch SSegment sseg(m_snd_una + m_slen, len, bCtrl); 472f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slist.push_back(sseg); 473f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 474f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 475f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch memcpy(m_sbuf + m_slen, data, len); 476f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slen += len; 477f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //LOG(LS_INFO) << "PseudoTcp::queue - m_slen = " << m_slen; 478f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return len; 479f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 480f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 4813345a6884c488ff3a535c2c9acdd33d74b37e311Iain MerrickIPseudoTcpNotify::WriteResult PseudoTcp::packet(uint32 seq, uint8 flags, 4823345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick const char* data, uint32 len) { 483f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(HEADER_SIZE + len <= MAX_PACKET); 484f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 485f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 now = Now(); 486f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 487f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint8 buffer[MAX_PACKET]; 488f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch long_to_bytes(m_conv, buffer); 489f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch long_to_bytes(seq, buffer + 4); 490f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch long_to_bytes(m_rcv_nxt, buffer + 8); 491f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch buffer[12] = 0; 492f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch buffer[13] = flags; 493f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch short_to_bytes(uint16(m_rcv_wnd), buffer + 14); 494f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 495f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Timestamp computations 496f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch long_to_bytes(now, buffer + 16); 497f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch long_to_bytes(m_ts_recent, buffer + 20); 498f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_ts_lastack = m_rcv_nxt; 499f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 500f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch memcpy(buffer + HEADER_SIZE, data, len); 501f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 502f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_VERBOSE 503f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "<-- <CONV=" << m_conv 504f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><FLG=" << static_cast<unsigned>(flags) 505f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><SEQ=" << seq << ":" << seq + len 506f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><ACK=" << m_rcv_nxt 507f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><WND=" << m_rcv_wnd 508f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><TS=" << (now % 10000) 509f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><TSR=" << (m_ts_recent % 10000) 510f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><LEN=" << len << ">"; 511f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 512f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 513f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch IPseudoTcpNotify::WriteResult wres = m_notify->TcpWritePacket(this, reinterpret_cast<char *>(buffer), len + HEADER_SIZE); 514f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Note: When data is NULL, this is an ACK packet. We don't read the return value for those, 515f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // and thus we won't retry. So go ahead and treat the packet as a success (basically simulate 516f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // as if it were dropped), which will prevent our timers from being messed up. 517f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((wres != IPseudoTcpNotify::WR_SUCCESS) && (NULL != data)) 518f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return wres; 519f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 520f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_t_ack = 0; 521f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (len > 0) { 522f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_lastsend = now; 523f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 524f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_lasttraffic = now; 525f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bOutgoing = true; 526f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 527f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return IPseudoTcpNotify::WR_SUCCESS; 528f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 529f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 5303345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickbool PseudoTcp::parse(const uint8* buffer, uint32 size) { 531f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (size < 12) 532f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 533f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 534f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch Segment seg; 535f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.conv = bytes_to_long(buffer); 536f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.seq = bytes_to_long(buffer + 4); 537f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.ack = bytes_to_long(buffer + 8); 538f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.flags = buffer[13]; 539f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.wnd = bytes_to_short(buffer + 14); 5403345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick 541f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.tsval = bytes_to_long(buffer + 16); 542f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.tsecr = bytes_to_long(buffer + 20); 543f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 544f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.data = reinterpret_cast<const char *>(buffer) + HEADER_SIZE; 545f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.len = size - HEADER_SIZE; 546f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 547f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_VERBOSE 548f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "--> <CONV=" << seg.conv 549f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><FLG=" << static_cast<unsigned>(seg.flags) 550f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><SEQ=" << seg.seq << ":" << seg.seq + seg.len 551f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><ACK=" << seg.ack 552f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><WND=" << seg.wnd 553f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><TS=" << (seg.tsval % 10000) 554f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><TSR=" << (seg.tsecr % 10000) 555f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << "><LEN=" << seg.len << ">"; 556f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 557f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 558f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return process(seg); 559f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 560f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 5613345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickbool PseudoTcp::clock_check(uint32 now, long& nTimeout) { 562f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_shutdown == SD_FORCEFUL) 563f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 564f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 565f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((m_shutdown == SD_GRACEFUL) 566f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch && ((m_state != TCP_ESTABLISHED) 567f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch || ((m_slen == 0) && (m_t_ack == 0)))) { 568f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 569f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 570f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 571f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state == TCP_CLOSED) { 572f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nTimeout = CLOSED_TIMEOUT; 573f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return true; 574f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 575f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 576f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nTimeout = DEFAULT_TIMEOUT; 577f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 578f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_t_ack) { 579f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nTimeout = talk_base::_min<int32>(nTimeout, 580dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen talk_base::TimeDiff(m_t_ack + m_ack_delay, now)); 581f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 582f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_rto_base) { 583f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nTimeout = talk_base::_min<int32>(nTimeout, 584f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch talk_base::TimeDiff(m_rto_base + m_rx_rto, now)); 585f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 586f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_snd_wnd == 0) { 587f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nTimeout = talk_base::_min<int32>(nTimeout, talk_base::TimeDiff(m_lastsend + m_rx_rto, now)); 588f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 589f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if PSEUDO_KEEPALIVE 590f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state == TCP_ESTABLISHED) { 591f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nTimeout = talk_base::_min<int32>(nTimeout, 592f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch talk_base::TimeDiff(m_lasttraffic + (m_bOutgoing ? IDLE_PING * 3/2 : IDLE_PING), now)); 593f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 594f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // PSEUDO_KEEPALIVE 595f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return true; 596f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 597f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 5983345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickbool PseudoTcp::process(Segment& seg) { 599f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // If this is the wrong conversation, send a reset!?! (with the correct conversation?) 600f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.conv != m_conv) { 601f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //if ((seg.flags & FLAG_RST) == 0) { 602f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // packet(tcb, seg.ack, 0, FLAG_RST, 0, 0); 603f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //} 604f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_ERROR) << "wrong conversation"; 605f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 606f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 607f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 608f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 now = Now(); 609f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_lasttraffic = m_lastrecv = now; 610f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bOutgoing = false; 611f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 612f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state == TCP_CLOSED) { 613f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // !?! send reset? 614f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_ERROR) << "closed"; 615f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 616f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 617f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 618f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check if this is a reset segment 619f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.flags & FLAG_RST) { 620f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch closedown(ECONNRESET); 621f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 622f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 623f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 624f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check for control data 625f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch bool bConnect = false; 626f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.flags & FLAG_CTL) { 627f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.len == 0) { 628f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_ERROR) << "Missing control code"; 629f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 630f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else if (seg.data[0] == CTL_CONNECT) { 631f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch bConnect = true; 632f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_state == TCP_LISTEN) { 633f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_state = TCP_SYN_RECEIVED; 634f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "State: TCP_SYN_RECEIVED"; 635f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //m_notify->associate(addr); 636f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch char buffer[1]; 637f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch buffer[0] = CTL_CONNECT; 638f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch queue(buffer, 1, true); 639f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else if (m_state == TCP_SYN_SENT) { 640f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_state = TCP_ESTABLISHED; 641f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "State: TCP_ESTABLISHED"; 642f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch adjustMTU(); 643f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_notify) { 644f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_notify->OnTcpOpen(this); 645f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 646f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //notify(evOpen); 647f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 648f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 649f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_WARNING) << "Unknown control code: " << seg.data[0]; 650f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 651f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 652f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 653f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 654f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Update timestamp 655f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((seg.seq <= m_ts_lastack) && (m_ts_lastack < seg.seq + seg.len)) { 656f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_ts_recent = seg.tsval; 657f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 658f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 659f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check if this is a valuable ack 660f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((seg.ack > m_snd_una) && (seg.ack <= m_snd_nxt)) { 661f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Calculate round-trip time 662f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.tsecr) { 663f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch long rtt = talk_base::TimeDiff(now, seg.tsecr); 664f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (rtt >= 0) { 665f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_rx_srtt == 0) { 666f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_srtt = rtt; 667f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_rttvar = rtt / 2; 668f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 669f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_rttvar = (3 * m_rx_rttvar + abs(long(rtt - m_rx_srtt))) / 4; 670f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_srtt = (7 * m_rx_srtt + rtt) / 8; 671f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 672f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rx_rto = bound(MIN_RTO, m_rx_srtt + 673f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch talk_base::_max<uint32>(1, 4 * m_rx_rttvar), MAX_RTO); 674f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_VERBOSE 675f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "rtt: " << rtt 676f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << " srtt: " << m_rx_srtt 677f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << " rto: " << m_rx_rto; 678f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 679f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 680f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(false); 681f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 682f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 683f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 684f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_snd_wnd = seg.wnd; 685f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 686f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nAcked = seg.ack - m_snd_una; 687f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_snd_una = seg.ack; 688f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 689f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rto_base = (m_snd_una == m_snd_nxt) ? 0 : now; 690f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 691f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slen -= nAcked; 692f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch memmove(m_sbuf, m_sbuf + nAcked, m_slen); 693f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //LOG(LS_INFO) << "PseudoTcp::process - m_slen = " << m_slen; 694f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 695f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch for (uint32 nFree = nAcked; nFree > 0; ) { 696f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(!m_slist.empty()); 697f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (nFree < m_slist.front().len) { 698f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slist.front().len -= nFree; 699f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nFree = 0; 700f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 701f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_slist.front().len > m_largest) { 702f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_largest = m_slist.front().len; 703f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 704f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nFree -= m_slist.front().len; 705f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slist.pop_front(); 706f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 707f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 708f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 709f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_dup_acks >= 3) { 710f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_snd_una >= m_recover) { // NewReno 711f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nInFlight = m_snd_nxt - m_snd_una; 7123345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick m_cwnd = talk_base::_min(m_ssthresh, nInFlight + m_mss); // (Fast Retransmit) 713f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 714f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "exit recovery"; 715f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 716f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_dup_acks = 0; 717f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 718f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 719f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "recovery retransmit"; 720f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 721f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (!transmit(m_slist.begin(), now)) { 722f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch closedown(ECONNABORTED); 723f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 724f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 725f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd += m_mss - talk_base::_min(nAcked, m_cwnd); 726f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 727f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 728f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_dup_acks = 0; 729f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Slow start, congestion avoidance 730f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_cwnd < m_ssthresh) { 731f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd += m_mss; 732f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 733f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd += talk_base::_max<uint32>(1, m_mss * m_mss / m_cwnd); 734f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 735f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 736f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 737f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // !?! A bit hacky 738f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((m_state == TCP_SYN_RECEIVED) && !bConnect) { 739f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_state = TCP_ESTABLISHED; 740f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "State: TCP_ESTABLISHED"; 741f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch adjustMTU(); 742f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_notify) { 743f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_notify->OnTcpOpen(this); 744f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 745f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //notify(evOpen); 746f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 7473345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick 748f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // If we make room in the send queue, notify the user 749f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // The goal it to make sure we always have at least enough data to fill the 750f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // window. We'd like to notify the app when we are halfway to that point. 751f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch const uint32 kIdealRefillSize = (sizeof(m_sbuf) + sizeof(m_rbuf)) / 2; 752f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_bWriteEnable && (m_slen < kIdealRefillSize)) { 753f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bWriteEnable = false; 754f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_notify) { 755f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_notify->OnTcpWriteable(this); 756f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 757f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //notify(evWrite); 758f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 759f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else if (seg.ack == m_snd_una) { 760f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // !?! Note, tcp says don't do this... but otherwise how does a closed window become open? 761f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_snd_wnd = seg.wnd; 762f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 763f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Check duplicate acks 764f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.len > 0) { 765f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // it's a dup ack, but with a data payload, so don't modify m_dup_acks 766f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else if (m_snd_una != m_snd_nxt) { 767f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_dup_acks += 1; 768f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_dup_acks == 3) { // (Fast Retransmit) 769f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 770f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "enter recovery"; 771f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "recovery retransmit"; 772f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 773f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (!transmit(m_slist.begin(), now)) { 774f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch closedown(ECONNABORTED); 775f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 776f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 777f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_recover = m_snd_nxt; 778f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nInFlight = m_snd_nxt - m_snd_una; 779f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_ssthresh = talk_base::_max(nInFlight / 2, 2 * m_mss); 780f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //LOG(LS_INFO) << "m_ssthresh: " << m_ssthresh << " nInFlight: " << nInFlight << " m_mss: " << m_mss; 781f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd = m_ssthresh + 3 * m_mss; 782f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else if (m_dup_acks > 3) { 783f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd += m_mss; 784f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 785f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 786f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_dup_acks = 0; 787f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 788f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 789f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 790f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Conditions were acks must be sent: 791f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // 1) Segment is too old (they missed an ACK) (immediately) 792f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // 2) Segment is too new (we missed a segment) (immediately) 793f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // 3) Segment has data (so we need to ACK!) (delayed) 794f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // ... so the only time we don't need to ACK, is an empty segment that points to rcv_nxt! 795f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 796f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch SendFlags sflags = sfNone; 797f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.seq != m_rcv_nxt) { 798f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch sflags = sfImmediateAck; // (Fast Recovery) 799f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else if (seg.len != 0) { 800dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen if (m_ack_delay == 0) { 801dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen sflags = sfImmediateAck; 802dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen } else { 803dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen sflags = sfDelayedAck; 804dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen } 805f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 806f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 807f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (sflags == sfImmediateAck) { 808f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.seq > m_rcv_nxt) { 809f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_INFO) << "too new"; 810f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else if (seg.seq + seg.len <= m_rcv_nxt) { 811f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_INFO) << "too old"; 812f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 813f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 814f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 815f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 816f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Adjust the incoming segment to fit our receive buffer 817f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.seq < m_rcv_nxt) { 818f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nAdjust = m_rcv_nxt - seg.seq; 819f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (nAdjust < seg.len) { 820f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.seq += nAdjust; 821f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.data += nAdjust; 822f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.len -= nAdjust; 823f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 824f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.len = 0; 825f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 826f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 827f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((seg.seq + seg.len - m_rcv_nxt) > (sizeof(m_rbuf) - m_rlen)) { 828f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nAdjust = seg.seq + seg.len - m_rcv_nxt - (sizeof(m_rbuf) - m_rlen); 829f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (nAdjust < seg.len) { 830f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.len -= nAdjust; 831f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 832f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg.len = 0; 833f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 834f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 835f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 836f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch bool bIgnoreData = (seg.flags & FLAG_CTL) || (m_shutdown != SD_NONE); 837f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch bool bNewData = false; 838f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 839f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.len > 0) { 840f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (bIgnoreData) { 841f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.seq == m_rcv_nxt) { 842f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rcv_nxt += seg.len; 843f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 844f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 845f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nOffset = seg.seq - m_rcv_nxt; 846f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch memcpy(m_rbuf + m_rlen + nOffset, seg.data, seg.len); 847f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg.seq == m_rcv_nxt) { 848f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rlen += seg.len; 849f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rcv_nxt += seg.len; 850f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rcv_wnd -= seg.len; 851f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch bNewData = true; 8523345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick 853f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch RList::iterator it = m_rlist.begin(); 854f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch while ((it != m_rlist.end()) && (it->seq <= m_rcv_nxt)) { 855f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (it->seq + it->len > m_rcv_nxt) { 856f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch sflags = sfImmediateAck; // (Fast Recovery) 857f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nAdjust = (it->seq + it->len) - m_rcv_nxt; 858f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 859f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "Recovered " << nAdjust << " bytes (" << m_rcv_nxt << " -> " << m_rcv_nxt + nAdjust << ")"; 860f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 861f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rlen += nAdjust; 862f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rcv_nxt += nAdjust; 863f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rcv_wnd -= nAdjust; 864f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 865f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch it = m_rlist.erase(it); 866f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 867f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 868f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 869f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "Saving " << seg.len << " bytes (" << seg.seq << " -> " << seg.seq + seg.len << ")"; 870f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 871f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch RSegment rseg; 872f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch rseg.seq = seg.seq; 873f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch rseg.len = seg.len; 874f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch RList::iterator it = m_rlist.begin(); 875f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch while ((it != m_rlist.end()) && (it->seq < rseg.seq)) { 876f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ++it; 877f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 878f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rlist.insert(it, rseg); 879f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 880f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 881f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 882f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 883f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch attemptSend(sflags); 884f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 885f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // If we have new data, notify the user 886f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (bNewData && m_bReadEnable) { 887f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_bReadEnable = false; 888f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_notify) { 889f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_notify->OnTcpReadable(this); 890f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 891f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //notify(evRead); 892f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 893f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 894f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return true; 895f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 896f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 8973345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickbool PseudoTcp::transmit(const SList::iterator& seg, uint32 now) { 898f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg->xmit >= ((m_state == TCP_ESTABLISHED) ? 15 : 30)) { 899f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_VERBOSE) << "too many retransmits"; 900f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 901f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 902f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 903f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nTransmit = talk_base::_min(seg->len, m_mss); 904f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 905f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch while (true) { 906f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 seq = seg->seq; 907f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint8 flags = (seg->bCtrl ? FLAG_CTL : 0); 9083345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick const char* buffer = m_sbuf + (seg->seq - m_snd_una); 909f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch IPseudoTcpNotify::WriteResult wres = this->packet(seq, flags, buffer, nTransmit); 910f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 911f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (wres == IPseudoTcpNotify::WR_SUCCESS) 912f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch break; 913f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 914f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (wres == IPseudoTcpNotify::WR_FAIL) { 915f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_VERBOSE) << "packet failed"; 916f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 917f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 918f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 919f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(wres == IPseudoTcpNotify::WR_TOO_LARGE); 920f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 921f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch while (true) { 922f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (PACKET_MAXIMUMS[m_msslevel + 1] == 0) { 923f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_VERBOSE) << "MTU too small"; 924f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return false; 925f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 926f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // !?! We need to break up all outstanding and pending packets and then retransmit!?! 927f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 928f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_mss = PACKET_MAXIMUMS[++m_msslevel] - PACKET_OVERHEAD; 929f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd = 2 * m_mss; // I added this... haven't researched actual formula 930f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_mss < nTransmit) { 931f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nTransmit = m_mss; 932f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch break; 933f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 934f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 935f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 936f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "Adjusting mss to " << m_mss << " bytes"; 937f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 938f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 939f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 940f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (nTransmit < seg->len) { 941f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_VERBOSE) << "mss reduced to " << m_mss; 942f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 943f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch SSegment subseg(seg->seq + nTransmit, seg->len - nTransmit, seg->bCtrl); 944f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //subseg.tstamp = seg->tstamp; 945f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch subseg.xmit = seg->xmit; 946f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg->len = nTransmit; 947f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 948f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch SList::iterator next = seg; 949f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slist.insert(++next, subseg); 950f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 951f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 952f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg->xmit == 0) { 953f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_snd_nxt += seg->len; 954f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 955f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg->xmit += 1; 956f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //seg->tstamp = now; 957f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_rto_base == 0) { 958f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_rto_base = now; 959f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 960f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 961f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return true; 962f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 963f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 9643345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrickvoid PseudoTcp::attemptSend(SendFlags sflags) { 965f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 now = Now(); 966f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 967f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (talk_base::TimeDiff(now, m_lastsend) > static_cast<long>(m_rx_rto)) { 968f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd = m_mss; 969f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 970f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 971f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG 972f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch bool bFirst = true; 973f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch UNUSED(bFirst); 974f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 975f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 976f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch while (true) { 977f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 cwnd = m_cwnd; 978f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((m_dup_acks == 1) || (m_dup_acks == 2)) { // Limited Transmit 979f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch cwnd += m_dup_acks * m_mss; 980f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 981f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nWindow = talk_base::_min(m_snd_wnd, cwnd); 982f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nInFlight = m_snd_nxt - m_snd_una; 983f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nUseable = (nInFlight < nWindow) ? (nWindow - nInFlight) : 0; 984f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 985f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch uint32 nAvailable = talk_base::_min(m_slen - nInFlight, m_mss); 986f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 987f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (nAvailable > nUseable) { 988f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (nUseable * 4 < nWindow) { 989f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // RFC 813 - avoid SWS 990f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nAvailable = 0; 991f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 992f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch nAvailable = nUseable; 993f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 994f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 995f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 996f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_VERBOSE 997f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (bFirst) { 998f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch bFirst = false; 999f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "[cwnd: " << m_cwnd 1000f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << " nWindow: " << nWindow 1001f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << " nInFlight: " << nInFlight 1002f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << " nAvailable: " << nAvailable 1003f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << " nQueued: " << m_slen - nInFlight 1004f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << " nEmpty: " << sizeof(m_sbuf) - m_slen 1005f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch << " ssthresh: " << m_ssthresh << "]"; 1006f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1007f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 1008f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1009f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (nAvailable == 0) { 1010f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (sflags == sfNone) 1011f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return; 1012f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1013f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // If this is an immediate ack, or the second delayed ack 1014f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if ((sflags == sfImmediateAck) || m_t_ack) { 1015f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch packet(m_snd_nxt, 0, 0, 0); 1016f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } else { 1017f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_t_ack = Now(); 1018f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 10193345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick return; 1020f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 10213345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick 1022dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen // Nagle's algorithm. 1023dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen // If there is data already in-flight, and we haven't a full segment of 1024dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen // data ready to send then hold off until we get more to send, or the 1025dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen // in-flight data is acknowledged. 1026dc0f95d653279beabeb9817299e2902918ba123eKristian Monsen if (m_use_nagling && (m_snd_nxt > m_snd_una) && (nAvailable < m_mss)) { 1027f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return; 1028f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1029f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1030f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Find the next segment to transmit 1031f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch SList::iterator it = m_slist.begin(); 1032f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch while (it->xmit > 0) { 1033f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ++it; 1034f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch ASSERT(it != m_slist.end()); 1035f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1036f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch SList::iterator seg = it; 1037f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1038f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // If the segment is too large, break it into two 1039f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (seg->len > nAvailable) { 1040f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch SSegment subseg(seg->seq + nAvailable, seg->len - nAvailable, seg->bCtrl); 1041f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch seg->len = nAvailable; 1042f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slist.insert(++it, subseg); 1043f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1044f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1045f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (!transmit(seg, now)) { 1046f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG_F(LS_VERBOSE) << "transmit failed"; 1047f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // TODO: consider closing socket 1048f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch return; 1049f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1050f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1051f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch sflags = sfNone; 1052f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1053f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 1054f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1055f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochvoid 1056f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen MurdochPseudoTcp::closedown(uint32 err) { 1057f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_slen = 0; 1058f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1059f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "State: TCP_CLOSED"; 1060f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_state = TCP_CLOSED; 1061f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (m_notify) { 1062f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_notify->OnTcpClosed(this, err); 1063f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1064f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch //notify(evClose, err); 1065f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 1066f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 1067f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdochvoid 1068f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen MurdochPseudoTcp::adjustMTU() { 1069f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Determine our current mss level, so that we can adjust appropriately later 1070f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch for (m_msslevel = 0; PACKET_MAXIMUMS[m_msslevel + 1] > 0; ++m_msslevel) { 1071f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch if (static_cast<uint16>(PACKET_MAXIMUMS[m_msslevel]) <= m_mtu_advise) { 1072f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch break; 1073f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1074f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch } 1075f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_mss = m_mtu_advise - PACKET_OVERHEAD; 1076f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // !?! Should we reset m_largest here? 1077f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#if _DEBUGMSG >= _DBG_NORMAL 1078f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch LOG(LS_INFO) << "Adjusting mss to " << m_mss << " bytes"; 1079f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch#endif // _DEBUGMSG 1080f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch // Enforce minimums on ssthresh and cwnd 1081f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_ssthresh = talk_base::_max(m_ssthresh, 2 * m_mss); 1082f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch m_cwnd = talk_base::_max(m_cwnd, m_mss); 1083f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch} 1084f74420b3285b9fe04a7e00aa3b8c0ab07ea344bcBen Murdoch 10853345a6884c488ff3a535c2c9acdd33d74b37e311Iain Merrick} // namespace cricket 1086