lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
kamhung
2015-11-12 18:05:27 +08:00
parent d64031aa00
commit 5bd35d38fe
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/com/wentch/redkale/net/Transport.java
View File

@@ -30,6 +30,8 @@ public final class Transport {
protected final int bufferCapacity; protected final int bufferCapacity;
protected final boolean tcp;
protected final String protocol; protected final String protocol;
protected final AsynchronousChannelGroup group; protected final AsynchronousChannelGroup group;
@@ -49,6 +51,7 @@ public final class Transport {
public Transport(String name, String protocol, WatchFactory watch, int bufferPoolSize, Collection<InetSocketAddress> addresses) { public Transport(String name, String protocol, WatchFactory watch, int bufferPoolSize, Collection<InetSocketAddress> addresses) {
this.name = name; this.name = name;
this.protocol = protocol; this.protocol = protocol;
this.tcp = "TCP".equalsIgnoreCase(protocol);
this.bufferPoolSize = bufferPoolSize; this.bufferPoolSize = bufferPoolSize;
this.bufferCapacity = 8192; this.bufferCapacity = 8192;
AsynchronousChannelGroup g = null; AsynchronousChannelGroup g = null;
@@ -129,7 +132,7 @@ public final class Transport {
} }
public boolean isTCP() { public boolean isTCP() {
return "TCP".equalsIgnoreCase(protocol); return tcp;
} }
public AsyncConnection pollConnection(SocketAddress addr) { public AsyncConnection pollConnection(SocketAddress addr) {
@@ -137,7 +140,7 @@ public final class Transport {
final boolean rand = addr == null; final boolean rand = addr == null;
if (rand && remoteAddres.length < 1) throw new RuntimeException("Transport (" + this.name + ") has no remoteAddress list"); if (rand && remoteAddres.length < 1) throw new RuntimeException("Transport (" + this.name + ") has no remoteAddress list");
try { try {
if ("TCP".equalsIgnoreCase(protocol)) { if (tcp) {
AsynchronousSocketChannel channel = null; AsynchronousSocketChannel channel = null;
if (rand) { //随机取地址 if (rand) { //随机取地址
int p = 0; int p = 0;