Changes in uspace/srv/net/tcp/ucall.c [8499160:5441670] in mainline

File:

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

uspace/srv/net/tcp/ucall.c

@@ -1 +1 @@
 /*
- * Copyright (c) 2015 Jiri Svoboda
+ * Copyright (c) 2011 Jiri Svoboda
  * All rights reserved.
  *
@@ -35 +35 @@
  */
 
-#include <errno.h>
 #include <fibril_synch.h>
 #include <io/log.h>
@@ -51 +50 @@
 /** OPEN user call
  *
- * @param epp           Endpoint pair
+ * @param lsock         Local socket
+ * @param fsock         Foreign socket
  * @param acpass        Active/passive
  * @param oflags        Open flags
@@ -65 +65 @@
  * establishment.
  */
-tcp_error_t tcp_uc_open(inet_ep2_t *epp, acpass_t acpass,
+tcp_error_t tcp_uc_open(tcp_sock_t *lsock, tcp_sock_t *fsock, acpass_t acpass,
     tcp_open_flags_t oflags, tcp_conn_t **conn)
 {
         tcp_conn_t *nconn;
-        int rc;
-
-        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_open(%p, %s, %s, %p)",
-            epp, acpass == ap_active ? "active" : "passive",
+
+        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_open(%p, %p, %s, %s, %p)",
+            lsock, fsock, acpass == ap_active ? "active" : "passive",
             oflags == tcp_open_nonblock ? "nonblock" : "none", conn);
 
-        nconn = tcp_conn_new(epp);
-        rc = tcp_conn_add(nconn);
-        if (rc != EOK) {
-                tcp_conn_delete(nconn);
-                return TCP_EEXISTS;
-        }
-
+        nconn = tcp_conn_new(lsock, fsock);
+        tcp_conn_add(nconn);
         tcp_conn_lock(nconn);
 
@@ -194 +188 @@
         /* Wait for data to become available */
         while (conn->rcv_buf_used == 0 && !conn->rcv_buf_fin && !conn->reset) {
-                tcp_conn_unlock(conn);
-                return TCP_EAGAIN;
                 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_receive() - wait for data");
                 fibril_condvar_wait(&conn->rcv_buf_cv, &conn->lock);
@@ -258 +250 @@
                 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_close - listen/syn_sent");
                 tcp_conn_reset(conn);
+                tcp_conn_remove(conn);
                 tcp_conn_unlock(conn);
                 return TCP_EOK;
@@ -301 +294 @@
 }
 
-void tcp_uc_set_cb(tcp_conn_t *conn, tcp_cb_t *cb, void *arg)
-{
-        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_set_cb(%p, %p, %p)",
+void tcp_uc_set_cstate_cb(tcp_conn_t *conn, tcp_cstate_cb_t cb, void *arg)
+{
+        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_set_ctate_cb(%p, %p, %p)",
             conn, cb, arg);
 
-        conn->cb = cb;
-        conn->cb_arg = arg;
-}
-
-void *tcp_uc_get_userptr(tcp_conn_t *conn)
-{
-        return conn->cb_arg;
+        conn->cstate_cb = cb;
+        conn->cstate_cb_arg = arg;
 }
 
@@ -320 +308 @@
 
 /** Segment arrived */
-void tcp_as_segment_arrived(inet_ep2_t *epp, tcp_segment_t *seg)
+void tcp_as_segment_arrived(tcp_sockpair_t *sp, tcp_segment_t *seg)
 {
         tcp_conn_t *conn;
@@ -326 +314 @@
         log_msg(LOG_DEFAULT, LVL_DEBUG,
             "tcp_as_segment_arrived(f:(%u), l:(%u))",
-            epp->remote.port, epp->local.port);
-
-        conn = tcp_conn_find_ref(epp);
+            sp->foreign.port, sp->local.port);
+
+        conn = tcp_conn_find_ref(sp);
         if (conn == NULL) {
                 log_msg(LOG_DEFAULT, LVL_WARN, "No connection found.");
-                tcp_unexpected_segment(epp, seg);
+                tcp_unexpected_segment(sp, seg);
                 return;
         }
 
-        tcp_conn_segment_arrived(conn, epp, seg);
+        tcp_conn_lock(conn);
+
+        if (conn->cstate == st_closed) {
+                log_msg(LOG_DEFAULT, LVL_WARN, "Connection is closed.");
+                tcp_unexpected_segment(sp, seg);
+                tcp_conn_unlock(conn);
+                tcp_conn_delref(conn);
+                return;
+        }
+
+        if (inet_addr_is_any(&conn->ident.foreign.addr))
+                conn->ident.foreign.addr = sp->foreign.addr;
+        
+        if (conn->ident.foreign.port == TCP_PORT_ANY)
+                conn->ident.foreign.port = sp->foreign.port;
+        
+        if (inet_addr_is_any(&conn->ident.local.addr))
+                conn->ident.local.addr = sp->local.addr;
+
+        tcp_conn_segment_arrived(conn, seg);
+
+        tcp_conn_unlock(conn);
         tcp_conn_delref(conn);
 }