请教 select问题

发布于 2018-05-31 14:58:38 浏览：3723 订阅该版

使用lwip的ppp模式，驱动4G模块。
现在网络能正常使用。
但是使用select功能发现会导致死机。

阅读了net_sockets的实现，发现POSIX接口使用了一层映射将socket 句柄转换为文件系统句柄,
socket, recv , send等接口都做了映射，唯独select没有做映射。
所以有些疑惑，怀疑是select实现有bug。

自己将socket映射后调用lwip_select发现问题解决。不是很清楚是系统问题还是我的使用问题。

int select(int s, fd_set *readset, fd_set *writeset, fd_set *exceptset,
                struct timeval *timeout)
{
    int ret;
    int sock = dfs_net_getsocket(s);
    if ( readset )
    {
        FD_ZERO(readset);
        FD_SET(sock,readset);
    }
    if ( writeset )
    {
        FD_ZERO(writeset);
        FD_SET(sock,writeset);
    }
    ret = lwip_select(sock + 1,readset, writeset, exceptset,timeout);
    if ( ret > 0 )
    {
        if (!FD_ISSET(sock, readset) && !FD_ISSET(sock, writeset)) 
            {
                rt_kprintf("Should NOT arrive"); 
            }
    }
    return ret;
}

7 个回答

Cheney_Chen 2018-05-31

这家伙很懒，什么也没写！

系统中自带select函数，不需要自己封装实现，使用select函数需要开启在ENV中开启RT_USING_DFS_NET使用标准POSIX接口，头文件引用#include <sys/select.h>即可使用

[attach]3892[/attach]

Hubert_Xie 2018-06-01

这家伙很懒，什么也没写！

系统中自带select函数，不需要自己封装实现，使用select函数需要开启在ENV中开启RT_USING_DFS_NET使 …

我已经开启了以下两个宏，应用代码在Linux中能正常运行的。

RT_USING_DFS_NET
RT_USING_POSIX

Hubert_Xie 2018-07-19

这家伙很懒，什么也没写！

wandersky 2018-08-09

这家伙很懒，什么也没写！

我也发现问题了，我在调试ftp服务器的时候，由于PASV模式，使用到select然后就不正常，使用PORT模式，就没有问题。

else if(str_begin_with(buf, "PASV")==0)
        {
                int dig1, dig2;
                int sockfd;
                int optval='1';//char optval='1';//willow change
                session->pasv_port = 10000;
                session->pasv_active = 1;
                local.sin_port=htons(session->pasv_port);
                local.sin_addr.s_addr=INADDR_ANY;
                dig1 = (int)(session->pasv_port/256);
                dig2 = session->pasv_port % 256;
                FD_ZERO(&readfds);
                if((sockfd=socket(PF_INET, SOCK_STREAM, 0))==-1)
                {
                        rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
                        send(session->sockfd, sbuf, strlen(sbuf), 0);
                        goto err1;
                }
                if(setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval))==-1)
                {
                        rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
                        send(session->sockfd, sbuf, strlen(sbuf), 0);
                        goto err1;
                }
                if(bind(sockfd, (struct sockaddr *)&local, addr_len)==-1)
                {
                        rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
                        send(session->sockfd, sbuf, strlen(sbuf), 0);
                        goto err1;
                }
                if(listen(sockfd, 1)==-1)
                {
                        rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
                        send(session->sockfd, sbuf, strlen(sbuf), 0);
                        goto err1;
                }
                rt_kprintf("Listening %d seconds @ port %d\n", tv.tv_sec, session->pasv_port);
                //rt_sprintf(sbuf, "227 Entering passive mode (%d,%d,%d,%d,%d,%d)\r\n", 127, 0, 0, 1, dig1, dig2);
                rt_sprintf(sbuf, "227 Entering passive mode (%d,%d,%d,%d,%d,%d)\r\n", 0, 0, 0, 0, dig1, dig2);
                send(session->sockfd, sbuf, strlen(sbuf), 0);
                FD_SET(sockfd, &readfds);
                select(0, &readfds, 0, 0, &tv);
                if(FD_ISSET(sockfd, &readfds))
                {
                        if((session->pasv_sockfd = accept(sockfd, (struct sockaddr*)&pasvremote, &addr_len))==-1)
                        {
                                rt_sprintf(sbuf, "425 Can't open data connection.\r\n");
                                send(session->sockfd, sbuf, strlen(sbuf), 0);
                                goto err1;
                        }
                        else
                        {
                                rt_kprintf("Got Data(PASV) connection from %s\n", inet_ntoa(pasvremote.sin_addr));
                                session->pasv_active = 1;
                                closesocket(sockfd);
                        }
                }
                else
                {
err1:
                        closesocket(sockfd);//closesocket(session->pasv_sockfd);
                        session->pasv_active = 0;
                        rt_free(sbuf);
                        return 0;
                }

正在努力解决中。。。

wandersky 2018-08-09

这家伙很懒，什么也没写！

头文件已经修改如下

#include <rtthread.h>
#include <dfs_posix.h>
#include <sys/socket.h>//#include <lwip/sockets.h>
#include <time.h>

armink 2018-08-09

这家伙很懒，什么也没写！

我也发现问题了，我在调试ftp服务器的时候，由于PASV模式，使用到select然后就不正常，使用PORT模式，就没 …

select 功能在 RT-Thread 中还是蛮常用的。
MQTT 软件包中，还同时对 PIPE 和网络一起使用 select 。可否先对比具体的调用代码。

wandersky 2018-08-10

这家伙很懒，什么也没写！

已解决
select(0, &readfds, 0, 0, &tv);
使用有问题，应该
select(FD_SETSIZE, &readfds, 0, 0, &tv);

请教 select问题

撰写答案

关于作者

Hubert_Xie

相关问题

热门标签

本月文章贡献

请教 select问题

撰写答案

关于作者

Hubert_Xie

相关问题

推荐文章

最新文章

热门标签

本月问答贡献

本月文章贡献