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

Timestamp:

2011-12-09T16:06:28Z (12 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

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

Children:

03be171

Parents:

0ac2158

Message:

Implement RST processing.

File:

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

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

@@ -117 +117 @@
 
         conn->cstate = st_listen;
+        conn->reset = false;
+        conn->ap = ap_passive;
         conn->fin_is_acked = false;
         conn->ident.local = *lsock;
@@ -176 +178 @@
         conn->snd_nxt = conn->iss;
         conn->snd_una = conn->iss;
+        conn->ap = ap_active;
 
         tcp_tqueue_ctrl_seg(conn, CTL_SYN);
@@ -278 +281 @@
         log_msg(LVL_DEBUG, "%s: tcp_conn_reset()", conn->name);
         tcp_conn_state_set(conn, st_closed);
+        conn->reset = true;
+
         tcp_conn_tw_timer_clear(conn);
         tcp_tqueue_clear(&conn->retransmit);
+
+        fibril_condvar_broadcast(&conn->rcv_buf_cv);
+}
+
+/** Signal to the user that connection has been reset.
+ *
+ * Send an out-of-band signal to the user.
+ */
+static void tcp_reset_signal(tcp_conn_t *conn)
+{
+        /* TODO */
+        log_msg(LVL_DEBUG, "%s: tcp_reset_signal()", conn->name);
 }
 
@@ -485 +502 @@
 static cproc_t tcp_conn_seg_proc_rst(tcp_conn_t *conn, tcp_segment_t *seg)
 {
-        /* TODO */
-        return cp_continue;
+        switch (conn->cstate) {
+        case st_syn_received:
+                /* XXX In case of passive open, revert to Listen state */
+                if (conn->ap == ap_passive) {
+                        tcp_conn_state_set(conn, st_listen);
+                        /* XXX Revert conn->ident */
+                        tcp_conn_tw_timer_clear(conn);
+                        tcp_tqueue_clear(&conn->retransmit);
+                } else {
+                        tcp_conn_reset(conn);
+                }
+                break;
+        case st_established:
+        case st_fin_wait_1:
+        case st_fin_wait_2:
+        case st_close_wait:
+                /* General "connection reset" signal */
+                tcp_reset_signal(conn);
+                tcp_conn_reset(conn);
+                break;
+        case st_closing:
+        case st_last_ack:
+        case st_time_wait:
+                tcp_conn_reset(conn);
+                break;
+        case st_listen:
+        case st_syn_sent:
+        case st_closed:
+                assert(false);
+        }
+
+        return cp_done;
 }