test (a3d27b0a) · Commits · jan.koester / libnetplus

src/event/epoll.cpp

+4 −0

Original line number	Diff line number	Diff line
		@@ -314,6 +314,7 @@ namespace netplus {
		rcv = c->csock->recvData(buf, 0);
		} catch (NetException& e) {
		if (e.getErrorType() == NetException::Note){
		rearm.disarm();
		setpollEventsFd(fd,EPOLLIN \| EPOLLRDHUP \| EPOLLONESHOT);
		return;
		}
		@@ -336,6 +337,7 @@ namespace netplus {
		c->csock->flush_out();
		} catch (NetException& e) {
		if (e.getErrorType() == NetException::Note){
		rearm.disarm();
		setpollEventsFd(fd,EPOLLOUT \| EPOLLRDHUP \| EPOLLONESHOT);
		return;
		}
		@@ -356,6 +358,7 @@ namespace netplus {

		} catch (NetException& e) {
		if (e.getErrorType() == NetException::Note){
		rearm.disarm();
		setpollEventsFd(fd,EPOLLOUT \| EPOLLRDHUP \| EPOLLONESHOT);
		return;
		}
		@@ -382,6 +385,7 @@ namespace netplus {
		int ev = EPOLLIN \| EPOLLRDHUP \| EPOLLONESHOT;
		if (c->csock->hasPendingWrite() \|\| !c->SendData.empty())
		ev \|= EPOLLOUT;
		rearm.disarm();
		setpollEventsFd(fd, ev);
		return;
		}