From 97b20f71bcae77e6183aea035a108f8160e1a27a Mon Sep 17 00:00:00 2001
From: wentch <22250530@qq.com>
Date: Tue, 29 Dec 2015 17:22:58 +0800
Subject: [PATCH]

---
 src/org/redkale/net/http/WebSocket.java       | 10 ++++++----
 src/org/redkale/net/http/WebSocketRunner.java |  2 +-
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/src/org/redkale/net/http/WebSocket.java b/src/org/redkale/net/http/WebSocket.java
index b30a7db8e..92aa62c72 100644
--- a/src/org/redkale/net/http/WebSocket.java
+++ b/src/org/redkale/net/http/WebSocket.java
@@ -57,7 +57,7 @@ public abstract class WebSocket {
 
     public static final int RETCODE_WSOFFLINE = 1 << 8; //256
 
-    WebSocketRunner runner; //不可能为空 
+    WebSocketRunner _runner; //不可能为空 
 
     WebSocketEngine _engine; //不可能为空 
 
@@ -86,15 +86,17 @@ public abstract class WebSocket {
      * @return
      */
     public final int send(WebSocketPacket packet) {
-        if (this.runner != null) return this.runner.sendMessage(packet);
-        return RETCODE_WSOCKET_CLOSED;
+        int rs = 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
      */
     public final void close() {
-        if (this.runner != null) this.runner.closeRunner();
+        if (this._runner != null) this._runner.closeRunner();
     }
 
     /**
diff --git a/src/org/redkale/net/http/WebSocketRunner.java b/src/org/redkale/net/http/WebSocketRunner.java
index 90842a2c4..62394f9c0 100644
--- a/src/org/redkale/net/http/WebSocketRunner.java
+++ b/src/org/redkale/net/http/WebSocketRunner.java
@@ -52,7 +52,7 @@ public class WebSocketRunner implements Runnable {
         this.webSocket = webSocket;
         this.channel = channel;
         this.wsbinary = wsbinary;
-        webSocket.runner = this;
+        webSocket._runner = this;
         this.coder.logger = context.getLogger();
         this.coder.debugable = false;//context.getLogger().isLoggable(Level.FINEST);
         this.readBuffer = context.pollBuffer();