Changes in uspace/srv/net/tl/tcp/tcp.c [be942bc:46d4d9f] in mainline

File:

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

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

@@ -829 +829 @@
         /* Notify the destination socket */
         async_msg_5(socket->phone, NET_SOCKET_RECEIVED,
-            (sysarg_t) socket->socket_id,
+            (ipcarg_t) socket->socket_id,
             ((packet_dimension->content < socket_data->data_fragment_size) ?
             packet_dimension->content : socket_data->data_fragment_size), 0, 0,
-            (sysarg_t) fragments);
+            (ipcarg_t) fragments);
 
         return EOK;
@@ -1090 +1090 @@
                         /* Notify the destination socket */
                         async_msg_5(socket->phone, NET_SOCKET_ACCEPTED,
-                            (sysarg_t) listening_socket->socket_id,
+                            (ipcarg_t) listening_socket->socket_id,
                             socket_data->data_fragment_size, TCP_HEADER_SIZE,
-                            0, (sysarg_t) socket->socket_id);
+                            0, (ipcarg_t) socket->socket_id);
 
                         fibril_rwlock_write_unlock(socket_data->local_lock);
@@ -1240 +1240 @@
 
         *answer_count = 0;
-        switch (IPC_GET_IMETHOD(*call)) {
+        switch (IPC_GET_METHOD(*call)) {
         case NET_TL_RECEIVED:
 //              fibril_rwlock_read_lock(&tcp_globals.lock);
@@ -1323 +1323 @@
 
                 /* Process the call */
-                switch (IPC_GET_IMETHOD(call)) {
+                switch (IPC_GET_METHOD(call)) {
                 case IPC_M_PHONE_HUNGUP:
                         keep_on_going = false;
@@ -1365 +1365 @@
 
                 case NET_SOCKET_BIND:
-                        res = async_data_write_accept((void **) &addr, false,
-                            0, 0, 0, &addrlen);
+                        res = data_receive((void **) &addr, &addrlen);
                         if (res != EOK)
                                 break;
@@ -1403 +1402 @@
 
                 case NET_SOCKET_CONNECT:
-                        res = async_data_write_accept((void **) &addr, false,
-                            0, 0, 0, &addrlen);
+                        res = data_receive((void **) &addr, &addrlen);
                         if (res != EOK)
                                 break;
@@ -1455 +1453 @@
 
                 case NET_SOCKET_SENDTO:
-                        res = async_data_write_accept((void **) &addr, false,
-                            0, 0, 0, &addrlen);
+                        res = data_receive((void **) &addr, &addrlen);
                         if (res != EOK)
                                 break;
@@ -2085 +2082 @@
         if (!fibril) {
                 free(operation_timeout);
-                return ENOMEM;
-        }
-
+                return EPARTY;  /* FIXME: use another EC */
+        }
 //      fibril_mutex_lock(&socket_data->operation.mutex);
         /* Start the timeout fibril */
@@ -2485 +2481 @@
                  * result.
                  */
-                if ((IPC_GET_IMETHOD(call) == IPC_M_PHONE_HUNGUP) ||
+                if ((IPC_GET_METHOD(call) == IPC_M_PHONE_HUNGUP) ||
                     (res == EHANGUP))
                         return;