Lines Matching refs:tcp_socket_t
117 } tcp_socket_t; typedef
140 static tcp_socket_t *lookup_socket(ipv4_addr remote_ip, ipv4_addr local_ip, uint16_t remote_port, u…
141 static void add_socket_to_list(tcp_socket_t *s);
142 static void remove_socket_from_list(tcp_socket_t *s);
143 static tcp_socket_t *create_tcp_socket(bool alloc_buffers);
146 static status_t tcp_socket_send(tcp_socket_t *s, const void *data, size_t len, tcp_flags_t flags, c…
147 static void handle_data(tcp_socket_t *s, const void *data, size_t len, uint32_t sequence);
148 static void send_ack(tcp_socket_t *s);
149 static void handle_ack(tcp_socket_t *s, uint32_t sequence, uint32_t win_size);
153 static void tcp_remote_close(tcp_socket_t *s);
154 static void tcp_wakeup_waiters(tcp_socket_t *s);
155 static void inc_socket_ref(tcp_socket_t *s);
156 static bool dec_socket_ref(tcp_socket_t *s);
203 static void dump_socket(tcp_socket_t *s) { in dump_socket()
218 static tcp_socket_t *lookup_socket(ipv4_addr remote_ip, ipv4_addr local_ip, uint16_t remote_port, u… in lookup_socket()
224 tcp_socket_t *s = NULL; in lookup_socket()
225 list_for_every_entry(&tcp_socket_list, s, tcp_socket_t, node) { in lookup_socket()
240 list_for_every_entry(&tcp_socket_list, s, tcp_socket_t, node) { in lookup_socket()
262 static void add_socket_to_list(tcp_socket_t *s) { in add_socket_to_list()
273 static void remove_socket_from_list(tcp_socket_t *s) { in remove_socket_from_list()
285 static void inc_socket_ref(tcp_socket_t *s) { in inc_socket_ref()
293 static bool dec_socket_ref(tcp_socket_t *s) { in dec_socket_ref()
312 static void tcp_timer_set(tcp_socket_t *s, net_timer_t *timer, net_timer_callback_t cb, lk_time_t d… in tcp_timer_set()
320 static void tcp_timer_cancel(tcp_socket_t *s, net_timer_t *timer) { in tcp_timer_cancel()
383 tcp_socket_t *s = lookup_socket(src_ip, dst_ip, header->source_port, header->dest_port); in tcp_input()
423 tcp_socket_t *accept_socket = create_tcp_socket(true); in tcp_input()
591 static void handle_data(tcp_socket_t *s, const void *data, size_t len, uint32_t sequence) { in handle_data()
640 static status_t tcp_socket_send(tcp_socket_t *s, const void *data, size_t len, tcp_flags_t flags, in tcp_socket_send()
675 static void send_ack(tcp_socket_t *s) { in send_ack()
737 static void handle_ack(tcp_socket_t *s, uint32_t sequence, uint32_t win_size) { in handle_ack()
780 static ssize_t tcp_write_pending_data(tcp_socket_t *s) { in tcp_write_pending_data()
812 static ssize_t tcp_retransmit(tcp_socket_t *s) { in tcp_retransmit()
833 tcp_socket_t *s = _s; in handle_retransmit_timeout()
852 tcp_socket_t *s = _s; in handle_delayed_ack_timeout()
865 tcp_socket_t *s = _s; in handle_time_wait_timeout()
883 static void tcp_wakeup_waiters(tcp_socket_t *s) { in tcp_wakeup_waiters()
892 static void tcp_remote_close(tcp_socket_t *s) { in tcp_remote_close()
910 static tcp_socket_t *create_tcp_socket(bool alloc_buffers) { in create_tcp_socket()
911 tcp_socket_t *s; in create_tcp_socket()
913 s = calloc(1, sizeof(tcp_socket_t)); in create_tcp_socket()
947 status_t tcp_open_listen(tcp_socket_t **handle, uint16_t port) { in tcp_open_listen()
948 tcp_socket_t *s; in tcp_open_listen()
971 status_t tcp_accept_timeout(tcp_socket_t *listen_socket, tcp_socket_t **accept_socket, lk_time_t ti… in tcp_accept_timeout()
975 tcp_socket_t *s = listen_socket; in tcp_accept_timeout()
997 ssize_t tcp_read(tcp_socket_t *socket, void *buf, size_t len) { in tcp_read()
1006 tcp_socket_t *s = socket; in tcp_read()
1051 ssize_t tcp_write(tcp_socket_t *socket, const void *buf, size_t len) { in tcp_write()
1060 tcp_socket_t *s = socket; in tcp_write()
1111 status_t tcp_close(tcp_socket_t *socket) { in tcp_close()
1115 tcp_socket_t *s = socket; in tcp_close()
1195 tcp_socket_t *s = NULL; in cmd_tcp()
1196 list_for_every_entry(&tcp_socket_list, s, tcp_socket_t, node) { in cmd_tcp()
1204 tcp_socket_t *handle = NULL; in cmd_tcp()
1209 tcp_socket_t *accepted; in cmd_tcp()
1221 tcp_socket_t *handle = NULL; in cmd_tcp()
1226 tcp_socket_t *accepted; in cmd_tcp()