Changeset 88a1bb9 in mainline for uspace/srv/net/tl/tcp/tcp.c
- Timestamp:
- 2010-11-18T23:20:09Z (13 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- 4eca056
- Parents:
- f772bc55
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/net/tl/tcp/tcp.c
rf772bc55 r88a1bb9 161 161 162 162 static int tcp_release_and_return(packet_t, int); 163 static void tcp_prepare_operation_header(socket_core_ ref, tcp_socket_data_t *,163 static void tcp_prepare_operation_header(socket_core_t *, tcp_socket_data_t *, 164 164 tcp_header_t *, int synchronize, int); 165 static int tcp_prepare_timeout(int (*)(void *), socket_core_ ref,165 static int tcp_prepare_timeout(int (*)(void *), socket_core_t *, 166 166 tcp_socket_data_t *, size_t, tcp_socket_state_t, suseconds_t, int); 167 static void tcp_free_socket_data(socket_core_ ref);167 static void tcp_free_socket_data(socket_core_t *); 168 168 169 169 static int tcp_timeout(void *); … … 172 172 173 173 static int tcp_process_packet(device_id_t, packet_t, services_t); 174 static int tcp_connect_core(socket_core_ ref, socket_cores_ref,174 static int tcp_connect_core(socket_core_t *, socket_cores_ref, 175 175 struct sockaddr *, socklen_t); 176 static int tcp_queue_prepare_packet(socket_core_ ref, tcp_socket_data_t *,176 static int tcp_queue_prepare_packet(socket_core_t *, tcp_socket_data_t *, 177 177 packet_t, size_t); 178 static int tcp_queue_packet(socket_core_ ref, tcp_socket_data_t *, packet_t,178 static int tcp_queue_packet(socket_core_t *, tcp_socket_data_t *, packet_t, 179 179 size_t); 180 static packet_t tcp_get_packets_to_send(socket_core_ ref, tcp_socket_data_t *);180 static packet_t tcp_get_packets_to_send(socket_core_t *, tcp_socket_data_t *); 181 181 static void tcp_send_packets(device_id_t, packet_t); 182 182 183 static void tcp_process_acknowledgement(socket_core_ ref, tcp_socket_data_t *,183 static void tcp_process_acknowledgement(socket_core_t *, tcp_socket_data_t *, 184 184 tcp_header_t *); 185 static packet_t tcp_send_prepare_packet(socket_core_ ref, tcp_socket_data_t *,185 static packet_t tcp_send_prepare_packet(socket_core_t *, tcp_socket_data_t *, 186 186 packet_t, size_t, size_t); 187 static packet_t tcp_prepare_copy(socket_core_ ref, tcp_socket_data_t *, packet_t,187 static packet_t tcp_prepare_copy(socket_core_t *, tcp_socket_data_t *, packet_t, 188 188 size_t, size_t); 189 /* static */ void tcp_retransmit_packet(socket_core_ ref, tcp_socket_data_t *,189 /* static */ void tcp_retransmit_packet(socket_core_t *, tcp_socket_data_t *, 190 190 size_t); 191 static int tcp_create_notification_packet(packet_t *, socket_core_ ref,191 static int tcp_create_notification_packet(packet_t *, socket_core_t *, 192 192 tcp_socket_data_t *, int, int); 193 193 static void tcp_refresh_socket_data(tcp_socket_data_t *); … … 195 195 static void tcp_initialize_socket_data(tcp_socket_data_t *); 196 196 197 static int tcp_process_listen(socket_core_ ref, tcp_socket_data_t *,197 static int tcp_process_listen(socket_core_t *, tcp_socket_data_t *, 198 198 tcp_header_t *, packet_t, struct sockaddr *, struct sockaddr *, size_t); 199 static int tcp_process_syn_sent(socket_core_ ref, tcp_socket_data_t *,199 static int tcp_process_syn_sent(socket_core_t *, tcp_socket_data_t *, 200 200 tcp_header_t *, packet_t); 201 static int tcp_process_syn_received(socket_core_ ref, tcp_socket_data_t *,201 static int tcp_process_syn_received(socket_core_t *, tcp_socket_data_t *, 202 202 tcp_header_t *, packet_t); 203 static int tcp_process_established(socket_core_ ref, tcp_socket_data_t *,203 static int tcp_process_established(socket_core_t *, tcp_socket_data_t *, 204 204 tcp_header_t *, packet_t, int, size_t); 205 static int tcp_queue_received_packet(socket_core_ ref, tcp_socket_data_t *,205 static int tcp_queue_received_packet(socket_core_t *, tcp_socket_data_t *, 206 206 packet_t, int, size_t); 207 207 … … 286 286 int result; 287 287 tcp_header_t *header; 288 socket_core_ refsocket;288 socket_core_t *socket; 289 289 tcp_socket_data_t *socket_data; 290 290 packet_t next_packet; … … 492 492 } 493 493 494 int tcp_process_established(socket_core_ refsocket, tcp_socket_data_t *494 int tcp_process_established(socket_core_t *socket, tcp_socket_data_t * 495 495 socket_data, tcp_header_t *header, packet_t packet, int fragments, 496 496 size_t total_length) … … 800 800 } 801 801 802 int tcp_queue_received_packet(socket_core_ refsocket,802 int tcp_queue_received_packet(socket_core_t *socket, 803 803 tcp_socket_data_t *socket_data, packet_t packet, int fragments, 804 804 size_t total_length) … … 837 837 } 838 838 839 int tcp_process_syn_sent(socket_core_ refsocket, tcp_socket_data_t *839 int tcp_process_syn_sent(socket_core_t *socket, tcp_socket_data_t * 840 840 socket_data, tcp_header_t *header, packet_t packet) 841 841 { … … 895 895 } 896 896 897 int tcp_process_listen(socket_core_ reflistening_socket,897 int tcp_process_listen(socket_core_t *listening_socket, 898 898 tcp_socket_data_t *listening_socket_data, tcp_header_t *header, 899 899 packet_t packet, struct sockaddr *src, struct sockaddr *dest, … … 901 901 { 902 902 packet_t next_packet; 903 socket_core_ refsocket;903 socket_core_t *socket; 904 904 tcp_socket_data_t *socket_data; 905 905 int socket_id; … … 1055 1055 } 1056 1056 1057 int tcp_process_syn_received(socket_core_ refsocket,1057 int tcp_process_syn_received(socket_core_t *socket, 1058 1058 tcp_socket_data_t *socket_data, tcp_header_t *header, packet_t packet) 1059 1059 { 1060 socket_core_ reflistening_socket;1060 socket_core_t *listening_socket; 1061 1061 tcp_socket_data_t *listening_socket_data; 1062 1062 int rc; … … 1122 1122 } 1123 1123 1124 void tcp_process_acknowledgement(socket_core_ refsocket,1124 void tcp_process_acknowledgement(socket_core_t *socket, 1125 1125 tcp_socket_data_t *socket_data, tcp_header_t *header) 1126 1126 { … … 1300 1300 int answer_count; 1301 1301 tcp_socket_data_t *socket_data; 1302 socket_core_ refsocket;1302 socket_core_t *socket; 1303 1303 packet_dimension_t *packet_dimension; 1304 1304 … … 1537 1537 tcp_timeout_t *timeout = data; 1538 1538 int keep_write_lock = false; 1539 socket_core_ refsocket;1539 socket_core_t *socket; 1540 1540 tcp_socket_data_t *socket_data; 1541 1541 … … 1613 1613 { 1614 1614 tcp_timeout_t *timeout = data; 1615 socket_core_ refsocket;1615 socket_core_t *socket; 1616 1616 tcp_socket_data_t *socket_data; 1617 1617 fibril_rwlock_t *local_lock; … … 1651 1651 } 1652 1652 1653 void tcp_retransmit_packet(socket_core_ refsocket, tcp_socket_data_t *1653 void tcp_retransmit_packet(socket_core_t *socket, tcp_socket_data_t * 1654 1654 socket_data, size_t sequence_number) 1655 1655 { … … 1681 1681 int backlog) 1682 1682 { 1683 socket_core_ refsocket;1683 socket_core_t *socket; 1684 1684 tcp_socket_data_t *socket_data; 1685 1685 … … 1707 1707 struct sockaddr *addr, socklen_t addrlen) 1708 1708 { 1709 socket_core_ refsocket;1709 socket_core_t *socket; 1710 1710 int rc; 1711 1711 … … 1732 1732 } 1733 1733 1734 int tcp_connect_core(socket_core_ refsocket, socket_cores_ref local_sockets,1734 int tcp_connect_core(socket_core_t *socket, socket_cores_ref local_sockets, 1735 1735 struct sockaddr *addr, socklen_t addrlen) 1736 1736 { … … 1823 1823 } 1824 1824 1825 int tcp_queue_prepare_packet(socket_core_ refsocket,1825 int tcp_queue_prepare_packet(socket_core_t *socket, 1826 1826 tcp_socket_data_t *socket_data, packet_t packet, size_t data_length) 1827 1827 { … … 1854 1854 } 1855 1855 1856 int tcp_queue_packet(socket_core_ refsocket, tcp_socket_data_t *socket_data,1856 int tcp_queue_packet(socket_core_t *socket, tcp_socket_data_t *socket_data, 1857 1857 packet_t packet, size_t data_length) 1858 1858 { … … 1876 1876 } 1877 1877 1878 packet_t tcp_get_packets_to_send(socket_core_ refsocket, tcp_socket_data_t *1878 packet_t tcp_get_packets_to_send(socket_core_t *socket, tcp_socket_data_t * 1879 1879 socket_data) 1880 1880 { … … 1936 1936 } 1937 1937 1938 packet_t tcp_send_prepare_packet(socket_core_ refsocket, tcp_socket_data_t *1938 packet_t tcp_send_prepare_packet(socket_core_t *socket, tcp_socket_data_t * 1939 1939 socket_data, packet_t packet, size_t data_length, size_t sequence_number) 1940 1940 { … … 1997 1997 } 1998 1998 1999 packet_t tcp_prepare_copy(socket_core_ refsocket, tcp_socket_data_t *1999 packet_t tcp_prepare_copy(socket_core_t *socket, tcp_socket_data_t * 2000 2000 socket_data, packet_t packet, size_t data_length, size_t sequence_number) 2001 2001 { … … 2027 2027 } 2028 2028 2029 void tcp_prepare_operation_header(socket_core_ refsocket,2029 void tcp_prepare_operation_header(socket_core_t *socket, 2030 2030 tcp_socket_data_t *socket_data, tcp_header_t *header, int synchronize, 2031 2031 int finalize) … … 2045 2045 2046 2046 int tcp_prepare_timeout(int (*timeout_function)(void *tcp_timeout_t), 2047 socket_core_ refsocket, tcp_socket_data_t *socket_data,2047 socket_core_t *socket, tcp_socket_data_t *socket_data, 2048 2048 size_t sequence_number, tcp_socket_state_t state, suseconds_t timeout, 2049 2049 int globals_read_only) … … 2094 2094 int flags, size_t *addrlen) 2095 2095 { 2096 socket_core_ refsocket;2096 socket_core_t *socket; 2097 2097 tcp_socket_data_t *socket_data; 2098 2098 int packet_id; … … 2152 2152 int fragments, size_t *data_fragment_size, int flags) 2153 2153 { 2154 socket_core_ refsocket;2154 socket_core_t *socket; 2155 2155 tcp_socket_data_t *socket_data; 2156 2156 packet_dimension_t *packet_dimension; … … 2227 2227 tcp_close_message(socket_cores_ref local_sockets, int socket_id) 2228 2228 { 2229 socket_core_ refsocket;2229 socket_core_t *socket; 2230 2230 tcp_socket_data_t *socket_data; 2231 2231 packet_t packet; … … 2293 2293 } 2294 2294 2295 int tcp_create_notification_packet(packet_t *packet, socket_core_ refsocket,2295 int tcp_create_notification_packet(packet_t *packet, socket_core_t *socket, 2296 2296 tcp_socket_data_t *socket_data, int synchronize, int finalize) 2297 2297 { … … 2330 2330 int new_socket_id, size_t *data_fragment_size, size_t *addrlen) 2331 2331 { 2332 socket_core_ refaccepted;2333 socket_core_ refsocket;2332 socket_core_t *accepted; 2333 socket_core_t *socket; 2334 2334 tcp_socket_data_t *socket_data; 2335 2335 packet_dimension_t *packet_dimension; … … 2400 2400 } 2401 2401 2402 void tcp_free_socket_data(socket_core_ refsocket)2402 void tcp_free_socket_data(socket_core_t *socket) 2403 2403 { 2404 2404 tcp_socket_data_t *socket_data;
Note:
See TracChangeset
for help on using the changeset viewer.