| /subsys/net/lib/mqtt/ |
| A D | mqtt_transport_socket_tcp.c | 28 if (client->transport.tcp.sock < 0) { in mqtt_client_tcp_connect()
32 NET_DBG("Created socket %d", client->transport.tcp.sock); in mqtt_client_tcp_connect()
40 ret = zsock_setsockopt(client->transport.tcp.sock, SOL_SOCKET, in mqtt_client_tcp_connect()
54 ret = setsockopt(client->transport.tcp.sock, in mqtt_client_tcp_connect()
70 ret = zsock_connect(client->transport.tcp.sock, client->broker, in mqtt_client_tcp_connect()
80 (void)zsock_close(client->transport.tcp.sock); in mqtt_client_tcp_connect()
91 ret = zsock_send(client->transport.tcp.sock, data + offset, in mqtt_client_tcp_write()
116 ret = zsock_sendmsg(client->transport.tcp.sock, message, 0); in mqtt_client_tcp_write_msg()
153 ret = zsock_recv(client->transport.tcp.sock, data, buflen, flags); in mqtt_client_tcp_read()
165 NET_INFO("Closing socket %d", client->transport.tcp.sock); in mqtt_client_tcp_disconnect()
[all …]
|
| A D | mqtt_transport_websocket.c | 39 transport_sock = client->transport.tcp.sock; in mqtt_client_websocket_connect()
|
| /subsys/net/ip/ |
| A D | tcp.c | 248 const struct tcp *conn = ctx->tcp; in net_tcp_endpoint_copy()
830 ((struct tcp *)ctx->tcp)->test_closed_cb = cb; in tcp_install_close_cb()
3596 struct tcp *conn = context->tcp; in net_tcp_put()
3660 struct tcp *conn = context->tcp; in net_tcp_update_recv_wnd()
3680 struct tcp *conn = context->tcp; in net_tcp_queue()
3977 struct tcp *conn = context->tcp; in net_tcp_accept()
4061 struct tcp *conn = context->tcp; in net_tcp_recv()
4532 struct tcp *conn = context->tcp; in net_tcp_set_option()
4569 struct tcp *conn = context->tcp; in net_tcp_get_option()
4605 struct tcp *conn = context->tcp; in net_tcp_tx_sem_get()
[all …]
|
| A D | net_stats.c | 159 GET_STAT(iface, tcp.recv), in stats()
160 GET_STAT(iface, tcp.sent), in stats()
161 GET_STAT(iface, tcp.drop)); in stats()
163 GET_STAT(iface, tcp.resent), in stats()
164 GET_STAT(iface, tcp.chkerr), in stats()
165 GET_STAT(iface, tcp.ackerr)); in stats()
167 GET_STAT(iface, tcp.rsterr), in stats()
168 GET_STAT(iface, tcp.rst), in stats()
169 GET_STAT(iface, tcp.rexmit)); in stats()
171 GET_STAT(iface, tcp.conndrop), in stats()
[all …]
|
| A D | net_stats.h | 299 UPDATE_STAT(iface, stats.tcp.drop++); in net_stats_update_tcp_drop()
304 UPDATE_STAT(iface, stats.tcp.sent++); in net_stats_update_tcp_seg_sent()
309 UPDATE_STAT(iface, stats.tcp.recv++); in net_stats_update_tcp_seg_recv()
314 UPDATE_STAT(iface, stats.tcp.seg_drop++); in net_stats_update_tcp_seg_drop()
319 UPDATE_STAT(iface, stats.tcp.rst++); in net_stats_update_tcp_seg_rst()
324 UPDATE_STAT(iface, stats.tcp.conndrop++); in net_stats_update_tcp_seg_conndrop()
329 UPDATE_STAT(iface, stats.tcp.connrst++); in net_stats_update_tcp_seg_connrst()
334 UPDATE_STAT(iface, stats.tcp.chkerr++); in net_stats_update_tcp_seg_chkerr()
339 UPDATE_STAT(iface, stats.tcp.ackerr++); in net_stats_update_tcp_seg_ackerr()
344 UPDATE_STAT(iface, stats.tcp.rsterr++); in net_stats_update_tcp_seg_rsterr()
[all …]
|
| A D | tcp_internal.h | 49 uint16_t net_tcp_get_supported_mss(const struct tcp *conn);
51 static inline uint16_t net_tcp_get_supported_mss(const struct tcp *conn) in net_tcp_get_supported_mss()
66 static inline enum tcp_state net_tcp_get_state(const struct tcp *conn) in net_tcp_get_state()
71 static inline enum tcp_state net_tcp_get_state(const struct tcp *conn) in net_tcp_get_state()
|
| A D | tcp_private.h | 255 struct tcp;
256 typedef void (*net_tcp_closed_cb_t)(struct tcp *conn, void *user_data);
258 struct tcp { /* TCP connection */ struct
268 struct tcp *accepted_conn; argument
360 typedef void (*net_tcp_cb_t)(struct tcp *conn, void *user_data); argument
|
| A D | CMakeLists.txt | 48 zephyr_library_sources_ifdef(CONFIG_NET_TCP tcp.c)
|
| A D | ipv4.c | 411 proto_hdr.tcp = net_tcp_input(pkt, &tcp_access); in net_ipv4_input()
412 if (proto_hdr.tcp) { in net_ipv4_input()
|
| A D | connection.c | 894 if (proto_hdr->tcp == NULL) { in net_conn_input()
897 src_port = proto_hdr->tcp->src_port; in net_conn_input()
898 dst_port = proto_hdr->tcp->dst_port; in net_conn_input()
|
| A D | ipv6.c | 776 proto_hdr.tcp = net_tcp_input(pkt, &tcp_access); in net_ipv6_input()
777 if (proto_hdr.tcp) { in net_ipv6_input()
|
| A D | net_context.c | 175 const struct tcp *tcp_conn = context->tcp; in is_in_tcp_time_wait_state()
|
| A D | Kconfig | 449 source "subsys/net/ip/Kconfig.tcp"
|
| /subsys/net/lib/shell/ |
| A D | stats.c | 539 GET_STAT(iface, tcp.resent)); in net_shell_print_statistics()
541 GET_STAT(iface, tcp.recv), in net_shell_print_statistics()
542 GET_STAT(iface, tcp.sent), in net_shell_print_statistics()
543 GET_STAT(iface, tcp.seg_drop)); in net_shell_print_statistics()
545 GET_STAT(iface, tcp.rexmit), in net_shell_print_statistics()
546 GET_STAT(iface, tcp.chkerr), in net_shell_print_statistics()
547 GET_STAT(iface, tcp.ackerr)); in net_shell_print_statistics()
549 GET_STAT(iface, tcp.rsterr), in net_shell_print_statistics()
550 GET_STAT(iface, tcp.rst)); in net_shell_print_statistics()
552 GET_STAT(iface, tcp.conndrop), in net_shell_print_statistics()
[all …]
|
| A D | conn.c | 117 static void tcp_cb(struct tcp *conn, void *user_data) in tcp_cb()
135 static void tcp_sent_list_cb(struct tcp *conn, void *user_data) in tcp_sent_list_cb()
|
| A D | CMakeLists.txt | 35 zephyr_library_sources_ifdef(CONFIG_NET_SHELL_TCP_SUPPORTED tcp.c)
|
| A D | tcp.c | 415 SHELL_SUBCMD_ADD((net), tcp, &net_cmd_tcp,
|
| /subsys/logging/backends/ |
| A D | Kconfig.net | 92 If you want to use TCP, add "tcp://" in front of the address
94 tcp://192.0.2.1:514
95 tcp://192.0.2.42
96 tcp://[2001:db8::1]:514
|
| /subsys/shell/backends/ |
| A D | shell_mqtt.c | 87 sh->fds[0].fd = sh->mqtt_cli.transport.tcp.sock; in prepare_fds()
|
| /subsys/net/lib/zperf/ |
| A D | zperf_shell.c | 2079 SHELL_CMD(tcp, &zperf_cmd_tcp,
|