Changeset 2e99277 in mainline for uspace/srv/net/tl/tcp/tcp.c

Timestamp:

2010-02-23T22:51:49Z (14 years ago)

Author:

Lukas Mejdrech <lukasmejdrech@…>

Branches:

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

Children:

aa85487

Parents:

8edacbc

Message:

• inner message processing fixed

File:

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

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

@@ -1070 +1070 @@
          *  - Answer the first IPC_M_CONNECT_ME_TO call.
          */
-        ipc_answer_0( callid, EOK );
+        res = EOK;
+        answer_count = 0;
 
         socket_cores_initialize( & local_sockets );
@@ -1076 +1077 @@
 
         while( keep_on_going ){
+
+                // answer the call
+                answer_call( callid, res, & answer, answer_count );
+
                 // refresh data
                 refresh_answer( & answer, & answer_count );
 
+                // get the next call
                 callid = async_get_call( & call );
-//              printf( "message %d\n", IPC_GET_METHOD( * call ));
-
+
+                // process the call
                 switch( IPC_GET_METHOD( call )){
                         case IPC_M_PHONE_HUNGUP:
                                 keep_on_going = false;
-                                res = EOK;
+                                res = EHANGUP;
                                 break;
                         case NET_SOCKET:
@@ -1231 +1237 @@
                                 break;
                 }
-
-//              printf( "res = %d\n", res );
-
-                answer_call( callid, res, & answer, answer_count );
         }
 
@@ -1273 +1275 @@
                                         // TODO release as connection lost
                                         //tcp_refresh_socket_data( socket_data );
-                                }
-                                // retransmit
-                                // TODO enable retransmit
-                                //tcp_retransmit_packet( socket, socket_data, timeout->sequence_number );
+                                }else{
+                                        // retransmit
+                                        tcp_retransmit_packet( socket, socket_data, timeout->sequence_number );
+                                }
                                 fibril_rwlock_write_unlock( socket_data->local_lock );
                         }else{