equal
deleted
inserted
replaced
46 */ |
46 */ |
47 |
47 |
48 class WindowsWatchService |
48 class WindowsWatchService |
49 extends AbstractWatchService |
49 extends AbstractWatchService |
50 { |
50 { |
51 private final static int WAKEUP_COMPLETION_KEY = 0; |
51 private static final int WAKEUP_COMPLETION_KEY = 0; |
52 |
52 |
53 // background thread to service I/O completion port |
53 // background thread to service I/O completion port |
54 private final Poller poller; |
54 private final Poller poller; |
55 |
55 |
56 /** |
56 /** |
240 |
240 |
241 /** |
241 /** |
242 * Background thread to service I/O completion port. |
242 * Background thread to service I/O completion port. |
243 */ |
243 */ |
244 private static class Poller extends AbstractPoller { |
244 private static class Poller extends AbstractPoller { |
245 private final static Unsafe UNSAFE = Unsafe.getUnsafe(); |
245 private static final Unsafe UNSAFE = Unsafe.getUnsafe(); |
246 |
246 |
247 /* |
247 /* |
248 * typedef struct _OVERLAPPED { |
248 * typedef struct _OVERLAPPED { |
249 * ULONG_PTR Internal; |
249 * ULONG_PTR Internal; |
250 * ULONG_PTR InternalHigh; |
250 * ULONG_PTR InternalHigh; |