1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.channel.epoll;
17
18 import io.netty.channel.unix.FileDescriptor;
19 import io.netty.util.internal.PlatformDependent;
20
21
22
23
24 public final class Epoll {
25
26 private static final Throwable UNAVAILABILITY_CAUSE;
27
28 static {
29 Throwable cause = null;
30 FileDescriptor epollFd = null;
31 FileDescriptor eventFd = null;
32 try {
33 epollFd = Native.newEpollCreate();
34 eventFd = Native.newEventFd();
35 } catch (Throwable t) {
36 cause = t;
37 } finally {
38 if (epollFd != null) {
39 try {
40 epollFd.close();
41 } catch (Exception ignore) {
42
43 }
44 }
45 if (eventFd != null) {
46 try {
47 eventFd.close();
48 } catch (Exception ignore) {
49
50 }
51 }
52 }
53
54 if (cause != null) {
55 UNAVAILABILITY_CAUSE = cause;
56 } else {
57 UNAVAILABILITY_CAUSE = PlatformDependent.hasUnsafe()
58 ? null
59 : new IllegalStateException(
60 "sun.misc.Unsafe not available",
61 PlatformDependent.getUnsafeUnavailabilityCause());
62 }
63 }
64
65
66
67
68
69 public static boolean isAvailable() {
70 return UNAVAILABILITY_CAUSE == null;
71 }
72
73
74
75
76
77
78
79 public static void ensureAvailability() {
80 if (UNAVAILABILITY_CAUSE != null) {
81 throw (Error) new UnsatisfiedLinkError(
82 "failed to load the required native library").initCause(UNAVAILABILITY_CAUSE);
83 }
84 }
85
86
87
88
89
90
91
92 public static Throwable unavailabilityCause() {
93 return UNAVAILABILITY_CAUSE;
94 }
95
96 private Epoll() { }
97 }