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

Timestamp:

2011-12-01T19:28:49Z (14 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

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

Children:

3aa2642a

Parents:

26ec91c

Message:

Fix RST to refuse connection and handle it properly in connect().

File:

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

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

@@ -59 +59 @@
 static void tcp_conn_seg_process(tcp_conn_t *conn, tcp_segment_t *seg);
 static void tcp_conn_tw_timer_set(tcp_conn_t *conn);
+static void tcp_conn_tw_timer_clear(tcp_conn_t *conn);
 
 /** Create new segment structure.
@@ -255 +256 @@
         list_foreach(conn_list, link) {
                 tcp_conn_t *conn = list_get_instance(link, tcp_conn_t, link);
-                if (tcp_sockpair_match(sp, &conn->ident)) {
+                tcp_sockpair_t *csp = &conn->ident;
+                log_msg(LVL_DEBUG, "compare with conn (f:(%x,%u), l:(%x,%u))",
+                    csp->foreign.addr.ipv4, csp->foreign.port,
+                    csp->local.addr.ipv4, csp->local.port);
+                if (tcp_sockpair_match(sp, csp)) {
                         return conn;
                 }
@@ -261 +266 @@
 
         return NULL;
+}
+
+/** Reset connection.
+ *
+ * @param conn  Connection
+ */
+static void tcp_conn_reset(tcp_conn_t *conn)
+{
+        log_msg(LVL_DEBUG, "%s: tcp_conn_reset()", conn->name);
+        tcp_conn_state_set(conn, st_closed);
+        tcp_conn_tw_timer_clear(conn);
+        tcp_tqueue_clear(&conn->retransmit);
 }
 
@@ -370 +387 @@
                 log_msg(LVL_DEBUG, "%s: Connection reset. -> Closed",
                     conn->name);
-                /* XXX Signal user error */
-                tcp_conn_state_set(conn, st_closed);
+                /* Reset connection */
+                tcp_conn_reset(conn);
                 /* XXX delete connection */
                 return;
@@ -1003 +1020 @@
 
         log_msg(LVL_DEBUG, "tw_timeout_func(%p)", conn);
+
+        if (conn->cstate == st_closed) {
+                log_msg(LVL_DEBUG, "Connection already closed.");
+                return;
+        }
+
         log_msg(LVL_DEBUG, "%s: TW Timeout -> Closed", conn->name);
-
         tcp_conn_remove(conn);
         tcp_conn_state_set(conn, st_closed);
@@ -1019 +1041 @@
 }
 
+/** Clear the Time-Wait timeout.
+ *
+ * @param conn          Connection
+ */
+void tcp_conn_tw_timer_clear(tcp_conn_t *conn)
+{
+        fibril_timer_clear(conn->tw_timer);
+}
+
 /** Trim segment to the receive window.
  *
@@ -1067 +1098 @@
 void tcp_reply_rst(tcp_sockpair_t *sp, tcp_segment_t *seg)
 {
-        tcp_sockpair_t rsp;
         tcp_segment_t *rseg;
 
         log_msg(LVL_DEBUG, "tcp_reply_rst(%p, %p)", sp, seg);
 
-        tcp_sockpair_flipped(sp, &rsp);
         rseg = tcp_segment_make_rst(seg);
-        tcp_transmit_segment(&rsp, rseg);
+        tcp_transmit_segment(sp, rseg);
 }