19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
20 *
21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
22 * or visit www.oracle.com if you need additional information or have any
23 * questions.
24 */
25
26 package sun.nio.ch;
27
28 import java.io.FileDescriptor;
29 import java.io.IOException;
30
31 abstract class UnixDispatcher extends NativeDispatcher {
32 private static final boolean SUPPORTS_PENDING_SIGNALS = NativeThread.supportPendingSignals();
33
34 @Override
35 void close(FileDescriptor fd) throws IOException {
36 close0(fd);
37 }
38
39 private void signalThreads(long reader, long writer) {
40 if (NativeThread.isNativeThread(reader))
41 NativeThread.signal(reader);
42 if (NativeThread.isNativeThread(writer))
43 NativeThread.signal(writer);
44 }
45
46 @Override
47 void implPreClose(FileDescriptor fd, long reader, long writer) throws IOException {
48 if (SUPPORTS_PENDING_SIGNALS) {
49 signalThreads(reader, writer);
50 }
51 preClose0(fd);
52 if (!SUPPORTS_PENDING_SIGNALS) {
53 signalThreads(reader, writer);
54 }
55 }
56
57 private static native void close0(FileDescriptor fd) throws IOException;
58
59 private static native void preClose0(FileDescriptor fd) throws IOException;
60
61 static native void init();
62
63 static {
64 IOUtil.load();
65 init();
66 }
67 }
|
19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
20 *
21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
22 * or visit www.oracle.com if you need additional information or have any
23 * questions.
24 */
25
26 package sun.nio.ch;
27
28 import java.io.FileDescriptor;
29 import java.io.IOException;
30
31 abstract class UnixDispatcher extends NativeDispatcher {
32 private static final boolean SUPPORTS_PENDING_SIGNALS = NativeThread.supportPendingSignals();
33
34 @Override
35 void close(FileDescriptor fd) throws IOException {
36 close0(fd);
37 }
38
39 private void signalThreads(NativeThread reader, NativeThread writer) {
40 if (NativeThread.isNativeThread(reader))
41 reader.signal();
42 if (NativeThread.isNativeThread(writer))
43 writer.signal();
44 }
45
46 @Override
47 void implPreClose(FileDescriptor fd, NativeThread reader, NativeThread writer) throws IOException {
48 if (SUPPORTS_PENDING_SIGNALS) {
49 signalThreads(reader, writer);
50 }
51 preClose0(fd);
52 if (!SUPPORTS_PENDING_SIGNALS) {
53 signalThreads(reader, writer);
54 }
55 }
56
57 private static native void close0(FileDescriptor fd) throws IOException;
58
59 private static native void preClose0(FileDescriptor fd) throws IOException;
60
61 static native void init();
62
63 static {
64 IOUtil.load();
65 init();
66 }
67 }
|