- 论坛徽章:
- 0
|
改成epoll还是出错
[pid 3340] epoll_create(65535) = 1230
[pid 3340] epoll_ctl(1230, EPOLL_CTL_ADD, 1252, {EPOLLOUT, {u32=165158888, u64=15763973250490344}}) = 0
[pid 3340] epoll_wait(1230, {{EPOLLOUT, {u32=165158888, u64=15763973250490344}}}, 1, 3) = 1
[pid 3340] close(1230) = 0
[pid 3340] write(1, "yhl test before checkout(3) <--B"..., 92yhl test before checkout(3) <--BaseSocket.cpp:437yhl test epoll_wait=1 <--BaseSocket.cpp:77
) = 92
[pid 3340] write(1, "yhl test selectEINTR1=1\n", 24yhl test selectEINTR1=1
) = 24
[pid 3340] --- SIGSEGV (Segmentation fault) @ 0 (0) ---
我把我的函数调用贴上来.按程序流程, [pid 3340] write(1, "yhl test selectEINTR1=1\n", 24yhl test selectEINTR1=1后,应该是printf("yhl test after checkout(%d)=%d <--%s:%d", timeout, ret, __FILE__, __LINE__), 但却出现段错误了,会不会别的线程访问指针越界,修改了我这个线程的堆栈数据.
int selectEINTR1(int fd, int event, int timeout)
{
int epfd;
struct epoll_event ev;
struct epoll_event events[1];
int rc;
ev.events = event;//ev.events = event | EPOLLET | EPOLLONESHOT;
epfd = epoll_create (65535);
if (epfd == -1){
printf("create epoll fail<--%s:%d\n", __FILE__, __LINE__);
return 0;
}
if (epoll_ctl (epfd, EPOLL_CTL_ADD, fd, &ev) != 0){
if (epoll_ctl (epfd, EPOLL_CTL_MOD, fd, &ev) != 0){
printf("epoll_ctl fail<--%s:%d\n", __FILE__, __LINE__);
return 0;
}
}
rc = epoll_wait (epfd, events, 1, timeout*1000);
close(epfd);
printf("yhl test epoll_wait=%d <--%s:%d\n", rc, __FILE__, __LINE__);
return rc;
}
int BaseSocket::readyForOutput(int timeout)
{
int ret = 0;
//ret = selectEINTR(sck + 1, NULL, &fdSet, NULL, &t);
ret = selectEINTR1(sck, EPOLLOUT, timeout);
printf("yhl test selectEINTR1=%d\n <--%s:%d", ret, __FILE__, __LINE__);
return ret;
}
bool BaseSocket::writeToSocket(char *buff, int len, int timeout, bool check_first) throw(exception)
{
int actuallysent = 0;
int sent;
bool firstflag = true;
int errcount = 0;
int ret = 0;
while (actuallysent < len) {
sent = write(sck, buff + actuallysent, len - actuallysent);
if (sent < 0) {
if (errno == EAGAIN && errcount < 3){
printf("yhl test before checkout(%d) <--%s:%d", timeout, __FILE__, __LINE__);
ret = readyForOutput(timeout);
printf("yhl test after checkout(%d)=%d <--%s:%d", timeout, ret, __FILE__, __LINE__);
if (ret < 0)
return false;
else if (ret == 0)
errcount++;
else
errcount = 0;
continue;
}
return false;
}
else if (sent == 0) {
errcount = 0;
return false; // other end is closed
}
actuallysent += sent;
}
//do_log(LOG_DEBUG, "yhl test send actuallysent:%d <--%s:%d", actuallysent, __FILE__, __LINE__);
return true;
} |
|
免费注册
发表于 2008-11-08 14:11
