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:23:27 +08:00
parent 97b20f71bc
commit 69b926d4c7
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -88,7 +88,7 @@ public abstract class WebSocket {
public final int send(WebSocketPacket packet) { public final int send(WebSocketPacket packet) {
int rs = RETCODE_WSOCKET_CLOSED; int rs = RETCODE_WSOCKET_CLOSED;
if (this._runner != null) rs = this._runner.sendMessage(packet); 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 + ")"); if(_engine.finest) _engine.logger.finest("wsgroupid:" + getGroupid() + " websocket send result is " + rs + " on " + this + " by message(" + packet + ")");
return rs; return rs;
} }
@@ -260,14 +260,14 @@ public abstract class WebSocket {
private int sendMessage(Serializable groupid, boolean recent, String text, boolean last) { private int sendMessage(Serializable groupid, boolean recent, String text, boolean last) {
if (_engine.node == null) return RETCODE_NODESERVICE_NULL; if (_engine.node == null) return RETCODE_NODESERVICE_NULL;
int rs = _engine.node.sendMessage(groupid, recent, text, last); int rs = _engine.node.sendMessage(groupid, recent, text, last);
if(_engine.finest) _engine.logger.finest("groupid:" + groupid + " websocket "+(recent ? "recent " : "") + "send result is " + rs + " on " + this + " by message(" + text + ")"); if(_engine.finest) _engine.logger.finest("wsgroupid:" + groupid + " websocket "+(recent ? "recent " : "") + "send result is " + rs + " on " + this + " by message(" + text + ")");
return rs; return rs;
} }
private int sendMessage(Serializable groupid, boolean recent, byte[] data, boolean last) { private int sendMessage(Serializable groupid, boolean recent, byte[] data, boolean last) {
if (_engine.node == null) return RETCODE_NODESERVICE_NULL; if (_engine.node == null) return RETCODE_NODESERVICE_NULL;
int rs = _engine.node.sendMessage(groupid, recent, data, last); int rs = _engine.node.sendMessage(groupid, recent, data, last);
if(_engine.finest) _engine.logger.finest("groupid:" + groupid + " websocket "+(recent ? "recent " : "") + "send result is " + rs + " on " + this + " by message(byte[" + data.length + "])"); if(_engine.finest) _engine.logger.finest("wsgroupid:" + groupid + " websocket "+(recent ? "recent " : "") + "send result is " + rs + " on " + this + " by message(byte[" + data.length + "])");
return rs; return rs;
} }