From bbfc9359e9828931c833f80739dd43d3d4f3e973 Mon Sep 17 00:00:00 2001 From: Joseph Henry Date: Thu, 8 Oct 2015 17:55:58 -0400 Subject: Minor timer changes (~21 Mb/s local) --- netcon/NetconEthernetTap.cpp | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'netcon/NetconEthernetTap.cpp') diff --git a/netcon/NetconEthernetTap.cpp b/netcon/NetconEthernetTap.cpp index 0b5b0727..538ae0be 100644 --- a/netcon/NetconEthernetTap.cpp +++ b/netcon/NetconEthernetTap.cpp @@ -307,7 +307,7 @@ void NetconEthernetTap::closeAll() closeConnection(tcp_connections.front()); } -#define ZT_LWIP_TCP_TIMER_INTERVAL 5 +#define ZT_LWIP_TCP_TIMER_INTERVAL 1 void NetconEthernetTap::threadMain() throw() @@ -344,6 +344,7 @@ void NetconEthernetTap::threadMain() if (since_tcp >= ZT_LWIP_TCP_TIMER_INTERVAL) { prev_tcp_time = now; lwipstack->tcp_tmr(); + //fprintf(stderr, "tcp_tmr\n"); } else { tcp_remaining = ZT_LWIP_TCP_TIMER_INTERVAL - since_tcp; } @@ -353,6 +354,7 @@ void NetconEthernetTap::threadMain() } else { etharp_remaining = ARP_TMR_INTERVAL - since_etharp; } + //fprintf(stderr, "poll_wait_time = %d\n", (unsigned long)std::min(tcp_remaining,etharp_remaining)); _phy.poll((unsigned long)std::min(tcp_remaining,etharp_remaining)); } closeAll(); @@ -399,6 +401,7 @@ void NetconEthernetTap::phyOnFileDescriptorActivity(PhySocket *sock,void **uptr, now space on the buffer */ if(sndbuf == 0) { _phy.setNotifyReadable(sock, false); + lwipstack->_tcp_output(conn->pcb); return; } -- cgit v1.2.3