Home
last modified time | relevance | path

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

12

/components/net/lwip/lwip-2.1.2/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.c92 if (conn) { in altcp_tcp_connected()
95 return conn->connected(conn->arg, conn, err); in altcp_tcp_connected()
105 if (conn) { in altcp_tcp_recv()
108 return conn->recv(conn->arg, conn, p, err); in altcp_tcp_recv()
122 if (conn) { in altcp_tcp_sent()
125 return conn->sent(conn->arg, conn, len); in altcp_tcp_sent()
138 return conn->poll(conn->arg, conn); in altcp_tcp_poll()
151 conn->err(conn->arg, err); in altcp_tcp_err()
411 if (conn && conn->state) { in altcp_tcp_nagle_disable()
421 if (conn && conn->state) { in altcp_tcp_nagle_enable()
[all …]
/components/net/lwip/lwip-1.4.1/src/api/
A Dapi_msg.c88 if ((conn != NULL) && sys_mbox_valid(&conn->recvmbox)) { in recv_raw()
162 if ((conn == NULL) || !sys_mbox_valid(&conn->recvmbox) ||
165 if ((conn == NULL) || !sys_mbox_valid(&conn->recvmbox)) {
326 if (conn) {
446 newconn = netconn_alloc(conn->type, conn->callback);
503 raw_recv(msg->conn->pcb.raw, recv_raw, msg->conn);
521 udp_recv(msg->conn->pcb.udp, recv_udp, msg->conn);
817 tcp_arg(conn->pcb.tcp, conn);
1095 tcp_arg(msg->conn->pcb.tcp, msg->conn);
1224 conn->write_offset < conn->current_msg->msg.w.len);
[all …]
A Dapi_lib.c77 msg.msg.conn = conn; in netconn_new_with_proto_and_callback()
113 msg.msg.conn = conn; in netconn_delete()
145 msg.msg.conn = conn; in netconn_getaddr()
174 msg.msg.conn = conn; in netconn_bind()
200 msg.msg.conn = conn; in netconn_connect()
225 msg.msg.conn = conn; in netconn_disconnect()
253 msg.msg.conn = conn; in netconn_listen_with_backlog()
317 msg.msg.conn = conn; in netconn_accept()
576 msg.msg.conn = conn; in netconn_send()
619 msg.msg.conn = conn; in netconn_write_partly()
[all …]
A Dsockets.c66 struct netconn *conn; member
207 if (!sock->conn) { in get_socket()
228 if (!sockets[s].conn) { in tryget_socket()
893 err = sock->conn->last_err = udp_sendto(sock->conn->pcb.udp, p,
963 struct netconn *conn; local
985 if (conn != NULL) {
997 if (!conn) {
1010 conn->socket = i;
1271 if (conn) {
1272 s = conn->socket;
[all …]
/components/net/lwip/lwip-2.0.3/src/api/
A Dapi_msg.c110 if ((conn != NULL) && sys_mbox_valid(&conn->recvmbox)) { in recv_raw()
355 if (conn) {
501 newconn = netconn_alloc(conn->type, conn->callback);
578 raw_recv(msg->conn->pcb.raw, recv_raw, msg->conn);
594 udp_recv(msg->conn->pcb.udp, recv_udp, msg->conn);
721 return conn;
886 if ((conn->linger >= 0) && (conn->pcb.tcp->unsent || conn->pcb.tcp->unacked)) {
1361 tcp_arg(msg->conn->pcb.tcp, msg->conn);
1512 conn->write_offset < conn->current_msg->msg.w.len);
1528 conn->current_msg->msg.w.len = conn->write_offset;
[all …]
A Dapi_lib.c134 API_MSG_VAR_REF(msg).conn = conn; in netconn_new_with_proto_and_callback()
177 API_MSG_VAR_REF(msg).conn = conn; in netconn_delete()
222 API_MSG_VAR_REF(msg).conn = conn; in netconn_getaddr()
275 API_MSG_VAR_REF(msg).conn = conn; in netconn_bind()
309 API_MSG_VAR_REF(msg).conn = conn; in netconn_connect()
334 API_MSG_VAR_REF(msg).conn = conn; in netconn_disconnect()
363 API_MSG_VAR_REF(msg).conn = conn; in netconn_listen_with_backlog()
712 API_MSG_VAR_REF(msg).conn = conn; in netconn_send()
761 API_MSG_VAR_REF(msg).conn = conn; in netconn_write_partly()
811 API_MSG_VAR_REF(msg).conn = conn; in netconn_close_shutdown()
[all …]
A Dsockets.c207 struct netconn *conn; member
373 if (!sock->conn) { in get_socket()
395 if (!sockets[s].conn) { in tryget_socket()
1242 struct netconn *conn; in lwip_socket() local
1274 if (!conn) { in lwip_socket()
1283 netconn_delete(conn); in lwip_socket()
1287 conn->socket = i; in lwip_socket()
1607 if (conn) { in event_callback()
1608 s = conn->socket; in event_callback()
1618 conn->socket--; in event_callback()
[all …]
/components/net/lwip/lwip-2.1.2/src/api/
A Dapi_msg.c169 if ((conn != NULL) && NETCONN_MBOX_VALID(conn, &conn->recvmbox)) { in recv_raw()
242 if (!NETCONN_MBOX_VALID(conn, &conn->recvmbox) ||
245 if (!NETCONN_MBOX_VALID(conn, &conn->recvmbox)) {
311 if (!NETCONN_MBOX_VALID(conn, &conn->recvmbox)) {
405 if (conn) {
466 if (NETCONN_MBOX_VALID(conn, &conn->recvmbox)) {
471 if (NETCONN_MBOX_VALID(conn, &conn->acceptmbox)) {
541 if (!NETCONN_MBOX_VALID(conn, &conn->acceptmbox)) {
561 newconn = netconn_alloc(conn->type, conn->callback);
981 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.c464 if (sock->conn) { in tryget_socket()
483 if (sock->conn) { in lwip_tryget_socket()
586 *conn = sock->conn; in free_socket_locked()
587 sock->conn = NULL; in free_socket_locked()
603 if (conn != NULL) { in free_socket_free_elements()
619 struct netconn *conn; in free_socket() local
1729 if (conn) { in lwip_socket()
1747 if (!conn) { in lwip_socket()
1760 conn->socket = i; in lwip_socket()
2508 if (conn) { in event_callback()
[all …]
/components/net/lwip/lwip-2.1.2/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 …]
/components/net/lwip/lwip-2.0.3/src/apps/lwiperf/
A Dlwiperf.c203 if ((conn != NULL) && (conn->report_fn != NULL)) { in lwip_tcp_conn_report()
212 conn->report_fn(conn->report_arg, report_type, in lwip_tcp_conn_report()
213 &conn->conn_pcb->local_ip, conn->conn_pcb->local_port, in lwip_tcp_conn_report()
214 &conn->conn_pcb->remote_ip, conn->conn_pcb->remote_port, in lwip_tcp_conn_report()
257 LWIP_ASSERT("conn invalid", (conn != NULL) && conn->base.tcp && (conn->base.server == 0)); in lwiperf_tcp_client_send_more()
285 txptr = &((u8_t*)&conn->settings)[conn->bytes_transferred]; in lwiperf_tcp_client_send_more()
290 txptr = &((u8_t*)&conn->settings)[conn->bytes_transferred - 24]; in lwiperf_tcp_client_send_more()
334 conn->poll_count = 0; in lwiperf_tcp_client_sent()
350 conn->poll_count = 0; in lwiperf_tcp_client_connected()
546 if (conn == NULL) { in lwiperf_tcp_accept()
[all …]
/components/net/lwip/lwip-1.4.1/src/include/lwip/
A Dapi.h206 (conn)->last_err = err; \
219 #define netconn_type(conn) (conn->type) argument
230 #define netconn_listen(conn) netconn_listen_with_backlog(conn, TCP_DEFAULT_LISTEN_BACKLOG) argument
253 #define netconn_err(conn) ((conn)->last_err) argument
254 #define netconn_recv_bufsize(conn) ((conn)->recv_bufsize) argument
274 #define netconn_set_sendtimeout(conn, timeout) ((conn)->send_timeout = (timeout)) argument
276 #define netconn_get_sendtimeout(conn) ((conn)->send_timeout) argument
280 #define netconn_set_recvtimeout(conn, timeout) ((conn)->recv_timeout = (timeout)) argument
282 #define netconn_get_recvtimeout(conn) ((conn)->recv_timeout) argument
286 #define netconn_set_recvbufsize(conn, recvbufsize) ((conn)->recv_bufsize = (recvbufsize)) argument
[all …]
/components/net/lwip/lwip-2.1.2/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);
124 err_t altcp_default_output(struct altcp_pcb *conn);
125 u16_t altcp_default_mss(struct altcp_pcb *conn);
126 u16_t altcp_default_sndbuf(struct altcp_pcb *conn);
127 u16_t altcp_default_sndqueuelen(struct altcp_pcb *conn);
[all …]
/components/net/lwip/lwip-2.1.2/src/include/lwip/
A Dapi.h317 #define netconn_type(conn) (conn->type) argument
332 #define netconn_listen(conn) netconn_listen_with_backlog(conn, TCP_DEFAULT_LISTEN_BACKLOG) 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
400 #define netconn_set_sendtimeout(conn, timeout) ((conn)->send_timeout = (timeout)) argument
402 #define netconn_get_sendtimeout(conn) ((conn)->send_timeout) argument
406 #define netconn_set_recvtimeout(conn, timeout) ((conn)->recv_timeout = (timeout)) argument
408 #define netconn_get_recvtimeout(conn) ((conn)->recv_timeout) argument
[all …]
A Daltcp.h95 void altcp_arg(struct altcp_pcb *conn, void *arg);
108 #define altcp_listen_with_backlog(conn, backlog) altcp_listen_with_backlog_and_err(conn, backlog, N… argument
110 #define altcp_listen(conn) altcp_listen_with_backlog_and_err(conn, TCP_DEFAULT_LISTEN_BACKLOG, NULL) argument
112 void altcp_abort(struct altcp_pcb *conn);
113 err_t altcp_close(struct altcp_pcb *conn);
117 err_t altcp_output(struct altcp_pcb *conn);
119 u16_t altcp_mss(struct altcp_pcb *conn);
120 u16_t altcp_sndbuf(struct altcp_pcb *conn);
121 u16_t altcp_sndqueuelen(struct altcp_pcb *conn);
122 void altcp_nagle_disable(struct altcp_pcb *conn);
[all …]
/components/net/lwip/lwip-2.1.2/src/apps/lwiperf/
A Dlwiperf.c231 if ((conn != NULL) && (conn->report_fn != NULL)) { in lwip_tcp_conn_report()
240 conn->report_fn(conn->report_arg, report_type, in lwip_tcp_conn_report()
241 &conn->conn_pcb->local_ip, conn->conn_pcb->local_port, in lwip_tcp_conn_report()
242 &conn->conn_pcb->remote_ip, conn->conn_pcb->remote_port, in lwip_tcp_conn_report()
285 LWIP_ASSERT("conn invalid", (conn != NULL) && conn->base.tcp && (conn->base.server == 0)); in lwiperf_tcp_client_send_more()
313 txptr = &((u8_t *)&conn->settings)[conn->bytes_transferred]; in lwiperf_tcp_client_send_more()
318 txptr = &((u8_t *)&conn->settings)[conn->bytes_transferred - 24]; in lwiperf_tcp_client_send_more()
362 conn->poll_count = 0; in lwiperf_tcp_client_sent()
445 …ret = lwiperf_tx_start_impl(&conn->conn_pcb->remote_ip, remote_port, &conn->settings, conn->report… in lwiperf_tx_start_passive()
614 if (conn == NULL) { in lwiperf_tcp_accept()
[all …]
/components/net/lwip/lwip-2.0.3/src/include/lwip/
A Dapi.h279 #define NETCONN_SET_SAFE_ERR(conn, err) do { if ((conn) != NULL) { \ argument
283 (conn)->last_err = err; \
299 #define netconn_type(conn) (conn->type) argument
313 #define netconn_listen(conn) netconn_listen_with_backlog(conn, TCP_DEFAULT_LISTEN_BACKLOG) argument
342 #define netconn_err(conn) ((conn)->last_err) argument
343 #define netconn_recv_bufsize(conn) ((conn)->recv_bufsize) argument
369 #define netconn_set_sendtimeout(conn, timeout) ((conn)->send_timeout = (timeout)) argument
371 #define netconn_get_sendtimeout(conn) ((conn)->send_timeout) argument
375 #define netconn_set_recvtimeout(conn, timeout) ((conn)->recv_timeout = (timeout)) argument
377 #define netconn_get_recvtimeout(conn) ((conn)->recv_timeout) argument
[all …]
/components/net/lwip/lwip-2.1.2/src/apps/altcp_tls/
A Daltcp_tls_mbedtls.c155 if (conn && conn->state) { in altcp_mbedtls_lower_connected()
160 return conn->connected(conn->arg, conn, err); in altcp_mbedtls_lower_connected()
226 return conn->recv(conn->arg, conn, NULL, ERR_OK); in altcp_mbedtls_lower_recv()
231 conn->err(conn->arg, ERR_CLSD); in altcp_mbedtls_lower_recv()
287 err = conn->connected(conn->arg, conn, ERR_OK); in altcp_mbedtls_lower_recv_process()
316 err = conn->recv(conn->arg, conn, buf, ERR_OK); in altcp_mbedtls_pass_rx_data()
338 return conn->recv(conn->arg, conn, NULL, ERR_OK); in altcp_mbedtls_pass_rx_data()
508 return conn->sent(conn->arg, conn, 0); in altcp_mbedtls_lower_sent()
535 return conn->poll(conn->arg, conn); in altcp_mbedtls_lower_poll()
548 conn->err(conn->arg, err); in altcp_mbedtls_lower_err()
[all …]
/components/net/lwip/lwip-2.0.3/src/apps/snmp/
A Dsnmp_netconn.c50 struct netconn *conn; in snmp_netconn_thread() local
57 conn = netconn_new(NETCONN_UDP_IPV6); in snmp_netconn_thread()
58 netconn_bind(conn, IP6_ADDR_ANY, SNMP_IN_PORT); in snmp_netconn_thread()
60 conn = netconn_new(NETCONN_UDP); in snmp_netconn_thread()
61 netconn_bind(conn, IP4_ADDR_ANY, SNMP_IN_PORT); in snmp_netconn_thread()
63 LWIP_ERROR("snmp_netconn: invalid conn", (conn != NULL), return;); in snmp_netconn_thread()
65 snmp_traps_handle = conn; in snmp_netconn_thread()
68 err = netconn_recv(conn, &buf); in snmp_netconn_thread()
71 snmp_receive(conn, buf->p, &buf->addr, buf->port); in snmp_netconn_thread()
96 struct netconn* conn = (struct netconn*)handle; in snmp_get_local_ip_for_dst() local
[all …]
/components/net/lwip/lwip-2.1.2/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 …]
/components/net/lwip/lwip-2.1.2/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()
/components/net/sal/impl/
A Daf_inet_lwip.c56 struct netconn *conn; member
86 static void event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len) in event_callback() argument
96 if (conn) in event_callback()
98 s = conn->socket; in event_callback()
107 if (conn->socket < 0) in event_callback()
111 conn->socket--; in event_callback()
116 s = conn->socket; in event_callback()
186 lwsock->conn->callback = event_callback; in inet_socket()
/components/net/lwip/lwip-2.0.3/src/apps/mqtt/
A Dmqtt.c511 if (client->conn != NULL) { in mqtt_close()
513 tcp_recv(client->conn, NULL); in mqtt_close()
514 tcp_err(client->conn, NULL); in mqtt_close()
515 tcp_sent(client->conn, NULL); in mqtt_close()
518 tcp_abort(client->conn); in mqtt_close()
521 client->conn = NULL; in mqtt_close()
944 client->conn = 0; in mqtt_tcp_err_cb()
1261 client->conn = tcp_new(); in mqtt_client_connect()
1262 if (client->conn == NULL) { in mqtt_client_connect()
1306 tcp_abort(client->conn); in mqtt_client_connect()
[all …]

Completed in 76 milliseconds

12