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

Browse Source
This commit is contained in:
地平线
2015-11-02 10:52:33 +08:00
parent 1db4f70651
commit 4dd706f491
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/com/wentch/redkale/net/AsyncConnection.java
View File

@@ -264,7 +264,7 @@ public abstract class AsyncConnection implements AsynchronousByteChannel, AutoCl
try { try {
int rs = 0; int rs = 0;
for (int i = offset; i < offset + length; i++) { for (int i = offset; i < offset + length; i++) {
rs += channel.write(srcs[i]); rs += channel.send(srcs[i], remoteAddress);
} }
if (handler != null) handler.completed(rs, attachment); if (handler != null) handler.completed(rs, attachment);
} catch (IOException e) { } catch (IOException e) {
@@ -295,7 +295,7 @@ public abstract class AsyncConnection implements AsynchronousByteChannel, AutoCl
@Override @Override
public <A> void write(ByteBuffer src, A attachment, CompletionHandler<Integer, ? super A> handler) { public <A> void write(ByteBuffer src, A attachment, CompletionHandler<Integer, ? super A> handler) {
try { try {
int rs = channel.write(src); int rs = channel.send(src, remoteAddress);
if (handler != null) handler.completed(rs, attachment); if (handler != null) handler.completed(rs, attachment);
} catch (IOException e) { } catch (IOException e) {
if (handler != null) handler.failed(e, attachment); if (handler != null) handler.failed(e, attachment);
@@ -305,7 +305,7 @@ public abstract class AsyncConnection implements AsynchronousByteChannel, AutoCl
@Override @Override
public Future<Integer> write(ByteBuffer src) { public Future<Integer> write(ByteBuffer src) {
try { try {
int rs = channel.write(src); int rs = channel.send(src, remoteAddress);
return new SimpleFuture(rs); return new SimpleFuture(rs);
} catch (IOException e) { } catch (IOException e) {
throw new RuntimeException(e); throw new RuntimeException(e);