?? sockets.c
字號:
} memset(&sin, 0, sizeof(sin)); sin.sin_len = sizeof(sin); sin.sin_family = AF_INET; /* get the IP address and port of the remote host */ netconn_peer(sock->conn, &naddr, &sin.sin_port); LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getpeername(%d, addr=", s)); ip_addr_debug_print(SOCKETS_DEBUG, &naddr); LWIP_DEBUGF(SOCKETS_DEBUG, (" port=%d)\n", sin.sin_port)); sin.sin_port = htons(sin.sin_port); sin.sin_addr.s_addr = naddr.addr; if (*namelen > sizeof(sin)) *namelen = sizeof(sin); memcpy(name, &sin, *namelen); sock_set_errno(sock, 0); return 0;}int lwip_getsockname (int s, struct sockaddr *name, socklen_t *namelen){ struct lwip_socket *sock; struct sockaddr_in sin; struct ip_addr *naddr; sock = get_socket(s); if (!sock) { set_errno(EBADF); return -1; } memset(&sin, 0, sizeof(sin)); sin.sin_len = sizeof(sin); sin.sin_family = AF_INET; /* get the IP address and port of the remote host */ netconn_addr(sock->conn, &naddr, &sin.sin_port); LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockname(%d, addr=", s)); ip_addr_debug_print(SOCKETS_DEBUG, naddr); LWIP_DEBUGF(SOCKETS_DEBUG, (" port=%d)\n", sin.sin_port)); sin.sin_port = htons(sin.sin_port); sin.sin_addr.s_addr = naddr->addr; if (*namelen > sizeof(sin)) *namelen = sizeof(sin); memcpy(name, &sin, *namelen); sock_set_errno(sock, 0); return 0;}int lwip_getsockopt (int s, int level, int optname, void *optval, socklen_t *optlen){ int err = 0; struct lwip_socket *sock = get_socket(s); if(!sock) { set_errno(EBADF); return -1; } if( NULL == optval || NULL == optlen ) { sock_set_errno( sock, EFAULT ); return -1; } /* Do length and type checks for the various options first, to keep it readable. */ switch( level ) { /* Level: SOL_SOCKET */ case SOL_SOCKET: switch(optname) { case SO_ACCEPTCONN: case SO_BROADCAST: /* UNIMPL case SO_DEBUG: */ /* UNIMPL case SO_DONTROUTE: */ case SO_ERROR: case SO_KEEPALIVE: /* UNIMPL case SO_OOBINLINE: */ /* UNIMPL case SO_RCVBUF: */ /* UNIMPL case SO_SNDBUF: */ /* UNIMPL case SO_RCVLOWAT: */ /* UNIMPL case SO_SNDLOWAT: */#if SO_REUSE case SO_REUSEADDR: case SO_REUSEPORT:#endif /* SO_REUSE */ case SO_TYPE: /* UNIMPL case SO_USELOOPBACK: */ if( *optlen < sizeof(int) ) { err = EINVAL; } break; default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, SOL_SOCKET, UNIMPL: optname=0x%x, ..)\n", s, optname)); err = ENOPROTOOPT; } /* switch */ break; /* Level: IPPROTO_IP */ case IPPROTO_IP: switch(optname) { /* UNIMPL case IP_HDRINCL: */ /* UNIMPL case IP_RCVDSTADDR: */ /* UNIMPL case IP_RCVIF: */ case IP_TTL: case IP_TOS: if( *optlen < sizeof(int) ) { err = EINVAL; } break; default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, IPPROTO_IP, UNIMPL: optname=0x%x, ..)\n", s, optname)); err = ENOPROTOOPT; } /* switch */ break; /* Level: IPPROTO_TCP */ case IPPROTO_TCP: if( *optlen < sizeof(int) ) { err = EINVAL; break; } /* If this is no TCP socket, ignore any options. */ if ( sock->conn->type != NETCONN_TCP ) return 0; switch( optname ) { case TCP_NODELAY: case TCP_KEEPALIVE: break; default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, IPPROTO_TCP, UNIMPL: optname=0x%x, ..)\n", s, optname)); err = ENOPROTOOPT; } /* switch */ break;/* UNDEFINED LEVEL */ default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, level=0x%x, UNIMPL: optname=0x%x, ..)\n", s, level, optname)); err = ENOPROTOOPT; } /* switch */ if( 0 != err ) { sock_set_errno(sock, err); return -1; } /* Now do the actual option processing */ switch(level) { /* Level: SOL_SOCKET */ case SOL_SOCKET: switch( optname ) { /* The option flags */ case SO_ACCEPTCONN: case SO_BROADCAST: /* UNIMPL case SO_DEBUG: */ /* UNIMPL case SO_DONTROUTE: */ case SO_KEEPALIVE: /* UNIMPL case SO_OOBINCLUDE: */#if SO_REUSE case SO_REUSEADDR: case SO_REUSEPORT:#endif /* SO_REUSE */ /*case SO_USELOOPBACK: UNIMPL */ *(int*)optval = sock->conn->pcb.tcp->so_options & optname; LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, SOL_SOCKET, optname=0x%x, ..) = %s\n", s, optname, (*(int*)optval?"on":"off"))); break; case SO_TYPE: switch (sock->conn->type) { case NETCONN_RAW: *(int*)optval = SOCK_RAW; break; case NETCONN_TCP: *(int*)optval = SOCK_STREAM; break; case NETCONN_UDP: case NETCONN_UDPLITE: case NETCONN_UDPNOCHKSUM: *(int*)optval = SOCK_DGRAM; break; default: /* unrecognized socket type */ *(int*)optval = sock->conn->type; LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, SOL_SOCKET, SO_TYPE): unrecognized socket type %d\n", s, *(int *)optval)); } /* switch */ LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, SOL_SOCKET, SO_TYPE) = %d\n", s, *(int *)optval)); break; case SO_ERROR: *(int *)optval = sock->err; sock->err = 0; LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, SOL_SOCKET, SO_ERROR) = %d\n", s, *(int *)optval)); break; } /* switch */ break;/* Level: IPPROTO_IP */ case IPPROTO_IP: switch( optname ) { case IP_TTL: *(int*)optval = sock->conn->pcb.tcp->ttl; LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, IPPROTO_IP, IP_TTL) = %d\n", s, *(int *)optval)); break; case IP_TOS: *(int*)optval = sock->conn->pcb.tcp->tos; LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, IPPROTO_IP, IP_TOS) = %d\n", s, *(int *)optval)); break; } /* switch */ break;/* Level: IPPROTO_TCP */ case IPPROTO_TCP: switch( optname ) { case TCP_NODELAY: *(int*)optval = (sock->conn->pcb.tcp->flags & TF_NODELAY); LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, IPPROTO_TCP, TCP_NODELAY) = %s\n", s, (*(int*)optval)?"on":"off") ); break; case TCP_KEEPALIVE: *(int*)optval = (int)sock->conn->pcb.tcp->keepalive; LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_getsockopt(%d, IPPROTO_IP, TCP_KEEPALIVE) = %d\n", s, *(int *)optval)); break; } /* switch */ break; } sock_set_errno(sock, err); return err ? -1 : 0;}int lwip_setsockopt (int s, int level, int optname, const void *optval, socklen_t optlen){ struct lwip_socket *sock = get_socket(s); int err = 0; if(!sock) { set_errno(EBADF); return -1; } if( NULL == optval ) { sock_set_errno( sock, EFAULT ); return -1; } /* Do length and type checks for the various options first, to keep it readable. */ switch( level ) {/* Level: SOL_SOCKET */ case SOL_SOCKET: switch(optname) { case SO_BROADCAST: /* UNIMPL case SO_DEBUG: */ /* UNIMPL case SO_DONTROUTE: */ case SO_KEEPALIVE: /* UNIMPL case SO_OOBINLINE: */ /* UNIMPL case SO_RCVBUF: */ /* UNIMPL case SO_SNDBUF: */ /* UNIMPL case SO_RCVLOWAT: */ /* UNIMPL case SO_SNDLOWAT: */#if SO_REUSE case SO_REUSEADDR: case SO_REUSEPORT:#endif /* SO_REUSE */ /* UNIMPL case SO_USELOOPBACK: */ if( optlen < sizeof(int) ) { err = EINVAL; } break; default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, SOL_SOCKET, UNIMPL: optname=0x%x, ..)\n", s, optname)); err = ENOPROTOOPT; } /* switch */ break;/* Level: IPPROTO_IP */ case IPPROTO_IP: switch(optname) { /* UNIMPL case IP_HDRINCL: */ /* UNIMPL case IP_RCVDSTADDR: */ /* UNIMPL case IP_RCVIF: */ case IP_TTL: case IP_TOS: if( optlen < sizeof(int) ) { err = EINVAL; } break; default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, IPPROTO_IP, UNIMPL: optname=0x%x, ..)\n", s, optname)); err = ENOPROTOOPT; } /* switch */ break;/* Level: IPPROTO_TCP */ case IPPROTO_TCP: if( optlen < sizeof(int) ) { err = EINVAL; break; } /* If this is no TCP socket, ignore any options. */ if ( sock->conn->type != NETCONN_TCP ) return 0; switch( optname ) { case TCP_NODELAY: case TCP_KEEPALIVE: break; default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, IPPROTO_TCP, UNIMPL: optname=0x%x, ..)\n", s, optname)); err = ENOPROTOOPT; } /* switch */ break;/* UNDEFINED LEVEL */ default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, level=0x%x, UNIMPL: optname=0x%x, ..)\n", s, level, optname)); err = ENOPROTOOPT; } /* switch */ if( 0 != err ) { sock_set_errno(sock, err); return -1; } /* Now do the actual option processing */ switch(level) {/* Level: SOL_SOCKET */ case SOL_SOCKET: switch(optname) { /* The option flags */ case SO_BROADCAST: /* UNIMPL case SO_DEBUG: */ /* UNIMPL case SO_DONTROUTE: */ case SO_KEEPALIVE: /* UNIMPL case SO_OOBINCLUDE: */#if SO_REUSE case SO_REUSEADDR: case SO_REUSEPORT:#endif /* SO_REUSE */ /* UNIMPL case SO_USELOOPBACK: */ if ( *(int*)optval ) { sock->conn->pcb.tcp->so_options |= optname; } else { sock->conn->pcb.tcp->so_options &= ~optname; } LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, SOL_SOCKET, optname=0x%x, ..) -> %s\n", s, optname, (*(int*)optval?"on":"off"))); break; } /* switch */ break;/* Level: IPPROTO_IP */ case IPPROTO_IP: switch( optname ) { case IP_TTL: sock->conn->pcb.tcp->ttl = (u8_t)(*(int*)optval); LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, IPPROTO_IP, IP_TTL, ..) -> %u\n", s, sock->conn->pcb.tcp->ttl)); break; case IP_TOS: sock->conn->pcb.tcp->tos = (u8_t)(*(int*)optval); LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, IPPROTO_IP, IP_TOS, ..)-> %u\n", s, sock->conn->pcb.tcp->tos)); break; } /* switch */ break;/* Level: IPPROTO_TCP */ case IPPROTO_TCP: switch( optname ) { case TCP_NODELAY: if ( *(int*)optval ) { sock->conn->pcb.tcp->flags |= TF_NODELAY; } else { sock->conn->pcb.tcp->flags &= ~TF_NODELAY; } LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, IPPROTO_TCP, TCP_NODELAY) -> %s\n", s, (*(int *)optval)?"on":"off") ); break; case TCP_KEEPALIVE: sock->conn->pcb.tcp->keepalive = (u32_t)(*(int*)optval); LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_setsockopt(%d, IPPROTO_TCP, TCP_KEEPALIVE) -> %lu\n", s, sock->conn->pcb.tcp->keepalive)); break; } /* switch */ break; } /* switch */ sock_set_errno(sock, err); return err ? -1 : 0;}int lwip_ioctl(int s, long cmd, void *argp){ struct lwip_socket *sock = get_socket(s); if(!sock) { set_errno(EBADF); return -1; } switch (cmd) { case FIONREAD: if (!argp) { sock_set_errno(sock, EINVAL); return -1; } *((u16_t*)argp) = sock->conn->recv_avail; LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_ioctl(%d, FIONREAD, %p) = %u\n", s, argp, *((u16_t*)argp))); sock_set_errno(sock, 0); return 0; case FIONBIO: if (argp && *(u32_t*)argp) sock->flags |= O_NONBLOCK; else sock->flags &= ~O_NONBLOCK; LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_ioctl(%d, FIONBIO, %d)\n", s, !!(sock->flags & O_NONBLOCK))); sock_set_errno(sock, 0); return 0; default: LWIP_DEBUGF(SOCKETS_DEBUG, ("lwip_ioctl(%d, UNIMPL: 0x%lx, %p)\n", s, cmd, argp)); sock_set_errno(sock, ENOSYS); /* not yet implemented */ return -1; }}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -