jdk/src/solaris/classes/sun/nio/ch/UnixAsynchronousSocketChannelImpl.java
changeset 22604 9b394795e216
parent 19607 bee007586d06
child 23010 6dadb192ad81
equal deleted inserted replaced
22603:816588059f9d 22604:9b394795e216
   140     // register events for outstanding I/O operations, caller already owns updateLock
   140     // register events for outstanding I/O operations, caller already owns updateLock
   141     private void updateEvents() {
   141     private void updateEvents() {
   142         assert Thread.holdsLock(updateLock);
   142         assert Thread.holdsLock(updateLock);
   143         int events = 0;
   143         int events = 0;
   144         if (readPending)
   144         if (readPending)
   145             events |= Port.POLLIN;
   145             events |= Net.POLLIN;
   146         if (connectPending || writePending)
   146         if (connectPending || writePending)
   147             events |= Port.POLLOUT;
   147             events |= Net.POLLOUT;
   148         if (events != 0)
   148         if (events != 0)
   149             port.startPoll(fdVal, events);
   149             port.startPoll(fdVal, events);
   150     }
   150     }
   151 
   151 
   152     // register events for outstanding I/O operations
   152     // register events for outstanding I/O operations
   202     /**
   202     /**
   203      * Invoked by event handler thread when file descriptor is polled
   203      * Invoked by event handler thread when file descriptor is polled
   204      */
   204      */
   205     @Override
   205     @Override
   206     public void onEvent(int events, boolean mayInvokeDirect) {
   206     public void onEvent(int events, boolean mayInvokeDirect) {
   207         boolean readable = (events & Port.POLLIN) > 0;
   207         boolean readable = (events & Net.POLLIN) > 0;
   208         boolean writable = (events & Port.POLLOUT) > 0;
   208         boolean writable = (events & Net.POLLOUT) > 0;
   209         if ((events & (Port.POLLERR | Port.POLLHUP)) > 0) {
   209         if ((events & (Net.POLLERR | Net.POLLHUP)) > 0) {
   210             readable = true;
   210             readable = true;
   211             writable = true;
   211             writable = true;
   212         }
   212         }
   213         finish(mayInvokeDirect, readable, writable);
   213         finish(mayInvokeDirect, readable, writable);
   214     }
   214     }