Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 25 of 26) sorted by relevance

12

/lib/lwip/lwip/src/core/
A Daltcp.c293 if (conn && conn->fns && conn->fns->recved) { in altcp_recved()
305 if (conn && conn->fns && conn->fns->bind) { in altcp_bind()
318 if (conn && conn->fns && conn->fns->connect) { in altcp_connect()
331 if (conn && conn->fns && conn->fns->listen) { in altcp_listen_with_backlog_and_err()
344 if (conn && conn->fns && conn->fns->abort) { in altcp_abort()
356 if (conn && conn->fns && conn->fns->close) { in altcp_close()
382 if (conn && conn->fns && conn->fns->write) { in altcp_write()
395 if (conn && conn->fns && conn->fns->output) { in altcp_output()
408 if (conn && conn->fns && conn->fns->mss) { in altcp_mss()
421 if (conn && conn->fns && conn->fns->sndbuf) { in altcp_sndbuf()
[all …]
A Daltcp_tcp.c94 if (conn) { in altcp_tcp_connected()
97 return conn->connected(conn->arg, conn, err); in altcp_tcp_connected()
110 return conn->recv(conn->arg, conn, p, err); in altcp_tcp_recv()
127 return conn->sent(conn->arg, conn, len); in altcp_tcp_sent()
140 return conn->poll(conn->arg, conn); in altcp_tcp_poll()
153 conn->err(conn->arg, err); in altcp_tcp_err()
417 if (conn && conn->state) { in altcp_tcp_nagle_disable()
427 if (conn && conn->state) { in altcp_tcp_nagle_enable()
437 if (conn && conn->state) { in altcp_tcp_nagle_disabled()
459 if (conn && conn->state) { in altcp_tcp_keepalive_disable()
[all …]
/lib/lwip/lwip/src/api/
A Dapi_msg.c169 if ((conn != NULL) && NETCONN_MBOX_VALID(conn, &conn->recvmbox)) { in recv_raw()
243 if (!NETCONN_MBOX_VALID(conn, &conn->recvmbox) ||
246 if (!NETCONN_MBOX_VALID(conn, &conn->recvmbox)) {
314 if (!NETCONN_MBOX_VALID(conn, &conn->recvmbox)) {
408 if (conn) {
469 if (NETCONN_MBOX_VALID(conn, &conn->recvmbox)) {
474 if (NETCONN_MBOX_VALID(conn, &conn->acceptmbox)) {
544 if (!NETCONN_MBOX_VALID(conn, &conn->acceptmbox)) {
564 newconn = netconn_alloc(conn->type, conn->callback);
985 if ((conn->linger >= 0) && (conn->pcb.tcp->unsent || conn->pcb.tcp->unacked)) {
[all …]
A Dapi_lib.c160 API_MSG_VAR_REF(msg).conn = conn; in netconn_new_with_proto_and_callback()
203 API_MSG_VAR_REF(msg).conn = conn; in netconn_prepare_delete()
279 API_MSG_VAR_REF(msg).conn = conn; in netconn_getaddr()
332 API_MSG_VAR_REF(msg).conn = conn; in netconn_bind()
359 API_MSG_VAR_REF(msg).conn = conn; in netconn_bind_if()
392 API_MSG_VAR_REF(msg).conn = conn; in netconn_connect()
417 API_MSG_VAR_REF(msg).conn = conn; in netconn_disconnect()
446 API_MSG_VAR_REF(msg).conn = conn; in netconn_listen_with_backlog()
682 msg->conn = conn; in netconn_tcp_recvd_msg()
951 API_MSG_VAR_REF(msg).conn = conn; in netconn_send()
[all …]
A Dsockets.c503 if (sock->conn) { in tryget_socket()
603 *conn = sock->conn; in free_socket_locked()
604 sock->conn = NULL; in free_socket_locked()
620 if (conn != NULL) { in free_socket_free_elements()
622 netconn_delete(conn); in free_socket_free_elements()
636 struct netconn *conn; in free_socket() local
1067 LWIP_UNUSED_ARG(conn); in lwip_sock_make_addr()
1725 struct netconn *conn; in lwip_socket() local
1745 if (conn) { in lwip_socket()
1763 if (!conn) { in lwip_socket()
[all …]
/lib/lwip/lwip/src/apps/http/
A Daltcp_proxyconnect.c164 if (conn && conn->state) { in altcp_proxyconnect_lower_connected()
170 if (conn->connected(conn->arg, conn, err) == ERR_ABRT) { in altcp_proxyconnect_lower_connected()
195 if (!conn) { in altcp_proxyconnect_lower_recv()
216 return conn->recv(conn->arg, conn, p, err); in altcp_proxyconnect_lower_recv()
238 return conn->connected(conn->arg, conn, ERR_OK); in altcp_proxyconnect_lower_recv()
255 if (conn) { in altcp_proxyconnect_lower_sent()
265 return conn->sent(conn->arg, conn, len); in altcp_proxyconnect_lower_sent()
279 if (conn) { in altcp_proxyconnect_lower_poll()
283 return conn->poll(conn->arg, conn); in altcp_proxyconnect_lower_poll()
293 if (conn) { in altcp_proxyconnect_lower_err()
[all …]
/lib/lwip/lwip/contrib/apps/shell/
A Dshell.c70 struct netconn *conn; member
219 sendstr(":", com->conn); in com_open()
221 sendstr(NEWLINE, com->conn); in com_open()
275 sendstr(NEWLINE, com->conn); in com_lstn()
614 sendstr(":", com->conn); in com_udpc()
697 sendstr(":", com->conn); in com_udpl()
780 sendstr(":", com->conn); in com_udpn()
1164 sendstr("> ", conn); in prompt()
1204 com.conn = conn; in shell_main()
1223 prompt(conn); in shell_main()
[all …]
/lib/lwip/lwip/src/apps/lwiperf/
A Dlwiperf.c232 if ((conn != NULL) && (conn->report_fn != NULL)) { in lwip_tcp_conn_report()
241 conn->report_fn(conn->report_arg, report_type, in lwip_tcp_conn_report()
242 &conn->conn_pcb->local_ip, conn->conn_pcb->local_port, in lwip_tcp_conn_report()
243 &conn->conn_pcb->remote_ip, conn->conn_pcb->remote_port, in lwip_tcp_conn_report()
286 LWIP_ASSERT("conn invalid", (conn != NULL) && conn->base.tcp && (conn->base.server == 0)); in lwiperf_tcp_client_send_more()
314 txptr = &((u8_t *)&conn->settings)[conn->bytes_transferred]; in lwiperf_tcp_client_send_more()
319 txptr = &((u8_t *)&conn->settings)[conn->bytes_transferred - 24]; in lwiperf_tcp_client_send_more()
363 conn->poll_count = 0; in lwiperf_tcp_client_sent()
446 …ret = lwiperf_tx_start_impl(&conn->conn_pcb->remote_ip, remote_port, &conn->settings, conn->report… in lwiperf_tx_start_passive()
620 if (conn == NULL) { in lwiperf_tcp_accept()
[all …]
/lib/lwip/lwip/src/include/lwip/priv/
A Daltcp_priv.h56 void altcp_free(struct altcp_pcb *conn);
66 typedef void (*altcp_abort_fn)(struct altcp_pcb *conn);
67 typedef err_t (*altcp_close_fn)(struct altcp_pcb *conn);
71 typedef err_t (*altcp_output_fn)(struct altcp_pcb *conn);
73 typedef u16_t (*altcp_mss_fn)(struct altcp_pcb *conn);
74 typedef u16_t (*altcp_sndbuf_fn)(struct altcp_pcb *conn);
133 err_t altcp_default_output(struct altcp_pcb *conn);
134 u16_t altcp_default_mss(struct altcp_pcb *conn);
135 u16_t altcp_default_sndbuf(struct altcp_pcb *conn);
136 u16_t altcp_default_sndqueuelen(struct altcp_pcb *conn);
[all …]
A Dapi_msg.h82 struct netconn *conn; member
160 #define LWIP_API_MSG_SEM(msg) (&(msg)->conn->op_completed)
220 void netconn_free(struct netconn *conn);
A Dsockets_priv.h69 struct netconn *conn; member
/lib/lwip/lwip/src/include/lwip/
A Dapi.h317 #define netconn_type(conn) (conn->type) argument
370 #define netconn_recv_bufsize(conn) ((conn)->recv_bufsize) argument
372 #define netconn_set_flags(conn, set_flags) do { (conn)->flags = (u8_t)((conn)->flags | (set_fl… argument
373 #define netconn_clear_flags(conn, clr_flags) do { (conn)->flags = (u8_t)((conn)->flags & (u8_t)(~… argument
374 #define netconn_is_flag_set(conn, flag) (((conn)->flags & (flag)) != 0) argument
377 #define netconn_get_callback_arg(conn) ((conn)->callback_arg.ptr) argument
403 #define netconn_set_sendtimeout(conn, timeout) ((conn)->send_timeout = (timeout)) argument
405 #define netconn_get_sendtimeout(conn) ((conn)->send_timeout) argument
409 #define netconn_set_recvtimeout(conn, timeout) ((conn)->recv_timeout = (timeout)) argument
411 #define netconn_get_recvtimeout(conn) ((conn)->recv_timeout) argument
[all …]
A Daltcp.h96 void altcp_arg(struct altcp_pcb *conn, void *arg);
109 #define altcp_listen_with_backlog(conn, backlog) altcp_listen_with_backlog_and_err(conn, backlog, N… argument
111 #define altcp_listen(conn) altcp_listen_with_backlog_and_err(conn, TCP_DEFAULT_LISTEN_BACKLOG, NULL) argument
113 void altcp_abort(struct altcp_pcb *conn);
114 err_t altcp_close(struct altcp_pcb *conn);
118 err_t altcp_output(struct altcp_pcb *conn);
120 u16_t altcp_mss(struct altcp_pcb *conn);
121 u16_t altcp_sndbuf(struct altcp_pcb *conn);
122 u16_t altcp_sndqueuelen(struct altcp_pcb *conn);
123 void altcp_nagle_disable(struct altcp_pcb *conn);
[all …]
A Daltcp_tls.h151 void *altcp_tls_context(struct altcp_pcb *conn);
175 err_t altcp_tls_get_session(struct altcp_pcb *conn, struct altcp_tls_session *dest);
182 err_t altcp_tls_set_session(struct altcp_pcb *conn, struct altcp_tls_session *from);
/lib/lwip/lwip/src/apps/altcp_tls/
A Daltcp_tls_mbedtls.c183 if (conn && conn->state) { in altcp_mbedtls_lower_connected()
189 return conn->connected(conn->arg, conn, err); in altcp_mbedtls_lower_connected()
258 return conn->recv(conn->arg, conn, NULL, ERR_OK); in altcp_mbedtls_lower_recv()
263 conn->err(conn->arg, ERR_ABRT); in altcp_mbedtls_lower_recv()
323 err = conn->connected(conn->arg, conn, ERR_OK); in altcp_mbedtls_lower_recv_process()
352 err = conn->recv(conn->arg, conn, buf, ERR_OK); in altcp_mbedtls_pass_rx_data()
374 return conn->recv(conn->arg, conn, NULL, ERR_OK); in altcp_mbedtls_pass_rx_data()
555 return conn->sent(conn->arg, conn, app_len); in altcp_mbedtls_lower_sent()
582 return conn->poll(conn->arg, conn); in altcp_mbedtls_lower_poll()
595 conn->err(conn->arg, err); in altcp_mbedtls_lower_err()
[all …]
/lib/lwip/lwip/contrib/apps/httpserver/
A Dhttpserver-netconn.c28 err = netconn_recv(conn, &inbuf); in http_server_netconn_serve()
53 netconn_close(conn); in http_server_netconn_serve()
64 struct netconn *conn, *newconn; in http_server_netconn_thread() local
71 conn = netconn_new(NETCONN_TCP_IPV6); in http_server_netconn_thread()
72 netconn_bind(conn, IP6_ADDR_ANY, 80); in http_server_netconn_thread()
74 conn = netconn_new(NETCONN_TCP); in http_server_netconn_thread()
75 netconn_bind(conn, IP_ADDR_ANY, 80); in http_server_netconn_thread()
80 netconn_listen(conn); in http_server_netconn_thread()
83 err = netconn_accept(conn, &newconn); in http_server_netconn_thread()
92 netconn_close(conn); in http_server_netconn_thread()
[all …]
/lib/lwip/lwip/src/apps/snmp/
A Dsnmp_netconn.c51 struct netconn *conn; in snmp_netconn_thread() local
58 conn = netconn_new(NETCONN_UDP_IPV6); in snmp_netconn_thread()
59 netconn_bind(conn, IP6_ADDR_ANY, LWIP_IANA_PORT_SNMP); in snmp_netconn_thread()
61 conn = netconn_new(NETCONN_UDP); in snmp_netconn_thread()
62 netconn_bind(conn, IP4_ADDR_ANY, LWIP_IANA_PORT_SNMP); in snmp_netconn_thread()
64 LWIP_ERROR("snmp_netconn: invalid conn", (conn != NULL), return;); in snmp_netconn_thread()
66 snmp_traps_handle = conn; in snmp_netconn_thread()
69 err = netconn_recv(conn, &buf); in snmp_netconn_thread()
72 snmp_receive(conn, buf->p, &buf->addr, buf->port); in snmp_netconn_thread()
97 struct netconn *conn = (struct netconn *)handle; in snmp_get_local_ip_for_dst() local
[all …]
/lib/lwip/lwip/contrib/apps/udpecho/
A Dudpecho.c46 struct netconn *conn; in udpecho_thread() local
53 conn = netconn_new(NETCONN_UDP_IPV6); in udpecho_thread()
54 LWIP_ERROR("udpecho: invalid conn", (conn != NULL), return;); in udpecho_thread()
55 netconn_bind(conn, IP6_ADDR_ANY, 7); in udpecho_thread()
57 conn = netconn_new(NETCONN_UDP); in udpecho_thread()
58 LWIP_ERROR("udpecho: invalid conn", (conn != NULL), return;); in udpecho_thread()
59 netconn_bind(conn, IP_ADDR_ANY, 7); in udpecho_thread()
63 err = netconn_recv(conn, &buf); in udpecho_thread()
70 err = netconn_send(conn, buf); in udpecho_thread()
/lib/lwip/lwip/contrib/apps/tcpecho/
A Dtcpecho.c44 struct netconn *conn, *newconn; in tcpecho_thread() local
51 conn = netconn_new(NETCONN_TCP_IPV6); in tcpecho_thread()
52 netconn_bind(conn, IP6_ADDR_ANY, 7); in tcpecho_thread()
54 conn = netconn_new(NETCONN_TCP); in tcpecho_thread()
55 netconn_bind(conn, IP_ADDR_ANY, 7); in tcpecho_thread()
57 LWIP_ERROR("tcpecho: invalid conn", (conn != NULL), return;); in tcpecho_thread()
60 netconn_listen(conn); in tcpecho_thread()
65 err = netconn_accept(conn, &newconn); in tcpecho_thread()
/lib/lwip/lwip/test/unit/mqtt/
A Dtest_mqtt.c93 client->conn->connected(client->conn->callback_arg, client->conn, ERR_OK); in START_TEST()
98 client->conn->rcv_wnd -= p->tot_len; in START_TEST()
99 if (client->conn->recv(client->conn->callback_arg, client->conn, p, ERR_OK) != ERR_OK) { in START_TEST()
/lib/lwip/lwip/src/apps/mqtt/
A Dmqtt.c542 if (client->conn != NULL) { in mqtt_close()
544 altcp_recv(client->conn, NULL); in mqtt_close()
545 altcp_err(client->conn, NULL); in mqtt_close()
546 altcp_sent(client->conn, NULL); in mqtt_close()
549 altcp_abort(client->conn); in mqtt_close()
552 client->conn = NULL; in mqtt_close()
1023 client->conn = NULL; in mqtt_tcp_err_cb()
1390 if (client->conn == NULL) { in mqtt_client_connect()
1395 altcp_arg(client->conn, client); in mqtt_client_connect()
1442 altcp_abort(client->conn); in mqtt_client_connect()
[all …]
/lib/efi_loader/
A Defi_variable_tee.c57 static int get_connection(struct mm_connection *conn) in get_connection() argument
80 conn->tee = tee; in get_connection()
81 conn->session = arg.session; in get_connection()
100 struct mm_connection conn = { NULL, 0 }; in optee_mm_communicate() local
115 rc = get_connection(&conn); in optee_mm_communicate()
121 if (tee_shm_register(conn.tee, comm_buf, buf_size, 0, &shm)) { in optee_mm_communicate()
123 tee_close_session(conn.tee, conn.session); in optee_mm_communicate()
129 arg.session = conn.session; in optee_mm_communicate()
137 rc = tee_invoke_func(conn.tee, &arg, 2, param); in optee_mm_communicate()
139 tee_close_session(conn.tee, conn.session); in optee_mm_communicate()
/lib/lwip/lwip/contrib/addons/tcp_md5/
A Dtcp_md5.c484 …if (sock->conn && (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) && (sock->conn->pcb… in tcp_md5_setsockopt_hook()
517 … tcp_ext_arg_set_callbacks(sock->conn->pcb.tcp, tcp_md5_extarg_id, &tcp_md5_ext_arg_callbacks); in tcp_md5_setsockopt_hook()
518 … info->next = (struct tcp_md5_conn_info *)tcp_ext_arg_get(sock->conn->pcb.tcp, tcp_md5_extarg_id); in tcp_md5_setsockopt_hook()
519 tcp_ext_arg_set(sock->conn->pcb.tcp, tcp_md5_extarg_id, info); in tcp_md5_setsockopt_hook()
/lib/lwip/lwip/src/include/lwip/apps/
A Dmqtt_priv.h82 struct altcp_pcb *conn; member
/lib/lwip/lwip/test/unit/api/
A Dtest_sockets.c775 struct netconn *sact_conn = sact_sock->conn; in START_TEST()

Completed in 79 milliseconds

12