author | chegar |
Thu, 21 Nov 2019 12:14:29 +0000 | |
changeset 59205 | afcc8af048e6 |
parent 47216 | 71c04702a3d5 |
permissions | -rw-r--r-- |
3320
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
1 |
/* |
59205
afcc8af048e6
8233847: (sctp) Flx link-local IPv6 scope handling and test cleanup
chegar
parents:
47216
diff
changeset
|
2 |
* Copyright (c) 2009, 2019, Oracle and/or its affiliates. All rights reserved. |
3320
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
3 |
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
4 |
* |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
5 |
* This code is free software; you can redistribute it and/or modify it |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
6 |
* under the terms of the GNU General Public License version 2 only, as |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
7 |
* published by the Free Software Foundation. |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
8 |
* |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
9 |
* This code is distributed in the hope that it will be useful, but WITHOUT |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
10 |
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
11 |
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
12 |
* version 2 for more details (a copy is included in the LICENSE file that |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
13 |
* accompanied this code). |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
14 |
* |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
15 |
* You should have received a copy of the GNU General Public License version |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
16 |
* 2 along with this work; if not, write to the Free Software Foundation, |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
17 |
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
18 |
* |
5506 | 19 |
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA |
20 |
* or visit www.oracle.com if you need additional information or have any |
|
21 |
* questions. |
|
3320
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
22 |
*/ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
23 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
24 |
/* @test |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
25 |
* @bug 6863110 |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
26 |
* @summary Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
27 |
* @author chegar |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
28 |
*/ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
29 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
30 |
import java.net.InetSocketAddress; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
31 |
import java.net.SocketAddress; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
32 |
import java.io.IOException; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
33 |
import java.util.Iterator; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
34 |
import java.util.Set; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
35 |
import java.util.concurrent.CountDownLatch; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
36 |
import java.nio.ByteBuffer; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
37 |
import java.nio.channels.Selector; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
38 |
import java.nio.channels.SelectionKey; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
39 |
import com.sun.nio.sctp.AbstractNotificationHandler; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
40 |
import com.sun.nio.sctp.AssociationChangeNotification; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
41 |
import com.sun.nio.sctp.AssociationChangeNotification.AssocChangeEvent; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
42 |
import com.sun.nio.sctp.HandlerResult; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
43 |
import com.sun.nio.sctp.Notification; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
44 |
import com.sun.nio.sctp.SctpChannel; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
45 |
import com.sun.nio.sctp.SctpServerChannel; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
46 |
import com.sun.nio.sctp.ShutdownNotification; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
47 |
import static java.lang.System.out; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
48 |
import static java.lang.System.err; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
49 |
import static java.nio.channels.SelectionKey.OP_CONNECT; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
50 |
import static java.nio.channels.SelectionKey.OP_READ; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
51 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
52 |
public class CommUp { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
53 |
static CountDownLatch acceptLatch = new CountDownLatch(1); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
54 |
static final int TIMEOUT = 10000; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
55 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
56 |
CommUpNotificationHandler clientHandler = new CommUpNotificationHandler(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
57 |
CommUpNotificationHandler serverHandler = new CommUpNotificationHandler(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
58 |
CommUpServer server; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
59 |
Thread clientThread; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
60 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
61 |
void test(String[] args) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
62 |
SocketAddress address = null; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
63 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
64 |
if (!Util.isSCTPSupported()) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
65 |
out.println("SCTP protocol is not supported"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
66 |
out.println("Test cannot be run"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
67 |
return; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
68 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
69 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
70 |
if (args.length == 2) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
71 |
/* requested to connecct to a specific address */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
72 |
try { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
73 |
int port = Integer.valueOf(args[1]); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
74 |
address = new InetSocketAddress(args[0], port); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
75 |
} catch (NumberFormatException nfe) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
76 |
err.println(nfe); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
77 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
78 |
} else { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
79 |
/* start server on local machine, default */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
80 |
try { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
81 |
server = new CommUpServer(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
82 |
server.start(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
83 |
address = server.address(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
84 |
debug("Server started and listening on " + address); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
85 |
} catch (IOException ioe) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
86 |
ioe.printStackTrace(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
87 |
return; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
88 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
89 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
90 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
91 |
/* store the main thread so that the server can interrupt it, if necessary */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
92 |
clientThread = Thread.currentThread(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
93 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
94 |
doClient(address); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
95 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
96 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
97 |
void doClient(SocketAddress peerAddress) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
98 |
SctpChannel sc = null; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
99 |
try { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
100 |
debug("connecting to " + peerAddress); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
101 |
sc = SctpChannel.open(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
102 |
sc.configureBlocking(false); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
103 |
check(sc.isBlocking() == false, "Should be in non-blocking mode"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
104 |
sc.connect(peerAddress); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
105 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
106 |
Selector selector = Selector.open(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
107 |
SelectionKey selectiontKey = sc.register(selector, OP_CONNECT); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
108 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
109 |
/* Expect two interest Ops */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
110 |
boolean opConnectReceived = false; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
111 |
boolean opReadReceived = false; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
112 |
for (int z=0; z<2; z++) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
113 |
debug("select " + z); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
114 |
int keysAdded = selector.select(TIMEOUT); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
115 |
debug("returned " + keysAdded + " keys"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
116 |
if (keysAdded > 0) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
117 |
Set<SelectionKey> keys = selector.selectedKeys(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
118 |
Iterator<SelectionKey> i = keys.iterator(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
119 |
while(i.hasNext()) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
120 |
SelectionKey sk = i.next(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
121 |
i.remove(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
122 |
SctpChannel readyChannel = |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
123 |
(SctpChannel)sk.channel(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
124 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
125 |
/* OP_CONNECT */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
126 |
if (sk.isConnectable()) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
127 |
/* some trivial checks */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
128 |
check(opConnectReceived == false, |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
129 |
"should only received one OP_CONNECT"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
130 |
check(opReadReceived == false, |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
131 |
"should not receive OP_READ before OP_CONNECT"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
132 |
check(readyChannel.equals(sc), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
133 |
"channels should be equal"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
134 |
check(!sk.isAcceptable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
135 |
"key should not be acceptable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
136 |
check(!sk.isReadable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
137 |
"key should not be readable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
138 |
check(!sk.isWritable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
139 |
"key should not be writable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
140 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
141 |
/* now process the OP_CONNECT */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
142 |
opConnectReceived = true; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
143 |
check((sk.interestOps() & OP_CONNECT) == OP_CONNECT, |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
144 |
"selection key interest ops should contain OP_CONNECT"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
145 |
sk.interestOps(OP_READ); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
146 |
check((sk.interestOps() & OP_CONNECT) != OP_CONNECT, |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
147 |
"selection key interest ops should not contain OP_CONNECT"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
148 |
check(sc.finishConnect(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
149 |
"finishConnect should return true"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
150 |
} /* OP_READ */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
151 |
else if (sk.isReadable()) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
152 |
/* some trivial checks */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
153 |
check(opConnectReceived == true, |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
154 |
"should receive one OP_CONNECT before OP_READ"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
155 |
check(opReadReceived == false, |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
156 |
"should not receive OP_READ before OP_CONNECT"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
157 |
check(readyChannel.equals(sc), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
158 |
"channels should be equal"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
159 |
check(!sk.isAcceptable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
160 |
"key should not be acceptable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
161 |
check(sk.isReadable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
162 |
"key should be readable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
163 |
check(!sk.isWritable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
164 |
"key should not be writable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
165 |
check(!sk.isConnectable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
166 |
"key should not be connectable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
167 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
168 |
/* now process the OP_READ */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
169 |
opReadReceived = true; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
170 |
selectiontKey.cancel(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
171 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
172 |
/* try with small buffer to see if native |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
173 |
* implementation can handle this */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
174 |
ByteBuffer buffer = ByteBuffer.allocateDirect(1); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
175 |
readyChannel.receive(buffer, null, clientHandler); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
176 |
check(clientHandler.receivedCommUp(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
177 |
"Client should have received COMM_UP"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
178 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
179 |
/* dont close (or put anything on) the channel until |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
180 |
* we check that the server's accepted channel also |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
181 |
* received COMM_UP */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
182 |
serverHandler.waitForCommUp(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
183 |
} else { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
184 |
fail("Unexpected selection key"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
185 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
186 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
187 |
} else { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
188 |
fail("Client selector returned 0 ready keys"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
189 |
/* stop the server */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
190 |
server.thread().interrupt(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
191 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
192 |
} //for |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
193 |
|
59205
afcc8af048e6
8233847: (sctp) Flx link-local IPv6 scope handling and test cleanup
chegar
parents:
47216
diff
changeset
|
194 |
try { sc.close(); } |
afcc8af048e6
8233847: (sctp) Flx link-local IPv6 scope handling and test cleanup
chegar
parents:
47216
diff
changeset
|
195 |
catch (IOException ioe) { unexpected(ioe); } |
afcc8af048e6
8233847: (sctp) Flx link-local IPv6 scope handling and test cleanup
chegar
parents:
47216
diff
changeset
|
196 |
|
3320
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
197 |
} catch (IOException ioe) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
198 |
unexpected(ioe); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
199 |
} catch (InterruptedException ie) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
200 |
unexpected(ie); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
201 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
202 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
203 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
204 |
class CommUpServer implements Runnable |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
205 |
{ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
206 |
final InetSocketAddress serverAddr; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
207 |
private SctpServerChannel ssc; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
208 |
private Thread serverThread; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
209 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
210 |
public CommUpServer() throws IOException { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
211 |
ssc = SctpServerChannel.open().bind(null); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
212 |
java.util.Set<SocketAddress> addrs = ssc.getAllLocalAddresses(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
213 |
if (addrs.isEmpty()) |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
214 |
debug("addrs should not be empty"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
215 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
216 |
serverAddr = (InetSocketAddress) addrs.iterator().next(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
217 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
218 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
219 |
void start() { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
220 |
serverThread = new Thread(this, "CommUpServer-" + |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
221 |
serverAddr.getPort()); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
222 |
serverThread.start(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
223 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
224 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
225 |
InetSocketAddress address () { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
226 |
return serverAddr; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
227 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
228 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
229 |
Thread thread() { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
230 |
return serverThread; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
231 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
232 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
233 |
@Override |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
234 |
public void run() { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
235 |
Selector selector = null; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
236 |
SctpChannel sc = null; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
237 |
SelectionKey readKey = null; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
238 |
try { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
239 |
sc = ssc.accept(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
240 |
debug("accepted " + sc); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
241 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
242 |
selector = Selector.open(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
243 |
sc.configureBlocking(false); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
244 |
check(sc.isBlocking() == false, "Should be in non-blocking mode"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
245 |
readKey = sc.register(selector, SelectionKey.OP_READ); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
246 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
247 |
debug("select"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
248 |
int keysAdded = selector.select(TIMEOUT); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
249 |
debug("returned " + keysAdded + " keys"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
250 |
if (keysAdded > 0) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
251 |
Set<SelectionKey> keys = selector.selectedKeys(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
252 |
Iterator<SelectionKey> i = keys.iterator(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
253 |
while(i.hasNext()) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
254 |
SelectionKey sk = i.next(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
255 |
i.remove(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
256 |
SctpChannel readyChannel = |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
257 |
(SctpChannel)sk.channel(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
258 |
check(readyChannel.equals(sc), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
259 |
"channels should be equal"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
260 |
check(!sk.isAcceptable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
261 |
"key should not be acceptable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
262 |
check(sk.isReadable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
263 |
"key should be readable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
264 |
check(!sk.isWritable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
265 |
"key should not be writable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
266 |
check(!sk.isConnectable(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
267 |
"key should not be connectable"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
268 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
269 |
/* block until we check if the client has received its COMM_UP*/ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
270 |
clientHandler.waitForCommUp(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
271 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
272 |
ByteBuffer buffer = ByteBuffer.allocateDirect(1); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
273 |
sc.receive(buffer, null, serverHandler); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
274 |
check(serverHandler.receivedCommUp(), |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
275 |
"Accepted channel should have received COMM_UP"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
276 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
277 |
} else { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
278 |
fail("Server selector returned 0 ready keys"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
279 |
/* stop the client */ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
280 |
clientThread.interrupt(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
281 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
282 |
} catch (IOException ioe) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
283 |
ioe.printStackTrace(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
284 |
} catch (InterruptedException unused) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
285 |
} finally { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
286 |
if (readKey != null) readKey.cancel(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
287 |
try { if (selector != null) selector.close(); } |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
288 |
catch (IOException ioe) { unexpected(ioe); } |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
289 |
try { if (ssc != null) ssc.close(); } |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
290 |
catch (IOException ioe) { unexpected(ioe); } |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
291 |
try { if (sc != null) sc.close(); } |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
292 |
catch (IOException ioe) { unexpected(ioe); } |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
293 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
294 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
295 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
296 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
297 |
class CommUpNotificationHandler extends AbstractNotificationHandler<Object> |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
298 |
{ |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
299 |
private boolean receivedCommUp; // false |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
300 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
301 |
public synchronized boolean receivedCommUp() { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
302 |
return receivedCommUp; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
303 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
304 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
305 |
public synchronized boolean waitForCommUp() throws InterruptedException { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
306 |
while (receivedCommUp == false) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
307 |
wait(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
308 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
309 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
310 |
return false; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
311 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
312 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
313 |
@Override |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
314 |
public HandlerResult handleNotification( |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
315 |
Notification notification, Object attachment) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
316 |
fail("Unknown notification type"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
317 |
return HandlerResult.CONTINUE; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
318 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
319 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
320 |
@Override |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
321 |
public synchronized HandlerResult handleNotification( |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
322 |
AssociationChangeNotification notification, Object attachment) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
323 |
AssocChangeEvent event = notification.event(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
324 |
debug("AssociationChangeNotification"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
325 |
debug(" Association: " + notification.association()); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
326 |
debug(" Event: " + event); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
327 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
328 |
if (event.equals(AssocChangeEvent.COMM_UP)) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
329 |
receivedCommUp = true; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
330 |
notifyAll(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
331 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
332 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
333 |
return HandlerResult.RETURN; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
334 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
335 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
336 |
@Override |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
337 |
public HandlerResult handleNotification( |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
338 |
ShutdownNotification notification, Object attachment) { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
339 |
debug("ShutdownNotification"); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
340 |
debug(" Association: " + notification.association()); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
341 |
return HandlerResult.RETURN; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
342 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
343 |
} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
344 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
345 |
//--------------------- Infrastructure --------------------------- |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
346 |
boolean debug = true; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
347 |
volatile int passed = 0, failed = 0; |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
348 |
void pass() {passed++;} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
349 |
void fail() {failed++; Thread.dumpStack();} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
350 |
void fail(String msg) {err.println(msg); fail();} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
351 |
void unexpected(Throwable t) {failed++; t.printStackTrace();} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
352 |
void check(boolean cond) {if (cond) pass(); else fail();} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
353 |
void check(boolean cond, String failMessage) {if (cond) pass(); else fail(failMessage);} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
354 |
void debug(String message) {if(debug) { out.println(Thread.currentThread().getName() + ": " + message); } } |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
355 |
void sleep(long millis) { try { Thread.currentThread().sleep(millis); } |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
356 |
catch(InterruptedException ie) { unexpected(ie); }} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
357 |
public static void main(String[] args) throws Throwable { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
358 |
Class<?> k = new Object(){}.getClass().getEnclosingClass(); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
359 |
try {k.getMethod("instanceMain",String[].class) |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
360 |
.invoke( k.newInstance(), (Object) args);} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
361 |
catch (Throwable e) {throw e.getCause();}} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
362 |
public void instanceMain(String[] args) throws Throwable { |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
363 |
try {test(args);} catch (Throwable t) {unexpected(t);} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
364 |
out.printf("%nPassed = %d, failed = %d%n%n", passed, failed); |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
365 |
if (failed > 0) throw new AssertionError("Some tests failed");} |
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
366 |
|
a7c037dd2e14
6863110: Newly connected/accepted SctpChannel should fire OP_READ if registered with a Selector
chegar
parents:
diff
changeset
|
367 |
} |