equal
deleted
inserted
replaced
91 // create socket pair for wakeup mechanism |
91 // create socket pair for wakeup mechanism |
92 int[] sv = new int[2]; |
92 int[] sv = new int[2]; |
93 try { |
93 try { |
94 socketpair(sv); |
94 socketpair(sv); |
95 // register one end with epoll |
95 // register one end with epoll |
96 epollCtl(epfd, EPOLL_CTL_ADD, sv[0], POLLIN); |
96 epollCtl(epfd, EPOLL_CTL_ADD, sv[0], Net.POLLIN); |
97 } catch (IOException x) { |
97 } catch (IOException x) { |
98 close0(epfd); |
98 close0(epfd); |
99 throw x; |
99 throw x; |
100 } |
100 } |
101 this.sp = sv; |
101 this.sp = sv; |