Lines Matching defs:conn
132 ((((name)->sa_family == AF_INET) && !(NETCONNTYPE_ISIPV6((sock)->conn->type))) || \
133 (((name)->sa_family == AF_INET6) && (NETCONNTYPE_ISIPV6((sock)->conn->type))))
173 if ((sock)->conn == NULL) { done_socket(sock); return EINVAL; } }while(0)
176 if (((sock)->conn == NULL) || ((sock)->conn->pcb.tcp == NULL)) { done_socket(sock); return EINVAL; } }while(0)
179 if (NETCONNTYPE_GROUP(netconn_type((sock)->conn)) != netconntype) { done_socket(sock); return ENOPROTOOPT; } }while(0)
296 static void event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len);
308 static int free_socket_locked(struct lwip_sock *sock, int is_tcp, struct netconn **conn,
310 static void free_socket_free_elements(int is_tcp, struct netconn *conn, union lwip_sock_lastdata *lastdata);
389 struct netconn *conn = NULL;
401 freed = free_socket_locked(sock, is_tcp, &conn, &lastdata);
407 free_socket_free_elements(is_tcp, conn, &lastdata);
472 if (sock->conn) {
519 if (!sockets[i].conn) {
528 sockets[i].conn = newconn;
553 * @param conn the socekt's netconn is stored here, must be freed externally
557 free_socket_locked(struct lwip_sock *sock, int is_tcp, struct netconn **conn,
573 *conn = sock->conn;
574 sock->conn = NULL;
581 free_socket_free_elements(int is_tcp, struct netconn *conn, union lwip_sock_lastdata *lastdata)
590 if (conn != NULL) {
591 /* netconn_prepare_delete() has already been called, here we only free the conn */
592 netconn_delete(conn);
606 struct netconn *conn;
613 freed = free_socket_locked(sock, is_tcp, &conn, &lastdata);
618 free_socket_free_elements(is_tcp, conn, &lastdata);
647 err = netconn_accept(sock->conn, &newconn);
650 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) {
764 err = netconn_bind(sock->conn, &local_addr, local_port);
804 if (sock->conn != NULL) {
805 is_tcp = NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP;
819 err = netconn_prepare_delete(sock->conn);
863 err = netconn_disconnect(sock->conn);
886 err = netconn_connect(sock->conn, &remote_addr, remote_port);
926 err = netconn_listen_with_backlog(sock->conn, (u8_t)backlog);
930 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) {
957 LWIP_ASSERT("this should be checked internally", NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP);
975 err = netconn_recv_tcp_pbuf_flags(sock->conn, &p, apiflags);
1044 netconn_tcp_recvd(sock->conn, (size_t)recvd);
1053 lwip_sock_make_addr(struct netconn *conn, ip_addr_t *fromaddr, u16_t port,
1059 LWIP_UNUSED_ARG(conn);
1067 if (NETCONNTYPE_ISIPV6(netconn_type(conn)) && IP_IS_V4(fromaddr)) {
1103 err_t err = netconn_getaddr(sock->conn, &tmpaddr, &port, 0);
1108 return lwip_sock_make_addr(sock->conn, &tmpaddr, port, from, fromlen);
1142 err = netconn_recv_udp_raw_netbuf_flags(sock->conn, &buf, apiflags);
1180 lwip_sock_make_addr(sock->conn, netbuf_fromaddr(buf), netbuf_fromport(buf),
1254 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) {
1358 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) {
1440 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) {
1459 err = netconn_write_partly(sock->conn, data, size, write_flags, &written);
1507 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) {
1514 err = netconn_write_vectors_partly(sock->conn, (struct netvector *)msg->msg_iov, (u16_t)msg->msg_iovlen, write_flags, &written);
1620 err = netconn_send(sock->conn, &chain_buf);
1669 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) {
1703 ip_addr_set_any(NETCONNTYPE_ISIPV6(netconn_type(sock->conn)), &buf.addr);
1720 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_RAW) {
1743 err = netconn_send(sock->conn, &buf);
1757 struct netconn *conn;
1765 conn = netconn_new_with_proto_and_callback(DOMAIN_TO_NETCONN_TYPE(domain, NETCONN_RAW),
1771 conn = netconn_new_with_callback(DOMAIN_TO_NETCONN_TYPE(domain,
1777 if (conn) {
1779 conn->flags &= ~NETCONN_FLAG_PKTINFO;
1784 conn = netconn_new_with_callback(DOMAIN_TO_NETCONN_TYPE(domain, NETCONN_TCP), DEFAULT_SOCKET_EVENTCB);
1795 if (!conn) {
1801 i = alloc_socket(conn, 0);
1804 netconn_delete(conn);
1808 conn->socket = i;
2554 event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len)
2563 if (conn) {
2564 s = conn->socket;
2572 if (conn->socket < 0) {
2574 /* conn->socket is -1 on initialization
2575 lwip_accept adjusts sock->recvevent if conn->socket < -1 */
2576 conn->socket--;
2581 s = conn->socket;
2746 if (sock->conn != NULL) {
2747 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) {
2770 err = netconn_shutdown(sock->conn, shut_rx, shut_tx);
2792 err = netconn_getaddr(sock->conn, &naddr, &port, local);
2801 if (NETCONNTYPE_ISIPV6(netconn_type(sock->conn)) &&
2885 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem = &sock->conn->op_completed;
2983 if (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_TCP) {
2987 if ((sock->conn->pcb.tcp != NULL) && (sock->conn->pcb.tcp->state == LISTEN)) {
3002 (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP)) {
3010 *(int *)optval = ip_get_option(sock->conn->pcb.ip, optname);
3017 switch (NETCONNTYPE_GROUP(netconn_type(sock->conn))) {
3028 *(int *)optval = netconn_type(sock->conn);
3032 } /* switch (netconn_type(sock->conn)) */
3039 *(int *)optval = err_to_errno(netconn_err(sock->conn));
3047 LWIP_SO_SNDRCVTIMEO_SET(optval, netconn_get_sendtimeout(sock->conn));
3053 LWIP_SO_SNDRCVTIMEO_SET(optval, netconn_get_recvtimeout(sock->conn));
3059 *(int *)optval = netconn_get_recvbufsize(sock->conn);
3067 conn_linger = sock->conn->linger;
3082 if (udp_is_flag_set(sock->conn->pcb.udp, UDP_FLAGS_UDPLITE)) {
3088 *(int *)optval = udp_is_flag_set(sock->conn->pcb.udp, UDP_FLAGS_NOCHKSUM) ? 1 : 0;
3104 *(int *)optval = sock->conn->pcb.ip->ttl;
3110 *(int *)optval = sock->conn->pcb.ip->tos;
3117 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_UDP) {
3121 *(u8_t *)optval = udp_get_multicast_ttl(sock->conn->pcb.udp);
3127 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_UDP) {
3131 inet_addr_from_ip4addr((struct in_addr *)optval, udp_get_multicast_netif_addr(sock->conn->pcb.udp));
3137 if ((sock->conn->pcb.udp->flags & UDP_FLAGS_MULTICAST_LOOP) != 0) {
3159 if (sock->conn->pcb.tcp->state == LISTEN) {
3165 *(int *)optval = tcp_nagle_disabled(sock->conn->pcb.tcp);
3170 *(int *)optval = (int)sock->conn->pcb.tcp->keep_idle;
3177 *(int *)optval = (int)(sock->conn->pcb.tcp->keep_idle / 1000);
3182 *(int *)optval = (int)(sock->conn->pcb.tcp->keep_intvl / 1000);
3187 *(int *)optval = (int)sock->conn->pcb.tcp->keep_cnt;
3207 *(int *)optval = (netconn_get_ipv6only(sock->conn) ? 1 : 0);
3226 if (!NETCONNTYPE_ISUDPLITE(netconn_type(sock->conn))) {
3232 *(int *)optval = sock->conn->pcb.udp->chksum_len_tx;
3237 *(int *)optval = sock->conn->pcb.udp->chksum_len_rx;
3255 if (sock->conn->pcb.raw->chksum_reqd == 0) {
3258 *(int *)optval = sock->conn->pcb.raw->chksum_offset;
3336 LWIP_SETGETSOCKOPT_DATA_VAR_REF(data).completed_sem = &sock->conn->op_completed;
3413 (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP)) {
3422 ip_set_option(sock->conn->pcb.ip, optname);
3424 ip_reset_option(sock->conn->pcb.ip, optname);
3442 netconn_set_sendtimeout(sock->conn, ms_long);
3455 netconn_set_recvtimeout(sock->conn, (u32_t)ms_long);
3462 netconn_set_recvbufsize(sock->conn, *(const int *)optval);
3478 sock->conn->linger = (s16_t)lingersec;
3480 sock->conn->linger = -1;
3489 if (udp_is_flag_set(sock->conn->pcb.udp, UDP_FLAGS_UDPLITE)) {
3496 udp_set_flags(sock->conn->pcb.udp, UDP_FLAGS_NOCHKSUM);
3498 udp_clear_flags(sock->conn->pcb.udp, UDP_FLAGS_NOCHKSUM);
3517 switch (NETCONNTYPE_GROUP(netconn_type(sock->conn))) {
3520 tcp_bind_netif(sock->conn->pcb.tcp, n);
3525 udp_bind_netif(sock->conn->pcb.udp, n);
3530 raw_bind_netif(sock->conn->pcb.raw, n);
3552 sock->conn->pcb.ip->ttl = (u8_t)(*(const int *)optval);
3554 s, sock->conn->pcb.ip->ttl));
3558 sock->conn->pcb.ip->tos = (u8_t)(*(const int *)optval);
3560 s, sock->conn->pcb.ip->tos));
3566 sock->conn->flags |= NETCONN_FLAG_PKTINFO;
3568 sock->conn->flags &= ~NETCONN_FLAG_PKTINFO;
3575 udp_set_multicast_ttl(sock->conn->pcb.udp, (u8_t)(*(const u8_t *)optval));
3581 udp_set_multicast_netif_addr(sock->conn->pcb.udp, &if_addr);
3587 udp_set_flags(sock->conn->pcb.udp, UDP_FLAGS_MULTICAST_LOOP);
3589 udp_clear_flags(sock->conn->pcb.udp, UDP_FLAGS_MULTICAST_LOOP);
3635 if (sock->conn->pcb.tcp->state == LISTEN) {
3642 tcp_nagle_disable(sock->conn->pcb.tcp);
3644 tcp_nagle_enable(sock->conn->pcb.tcp);
3650 sock->conn->pcb.tcp->keep_idle = (u32_t)(*(const int *)optval);
3652 s, sock->conn->pcb.tcp->keep_idle));
3657 sock->conn->pcb.tcp->keep_idle = 1000 * (u32_t)(*(const int *)optval);
3659 s, sock->conn->pcb.tcp->keep_idle));
3662 sock->conn->pcb.tcp->keep_intvl = 1000 * (u32_t)(*(const int *)optval);
3664 s, sock->conn->pcb.tcp->keep_intvl));
3667 sock->conn->pcb.tcp->keep_cnt = (u32_t)(*(const int *)optval);
3669 s, sock->conn->pcb.tcp->keep_cnt));
3688 netconn_set_ipv6only(sock->conn, 1);
3690 netconn_set_ipv6only(sock->conn, 0);
3693 s, (netconn_get_ipv6only(sock->conn) ? 1 : 0)));
3707 netif = netif_get_by_index((u8_t)imr->ipv6mr_interface, get_net_group_from_ippcb(sock->conn->pcb.ip));
3749 if (!NETCONNTYPE_ISUDPLITE(netconn_type(sock->conn))) {
3757 sock->conn->pcb.udp->chksum_len_tx = 8;
3759 sock->conn->pcb.udp->chksum_len_tx = (u16_t) * (const int *)optval;
3767 sock->conn->pcb.udp->chksum_len_rx = 8;
3769 sock->conn->pcb.udp->chksum_len_rx = (u16_t) * (const int *)optval;
3789 if (sock->conn->pcb.raw->protocol == IPPROTO_ICMPV6) {
3796 sock->conn->pcb.raw->chksum_reqd = 0;
3802 sock->conn->pcb.raw->chksum_reqd = 1;
3803 sock->conn->pcb.raw->chksum_offset = (u16_t) * (const int *)optval;
3806 s, sock->conn->pcb.raw->chksum_reqd));
3849 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) != NETCONN_TCP) {
3856 err_t err = netconn_recv_udp_raw_netbuf_flags(sock->conn, &rxbuf, NETCONN_DONTBLOCK);
3871 SYS_ARCH_GET(sock->conn->recv_avail, recv_avail);
3878 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) {
3900 netconn_set_nonblocking(sock->conn, val);
3934 ret = netconn_is_nonblocking(sock->conn) ? O_NONBLOCK : 0;
3937 if (NETCONNTYPE_GROUP(netconn_type(sock->conn)) == NETCONN_TCP) {
3947 if (sock->conn->pcb.tcp) {
3948 if (!(sock->conn->pcb.tcp->flags & TF_RXCLOSED)) {
3951 if (!(sock->conn->pcb.tcp->flags & TF_FIN)) {
3974 netconn_set_nonblocking(sock->conn, val & O_NONBLOCK);
4148 netconn_join_leave_group(sock->conn, &multi_addr, &if_addr, NETCONN_LEAVE);
4239 netconn_join_leave_group_netif(sock->conn, &multi_addr, if_idx, NETCONN_LEAVE);