2 enjoy524 enjoy524 于 2016.03.16 14:06 提问

epoll异步服务端程序,客户端采用多线程访问,服务端总是返回errno 9和107 2C

#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include

#include

using namespace std;

#define MAX_EVENTS 65535
#define SERVER_PORT 8887
#define LISTEN_BACKLOG 2048

char send_buf[64] = {0};

int setnonblocking(int& sockfd)
{
if (fcntl(sockfd, F_SETFL, fcntl(sockfd, F_GETFD, 0)|O_NONBLOCK) == -1)
{
return -1;
}
return 0;
}

void* recv_send_data(void *data)
{
int _socket = *(int *)data;
char recvBuf[16] = {0};
int recv_len = -1;
int res = 1;
while(res)
{
recv_len = recv(_socket, recvBuf, 13, 0);
if(recv_len < 0)
{
if(errno == EAGAIN || errno == EINTR || errno == EWOULDBLOCK)
{
continue;
}
else
{
cout << "recv error! errno: " << errno << endl;
break;
}
}
else if(recv_len == 0) //对端已正常关闭
{
res = 0;
}

    if(recv_len == sizeof(recvBuf))
    {
        res = 1;
    }
    else
    {
        res = 0;
    }
}

if(recv_len > 0)
{
    send(_socket, send_buf, strlen(send_buf), 0);
}
close(_socket);

}

int main()
{
signal(SIGPIPE,SIG_IGN);
sprintf(send_buf, "%s", "Hello world!");
struct rlimit rt;
rt.rlim_max = rt.rlim_cur = 1048576;
int epollFd = epoll_create(MAX_EVENTS);
setrlimit(RLIMIT_NOFILE, &rt);

/*******创建服务端socket,绑定、监听*******/
struct sockaddr_in server_addr;
bzero(&server_addr, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htons(INADDR_ANY);
server_addr.sin_port = htons(SERVER_PORT);
int server_socket = socket(AF_INET, SOCK_STREAM, 0);
if(server_socket < 0)
{
    cout << "create server socket failed!" << endl;
    return -1;
}
setnonblocking(server_socket);
int opt = 1;
setsockopt(server_socket, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
if(bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)))
{
    cout << "server bind failed!" << endl; 
    return -1;
}

if(listen(server_socket, LISTEN_BACKLOG))
{
    cout << "server listen failed" << endl;
    return -1;
}

/**************向epollFd添加fd监听事件**************/
struct epoll_event server_ev;
server_ev.events = EPOLLIN | EPOLLET;
server_ev.data.fd = server_socket;
if(-1 == epoll_ctl(epollFd, EPOLL_CTL_ADD, server_socket, &server_ev))
{
    cout << "epoll_ctl server socket failed" << endl;
    return -1;
}

while(true)
{
    struct epoll_event events[MAX_EVENTS];
    int nfds = epoll_wait(epollFd, events, MAX_EVENTS, -1);
    if(nfds < 0)
    {
        cout << "epoll_wait failed" << endl;
        return -1;
    }
    for(int i = 0; i < nfds; ++i)
    {
        if(events[i].data.fd == server_socket)
        {
            struct sockaddr_in clientAddr;
            socklen_t length = sizeof(clientAddr);
            int remote_socket = accept(events[i].data.fd, (struct sockaddr*)&clientAddr, &length);
            if(remote_socket < 0)
            {
                cout << "accept socket failed!" << endl;
                continue;
            }
            cout << "socket connect successfully" << endl;
            setnonblocking(remote_socket);
            struct epoll_event client_ev;
            client_ev.data.fd = remote_socket;
            client_ev.events = EPOLLIN | EPOLLET;
            if(-1 == epoll_ctl(epollFd, EPOLL_CTL_ADD, remote_socket, &client_ev))
            {
                cout << "epoll_ctl client socket failed" << endl;
                return -1;
            }
        }
        else
        {
            pthread_t thread;
            pthread_attr_t attr;
            pthread_attr_init(&attr);
            pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);
            pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);

            if(pthread_create(&thread, &attr, recv_send_data, (void*)&(events[i].data.fd)))
            {
                cout << "create thread failed" << endl;
                return -1;
            }
        }
    }
}
close(server_socket);
cout << "abort" << endl;
return 0;

}

1个回答

mianbaohebg
mianbaohebg   2016.12.17 22:58

如何修改驱动参数使之变成竖屏。通过修改注册表只能把显示调整成竖屏,即LCD旋转90度,但是触摸点的位置还是原来的。所以真能通过调整驱动来实

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
epoll服务端与客户端代码实例(复制即用)
服务端: #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #define MAXBUF 102
C# Socket编程 服务端与客户端(四) 异步服务端
异步编写Socket服务端
epoll机制:epoll_create、epoll_ctl、epoll_wait、close(在epoll的ET模式下,read和write或send和recv当返回值<0且errno=EAGAIN
在linux的网络编程中,很长的时间都在使用select来做事件触发。在linux新的内核中,有了一种替换它的机制,就是epoll。相比于select,epoll最大的好处在于它不会随着监听fd数目的增长而降低效率。因为在内核中的select实现中,它是采用轮询来处理的,轮询的fd数目越多,自然耗时越多。并且,linux/posix_types.h头文件有这样的声明: #define __FD_
处理大并发之一 对epoll的理解,epoll客户端服务端代码
处理大并发之二 对epoll的理解,epoll客户端服务端代码 序言: 该博客是一系列的博客,首先从最基础的epoll说起,然后研究libevent源码及使用方法,最后研究nginx和node.js,关于select,poll这里不做说明,只说明其相对于epoll的不足,其实select和poll我也没用过,因为我选择了epoll。 说起epoll,做过大并发的估计都不陌生,之前做了个ST
epoll ET模式服务器和客户端源码例子
关于epoll替代select作为高性能服务器的事件通知机制
socket编程 -- epoll模型服务端/客户端通信的实现
本例实现如下功能: 支持多客户端与一个服务端进行通信,客户端给服务端发送字符串数据,服务端将字符串中小写转为大写后发送回客户端,客户端打印输出经转换后的字符串。 例如:发送abcde,打印输出ABCDE 服务端源码如下:/*server.c*/ #include <stdio.h> #include <stdlib.h> #include <string.h> #include <netine
EPOLL 判断客户端连接关闭
1. TCP recv返回0, 说明对方关闭 2. 注册EPOLLERR, 收到事件是关闭 3. recv/send 返回-1时, 如果错误不是EWOULDBLOCK或者EINTR, 也主动关闭连接。  #include #include #include #include #include #include #include #include #include #in
JAVA 中多线程服务端 多个客户端的实现
服务端代码:import java.io.*;import java.net.ServerSocket;import java.net.Socket;class ServeOneClient extends Thread...{    private Socket socket;    private BufferedReader in;    private PrintWriter ou
vc 异步多线程socket 包括服务端和客户端
vc 异步 多线程socket 包括服务端和客户端。
自己趟过epoll的坑
坑的背景 本人用epoll来实现多路复用,epoll触发模式有两种: ET(边缘模式)LT(水平模式) LT模式 是标准模式,意味着每次epoll_wait()返回后,事件处理后,如果之后还有数据,会不断触发,也就是说,一个套接字上一次完整的数据,epoll_wait()可能会返回多次,直到没有数据为止。 ET模式 也称高效模式,有数据过来后,epoll_wait()会