New upstream version 3.7.2
Markus Koschany
4 years ago
36 | 36 |
<parent>
|
37 | 37 |
<groupId>org.jboss.xnio</groupId>
|
38 | 38 |
<artifactId>xnio-all</artifactId>
|
39 | |
<version>3.7.0.Final</version>
|
|
39 |
<version>3.7.2.Final</version>
|
40 | 40 |
</parent>
|
41 | 41 |
|
42 | 42 |
<dependencies>
|
|
174 | 174 |
</includes>
|
175 | 175 |
<enableAssertions>true</enableAssertions>
|
176 | 176 |
<redirectTestOutputToFile>true</redirectTestOutputToFile>
|
|
177 |
<argLine>-Djdk.attach.allowAttachSelf</argLine>
|
177 | 178 |
</configuration>
|
178 | 179 |
</plugin>
|
179 | 180 |
<plugin>
|
|
185 | 186 |
<footer><![CDATA[XNIO API ]]>${project.version}</footer>
|
186 | 187 |
<bottom><![CDATA[<i>Copyright © 2017 JBoss, a division of Red Hat, Inc.</i>]]></bottom>
|
187 | 188 |
<links>
|
188 | |
<link>http://java.sun.com/javase/8/docs/api/</link>
|
|
189 |
<link>https://docs.oracle.com/javase/8/docs/api/</link>
|
189 | 190 |
</links>
|
190 | 191 |
</configuration>
|
191 | 192 |
</plugin>
|
35 | 35 |
* @param executor the executor to use to execute listener notifiers.
|
36 | 36 |
*/
|
37 | 37 |
public FutureResult(final Executor executor) {
|
38 | |
ioFuture = new AbstractIoFuture<T>() {
|
39 | |
protected Executor getNotifierExecutor() {
|
40 | |
return executor;
|
41 | |
}
|
42 | |
};
|
|
38 |
ioFuture = new AbstractIoFuture<T>(){};
|
43 | 39 |
}
|
44 | 40 |
|
45 | 41 |
/**
|
468 | 468 |
// given caller is reading, tell it to continue only if we can move away from NEED_WRAP
|
469 | 469 |
// and flush any wrapped data we may have left
|
470 | 470 |
if (doFlush()) {
|
|
471 |
if (result.getStatus() == SSLEngineResult.Status.CLOSED) {
|
|
472 |
closeOutbound();
|
|
473 |
return false;
|
|
474 |
}
|
471 | 475 |
if (!handleWrapResult(result = engineWrap(Buffers.EMPTY_BYTE_BUFFER, buffer), true) || !doFlush()) {
|
472 | 476 |
needWrap();
|
473 | 477 |
return false;
|
30 | 30 |
<parent>
|
31 | 31 |
<groupId>org.jboss.xnio</groupId>
|
32 | 32 |
<artifactId>xnio-all</artifactId>
|
33 | |
<version>3.7.0.Final</version>
|
|
33 |
<version>3.7.2.Final</version>
|
34 | 34 |
</parent>
|
35 | 35 |
|
36 | 36 |
<properties>
|
26 | 26 |
import java.net.ServerSocket;
|
27 | 27 |
import java.net.Socket;
|
28 | 28 |
import java.net.SocketAddress;
|
|
29 |
import java.nio.channels.ClosedChannelException;
|
29 | 30 |
import java.nio.channels.SelectionKey;
|
30 | 31 |
import java.nio.channels.ServerSocketChannel;
|
31 | 32 |
import java.nio.channels.SocketChannel;
|
|
479 | 480 |
IoUtils.safeClose(accepted);
|
480 | 481 |
return;
|
481 | 482 |
}
|
|
483 |
} catch (ClosedChannelException e) {
|
|
484 |
tcpServerLog.logf(FQCN, Logger.Level.DEBUG, e, "ClosedChannelException occurred at accepting request on the server channel %s", channel);
|
|
485 |
return;
|
482 | 486 |
} catch (IOException e) {
|
483 | |
tcpServerLog.logf(FQCN, Logger.Level.DEBUG, e, "Exception accepting request, closing server channel %s", this);
|
|
487 |
tcpServerLog.logf(FQCN, Logger.Level.ERROR, e, "Exception accepting request, closing server channel %s", this);
|
484 | 488 |
IoUtils.safeClose(channel);
|
485 | 489 |
return;
|
486 | 490 |
}
|
333 | 333 |
}
|
334 | 334 |
}
|
335 | 335 |
} catch (IOException e) {
|
336 | |
selectorLog.tracef("ConnectHandle.handleReady Exception, " + e);
|
|
336 |
selectorLog.tracef("ConnectHandle.handleReady Exception, %s", e);
|
337 | 337 |
futureResult.setException(e);
|
338 | 338 |
} finally {
|
339 | 339 |
if (!ok) {
|
|
620 | 620 |
}
|
621 | 621 |
synchronized (workLock) {
|
622 | 622 |
selectorWorkQueue.add(command);
|
623 | |
log.tracef("Added task " + command);
|
|
623 |
log.tracef("Added task %s", command);
|
624 | 624 |
}
|
625 | 625 |
if (polling) { // flag is always false if we're the same thread
|
626 | 626 |
selector.wakeup();
|
31 | 31 |
<artifactId>xnio-all</artifactId>
|
32 | 32 |
<packaging>pom</packaging>
|
33 | 33 |
<name>XNIO Parent POM</name>
|
34 | |
<version>3.7.0.Final</version>
|
|
34 |
<version>3.7.2.Final</version>
|
35 | 35 |
<description>The aggregator POM of the XNIO project</description>
|
36 | 36 |
|
37 | 37 |
<licenses>
|
|
48 | 48 |
</modules>
|
49 | 49 |
|
50 | 50 |
<properties>
|
51 | |
<byteman-version>3.0.3</byteman-version>
|
52 | |
<version.org.jboss.logging.jboss-logging>3.3.1.Final</version.org.jboss.logging.jboss-logging>
|
53 | |
<version.org.jboss.logging.jboss-logging-tools>2.1.0.Final</version.org.jboss.logging.jboss-logging-tools>
|
54 | |
<version.org.jboss.logmanager.jboss-logmanager>2.0.7.Final</version.org.jboss.logmanager.jboss-logmanager>
|
|
51 |
<byteman-version>4.0.6</byteman-version>
|
|
52 |
<version.org.jboss.logging.jboss-logging>3.4.0.Final</version.org.jboss.logging.jboss-logging>
|
|
53 |
<version.org.jboss.logging.jboss-logging-tools>2.2.0.Final</version.org.jboss.logging.jboss-logging-tools>
|
|
54 |
<version.org.jboss.logmanager.jboss-logmanager>2.1.10.Final</version.org.jboss.logmanager.jboss-logmanager>
|
55 | 55 |
<version.org.jboss.threads>2.3.0.Beta2</version.org.jboss.threads>
|
56 | 56 |
<version.org.wildfly.common>1.3.0.Final</version.org.wildfly.common>
|
57 | 57 |
<version.org.wildfly.client-config>1.0.0.Final</version.org.wildfly.client-config>
|