epoll_data里的ptr问题.
最近刚开始学linux编程,今天用epoll做一个简单的TCP服务器的时候,出现了问题,自己摸索了好久,一直没有解决,希望有哪位大侠帮帮我,,问题是这样的.按照网上的资料,这是网上的一段代码..
typedef struct _socket_data{
int fd;
int stype;
}socket_data,*psocket_data;
int main(int argc, char **argv)
{
intservPort = 6888;
int listenq = 1024;
int listenfd, connfd, kdpfd, nfds, n, nread, curfds,acceptCount = 0;
struct sockaddr_in servaddr, cliaddr;
socklen_t socklen = sizeof(struct sockaddr_in);
struct epoll_event ev;
struct epoll_event events;
struct rlimit rt;
char buf;
/* 设置每个进程允许打开的最大文件数 */
rt.rlim_max = rt.rlim_cur = MAXEPOLLSIZE;
if (setrlimit(RLIMIT_NOFILE, &rt) == -1)
{
perror("setrlimit error");
return -1;
}
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl (INADDR_ANY);
servaddr.sin_port = htons (servPort);
listenfd = socket(AF_INET, SOCK_STREAM, 0);
if (listenfd == -1) {
perror("can't create socket file");
return -1;
}
int opt = 1;
setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
if (setnonblocking(listenfd) < 0) {
perror("setnonblock error");
}
if (bind(listenfd, (struct sockaddr *) &servaddr, sizeof(struct sockaddr)) == -1)
{
perror("bind error");
return -1;
}
if (listen(listenfd, listenq) == -1)
{
perror("listen error");
return -1;
}
/* 创建 epoll 句柄，把监听 socket 加入到 epoll 集合里 */
psocket_data sdata=(psocket_data)malloc(sizeof(socket_data));
sdata->stype=1;
sdata->fd = listenfd;
kdpfd = epoll_create(MAXEPOLLSIZE);
//ev.data.fd = listenfd;
ev.data.ptr = ()sdata;
ev.events = EPOLLIN | EPOLLET;
if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, listenfd, &ev) < 0)
{
fprintf(stderr, "epoll set insertion error: fd=%d\n", listenfd);
return -1;
}
curfds = 1;
printf("epollserver startup,port %d, max connection is %d, backlog is %d\n", servPort, MAXEPOLLSIZE, listenq);
for (;;) {
/* 等待有事件发生 */
nfds = epoll_wait(kdpfd, events, curfds, -1);
if (nfds == -1)
{
perror("epoll_wait");
continue;
}
/* 处理所有事件 */
for (n = 0; n < nfds; ++n)
{
if (events.data.fd == listenfd)
{
connfd = accept(listenfd, (struct sockaddr *)&cliaddr,&socklen);
if (connfd < 0)
{
perror("accept error");
continue;
}
sprintf(buf, "accept form %s:%d\n", inet_ntoa(cliaddr.sin_addr), cliaddr.sin_port);
printf("%d:%s", ++acceptCount, buf);
if (curfds >= MAXEPOLLSIZE) {
fprintf(stderr, "too many connection, more than %d\n", MAXEPOLLSIZE);
shutdown(connfd, SHUT_RDWR);
close(connfd);
continue;
}
if (setnonblocking(connfd) < 0) {
perror("setnonblocking error");
}
ev.events = EPOLLIN | EPOLLET;
ev.data.fd = connfd;
if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, connfd, &ev) < 0)
{
fprintf(stderr, "add socket '%d' to epoll failed: %s\n", connfd, strerror(errno));
return -1;
}
curfds++;
continue;
}
// 处理客户端请求
if (handle(events.data.fd) < 0) {
epoll_ctl(kdpfd, EPOLL_CTL_DEL, events.data.fd,&ev);
curfds--;
}
}
}
close(listenfd);
return 0;
}源代码是直接把句柄赋给了ev.data.fd
//ev.data.fd = listenfd;
然后编译运行是正常的...但是我需要修改下代码,把ptr指向我定义的一个结构,然后,
客户端连接的时候,就会一直
epoll_wait: Invalid argument
如果取消对data.ptr的赋值就正常,也查找了很多网上的资料,他们也是那样赋值的,但却没看到谁说这样有问题.所以不知道我哪里做错了,希望大家指点一下,谢谢.
下面循环部分的events.data.fd == listenfd判断肯定是错误的,但是我感觉我的代码终止在了perror("epoll_wait");这里,所以我就没修改,
是哪里有问题呢. data是一个union，你用了fd，就不能再用ptr了 我知道了,因为perror持续打印,把第一条出错语句盖掉了,所以我一直没看到第一句出错,,现在问题找到了,是因为我一直觉得他执行不到events.data.fd == listenfd这一句,但其实就是这句出错,因为data.fd不能用了.解决了,谢谢.
页:
[1]