Lines Matching refs:conn
66 struct netconn *conn;
175 static void event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len);
207 if (!sock->conn) {
228 if (!sockets[s].conn) {
252 if (!sockets[i].conn) {
253 sockets[i].conn = newconn;
292 sock->conn = NULL;
329 if (netconn_is_nonblocking(sock->conn) && (sock->rcvevent <= 0)) {
336 err = netconn_accept(sock->conn, &newconn);
339 if (netconn_type(sock->conn) != NETCONN_TCP) {
431 err = netconn_bind(sock->conn, &local_addr, ntohs(local_port));
457 if(sock->conn != NULL) {
458 is_tcp = netconn_type(sock->conn) == NETCONN_TCP;
463 netconn_delete(sock->conn);
490 err = netconn_disconnect(sock->conn);
502 err = netconn_connect(sock->conn, &remote_addr, ntohs(remote_port));
540 err = netconn_listen_with_backlog(sock->conn, (u8_t)backlog);
544 if (netconn_type(sock->conn) != NETCONN_TCP) {
583 if (((flags & MSG_DONTWAIT) || netconn_is_nonblocking(sock->conn)) &&
587 netconn_recved(sock->conn, (u32_t)off);
599 if (netconn_type(sock->conn) == NETCONN_TCP) {
600 err = netconn_recv_tcp_pbuf(sock->conn, (struct pbuf **)&buf);
602 err = netconn_recv(sock->conn, (struct netbuf **)&buf);
610 netconn_recved(sock->conn, (u32_t)off);
629 if (netconn_type(sock->conn) == NETCONN_TCP) {
652 if (netconn_type(sock->conn) == NETCONN_TCP) {
671 if (netconn_type(sock->conn) == NETCONN_TCP) {
673 netconn_getaddr(sock->conn, addr, &port, 0);
696 if (netconn_type(sock->conn) == NETCONN_TCP) {
698 netconn_getaddr(sock->conn, addr, &port, 0);
716 if ((netconn_type(sock->conn) == NETCONN_TCP) && (buflen - copylen > 0)) {
724 if (netconn_type(sock->conn) == NETCONN_TCP) {
735 netconn_recved(sock->conn, (u32_t)off);
769 if (sock->conn->type != NETCONN_TCP) {
782 err = netconn_write_partly(sock->conn, data, size, write_flags, &written);
807 if (sock->conn->type == NETCONN_TCP) {
837 if (sock->conn->type != NETCONN_RAW) {
852 remote_addr = &sock->conn->pcb.ip->remote_ip;
854 if (NETCONNTYPE_GROUP(sock->conn->type) == NETCONN_UDP) {
855 remote_port = sock->conn->pcb.udp->remote_port;
864 if (netconn_type(sock->conn) == NETCONN_RAW) {
866 err = sock->conn->last_err = raw_sendto(sock->conn->pcb.raw, p, remote_addr);
877 err = sock->conn->last_err = udp_sendto_chksum(sock->conn->pcb.udp, p,
880 err = sock->conn->last_err = udp_sendto(sock->conn->pcb.udp, p,
922 if (sock->conn->type != NETCONN_RAW) {
937 err = netconn_send(sock->conn, &buf);
950 struct netconn *conn;
958 conn = netconn_new_with_proto_and_callback(NETCONN_RAW, (u8_t)protocol, event_callback);
963 conn = netconn_new_with_callback( (protocol == IPPROTO_UDPLITE) ?
969 conn = netconn_new_with_callback(NETCONN_TCP, event_callback);
972 if (conn != NULL) {
974 netconn_set_noautorecved(conn, 1);
984 if (!conn) {
990 i = alloc_socket(conn, 0);
993 netconn_delete(conn);
997 conn->socket = i;
1247 event_callback(struct netconn *conn, enum netconn_evt evt, u16_t len)
1258 if (conn) {
1259 s = conn->socket;
1267 if (conn->socket < 0) {
1269 conn->socket--;
1274 s = conn->socket;
1380 if (sock->conn != NULL) {
1381 if (netconn_type(sock->conn) != NETCONN_TCP) {
1401 err = netconn_shutdown(sock->conn, shut_rx, shut_tx);
1424 netconn_getaddr(sock->conn, &naddr, &sin.sin_port, local);
1513 if ((sock->conn->type != NETCONN_UDP) ||
1514 ((udp_flags(sock->conn->pcb.udp) & UDP_FLAGS_UDPLITE) != 0)) {
1555 if (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP) {
1577 if (sock->conn->type != NETCONN_TCP)
1606 if (sock->conn->type != NETCONN_UDPLITE) {
1646 sys_arch_sem_wait(&sock->conn->op_completed, 0);
1694 *(int*)optval = ip_get_option(sock->conn->pcb.ip, optname);
1700 switch (NETCONNTYPE_GROUP(sock->conn->type)) {
1711 *(int*)optval = sock->conn->type;
1715 } /* switch (sock->conn->type) */
1723 sock_set_errno(sock, err_to_errno(sock->conn->last_err));
1733 *(int *)optval = netconn_get_sendtimeout(sock->conn);
1738 *(int *)optval = netconn_get_recvtimeout(sock->conn);
1743 *(int *)optval = netconn_get_recvbufsize(sock->conn);
1748 *(int*)optval = (udp_flags(sock->conn->pcb.udp) & UDP_FLAGS_NOCHKSUM) ? 1 : 0;
1761 *(int*)optval = sock->conn->pcb.ip->ttl;
1766 *(int*)optval = sock->conn->pcb.ip->tos;
1772 *(u8_t*)optval = sock->conn->pcb.ip->ttl;
1777 inet_addr_from_ipaddr((struct in_addr*)optval, &sock->conn->pcb.udp->multicast_ip);
1782 if ((sock->conn->pcb.udp->flags & UDP_FLAGS_MULTICAST_LOOP) != 0) {
1802 *(int*)optval = tcp_nagle_disabled(sock->conn->pcb.tcp);
1807 *(int*)optval = (int)sock->conn->pcb.tcp->keep_idle;
1814 *(int*)optval = (int)(sock->conn->pcb.tcp->keep_idle/1000);
1819 *(int*)optval = (int)(sock->conn->pcb.tcp->keep_intvl/1000);
1824 *(int*)optval = (int)sock->conn->pcb.tcp->keep_cnt;
1840 *(int*)optval = sock->conn->pcb.udp->chksum_len_tx;
1845 *(int*)optval = sock->conn->pcb.udp->chksum_len_rx;
1859 sys_sem_signal(&sock->conn->op_completed);
1917 if ((sock->conn->type != NETCONN_UDP) ||
1918 ((udp_flags(sock->conn->pcb.udp) & UDP_FLAGS_UDPLITE) != 0)) {
1948 if (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP) {
1956 if (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP) {
1964 if (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP) {
1973 if (NETCONNTYPE_GROUP(sock->conn->type) != NETCONN_UDP) {
1994 if (sock->conn->type != NETCONN_TCP)
2023 if (sock->conn->type != NETCONN_UDPLITE)
2063 sys_arch_sem_wait(&sock->conn->op_completed, 0);
2111 ip_set_option(sock->conn->pcb.ip, optname);
2113 ip_reset_option(sock->conn->pcb.ip, optname);
2120 netconn_set_sendtimeout(sock->conn, (s32_t)*(int*)optval);
2125 netconn_set_recvtimeout(sock->conn, *(int*)optval);
2130 netconn_set_recvbufsize(sock->conn, *(int*)optval);
2136 udp_setflags(sock->conn->pcb.udp, udp_flags(sock->conn->pcb.udp) | UDP_FLAGS_NOCHKSUM);
2138 udp_setflags(sock->conn->pcb.udp, udp_flags(sock->conn->pcb.udp) & ~UDP_FLAGS_NOCHKSUM);
2152 sock->conn->pcb.ip->ttl = (u8_t)(*(int*)optval);
2154 s, sock->conn->pcb.ip->ttl));
2157 sock->conn->pcb.ip->tos = (u8_t)(*(int*)optval);
2159 s, sock->conn->pcb.ip->tos));
2163 sock->conn->pcb.udp->ttl = (u8_t)(*(u8_t*)optval);
2166 inet_addr_to_ipaddr(&sock->conn->pcb.udp->multicast_ip, (struct in_addr*)optval);
2170 udp_setflags(sock->conn->pcb.udp, udp_flags(sock->conn->pcb.udp) | UDP_FLAGS_MULTICAST_LOOP);
2172 udp_setflags(sock->conn->pcb.udp, udp_flags(sock->conn->pcb.udp) & ~UDP_FLAGS_MULTICAST_LOOP);
2207 tcp_nagle_disable(sock->conn->pcb.tcp);
2209 tcp_nagle_enable(sock->conn->pcb.tcp);
2215 sock->conn->pcb.tcp->keep_idle = (u32_t)(*(int*)optval);
2217 s, sock->conn->pcb.tcp->keep_idle));
2222 sock->conn->pcb.tcp->keep_idle = 1000*(u32_t)(*(int*)optval);
2224 s, sock->conn->pcb.tcp->keep_idle));
2227 sock->conn->pcb.tcp->keep_intvl = 1000*(u32_t)(*(int*)optval);
2229 s, sock->conn->pcb.tcp->keep_intvl));
2232 sock->conn->pcb.tcp->keep_cnt = (u32_t)(*(int*)optval);
2234 s, sock->conn->pcb.tcp->keep_cnt));
2250 sock->conn->pcb.udp->chksum_len_tx = 8;
2252 sock->conn->pcb.udp->chksum_len_tx = (u16_t)*(int*)optval;
2260 sock->conn->pcb.udp->chksum_len_rx = 8;
2262 sock->conn->pcb.udp->chksum_len_rx = (u16_t)*(int*)optval;
2277 sys_sem_signal(&sock->conn->op_completed);
2302 SYS_ARCH_GET(sock->conn->recv_avail, recv_avail);
2311 if (netconn_type(sock->conn) != NETCONN_TCP) {
2330 netconn_set_nonblocking(sock->conn, val);
2352 if (!sock || !sock->conn) {
2358 ret = netconn_is_nonblocking(sock->conn) ? O_NONBLOCK : 0;
2363 netconn_set_nonblocking(sock->conn, val & O_NONBLOCK);