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

Browse Source
This commit is contained in:
Redkale
2018-04-16 13:29:12 +08:00
parent 3497ab0c73
commit 812f83446e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/source/PoolTcpSource.java
View File

@@ -51,7 +51,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
return pollAsync().join();
}
protected abstract ByteBuffer reqConnectBuffer();
protected abstract ByteBuffer reqConnectBuffer(AsyncConnection conn);
protected abstract void respConnectBuffer(final ByteBuffer buffer, CompletableFuture<AsyncConnection> future, AsyncConnection conn);
@@ -59,7 +59,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
public CompletableFuture<AsyncConnection> pollAsync() {
return AsyncConnection.createTCP(group, this.servaddr, this.readTimeoutSeconds, this.writeTimeoutSeconds).thenCompose(conn -> {
CompletableFuture<AsyncConnection> future = new CompletableFuture();
final ByteBuffer buffer = reqConnectBuffer();
final ByteBuffer buffer = reqConnectBuffer(conn);
conn.write(buffer, null, new CompletionHandler<Integer, Void>() {
@Override
public void completed(Integer result, Void attachment1) {