mirror/lwip
1
0
Fork 0
mirror of https://github.com/lwip-tcpip/lwip.git synced 2025-04-16 08:43:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added debug messages for corner cases of TCP states.

Browse Source
This commit is contained in:
likewise 2002-11-21 10:29:51 +00:00
parent e26a3e347b
commit dfe1ab7438
2 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/core/tcp.c
View File

@ -461,7 +461,9 @@ tcp_slowtmr(void)
/* Steps through all of the active PCBs. */ /* Steps through all of the active PCBs. */
prev = NULL; prev = NULL;
pcb = tcp_active_pcbs; pcb = tcp_active_pcbs;
if (pcb == NULL) DEBUGF(TCP_DEBUG, ("tcp_slowtmr: no active pcbs"));
while(pcb != NULL) { while(pcb != NULL) {
DEBUGF(TCP_DEBUG, ("tcp_slowtmr: processing active pcb"));
ASSERT("tcp_timer_coarse: active pcb->state != CLOSED", pcb->state != CLOSED); ASSERT("tcp_timer_coarse: active pcb->state != CLOSED", pcb->state != CLOSED);
ASSERT("tcp_timer_coarse: active pcb->state != LISTEN", pcb->state != LISTEN); ASSERT("tcp_timer_coarse: active pcb->state != LISTEN", pcb->state != LISTEN);
ASSERT("tcp_timer_coarse: active pcb->state != TIME-WAIT", pcb->state != TIME_WAIT); ASSERT("tcp_timer_coarse: active pcb->state != TIME-WAIT", pcb->state != TIME_WAIT);
@ -470,8 +472,11 @@ tcp_slowtmr(void)
if(pcb->state == SYN_SENT && pcb->nrtx == TCP_SYNMAXRTX) { if(pcb->state == SYN_SENT && pcb->nrtx == TCP_SYNMAXRTX) {
++pcb_remove; ++pcb_remove;
} else if(pcb->nrtx == TCP_MAXRTX) { DEBUGF(TCP_DEBUG, ("tcp_slowtmr: max SYN retries reached"));
}
else if(pcb->nrtx == TCP_MAXRTX) {
++pcb_remove; ++pcb_remove;
DEBUGF(TCP_DEBUG, ("tcp_slowtmr: max DATA retries reached"));
} else { } else {
++pcb->rtime; ++pcb->rtime;
if(pcb->unacked != NULL && pcb->rtime >= pcb->rto) { if(pcb->unacked != NULL && pcb->rtime >= pcb->rto) {
@ -506,6 +511,7 @@ tcp_slowtmr(void)
if((u32_t)(tcp_ticks - pcb->tmr) > if((u32_t)(tcp_ticks - pcb->tmr) >
TCP_FIN_WAIT_TIMEOUT / TCP_SLOW_INTERVAL) { TCP_FIN_WAIT_TIMEOUT / TCP_SLOW_INTERVAL) {
++pcb_remove; ++pcb_remove;
DEBUGF(TCP_DEBUG, ("tcp_slowtmr: removing pcb stuck in FIN-WAIT-2"));
} }
} }
@ -518,6 +524,7 @@ tcp_slowtmr(void)
pcb->rto * TCP_OOSEQ_TIMEOUT) { pcb->rto * TCP_OOSEQ_TIMEOUT) {
tcp_segs_free(pcb->ooseq); tcp_segs_free(pcb->ooseq);
pcb->ooseq = NULL; pcb->ooseq = NULL;
DEBUGF(TCP_CWND_DEBUG, ("tcp: dropping OOSEQ queued data\n"));
} }
#endif /* TCP_QUEUE_OOSEQ */ #endif /* TCP_QUEUE_OOSEQ */
@ -526,6 +533,7 @@ tcp_slowtmr(void)
if((u32_t)(tcp_ticks - pcb->tmr) > if((u32_t)(tcp_ticks - pcb->tmr) >
TCP_SYN_RCVD_TIMEOUT / TCP_SLOW_INTERVAL) { TCP_SYN_RCVD_TIMEOUT / TCP_SLOW_INTERVAL) {
++pcb_remove; ++pcb_remove;
DEBUGF(TCP_DEBUG, ("tcp_slottmr: removing pcb stuck in SYN-RCVD\n"));
} }
} }
@ -554,6 +562,7 @@ tcp_slowtmr(void)
++pcb->polltmr; ++pcb->polltmr;
if(pcb->polltmr >= pcb->pollinterval) { if(pcb->polltmr >= pcb->pollinterval) {
pcb->polltmr = 0; pcb->polltmr = 0;
DEBUGF(TCP_DEBUG, ("tcp_slottmr: polling application\n"));
TCP_EVENT_POLL(pcb, err); TCP_EVENT_POLL(pcb, err);
if(err == ERR_OK) { if(err == ERR_OK) {
tcp_output(pcb); tcp_output(pcb);
@ -957,9 +966,11 @@ tcp_pcb_purge(struct tcp_pcb *pcb)
if(pcb->unacked != NULL) { if(pcb->unacked != NULL) {
DEBUGF(TCP_DEBUG, ("tcp_pcb_purge: data left on ->unacked\n")); DEBUGF(TCP_DEBUG, ("tcp_pcb_purge: data left on ->unacked\n"));
} }
#if TCP_QUEUE_OOSEQ // LW
if(pcb->ooseq != NULL) { if(pcb->ooseq != NULL) {
DEBUGF(TCP_DEBUG, ("tcp_pcb_purge: data left on ->ooseq\n")); DEBUGF(TCP_DEBUG, ("tcp_pcb_purge: data left on ->ooseq\n"));
} }
#endif
#endif /* TCP_DEBUG */ #endif /* TCP_DEBUG */
tcp_segs_free(pcb->unsent); tcp_segs_free(pcb->unsent);
#if TCP_QUEUE_OOSEQ #if TCP_QUEUE_OOSEQ

2
src/core/tcp_in.c
View File

@ -212,7 +212,9 @@ tcp_input(struct pbuf *p, struct netif *inp)
arrivals). */ arrivals). */
if(prev != NULL) { if(prev != NULL) {
((struct tcp_pcb_listen *)prev)->next = lpcb->next; ((struct tcp_pcb_listen *)prev)->next = lpcb->next;
// our successor is the remainder of the listening list
lpcb->next = tcp_listen_pcbs; lpcb->next = tcp_listen_pcbs;
// put this listening pcb at the head of the listening list
tcp_listen_pcbs = lpcb; tcp_listen_pcbs = lpcb;
} }