Lines Matching refs:conn
124 ((((name)->sa_family == AF_INET) && !(NETCONNTYPE_ISIPV6((sock)->conn->type))) || \
125 (((name)->sa_family == AF_INET6) && (NETCONNTYPE_ISIPV6((sock)->conn->type))))
165 if ((sock)->conn == NULL) { done_socket(sock); return EINVAL; } }while(0)
168 …if (((sock)->conn == NULL) || ((sock)->conn->pcb.tcp == NULL)) { done_socket(sock); return EINVAL;…
171 …if (NETCONNTYPE_GROUP(netconn_type((sock)->conn)) != netconntype) { done_socket(sock); return ENOP…
288 static void event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len);
300 static int free_socket_locked(struct lwip_sock *sock, int is_tcp, struct netconn **conn,
302 static void free_socket_free_elements(int is_tcp, struct netconn *conn, union lwip_sock_lastdata *l…
381 struct netconn *conn = NULL; in done_socket() local
393 freed = free_socket_locked(sock, is_tcp, &conn, &lastdata); in done_socket()
399 free_socket_free_elements(is_tcp, conn, &lastdata); in done_socket()
464 if (sock->conn) { in tryget_socket()
483 if (sock->conn) { in lwip_tryget_socket()
530 if (!sockets[i].conn) { in alloc_socket()
539 sockets[i].conn = newconn; in alloc_socket()
570 free_socket_locked(struct lwip_sock *sock, int is_tcp, struct netconn **conn, in free_socket_locked() argument
586 *conn = sock->conn; in free_socket_locked()
587 sock->conn = NULL; in free_socket_locked()
594 free_socket_free_elements(int is_tcp, struct netconn *conn, union lwip_sock_lastdata *lastdata) in free_socket_free_elements() argument
603 if (conn != NULL) { in free_socket_free_elements()
605 netconn_delete(conn); in free_socket_free_elements()
619 struct netconn *conn; in free_socket() local
626 freed = free_socket_locked(sock, is_tcp, &conn, &lastdata); in free_socket()
631 free_socket_free_elements(is_tcp, conn, &lastdata); in free_socket()
660 err = netconn_accept(sock->conn, &newconn); in lwip_accept()
663 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) { in lwip_accept()
778 err = netconn_bind(sock->conn, &local_addr, local_port); in lwip_bind()
807 if (sock->conn != NULL) { in lwip_close()
808 is_tcp = NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP; in lwip_close()
822 err = netconn_prepare_delete(sock->conn); in lwip_close()
855 err = netconn_disconnect(sock->conn); in lwip_connect()
878 err = netconn_connect(sock->conn, &remote_addr, remote_port); in lwip_connect()
918 err = netconn_listen_with_backlog(sock->conn, (u8_t)backlog); in lwip_listen()
922 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) { in lwip_listen()
949 …LWIP_ASSERT("this should be checked internally", NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NE… in lwip_recv_tcp()
967 err = netconn_recv_tcp_pbuf_flags(sock->conn, &p, apiflags); in lwip_recv_tcp()
1036 netconn_tcp_recvd(sock->conn, (size_t)recvd); in lwip_recv_tcp()
1045 lwip_sock_make_addr(struct netconn *conn, ip_addr_t *fromaddr, u16_t port, in lwip_sock_make_addr() argument
1051 LWIP_UNUSED_ARG(conn); in lwip_sock_make_addr()
1059 if (NETCONNTYPE_ISIPV6(netconn_type(conn)) && IP_IS_V4(fromaddr)) { in lwip_sock_make_addr()
1094 netconn_getaddr(sock->conn, &tmpaddr, &port, 0); in lwip_recv_tcp_from()
1099 return lwip_sock_make_addr(sock->conn, &tmpaddr, port, from, fromlen); in lwip_recv_tcp_from()
1133 err = netconn_recv_udp_raw_netbuf_flags(sock->conn, &buf, apiflags); in lwip_recvfrom_udp_raw()
1171 lwip_sock_make_addr(sock->conn, netbuf_fromaddr(buf), netbuf_fromport(buf), in lwip_recvfrom_udp_raw()
1233 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) { in lwip_recvfrom()
1337 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) { in lwip_recvmsg()
1419 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) { in lwip_send()
1434 err = netconn_write_partly(sock->conn, data, size, write_flags, &written); in lwip_send()
1471 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) { in lwip_sendmsg()
1478 …err = netconn_write_vectors_partly(sock->conn, (struct netvector *)msg->msg_iov, (u16_t)msg->msg_i… in lwip_sendmsg()
1584 err = netconn_send(sock->conn, &chain_buf); in lwip_sendmsg()
1621 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) { in lwip_sendto()
1655 ip_addr_set_any(NETCONNTYPE_ISIPV6(netconn_type(sock->conn)), &buf.addr); in lwip_sendto()
1672 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_RAW) { in lwip_sendto()
1695 err = netconn_send(sock->conn, &buf); in lwip_sendto()
1709 struct netconn *conn; in lwip_socket() local
1717 conn = netconn_new_with_proto_and_callback(DOMAIN_TO_NETCONN_TYPE(domain, NETCONN_RAW), in lwip_socket()
1723 conn = netconn_new_with_callback(DOMAIN_TO_NETCONN_TYPE(domain, in lwip_socket()
1729 if (conn) { in lwip_socket()
1731 conn->flags &= ~NETCONN_FLAG_PKTINFO; in lwip_socket()
1736 …conn = netconn_new_with_callback(DOMAIN_TO_NETCONN_TYPE(domain, NETCONN_TCP), DEFAULT_SOCKET_EVENT… in lwip_socket()
1747 if (!conn) { in lwip_socket()
1753 i = alloc_socket(conn, 0); in lwip_socket()
1756 netconn_delete(conn); in lwip_socket()
1760 conn->socket = i; in lwip_socket()
2499 event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len) in event_callback() argument
2508 if (conn) { in event_callback()
2509 s = conn->socket; in event_callback()
2517 if (conn->socket < 0) { in event_callback()
2521 conn->socket--; in event_callback()
2526 s = conn->socket; in event_callback()
2690 if (sock->conn != NULL) { in lwip_shutdown()
2691 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) { in lwip_shutdown()
2714 err = netconn_shutdown(sock->conn, shut_rx, shut_tx); in lwip_shutdown()
2736 err = netconn_getaddr(sock->conn, &naddr, &port, local); in lwip_getaddrname()
2745 if (NETCONNTYPE_ISIPV6(netconn_type(sock->conn)) && in lwip_getaddrname()
2829 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem = &sock->conn->op_completed; in lwip_getsockopt()
2927 if (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_TCP) { in lwip_getsockopt_impl()
2931 if ((sock->conn->pcb.tcp != NULL) && (sock->conn->pcb.tcp->state == LISTEN)) { in lwip_getsockopt_impl()
2946 (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP)) { in lwip_getsockopt_impl()
2954 *(int *)optval = ip_get_option(sock->conn->pcb.ip, optname); in lwip_getsockopt_impl()
2961 switch (NETCONNTYPE_GROUP(netconn_type(sock->conn))) { in lwip_getsockopt_impl()
2972 *(int *)optval = netconn_type(sock->conn); in lwip_getsockopt_impl()
2983 *(int *)optval = err_to_errno(netconn_err(sock->conn)); in lwip_getsockopt_impl()
2991 LWIP_SO_SNDRCVTIMEO_SET(optval, netconn_get_sendtimeout(sock->conn)); in lwip_getsockopt_impl()
2997 LWIP_SO_SNDRCVTIMEO_SET(optval, netconn_get_recvtimeout(sock->conn)); in lwip_getsockopt_impl()
3003 *(int *)optval = netconn_get_recvbufsize(sock->conn); in lwip_getsockopt_impl()
3011 conn_linger = sock->conn->linger; in lwip_getsockopt_impl()
3026 if (udp_is_flag_set(sock->conn->pcb.udp, UDP_FLAGS_UDPLITE)) { in lwip_getsockopt_impl()
3032 *(int *)optval = udp_is_flag_set(sock->conn->pcb.udp, UDP_FLAGS_NOCHKSUM) ? 1 : 0; in lwip_getsockopt_impl()
3048 *(int *)optval = sock->conn->pcb.ip->ttl; in lwip_getsockopt_impl()
3054 *(int *)optval = sock->conn->pcb.ip->tos; in lwip_getsockopt_impl()
3061 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_UDP) { in lwip_getsockopt_impl()
3065 *(u8_t *)optval = udp_get_multicast_ttl(sock->conn->pcb.udp); in lwip_getsockopt_impl()
3071 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_UDP) { in lwip_getsockopt_impl()
3075 …inet_addr_from_ip4addr((struct in_addr *)optval, udp_get_multicast_netif_addr(sock->conn->pcb.udp)… in lwip_getsockopt_impl()
3081 if ((sock->conn->pcb.udp->flags & UDP_FLAGS_MULTICAST_LOOP) != 0) { in lwip_getsockopt_impl()
3103 if (sock->conn->pcb.tcp->state == LISTEN) { in lwip_getsockopt_impl()
3109 *(int *)optval = tcp_nagle_disabled(sock->conn->pcb.tcp); in lwip_getsockopt_impl()
3114 *(int *)optval = (int)sock->conn->pcb.tcp->keep_idle; in lwip_getsockopt_impl()
3121 *(int *)optval = (int)(sock->conn->pcb.tcp->keep_idle / 1000); in lwip_getsockopt_impl()
3126 *(int *)optval = (int)(sock->conn->pcb.tcp->keep_intvl / 1000); in lwip_getsockopt_impl()
3131 *(int *)optval = (int)sock->conn->pcb.tcp->keep_cnt; in lwip_getsockopt_impl()
3151 *(int *)optval = (netconn_get_ipv6only(sock->conn) ? 1 : 0); in lwip_getsockopt_impl()
3170 if (!NETCONNTYPE_ISUDPLITE(netconn_type(sock->conn))) { in lwip_getsockopt_impl()
3176 *(int *)optval = sock->conn->pcb.udp->chksum_len_tx; in lwip_getsockopt_impl()
3181 *(int *)optval = sock->conn->pcb.udp->chksum_len_rx; in lwip_getsockopt_impl()
3199 if (sock->conn->pcb.raw->chksum_reqd == 0) { in lwip_getsockopt_impl()
3202 *(int *)optval = sock->conn->pcb.raw->chksum_offset; in lwip_getsockopt_impl()
3277 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem = &sock->conn->op_completed; in lwip_setsockopt()
3354 (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP)) { in lwip_setsockopt_impl()
3363 ip_set_option(sock->conn->pcb.ip, optname); in lwip_setsockopt_impl()
3365 ip_reset_option(sock->conn->pcb.ip, optname); in lwip_setsockopt_impl()
3383 netconn_set_sendtimeout(sock->conn, ms_long); in lwip_setsockopt_impl()
3396 netconn_set_recvtimeout(sock->conn, (u32_t)ms_long); in lwip_setsockopt_impl()
3403 netconn_set_recvbufsize(sock->conn, *(const int *)optval); in lwip_setsockopt_impl()
3419 sock->conn->linger = (s16_t)lingersec; in lwip_setsockopt_impl()
3421 sock->conn->linger = -1; in lwip_setsockopt_impl()
3430 if (udp_is_flag_set(sock->conn->pcb.udp, UDP_FLAGS_UDPLITE)) { in lwip_setsockopt_impl()
3437 udp_set_flags(sock->conn->pcb.udp, UDP_FLAGS_NOCHKSUM); in lwip_setsockopt_impl()
3439 udp_clear_flags(sock->conn->pcb.udp, UDP_FLAGS_NOCHKSUM); in lwip_setsockopt_impl()
3458 switch (NETCONNTYPE_GROUP(netconn_type(sock->conn))) { in lwip_setsockopt_impl()
3461 tcp_bind_netif(sock->conn->pcb.tcp, n); in lwip_setsockopt_impl()
3466 udp_bind_netif(sock->conn->pcb.udp, n); in lwip_setsockopt_impl()
3471 raw_bind_netif(sock->conn->pcb.raw, n); in lwip_setsockopt_impl()
3493 sock->conn->pcb.ip->ttl = (u8_t)(*(const int *)optval); in lwip_setsockopt_impl()
3495 s, sock->conn->pcb.ip->ttl)); in lwip_setsockopt_impl()
3499 sock->conn->pcb.ip->tos = (u8_t)(*(const int *)optval); in lwip_setsockopt_impl()
3501 s, sock->conn->pcb.ip->tos)); in lwip_setsockopt_impl()
3507 sock->conn->flags |= NETCONN_FLAG_PKTINFO; in lwip_setsockopt_impl()
3509 sock->conn->flags &= ~NETCONN_FLAG_PKTINFO; in lwip_setsockopt_impl()
3516 udp_set_multicast_ttl(sock->conn->pcb.udp, (u8_t)(*(const u8_t *)optval)); in lwip_setsockopt_impl()
3522 udp_set_multicast_netif_addr(sock->conn->pcb.udp, &if_addr); in lwip_setsockopt_impl()
3528 udp_set_flags(sock->conn->pcb.udp, UDP_FLAGS_MULTICAST_LOOP); in lwip_setsockopt_impl()
3530 udp_clear_flags(sock->conn->pcb.udp, UDP_FLAGS_MULTICAST_LOOP); in lwip_setsockopt_impl()
3576 if (sock->conn->pcb.tcp->state == LISTEN) { in lwip_setsockopt_impl()
3583 tcp_nagle_disable(sock->conn->pcb.tcp); in lwip_setsockopt_impl()
3585 tcp_nagle_enable(sock->conn->pcb.tcp); in lwip_setsockopt_impl()
3591 sock->conn->pcb.tcp->keep_idle = (u32_t)(*(const int *)optval); in lwip_setsockopt_impl()
3593 s, sock->conn->pcb.tcp->keep_idle)); in lwip_setsockopt_impl()
3598 sock->conn->pcb.tcp->keep_idle = 1000 * (u32_t)(*(const int *)optval); in lwip_setsockopt_impl()
3600 s, sock->conn->pcb.tcp->keep_idle)); in lwip_setsockopt_impl()
3603 sock->conn->pcb.tcp->keep_intvl = 1000 * (u32_t)(*(const int *)optval); in lwip_setsockopt_impl()
3605 s, sock->conn->pcb.tcp->keep_intvl)); in lwip_setsockopt_impl()
3608 sock->conn->pcb.tcp->keep_cnt = (u32_t)(*(const int *)optval); in lwip_setsockopt_impl()
3610 s, sock->conn->pcb.tcp->keep_cnt)); in lwip_setsockopt_impl()
3629 netconn_set_ipv6only(sock->conn, 1); in lwip_setsockopt_impl()
3631 netconn_set_ipv6only(sock->conn, 0); in lwip_setsockopt_impl()
3634 s, (netconn_get_ipv6only(sock->conn) ? 1 : 0))); in lwip_setsockopt_impl()
3686 if (!NETCONNTYPE_ISUDPLITE(netconn_type(sock->conn))) { in lwip_setsockopt_impl()
3694 sock->conn->pcb.udp->chksum_len_tx = 8; in lwip_setsockopt_impl()
3696 sock->conn->pcb.udp->chksum_len_tx = (u16_t) * (const int *)optval; in lwip_setsockopt_impl()
3704 sock->conn->pcb.udp->chksum_len_rx = 8; in lwip_setsockopt_impl()
3706 sock->conn->pcb.udp->chksum_len_rx = (u16_t) * (const int *)optval; in lwip_setsockopt_impl()
3726 if (sock->conn->pcb.raw->protocol == IPPROTO_ICMPV6) { in lwip_setsockopt_impl()
3733 sock->conn->pcb.raw->chksum_reqd = 0; in lwip_setsockopt_impl()
3739 sock->conn->pcb.raw->chksum_reqd = 1; in lwip_setsockopt_impl()
3740 sock->conn->pcb.raw->chksum_offset = (u16_t) * (const int *)optval; in lwip_setsockopt_impl()
3743 s, sock->conn->pcb.raw->chksum_reqd)); in lwip_setsockopt_impl()
3786 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) { in lwip_ioctl()
3793 err_t err = netconn_recv_udp_raw_netbuf_flags(sock->conn, &rxbuf, NETCONN_DONTBLOCK); in lwip_ioctl()
3808 SYS_ARCH_GET(sock->conn->recv_avail, recv_avail); in lwip_ioctl()
3815 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) { in lwip_ioctl()
3837 netconn_set_nonblocking(sock->conn, val); in lwip_ioctl()
3870 ret = netconn_is_nonblocking(sock->conn) ? O_NONBLOCK : 0; in lwip_fcntl()
3873 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) { in lwip_fcntl()
3883 if (sock->conn->pcb.tcp) { in lwip_fcntl()
3884 if (!(sock->conn->pcb.tcp->flags & TF_RXCLOSED)) { in lwip_fcntl()
3887 if (!(sock->conn->pcb.tcp->flags & TF_FIN)) { in lwip_fcntl()
3910 netconn_set_nonblocking(sock->conn, val & O_NONBLOCK); in lwip_fcntl()
4084 netconn_join_leave_group(sock->conn, &multi_addr, &if_addr, NETCONN_LEAVE); in lwip_socket_drop_registered_memberships()
4175 netconn_join_leave_group_netif(sock->conn, &multi_addr, if_idx, NETCONN_LEAVE); in lwip_socket_drop_registered_mld6_memberships()