Lines Matching refs:conn
70 struct netconn *conn; in netconn_new_with_proto_and_callback() local
73 conn = netconn_alloc(t, callback); in netconn_new_with_proto_and_callback()
74 if (conn != NULL) { in netconn_new_with_proto_and_callback()
77 msg.msg.conn = conn; in netconn_new_with_proto_and_callback()
79 LWIP_ASSERT("freeing conn without freeing pcb", conn->pcb.tcp == NULL); in netconn_new_with_proto_and_callback()
80 LWIP_ASSERT("conn has no op_completed", sys_sem_valid(&conn->op_completed)); in netconn_new_with_proto_and_callback()
81 LWIP_ASSERT("conn has no recvmbox", sys_mbox_valid(&conn->recvmbox)); in netconn_new_with_proto_and_callback()
83 LWIP_ASSERT("conn->acceptmbox shouldn't exist", !sys_mbox_valid(&conn->acceptmbox)); in netconn_new_with_proto_and_callback()
85 sys_sem_free(&conn->op_completed); in netconn_new_with_proto_and_callback()
86 sys_mbox_free(&conn->recvmbox); in netconn_new_with_proto_and_callback()
87 memp_free(MEMP_NETCONN, conn); in netconn_new_with_proto_and_callback()
91 return conn; in netconn_new_with_proto_and_callback()
103 netconn_delete(struct netconn *conn) in netconn_delete() argument
108 if (conn == NULL) { in netconn_delete()
113 msg.msg.conn = conn; in netconn_delete()
116 netconn_free(conn); in netconn_delete()
135 netconn_getaddr(struct netconn *conn, ip_addr_t *addr, u16_t *port, u8_t local) in netconn_getaddr() argument
140 LWIP_ERROR("netconn_getaddr: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_getaddr()
145 msg.msg.conn = conn; in netconn_getaddr()
151 NETCONN_SET_SAFE_ERR(conn, err); in netconn_getaddr()
166 netconn_bind(struct netconn *conn, ip_addr_t *addr, u16_t port) in netconn_bind() argument
171 LWIP_ERROR("netconn_bind: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_bind()
174 msg.msg.conn = conn; in netconn_bind()
179 NETCONN_SET_SAFE_ERR(conn, err); in netconn_bind()
192 netconn_connect(struct netconn *conn, ip_addr_t *addr, u16_t port) in netconn_connect() argument
197 LWIP_ERROR("netconn_connect: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_connect()
200 msg.msg.conn = conn; in netconn_connect()
206 NETCONN_SET_SAFE_ERR(conn, err); in netconn_connect()
217 netconn_disconnect(struct netconn *conn) in netconn_disconnect() argument
222 LWIP_ERROR("netconn_disconnect: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_disconnect()
225 msg.msg.conn = conn; in netconn_disconnect()
228 NETCONN_SET_SAFE_ERR(conn, err); in netconn_disconnect()
241 netconn_listen_with_backlog(struct netconn *conn, u8_t backlog) in netconn_listen_with_backlog() argument
250 LWIP_ERROR("netconn_listen: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_listen_with_backlog()
253 msg.msg.conn = conn; in netconn_listen_with_backlog()
259 NETCONN_SET_SAFE_ERR(conn, err); in netconn_listen_with_backlog()
262 LWIP_UNUSED_ARG(conn); in netconn_listen_with_backlog()
277 netconn_accept(struct netconn *conn, struct netconn **new_conn) in netconn_accept() argument
288 …LWIP_ERROR("netconn_accept: invalid conn", (conn != NULL), return ERR_A… in netconn_accept()
289 …LWIP_ERROR("netconn_accept: invalid acceptmbox", sys_mbox_valid(&conn->acceptmbox), return ERR_A… in netconn_accept()
291 err = conn->last_err; in netconn_accept()
299 …if (sys_arch_mbox_fetch(&conn->acceptmbox, (void **)&newconn, conn->recv_timeout) == SYS_ARCH_TIME… in netconn_accept()
300 NETCONN_SET_SAFE_ERR(conn, ERR_TIMEOUT); in netconn_accept()
304 sys_arch_mbox_fetch(&conn->acceptmbox, (void **)&newconn, 0); in netconn_accept()
307 API_EVENT(conn, NETCONN_EVT_RCVMINUS, 0); in netconn_accept()
311 NETCONN_SET_SAFE_ERR(conn, ERR_ABRT); in netconn_accept()
317 msg.msg.conn = conn; in netconn_accept()
326 LWIP_UNUSED_ARG(conn); in netconn_accept()
342 netconn_recv_data(struct netconn *conn, void **new_buf) in netconn_recv_data() argument
353 LWIP_ERROR("netconn_recv: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_recv_data()
354 LWIP_ERROR("netconn_accept: invalid recvmbox", sys_mbox_valid(&conn->recvmbox), return ERR_CONN;); in netconn_recv_data()
356 err = conn->last_err; in netconn_recv_data()
366 if (sys_arch_mbox_fetch(&conn->recvmbox, &buf, conn->recv_timeout) == SYS_ARCH_TIMEOUT) { in netconn_recv_data()
367 NETCONN_SET_SAFE_ERR(conn, ERR_TIMEOUT); in netconn_recv_data()
371 sys_arch_mbox_fetch(&conn->recvmbox, &buf, 0); in netconn_recv_data()
376 if (conn->type == NETCONN_TCP) in netconn_recv_data()
379 if (!netconn_get_noautorecved(conn) || (buf == NULL)) { in netconn_recv_data()
384 msg.msg.conn = conn; in netconn_recv_data()
396 API_EVENT(conn, NETCONN_EVT_RCVMINUS, 0); in netconn_recv_data()
398 NETCONN_SET_SAFE_ERR(conn, ERR_CLSD); in netconn_recv_data()
415 SYS_ARCH_DEC(conn->recv_avail, len); in netconn_recv_data()
418 API_EVENT(conn, NETCONN_EVT_RCVMINUS, len); in netconn_recv_data()
437 netconn_recv_tcp_pbuf(struct netconn *conn, struct pbuf **new_buf) in netconn_recv_tcp_pbuf() argument
439 LWIP_ERROR("netconn_recv: invalid conn", (conn != NULL) && in netconn_recv_tcp_pbuf()
440 netconn_type(conn) == NETCONN_TCP, return ERR_ARG;); in netconn_recv_tcp_pbuf()
442 return netconn_recv_data(conn, (void **)new_buf); in netconn_recv_tcp_pbuf()
454 netconn_recv(struct netconn *conn, struct netbuf **new_buf) in netconn_recv() argument
463 LWIP_ERROR("netconn_recv: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_recv()
464 LWIP_ERROR("netconn_accept: invalid recvmbox", sys_mbox_valid(&conn->recvmbox), return ERR_CONN;); in netconn_recv()
468 if (conn->type == NETCONN_TCP) in netconn_recv()
476 NETCONN_SET_SAFE_ERR(conn, ERR_MEM); in netconn_recv()
480 err = netconn_recv_data(conn, (void **)&p); in netconn_recv()
501 return netconn_recv_data(conn, (void **)new_buf); in netconn_recv()
517 netconn_recved(struct netconn *conn, u32_t length) in netconn_recved() argument
520 if ((conn != NULL) && (conn->type == NETCONN_TCP) && in netconn_recved()
521 (netconn_get_noautorecved(conn))) { in netconn_recved()
527 msg.msg.conn = conn; in netconn_recved()
533 LWIP_UNUSED_ARG(conn); in netconn_recved()
549 netconn_sendto(struct netconn *conn, struct netbuf *buf, ip_addr_t *addr, u16_t port) in netconn_sendto() argument
554 return netconn_send(conn, buf); in netconn_sendto()
567 netconn_send(struct netconn *conn, struct netbuf *buf) in netconn_send() argument
572 LWIP_ERROR("netconn_send: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_send()
576 msg.msg.conn = conn; in netconn_send()
580 NETCONN_SET_SAFE_ERR(conn, err); in netconn_send()
598 netconn_write_partly(struct netconn *conn, const void *dataptr, size_t size, in netconn_write_partly() argument
605 LWIP_ERROR("netconn_write: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_write_partly()
606 LWIP_ERROR("netconn_write: invalid conn->type", (conn->type == NETCONN_TCP), return ERR_VAL;); in netconn_write_partly()
610 dontblock = netconn_is_nonblocking(conn) || (apiflags & NETCONN_DONTBLOCK); in netconn_write_partly()
619 msg.msg.conn = conn; in netconn_write_partly()
624 if (conn->send_timeout != 0) { in netconn_write_partly()
640 || (conn->send_timeout != 0) in netconn_write_partly()
651 NETCONN_SET_SAFE_ERR(conn, err); in netconn_write_partly()
663 netconn_close_shutdown(struct netconn *conn, u8_t how) in netconn_close_shutdown() argument
668 LWIP_ERROR("netconn_close: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_close_shutdown()
671 msg.msg.conn = conn; in netconn_close_shutdown()
678 NETCONN_SET_SAFE_ERR(conn, err); in netconn_close_shutdown()
689 netconn_close(struct netconn *conn) in netconn_close() argument
692 return netconn_close_shutdown(conn, NETCONN_SHUT_RDWR); in netconn_close()
702 netconn_shutdown(struct netconn *conn, u8_t shut_rx, u8_t shut_tx) in netconn_shutdown() argument
704 …return netconn_close_shutdown(conn, (shut_rx ? NETCONN_SHUT_RD : 0) | (shut_tx ? NETCONN_SHUT_WR :… in netconn_shutdown()
719 netconn_join_leave_group(struct netconn *conn, in netconn_join_leave_group() argument
727 LWIP_ERROR("netconn_join_leave_group: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_join_leave_group()
730 msg.msg.conn = conn; in netconn_join_leave_group()
736 NETCONN_SET_SAFE_ERR(conn, err); in netconn_join_leave_group()