Changes in uspace/srv/net/tl/tcp/tcp.c [918e9910:1e2e0c1e] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/net/tl/tcp/tcp.c
r918e9910 r1e2e0c1e 613 613 next_packet = pq_detach( packet ); 614 614 length = packet_get_data_length( packet ); 615 tmp_packet = pq_add( socket_data->incoming, packet, new_sequence_number, length ); 616 if( ! tmp_packet ){ 615 if( ERROR_OCCURRED( pq_add( & socket_data->incoming, packet, new_sequence_number, length ))){ 617 616 // remove the corrupted packets 618 617 pq_release( tcp_globals.net_phone, packet_get_id( packet )); 619 618 pq_release( tcp_globals.net_phone, packet_get_id( next_packet )); 620 619 }else{ 621 socket_data->incoming = tmp_packet;622 620 while( next_packet ){ 623 621 new_sequence_number += length; … … 939 937 packet_t next; 940 938 packet_t acknowledged = NULL; 941 packet_t first;942 939 uint32_t old; 943 940 … … 981 978 } 982 979 // add to acknowledged or release 983 first = pq_add( acknowledged, packet, 0, 0 ); 984 if( first ){ 985 acknowledged = first; 986 }else{ 980 if( pq_add( & acknowledged, packet, 0, 0 ) != EOK ){ 987 981 pq_release( tcp_globals.net_phone, packet_get_id( packet )); 988 982 } … … 1508 1502 int tcp_queue_packet( socket_core_ref socket, tcp_socket_data_ref socket_data, packet_t packet, size_t data_length ){ 1509 1503 ERROR_DECLARE; 1510 packet_t first;1511 1504 1512 1505 assert( socket ); … … 1516 1509 ERROR_PROPAGATE( tcp_queue_prepare_packet( socket, socket_data, packet, data_length )); 1517 1510 1518 first = pq_add( socket_data->outgoing, packet, socket_data->next_outgoing, data_length ); 1519 if( ! first ){ 1520 return tcp_release_and_return( packet, EINVAL ); 1521 } 1522 socket_data->outgoing = first; 1511 if( ERROR_OCCURRED( pq_add( & socket_data->outgoing, packet, socket_data->next_outgoing, data_length ))){ 1512 return tcp_release_and_return( packet, ERROR_CODE ); 1513 } 1523 1514 socket_data->next_outgoing += data_length; 1524 1515 return EOK;
Note:
See TracChangeset
for help on using the changeset viewer.