Changes in uspace/srv/net/tl/tcp/ucall.c [0edaf0f6:ae481e0] in mainline

File:

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

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

@@ -53 +53 @@
  * @param fsock         Foreign socket
  * @param acpass        Active/passive
+ * @param oflags        Open flags
  * @param conn          Connection
  *
@@ -65 +66 @@
  */
 tcp_error_t tcp_uc_open(tcp_sock_t *lsock, tcp_sock_t *fsock, acpass_t acpass,
-    tcp_conn_t **conn)
+    tcp_open_flags_t oflags, tcp_conn_t **conn)
 {
         tcp_conn_t *nconn;
 
-        log_msg(LVL_DEBUG, "tcp_uc_open(%p, %p, %s, %p)",
+        log_msg(LVL_DEBUG, "tcp_uc_open(%p, %p, %s, %s, %p)",
             lsock, fsock, acpass == ap_active ? "active" : "passive",
-            conn);
+            oflags == tcp_open_nonblock ? "nonblock" : "none", conn);
 
         nconn = tcp_conn_new(lsock, fsock);
@@ -79 +80 @@
                 /* Synchronize (initiate) connection */
                 tcp_conn_sync(nconn);
+        }
+
+        if (oflags == tcp_open_nonblock) {
+                *conn = nconn;
+                return TCP_EOK;
         }
 
@@ -101 +107 @@
 
         *conn = nconn;
+        log_msg(LVL_DEBUG, "tcp_uc_open -> %p", nconn);
         return TCP_EOK;
 }
@@ -258 +265 @@
 {
         log_msg(LVL_DEBUG, "tcp_uc_status()");
+        cstatus->cstate = conn->cstate;
 }
 
@@ -270 +278 @@
         log_msg(LVL_DEBUG, "tcp_uc_delete()");
         tcp_conn_delete(conn);
+}
+
+void tcp_uc_set_cstate_cb(tcp_conn_t *conn, tcp_cstate_cb_t cb, void *arg)
+{
+        log_msg(LVL_DEBUG, "tcp_uc_set_ctate_cb(%p, %p, %p)",
+            conn, cb, arg);
+
+        conn->cstate_cb = cb;
+        conn->cstate_cb_arg = arg;
 }