Lines Matching refs:conn
80 static err_t netconn_close_shutdown(struct netconn *conn, u8_t how);
125 struct netconn *conn; in netconn_new_with_proto_and_callback() local
129 conn = netconn_alloc(t, callback); in netconn_new_with_proto_and_callback()
130 if (conn != NULL) { in netconn_new_with_proto_and_callback()
134 API_MSG_VAR_REF(msg).conn = conn; in netconn_new_with_proto_and_callback()
137 LWIP_ASSERT("freeing conn without freeing pcb", conn->pcb.tcp == NULL); in netconn_new_with_proto_and_callback()
138 LWIP_ASSERT("conn has no recvmbox", sys_mbox_valid(&conn->recvmbox)); in netconn_new_with_proto_and_callback()
140 LWIP_ASSERT("conn->acceptmbox shouldn't exist", !sys_mbox_valid(&conn->acceptmbox)); in netconn_new_with_proto_and_callback()
143 LWIP_ASSERT("conn has no op_completed", sys_sem_valid(&conn->op_completed)); in netconn_new_with_proto_and_callback()
144 sys_sem_free(&conn->op_completed); in netconn_new_with_proto_and_callback()
146 sys_mbox_free(&conn->recvmbox); in netconn_new_with_proto_and_callback()
147 memp_free(MEMP_NETCONN, conn); in netconn_new_with_proto_and_callback()
153 return conn; in netconn_new_with_proto_and_callback()
166 netconn_delete(struct netconn *conn) in netconn_delete() argument
172 if (conn == NULL) { in netconn_delete()
177 API_MSG_VAR_REF(msg).conn = conn; in netconn_delete()
197 netconn_free(conn); in netconn_delete()
214 netconn_getaddr(struct netconn *conn, ip_addr_t *addr, u16_t *port, u8_t local) in netconn_getaddr() argument
219 LWIP_ERROR("netconn_getaddr: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_getaddr()
224 API_MSG_VAR_REF(msg).conn = conn; in netconn_getaddr()
252 netconn_bind(struct netconn *conn, const ip_addr_t *addr, u16_t port) in netconn_bind() argument
257 LWIP_ERROR("netconn_bind: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_bind()
265 API_MSG_VAR_REF(msg).conn = conn; in netconn_bind()
284 netconn_connect(struct netconn *conn, const ip_addr_t *addr, u16_t port) in netconn_connect() argument
289 LWIP_ERROR("netconn_connect: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_connect()
297 API_MSG_VAR_REF(msg).conn = conn; in netconn_connect()
314 netconn_disconnect(struct netconn *conn) in netconn_disconnect() argument
319 LWIP_ERROR("netconn_disconnect: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_disconnect()
322 API_MSG_VAR_REF(msg).conn = conn; in netconn_disconnect()
339 netconn_listen_with_backlog(struct netconn *conn, u8_t backlog) in netconn_listen_with_backlog() argument
348 LWIP_ERROR("netconn_listen: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_listen_with_backlog()
351 API_MSG_VAR_REF(msg).conn = conn; in netconn_listen_with_backlog()
360 LWIP_UNUSED_ARG(conn); in netconn_listen_with_backlog()
376 netconn_accept(struct netconn *conn, struct netconn **new_conn) in netconn_accept() argument
388 …LWIP_ERROR("netconn_accept: invalid conn", (conn != NULL), return ERR_A… in netconn_accept()
390 err = conn->last_err; in netconn_accept()
396 if (!sys_mbox_valid(&conn->acceptmbox)) { in netconn_accept()
405 if (sys_arch_mbox_fetch(&conn->acceptmbox, &accept_ptr, conn->recv_timeout) == SYS_ARCH_TIMEOUT) { in netconn_accept()
412 sys_arch_mbox_fetch(&conn->acceptmbox, &accept_ptr, 0); in netconn_accept()
416 API_EVENT(conn, NETCONN_EVT_RCVMINUS, 0); in netconn_accept()
431 NETCONN_SET_SAFE_ERR(conn, ERR_CLSD); in netconn_accept()
439 API_MSG_VAR_REF(msg).conn = newconn; in netconn_accept()
449 LWIP_UNUSED_ARG(conn); in netconn_accept()
466 netconn_recv_data(struct netconn *conn, void **new_buf) in netconn_recv_data() argument
480 LWIP_ERROR("netconn_recv: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_recv_data()
483 if (NETCONNTYPE_GROUP(conn->type) == NETCONN_TCP) in netconn_recv_data()
486 if (!sys_mbox_valid(&conn->recvmbox)) { in netconn_recv_data()
488 return sys_mbox_valid(&conn->acceptmbox) ? ERR_CONN : ERR_CLSD; in netconn_recv_data()
492 LWIP_ERROR("netconn_recv: invalid recvmbox", sys_mbox_valid(&conn->recvmbox), return ERR_CONN;); in netconn_recv_data()
494 err = conn->last_err; in netconn_recv_data()
504 if (NETCONNTYPE_GROUP(conn->type) == NETCONN_TCP) in netconn_recv_data()
512 if (sys_arch_mbox_fetch(&conn->recvmbox, &buf, conn->recv_timeout) == SYS_ARCH_TIMEOUT) { in netconn_recv_data()
515 if (NETCONNTYPE_GROUP(conn->type) == NETCONN_TCP) in netconn_recv_data()
524 sys_arch_mbox_fetch(&conn->recvmbox, &buf, 0); in netconn_recv_data()
529 if (NETCONNTYPE_GROUP(conn->type) == NETCONN_TCP) in netconn_recv_data()
535 API_MSG_VAR_REF(msg).conn = conn; in netconn_recv_data()
548 API_EVENT(conn, NETCONN_EVT_RCVMINUS, 0); in netconn_recv_data()
549 if (conn->pcb.ip == NULL) { in netconn_recv_data()
551 return conn->last_err == ERR_OK ? ERR_RST : conn->last_err; in netconn_recv_data()
554 netconn_close_shutdown(conn, NETCONN_SHUT_RD); in netconn_recv_data()
572 SYS_ARCH_DEC(conn->recv_avail, len); in netconn_recv_data()
575 API_EVENT(conn, NETCONN_EVT_RCVMINUS, len); in netconn_recv_data()
595 netconn_recv_tcp_pbuf(struct netconn *conn, struct pbuf **new_buf) in netconn_recv_tcp_pbuf() argument
597 LWIP_ERROR("netconn_recv: invalid conn", (conn != NULL) && in netconn_recv_tcp_pbuf()
598 NETCONNTYPE_GROUP(netconn_type(conn)) == NETCONN_TCP, return ERR_ARG;); in netconn_recv_tcp_pbuf()
600 return netconn_recv_data(conn, (void **)new_buf); in netconn_recv_tcp_pbuf()
613 netconn_recv(struct netconn *conn, struct netbuf **new_buf) in netconn_recv() argument
622 LWIP_ERROR("netconn_recv: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_recv()
626 if (NETCONNTYPE_GROUP(conn->type) == NETCONN_TCP) in netconn_recv()
637 err = netconn_recv_data(conn, (void **)&p); in netconn_recv()
658 return netconn_recv_data(conn, (void **)new_buf); in netconn_recv()
675 netconn_sendto(struct netconn *conn, struct netbuf *buf, const ip_addr_t *addr, u16_t port) in netconn_sendto() argument
680 return netconn_send(conn, buf); in netconn_sendto()
694 netconn_send(struct netconn *conn, struct netbuf *buf) in netconn_send() argument
699 LWIP_ERROR("netconn_send: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_send()
703 API_MSG_VAR_REF(msg).conn = conn; in netconn_send()
726 netconn_write_partly(struct netconn *conn, const void *dataptr, size_t size, in netconn_write_partly() argument
733 LWIP_ERROR("netconn_write: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_write_partly()
734 …LWIP_ERROR("netconn_write: invalid conn->type", (NETCONNTYPE_GROUP(conn->type)== NETCONN_TCP), re… in netconn_write_partly()
738 dontblock = netconn_is_nonblocking(conn) || (apiflags & NETCONN_DONTBLOCK); in netconn_write_partly()
747 API_MSG_VAR_REF(msg).conn = conn; in netconn_write_partly()
752 if (conn->send_timeout != 0) { in netconn_write_partly()
768 || (conn->send_timeout != 0) in netconn_write_partly()
792 netconn_close_shutdown(struct netconn *conn, u8_t how) in netconn_close_shutdown() argument
798 LWIP_ERROR("netconn_close: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_close_shutdown()
801 API_MSG_VAR_REF(msg).conn = conn; in netconn_close_shutdown()
828 netconn_close(struct netconn *conn) in netconn_close() argument
831 return netconn_close_shutdown(conn, NETCONN_SHUT_RDWR); in netconn_close()
844 netconn_shutdown(struct netconn *conn, u8_t shut_rx, u8_t shut_tx) in netconn_shutdown() argument
846 …return netconn_close_shutdown(conn, (shut_rx ? NETCONN_SHUT_RD : 0) | (shut_tx ? NETCONN_SHUT_WR :… in netconn_shutdown()
862 netconn_join_leave_group(struct netconn *conn, in netconn_join_leave_group() argument
870 LWIP_ERROR("netconn_join_leave_group: invalid conn", (conn != NULL), return ERR_ARG;); in netconn_join_leave_group()
882 API_MSG_VAR_REF(msg).conn = conn; in netconn_join_leave_group()