select TCP回射服务器程序

#include
#include
int select(int maxfdpl,fd_set *readset,fd_set *writeset,fd_set *exceptset, const struct timeval *timeout)


struct timeval {
long tv_sec;
long tv_usec;
};


1)timeout == NULL,仅在有一个描述符准备好I/0的时候才返回，不然永久等待下去
2)timeout设置为一段时间，在这段时间内，有一个描述符准备好I/0返回，否则超时返回
3)timeout设置为0，检测描述符后立即返回，这称为轮询(polling).
一般情况下timeout是一个常数值，下一次运行时还是保持原来的值，如果要使用剩余时间，必须重新计算。但是linux下，timeout是会更新为剩余时间的。

前面两种情况的等待通过会被进程在等待期间捕获的信号中断，并从信号处理函数返回。


void FD_ZEROS(fd_set *fdset);
void FD_SET(int fd, fd_set *fdset);
void FD_CLR(int fd, fd_set *fdset);
int FD_ISSET(int fd, fd_set *fdset);


如果中间的三个参数readset, writeset, exceptset都为NULL，则select提供了一个微妙级别的定时器。
中间三个参数都是值----结果参数，调用时，指定了我们关心的描述符的值，返回时，结果将指示哪些描述符已就绪。
函数返回后，我们使用FD_ISSET宏来测试fd_set数据类型中的描述符，描述符集内任何与未就绪描述符对应的位都返回为0，所以，每次
重新select时，都需要重新设置关心的位为1.


maxfdpl参数指定了待测试的描述符个数，它的值是待测试的最大描述符总数。 ---------这个参数的作用是提高效率，FD_SETSIZE通常为1024，但实际中通常少于这个值。

返回值表示所有描述符集的已就绪的总位数。如果定时器返回，则返回0。返回-1表示出错。

#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <signal.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <errno.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/wait.h>
#include <strings.h>
#include "readn.h"

int main(int argc,char *argv[])
{
    int ret = 0;
    int listen_fd;
    int conn_fd;
    struct sockaddr_in server_addr;
    struct sockaddr_in client_addr;
    socklen_t len;
    fd_set readset;
    fd_set allset;
    int max_fd;
    int max_i;
    int i;
    int client[FD_SETSIZE];
    char recvline[MAXLINE];
    int n;

    listen_fd = socket(AF_INET,SOCK_STREAM,0);

    if(listen_fd < 0) {
        printf("socket error\n");
        return -1;
    }

    bzero(&server_addr,sizeof(struct sockaddr_in));

    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(10000);
    //server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    ret = inet_pton(AF_INET,"127.0.0.1",&server_addr.sin_addr.s_addr);
    if(ret < 0) {
        printf("inet_pton error\n");
        close(listen_fd);
        return ret;
    }else if(ret == 0) {
        printf("the second parameter of inet_addr is null\n");
    }

    if(bind(listen_fd,(struct sockaddr*)&server_addr,sizeof(struct sockaddr)) == -1) {
        printf("bind error\n");
        close(listen_fd);
        return -1;
    }


    if(listen(listen_fd,1024) == -1) {
        printf("listen error\n");
        close(listen_fd);
        return -1;
    }

    FD_ZERO(&allset);
    FD_SET(listen_fd,&allset);
    max_fd = listen_fd;
    for(i = 0;i < FD_SETSIZE;i++)
        client[i] = -1;
    max_i = -1;
    for(;;) {
        readset = allset;
        ret = select(max_fd+1,&readset,NULL,NULL,NULL);
        if(FD_ISSET(listen_fd,&readset)) {
            len = sizeof(client_addr);
            conn_fd = accept(listen_fd,(struct sockaddr*)&client_addr,&len);
            if(conn_fd < 0) {
                printf("accept error,errno=%d\n",errno);
                if(errno == EINTR)
                    continue;
                return -1;
            }
            FD_SET(conn_fd,&allset);
            if(conn_fd > max_fd)
                max_fd = conn_fd;
            for(i = 0;i < FD_SETSIZE;i++) {
                if(client[i] == -1) {
                    client[i] = conn_fd;
                    break;
                }
            }
            if(i == FD_SETSIZE) {
                printf("error too many fds,exceeds FD_SETSIZE\n");
                return -1;
            }
            if(i > max_i)
                max_i = i;
            if(--ret <= 0)
                continue;
        }
        for(i = 0; i <= max_i;i++)
        {
            if((client[i] != -1) && FD_ISSET(client[i],&readset)) {
                /*TODO::handle on conn_fd*/
                if((n=read(client[i],recvline,MAXLINE)) == 0) {
                    close(client[i]);
                    FD_CLR(client[i],&allset);
                    client[i] = -1;
                }else {
                    writen(client[i],recvline,n);
                }
                if(--ret <= 0)
                    break;
            }
        }
    }
    return 0;
}