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-12-17 10:57:49 +08:00
parent 2f89778fd6
commit 1824f8150c
3 changed files with 3 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/org/redkale/net/Context.java
View File

@@ -164,18 +164,18 @@ public class Context {
return bufferPool.get(); return bufferPool.get();
} }
protected void offerBuffer(ByteBuffer buffer) { public void offerBuffer(ByteBuffer buffer) {
bufferPool.accept(buffer); bufferPool.accept(buffer);
} }
protected void offerBuffer(ByteBuffer... buffers) { public void offerBuffer(ByteBuffer... buffers) {
if (buffers == null) return; if (buffers == null) return;
for (ByteBuffer buffer : buffers) { for (ByteBuffer buffer : buffers) {
bufferPool.accept(buffer); bufferPool.accept(buffer);
} }
} }
protected void offerBuffer(Collection<ByteBuffer> buffers) { public void offerBuffer(Collection<ByteBuffer> buffers) {
if (buffers == null) return; if (buffers == null) return;
for (ByteBuffer buffer : buffers) { for (ByteBuffer buffer : buffers) {
bufferPool.accept(buffer); bufferPool.accept(buffer);

17
src/org/redkale/net/http/HttpContext.java
View File

@@ -5,11 +5,9 @@
*/ */
package org.redkale.net.http; package org.redkale.net.http;
import java.nio.ByteBuffer;
import org.redkale.asm.MethodDebugVisitor; import org.redkale.asm.MethodDebugVisitor;
import java.nio.channels.CompletionHandler; import java.nio.channels.CompletionHandler;
import java.security.*; import java.security.*;
import java.util.Collection;
import java.util.concurrent.*; import java.util.concurrent.*;
import org.redkale.asm.*; import org.redkale.asm.*;
import static org.redkale.asm.Opcodes.*; import static org.redkale.asm.Opcodes.*;
@@ -49,21 +47,6 @@ public class HttpContext extends Context {
return responsePool; return responsePool;
} }
@Override
protected void offerBuffer(ByteBuffer buffer) {
super.offerBuffer(buffer);
}
@Override
protected void offerBuffer(ByteBuffer... buffers) {
super.offerBuffer(buffers);
}
@Override
protected void offerBuffer(Collection<ByteBuffer> buffers) {
super.offerBuffer(buffers);
}
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
protected <H extends CompletionHandler> Creator<H> loadAsyncHandlerCreator(Class<H> handlerClass) { protected <H extends CompletionHandler> Creator<H> loadAsyncHandlerCreator(Class<H> handlerClass) {
Creator<H> creator = asyncHandlerCreators.get(handlerClass); Creator<H> creator = asyncHandlerCreators.get(handlerClass);

17
src/org/redkale/net/sncp/SncpContext.java
View File

@@ -5,8 +5,6 @@
*/ */
package org.redkale.net.sncp; package org.redkale.net.sncp;
import java.nio.ByteBuffer;
import java.util.Collection;
import org.redkale.net.*; import org.redkale.net.*;
/** /**
@@ -21,21 +19,6 @@ public class SncpContext extends Context {
super(config); super(config);
} }
@Override
protected void offerBuffer(ByteBuffer buffer) {
super.offerBuffer(buffer);
}
@Override
protected void offerBuffer(ByteBuffer... buffers) {
super.offerBuffer(buffers);
}
@Override
protected void offerBuffer(Collection<ByteBuffer> buffers) {
super.offerBuffer(buffers);
}
public static class SncpContextConfig extends ContextConfig { public static class SncpContextConfig extends ContextConfig {
} }