Changeset 7cf7ded in mainline for uspace/srv/net/tl/tcp/conn.c

Timestamp:

2011-11-15T23:50:57Z (13 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

4f3f6285

Parents:

8218b6b

Message:

TCP retransmission (WIP). Allow setting timer in timer handler.
Simulate packet drop. Fixes.

File:

• uspace/srv/net/tl/tcp/conn.c (modified) (11 diffs)

uspace/srv/net/tl/tcp/conn.c

@@ -69 +69 @@
 {
         tcp_conn_t *conn = NULL;
+        bool tqueue_inited = false;
 
         /* Allocate connection structure */
@@ -105 +106 @@
 
         /* Initialize retransmission queue */
-        tcp_tqueue_init(&conn->retransmit, conn);
+        if (tcp_tqueue_init(&conn->retransmit, conn) != EOK)
+                goto error;
+
+        tqueue_inited = true;
 
         conn->cstate = st_listen;
@@ -116 +120 @@
 
 error:
+        if (tqueue_inited)
+                tcp_tqueue_fini(&conn->retransmit);
         if (conn != NULL && conn->rcv_buf != NULL)
                 free(conn->rcv_buf);
@@ -180 +186 @@
                 break;
         default:
+                log_msg(LVL_ERROR, "Connection state %d", conn->cstate);
                 assert(false);
         }
@@ -264 +271 @@
                 return true;
         case st_closed:
+                log_msg(LVL_WARN, "state=%d", (int) conn->cstate);
                 assert(false);
         }
@@ -347 +355 @@
 
         if ((seg->ctrl & CTL_RST) != 0) {
-                log_msg(LVL_DEBUG, "Connection reset.");
+                log_msg(LVL_DEBUG, "Connection reset. -> Closed");
                 /* XXX Signal user error */
                 conn->cstate = st_closed;
@@ -413 +421 @@
         log_msg(LVL_DEBUG, "tcp_conn_sa_seq(%p, %p)", conn, seg);
 
-        /* XXX Discard old duplicates */
+        /* Discard unacceptable segments ("old duplicates") */
+        if (!seq_no_segment_acceptable(conn, seg)) {
+                log_msg(LVL_DEBUG, "Replying ACK to unacceptable segment.");
+                tcp_tqueue_ctrl_seg(conn, CTL_ACK);
+                tcp_segment_delete(seg);
+                return;
+        }
 
         /* Queue for processing */
@@ -463 +477 @@
 static cproc_t tcp_conn_seg_proc_syn(tcp_conn_t *conn, tcp_segment_t *seg)
 {
-        /* TODO */
-        return cp_continue;
+        if ((seg->ctrl & CTL_SYN) == 0)
+                return cp_continue;
+
+        /*
+         * Assert SYN is in receive window, otherwise this step should not
+         * be reached.
+         */
+        assert(seq_no_in_rcv_wnd(conn, seg->seq));
+
+        log_msg(LVL_WARN, "SYN is in receive window, should send reset. XXX");
+
+        /*
+         * TODO
+         *
+         * Send a reset, resond "reset" to all outstanding RECEIVEs and SEND,
+         * flush segment queues. Send unsolicited "connection reset" signal
+         * to user, connection -> closed state, delete TCB, return.
+         */
+        return cp_done;
 }
 
@@ -790 +821 @@
 {
         log_msg(LVL_DEBUG, "tcp_conn_seg_proc_fin(%p, %p)", conn, seg);
+        log_msg(LVL_DEBUG, " seg->len=%zu, seg->ctl=%u", (size_t) seg->len,
+            (unsigned) seg->ctrl);
 
         /* Only process FIN if no text is left in segment. */
@@ -896 +929 @@
          * incoming segments queue.
          */
-        if (seg->len > 0)
+        if (seg->len > 0) {
+                log_msg(LVL_DEBUG, "Re-insert segment %p. seg->len=%zu",
+                    seg, (size_t) seg->len);
                 tcp_iqueue_insert_seg(&conn->incoming, seg);
-        else
+        } else {
                 tcp_segment_delete(seg);
+        }
 }
 
@@ -927 +963 @@
                 tcp_conn_sa_queue(conn, seg); break;
         case st_closed:
+                log_msg(LVL_DEBUG, "state=%d", (int) conn->cstate);
                 assert(false);
         }