Changeset d9ce049 in mainline for uspace/srv/net/tl/tcp/state.c

Timestamp:

2011-10-04T20:40:05Z (14 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

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

Children:

8c7a054

Parents:

32105348

Message:

Implement RECEIVE user call.

File:

• uspace/srv/net/tl/tcp/state.c (modified) (2 diffs)

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

@@ -35 +35 @@
  */
 
+#include <fibril_synch.h>
 #include <io/log.h>
 #include <macros.h>
@@ -107 +108 @@
     xflags_t *xflags)
 {
+        size_t xfer_size;
+
         log_msg(LVL_DEBUG, "tcp_uc_receive()");
+
+        fibril_mutex_lock(&conn->rcv_buf_lock);
+
+        /* Wait for data to become available */
+        while (conn->rcv_buf_used == 0) {
+                log_msg(LVL_DEBUG, "tcp_uc_receive() - wait for data");
+                fibril_condvar_wait(&conn->rcv_buf_cv, &conn->rcv_buf_lock);
+        }
+
+        /* Copy data from receive buffer to user buffer */
+        xfer_size = min(size, conn->rcv_buf_used);
+        memcpy(buf, conn->rcv_buf, xfer_size);
+        *rcvd = xfer_size;
+
+        /* Remove data from receive buffer */
+        memmove(conn->rcv_buf, conn->rcv_buf + xfer_size, conn->rcv_buf_used -
+            xfer_size);
+        conn->rcv_buf_used -= xfer_size;
+        conn->rcv_wnd += xfer_size;
+
+        fibril_mutex_unlock(&conn->rcv_buf_lock);
+
+        /* TODO */
+        *xflags = 0;
+
+        /* Send new size of receive window */
+        tcp_tqueue_ctrl_seg(conn, CTL_ACK);
+
+        log_msg(LVL_DEBUG, "tcp_uc_receive() - returning %zu bytes",
+            xfer_size);
 }