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

Browse Source
This commit is contained in:
wentch
2015-12-29 17:22:58 +08:00
parent 5b0ada9cd4
commit 97b20f71bc
2 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/org/redkale/net/http/WebSocket.java
View File

@@ -57,7 +57,7 @@ public abstract class WebSocket {
public static final int RETCODE_WSOFFLINE = 1 << 8; //256 public static final int RETCODE_WSOFFLINE = 1 << 8; //256
WebSocketRunner runner; //不可能为空 WebSocketRunner _runner; //不可能为空
WebSocketEngine _engine; //不可能为空 WebSocketEngine _engine; //不可能为空
@@ -86,15 +86,17 @@ public abstract class WebSocket {
* @return * @return
*/ */
public final int send(WebSocketPacket packet) { public final int send(WebSocketPacket packet) {
if (this.runner != null) return this.runner.sendMessage(packet); int rs = RETCODE_WSOCKET_CLOSED;
return RETCODE_WSOCKET_CLOSED; if (this._runner != null) rs = this._runner.sendMessage(packet);
if(_engine.finest) _engine.logger.finest("groupid:" + getGroupid() + " websocket send result is " + rs + " on " + this + " by message(" + packet + ")");
return rs;
} }
/** /**
* 显式地关闭WebSocket * 显式地关闭WebSocket
*/ */
public final void close() { public final void close() {
if (this.runner != null) this.runner.closeRunner(); if (this._runner != null) this._runner.closeRunner();
} }
/** /**

2
src/org/redkale/net/http/WebSocketRunner.java
View File

@@ -52,7 +52,7 @@ public class WebSocketRunner implements Runnable {
this.webSocket = webSocket; this.webSocket = webSocket;
this.channel = channel; this.channel = channel;
this.wsbinary = wsbinary; this.wsbinary = wsbinary;
webSocket.runner = this; webSocket._runner = this;
this.coder.logger = context.getLogger(); this.coder.logger = context.getLogger();
this.coder.debugable = false;//context.getLogger().isLoggable(Level.FINEST); this.coder.debugable = false;//context.getLogger().isLoggable(Level.FINEST);
this.readBuffer = context.pollBuffer(); this.readBuffer = context.pollBuffer();