Fork us on GitHub Follow us on Facebook Follow us on Twitter

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


Ignore:
Timestamp:
2010-02-23T22:51:49Z (12 years ago)
Author:
Lukas Mejdrech <lukasmejdrech@…>
Branches:
lfn, master
Children:
aa85487
Parents:
8edacbc
Message:
  • inner message processing fixed
File:
1 edited

Legend:

Unmodified
Added
Removed
  • uspace/srv/net/tl/tcp/tcp.c

    r8edacbc r2e99277  
    10701070         *  - Answer the first IPC_M_CONNECT_ME_TO call.
    10711071         */
    1072         ipc_answer_0( callid, EOK );
     1072        res = EOK;
     1073        answer_count = 0;
    10731074
    10741075        socket_cores_initialize( & local_sockets );
     
    10761077
    10771078        while( keep_on_going ){
     1079
     1080                // answer the call
     1081                answer_call( callid, res, & answer, answer_count );
     1082
    10781083                // refresh data
    10791084                refresh_answer( & answer, & answer_count );
    10801085
     1086                // get the next call
    10811087                callid = async_get_call( & call );
    1082 //              printf( "message %d\n", IPC_GET_METHOD( * call ));
    1083 
     1088
     1089                // process the call
    10841090                switch( IPC_GET_METHOD( call )){
    10851091                        case IPC_M_PHONE_HUNGUP:
    10861092                                keep_on_going = false;
    1087                                 res = EOK;
     1093                                res = EHANGUP;
    10881094                                break;
    10891095                        case NET_SOCKET:
     
    12311237                                break;
    12321238                }
    1233 
    1234 //              printf( "res = %d\n", res );
    1235 
    1236                 answer_call( callid, res, & answer, answer_count );
    12371239        }
    12381240
     
    12731275                                        // TODO release as connection lost
    12741276                                        //tcp_refresh_socket_data( socket_data );
    1275                                 }
    1276                                 // retransmit
    1277                                 // TODO enable retransmit
    1278                                 //tcp_retransmit_packet( socket, socket_data, timeout->sequence_number );
     1277                                }else{
     1278                                        // retransmit
     1279                                        tcp_retransmit_packet( socket, socket_data, timeout->sequence_number );
     1280                                }
    12791281                                fibril_rwlock_write_unlock( socket_data->local_lock );
    12801282                        }else{
Note: See TracChangeset for help on using the changeset viewer.