1 /*
2 * Copyright (c) 2001, 2016, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation. Oracle designates this
8 * particular file as subject to the "Classpath" exception as provided
9 * by Oracle in the LICENSE file that accompanied this code.
10 *
11 * This code is distributed in the hope that it will be useful, but WITHOUT
12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14 * version 2 for more details (a copy is included in the LICENSE file that
15 * accompanied this code).
16 *
17 * You should have received a copy of the GNU General Public License version
18 * 2 along with this work; if not, write to the Free Software Foundation,
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.IOException;
29 import java.nio.channels.*;
30 import java.nio.channels.spi.*;
31 import java.util.*;
32
33
34 /**
35 * An abstract selector impl.
36 */
37
38 abstract class AbstractPollSelectorImpl
39 extends SelectorImpl
40 {
41
42 // The poll fd array
43 PollArrayWrapper pollWrapper;
44
45 // Initial capacity of the pollfd array
46 protected final int INIT_CAP = 10;
47
48 // The list of SelectableChannels serviced by this Selector
49 protected SelectionKeyImpl[] channelArray;
50
51 // In some impls the first entry of channelArray is bogus
52 protected int channelOffset = 0;
53
54 // The number of valid channels in this Selector's poll array
55 protected int totalChannels;
56
57 // True if this Selector has been closed
58 private boolean closed = false;
59
60 // Lock for close and cleanup
61 private Object closeLock = new Object();
62
63 AbstractPollSelectorImpl(SelectorProvider sp, int channels, int offset) {
64 super(sp);
65 this.totalChannels = channels;
66 this.channelOffset = offset;
67 }
68
69 public void putEventOps(SelectionKeyImpl sk, int ops) {
70 synchronized (closeLock) {
71 if (closed)
72 throw new ClosedSelectorException();
73 pollWrapper.putEventOps(sk.getIndex(), ops);
74 }
75 }
76
77 public Selector wakeup() {
78 pollWrapper.interrupt();
79 return this;
80 }
81
82 protected abstract int doSelect(long timeout) throws IOException;
83
84 protected void implClose() throws IOException {
85 synchronized (closeLock) {
86 if (closed)
87 return;
88 closed = true;
89 // Deregister channels
90 for(int i=channelOffset; i<totalChannels; i++) {
91 SelectionKeyImpl ski = channelArray[i];
92 assert(ski.getIndex() != -1);
93 ski.setIndex(-1);
94 deregister(ski);
95 SelectableChannel selch = channelArray[i].channel();
96 if (!selch.isOpen() && !selch.isRegistered())
97 ((SelChImpl)selch).kill();
98 }
99 implCloseInterrupt();
100 pollWrapper.free();
101 pollWrapper = null;
102 selectedKeys = null;
103 channelArray = null;
104 totalChannels = 0;
105 }
106 }
107
108 protected abstract void implCloseInterrupt() throws IOException;
109
110 /**
111 * Copy the information in the pollfd structs into the opss
112 * of the corresponding Channels. Add the ready keys to the
113 * ready queue.
114 */
115 protected int updateSelectedKeys() {
116 int numKeysUpdated = 0;
117 // Skip zeroth entry; it is for interrupts only
118 for (int i=channelOffset; i<totalChannels; i++) {
119 int rOps = pollWrapper.getReventOps(i);
120 if (rOps != 0) {
121 SelectionKeyImpl sk = channelArray[i];
122 pollWrapper.putReventOps(i, 0);
170 assert (i >= 0);
171 if (i != totalChannels - 1) {
172 // Copy end one over it
173 SelectionKeyImpl endChannel = channelArray[totalChannels-1];
174 channelArray[i] = endChannel;
175 endChannel.setIndex(i);
176 pollWrapper.release(i);
177 PollArrayWrapper.replaceEntry(pollWrapper, totalChannels - 1,
178 pollWrapper, i);
179 } else {
180 pollWrapper.release(i);
181 }
182 // Destroy the last one
183 channelArray[totalChannels-1] = null;
184 totalChannels--;
185 pollWrapper.totalChannels--;
186 ski.setIndex(-1);
187 // Remove the key from keys and selectedKeys
188 keys.remove(ski);
189 selectedKeys.remove(ski);
190 deregister((AbstractSelectionKey)ski);
191 SelectableChannel selch = ski.channel();
192 if (!selch.isOpen() && !selch.isRegistered())
193 ((SelChImpl)selch).kill();
194 }
195 }
|
1 /*
2 * Copyright (c) 2001, 2018, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation. Oracle designates this
8 * particular file as subject to the "Classpath" exception as provided
9 * by Oracle in the LICENSE file that accompanied this code.
10 *
11 * This code is distributed in the hope that it will be useful, but WITHOUT
12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14 * version 2 for more details (a copy is included in the LICENSE file that
15 * accompanied this code).
16 *
17 * You should have received a copy of the GNU General Public License version
18 * 2 along with this work; if not, write to the Free Software Foundation,
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.IOException;
29 import java.nio.channels.*;
30 import java.nio.channels.spi.*;
31
32
33 /**
34 * An abstract selector impl.
35 */
36
37 abstract class AbstractPollSelectorImpl
38 extends SelectorImpl
39 {
40
41 // The poll fd array
42 PollArrayWrapper pollWrapper;
43
44 // Initial capacity of the pollfd array
45 protected final int INIT_CAP = 10;
46
47 // The list of SelectableChannels serviced by this Selector
48 protected SelectionKeyImpl[] channelArray;
49
50 // In some impls the first entry of channelArray is bogus
51 protected int channelOffset;
52
53 // The number of valid channels in this Selector's poll array
54 protected int totalChannels;
55
56 // True if this Selector has been closed
57 private boolean closed = false;
58
59 // Lock for close and cleanup
60 private final Object closeLock = new Object();
61
62 AbstractPollSelectorImpl(SelectorProvider sp, int channels, int offset) {
63 super(sp);
64 this.totalChannels = channels;
65 this.channelOffset = offset;
66 }
67
68 public void putEventOps(SelectionKeyImpl sk, int ops) {
69 synchronized (closeLock) {
70 if (closed)
71 throw new ClosedSelectorException();
72 pollWrapper.putEventOps(sk.getIndex(), ops);
73 }
74 }
75
76 public Selector wakeup() {
77 pollWrapper.interrupt();
78 return this;
79 }
80
81 protected abstract int doSelect(long timeout) throws IOException;
82
83 protected void implClose() throws IOException {
84 synchronized (closeLock) {
85 if (closed)
86 return;
87 closed = true;
88 // Deregister channels
89 for(int i=channelOffset; i<totalChannels; i++) {
90 SelectionKeyImpl ski = channelArray[i];
91 assert(ski.getIndex() != -1);
92 ski.setIndex(-1);
93 deregister(ski);
94 SelectableChannel selch = channelArray[i].channel();
95 if (!selch.isOpen() && !selch.isRegistered())
96 ((SelChImpl)selch).kill();
97 }
98 implCloseInterrupt();
99 pollWrapper.free();
100 pollWrapper = null;
101 selectedKeys.clear();
102 channelArray = null;
103 totalChannels = 0;
104 }
105 }
106
107 protected abstract void implCloseInterrupt() throws IOException;
108
109 /**
110 * Copy the information in the pollfd structs into the opss
111 * of the corresponding Channels. Add the ready keys to the
112 * ready queue.
113 */
114 protected int updateSelectedKeys() {
115 int numKeysUpdated = 0;
116 // Skip zeroth entry; it is for interrupts only
117 for (int i=channelOffset; i<totalChannels; i++) {
118 int rOps = pollWrapper.getReventOps(i);
119 if (rOps != 0) {
120 SelectionKeyImpl sk = channelArray[i];
121 pollWrapper.putReventOps(i, 0);
169 assert (i >= 0);
170 if (i != totalChannels - 1) {
171 // Copy end one over it
172 SelectionKeyImpl endChannel = channelArray[totalChannels-1];
173 channelArray[i] = endChannel;
174 endChannel.setIndex(i);
175 pollWrapper.release(i);
176 PollArrayWrapper.replaceEntry(pollWrapper, totalChannels - 1,
177 pollWrapper, i);
178 } else {
179 pollWrapper.release(i);
180 }
181 // Destroy the last one
182 channelArray[totalChannels-1] = null;
183 totalChannels--;
184 pollWrapper.totalChannels--;
185 ski.setIndex(-1);
186 // Remove the key from keys and selectedKeys
187 keys.remove(ski);
188 selectedKeys.remove(ski);
189 deregister(ski);
190 SelectableChannel selch = ski.channel();
191 if (!selch.isOpen() && !selch.isRegistered())
192 ((SelChImpl)selch).kill();
193 }
194 }
|