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

Timestamp:

2011-10-04T18:12:41Z (13 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

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

Children:

d9ce049

Parents:

032bbe7

Message:

Send buffer, sketch data transmission.

File:

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

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

@@ -48 +48 @@
 
 #define RCV_BUF_SIZE 4096
+#define SND_BUF_SIZE 4096
 
 LIST_INITIALIZE(conn_list);
@@ -77 +78 @@
         }
 
+        /** Allocate send buffer */
+        conn->snd_buf_size = SND_BUF_SIZE;
+        conn->snd_buf_used = 0;
+        conn->snd_buf = calloc(1, conn->snd_buf_size);
+        if (conn->snd_buf == NULL) {
+                free(conn);
+                return NULL;
+        }
+
         /* Set up receive window. */
         conn->rcv_wnd = conn->rcv_buf_size;
@@ -171 +181 @@
 
         return NULL;
+}
+
+/** Determine if SYN has been received.
+ *
+ * @param conn  Connection
+ * @return      @c true if SYN has been received, @c false otherwise.
+ */
+bool tcp_conn_got_syn(tcp_conn_t *conn)
+{
+        switch (conn->cstate) {
+        case st_listen:
+        case st_syn_sent:
+                return false;
+        case st_syn_received:
+        case st_established:
+        case st_fin_wait_1:
+        case st_fin_wait_2:
+        case st_close_wait:
+        case st_closing:
+        case st_last_ack:
+        case st_time_wait:
+                return true;
+        case st_closed:
+                assert(false);
+        }
+
+        assert(false);
 }
 
@@ -273 +310 @@
 
         log_msg(LVL_DEBUG, "Sent SYN, got SYN.");
+
+        /*
+         * Surprisingly the spec does not deal with initial window setting.
+         * Set SND.WND = SEG.WND and set SND.WL1 so that next segment
+         * will always be accepted as new window setting.
+         */
+        log_msg(LVL_DEBUG, "SND.WND := %" PRIu32 ", SND.WL1 := %" PRIu32 ", "
+            "SND.WL2 = %" PRIu32, seg->wnd, seg->seq, seg->seq);
+        conn->snd_wnd = seg->wnd;
+        conn->snd_wl1 = seg->seq;
+        conn->snd_wl2 = seg->seq;
 
         if (seq_no_syn_acked(conn)) {
@@ -618 +666 @@
         tcp_segment_text_copy(seg, conn->rcv_buf, xfer_size);
 
+        log_msg(LVL_DEBUG, "Received %zu bytes of data.", xfer_size);
+
         /* Advance RCV.NXT */
         conn->rcv_nxt += xfer_size;
@@ -764 +814 @@
 /** Compute flipped socket pair for response.
  *
- * Flipped socket pair has local and foreign sockes exchanged.
+ * Flipped socket pair has local and foreign sockets exchanged.
  *
  * @param sp            Socket pair