diff --git a/client/portgroup.cpp b/client/portgroup.cpp
index 9762fac..0d50228 100644
--- a/client/portgroup.cpp
+++ b/client/portgroup.cpp
@@ -138,6 +138,8 @@ void PortGroup::on_rpcChannel_disconnected()
     emit portListChanged(mPortGroupId);
     emit portGroupDataChanged(mPortGroupId);
 
+    isGetStatsPending_ = false;
+
     if (reconnect)
     {
         qDebug("starting reconnect timer for %d ms ...", reconnectAfter);
diff --git a/rpc/pbrpcchannel.cpp b/rpc/pbrpcchannel.cpp
index 7c7789e..5ef1003 100644
--- a/rpc/pbrpcchannel.cpp
+++ b/rpc/pbrpcchannel.cpp
@@ -102,9 +102,10 @@ void PbRpcChannel::CallMethod(
     if (isPending)
     {
         RpcCall call;
-        qDebug("RpcChannel: queueing method %d since %d is pending; "
-                "queued message = <%s>", 
-                method->index(), pendingMethodId, req->DebugString().c_str());
+        qDebug("RpcChannel: queueing rpc since method %d is pending;<----\n "
+                "queued method = %d\n"
+                "queued message = \n%s\n---->", 
+                pendingMethodId, method->index(), req->DebugString().c_str());
 
         call.method = method;
         call.controller = controller;
@@ -122,10 +123,9 @@ void PbRpcChannel::CallMethod(
 
     if (!req->IsInitialized())
     {
-        qWarning("RpcChannel: missing required fields in request");
-        qDebug("%s", req->InitializationErrorString().c_str());
-
-        qFatal("exiting");
+        qWarning("RpcChannel: missing required fields in request <----");
+        qDebug("req = \n%s", req->DebugString().c_str());
+        qDebug("error = \n%s\n--->", req->InitializationErrorString().c_str());
 
         controller->SetFailed("Required fields missing");
         done->Run();
@@ -146,9 +146,11 @@ void PbRpcChannel::CallMethod(
     // Avoid printing stats since it happens every couple of seconds
     if (pendingMethodId != 13)
     {
-        qDebug("client(%s) sending %d bytes encoding <%s>", __FUNCTION__, 
-                PB_HDR_SIZE + len, req->DebugString().c_str());
+        qDebug("client(%s) sending %d bytes <----", __FUNCTION__, 
+                PB_HDR_SIZE + len);
         BUFDUMP(msg, PB_HDR_SIZE);
+        qDebug("method = %d\n req = \n%s\n---->", 
+                method->index(), req->DebugString().c_str());
     }
 
     mpSocket->write(msg, PB_HDR_SIZE);
@@ -256,14 +258,17 @@ void PbRpcChannel::on_mpSocket_readyRead()
             // Avoid printing stats
             if (method != 13)
             {
-                qDebug("client(%s): Parsed as %s", __FUNCTION__,
-                    response->DebugString().c_str());
+                qDebug("client(%s): Received Msg <---- ", __FUNCTION__);
+                qDebug("method = %d\nresp = \n%s\n---->",
+                        method, response->DebugString().c_str());
             }
 
             if (!response->IsInitialized())
             {
-                qWarning("RpcChannel: missing required fields in response");
-                qDebug("%s", response->InitializationErrorString().c_str());
+                qWarning("RpcChannel: missing required fields in response <----");
+                qDebug("resp = \n%s", response->DebugString().c_str());
+                qDebug("error = \n%s\n--->", 
+                        response->InitializationErrorString().c_str());
 
                 controller->SetFailed("Required fields missing");
             }
@@ -286,7 +291,9 @@ void PbRpcChannel::on_mpSocket_readyRead()
     if (pendingCallList.size())
     {
         RpcCall call = pendingCallList.takeFirst();
-        qDebug("RpcChannel: executing queued method %d <%s>", 
+        qDebug("RpcChannel: executing queued method <----\n"
+               "method = %d\n"
+               "req = \n%s\n---->", 
                 call.method->index(), call.request->DebugString().c_str());
         CallMethod(call.method, call.controller, call.request, call.response,
                 call.done);
@@ -298,7 +305,9 @@ _error_exit:
     inStream->Skip(len);
 _error_exit2:
     parsing = false;
-    qDebug("client(%s) discarding received msg", __FUNCTION__);
+    qDebug("client(%s) discarding received msg <----", __FUNCTION__);
+    qDebug("method = %d\nreq = \n%s\n---->",
+            method, response->DebugString().c_str());
     return;
 }
 
diff --git a/rpc/rpcconn.cpp b/rpc/rpcconn.cpp
index 123c25d..0e162a0 100644
--- a/rpc/rpcconn.cpp
+++ b/rpc/rpcconn.cpp
@@ -42,6 +42,8 @@ RpcConnection::RpcConnection(int socketDescriptor,
 
     isPending = false;
     pendingMethodId = -1; // don't care as long as isPending is false
+
+    parsing = false;
 }
 
 RpcConnection::~RpcConnection()
@@ -69,6 +71,7 @@ void RpcConnection::start()
         qWarning("Unable to initialize TCP socket for incoming connection");
         return;
     }
+    qDebug("clientSock Thread = %p", clientSock->thread());
 
     qDebug("accepting new connection from %s: %d", 
             clientSock->peerAddress().toString().toAscii().constData(),
@@ -129,8 +132,11 @@ void RpcConnection::sendRpcReply(PbRpcController *controller)
 
     if (!response->IsInitialized())
     {
-        qWarning("response missing required fields!!");
-        qDebug("%s", response->InitializationErrorString().c_str());
+        qWarning("response missing required fields!! <----");
+        qDebug("response = \n%s"
+               "missing = \n%s---->",
+                response->DebugString().c_str(),
+                response->InitializationErrorString().c_str());
         qFatal("exiting");
         goto _exit;
     }
@@ -144,9 +150,11 @@ void RpcConnection::sendRpcReply(PbRpcController *controller)
     // Avoid printing stats since it happens once every couple of seconds
     if (pendingMethodId != 13)
     {
-        qDebug("Server(%s): sending %d bytes to client encoding <%s>", 
-            __FUNCTION__, len + PB_HDR_SIZE, response->DebugString().c_str());
-        //BUFDUMP(msg, len + 8);
+        qDebug("Server(%s): sending %d bytes to client <----",
+            __FUNCTION__, len + PB_HDR_SIZE);
+        BUFDUMP(msg, len + 8);
+        qDebug("method = %d\nreq = \n%s---->", 
+            pendingMethodId, response->DebugString().c_str());
     }
 
     clientSock->write(msg, PB_HDR_SIZE);
@@ -178,9 +186,11 @@ void RpcConnection::on_clientSock_dataAvail()
 {
     uchar    msg[PB_HDR_SIZE];
     int        msgLen;
+#if 0
     static bool parsing = false;
     static quint16    type, method;
     static quint32 len;
+#endif
     const ::google::protobuf::MethodDescriptor    *methodDesc;
     ::google::protobuf::Message    *req, *resp;
     PbRpcController *controller;
@@ -228,21 +238,35 @@ void RpcConnection::on_clientSock_dataAvail()
     req = service->GetRequestPrototype(methodDesc).New();
     resp = service->GetResponsePrototype(methodDesc).New();
 
-    if (len)
-        req->ParseFromBoundedZeroCopyStream(inStream, len);
+    if (len) {
+        bool ok = req->ParseFromBoundedZeroCopyStream(inStream, len);
+        if (!ok)
+            qWarning("ParseFromBoundedZeroCopyStream fail "
+                     "for method %d and len %d", method, len);
+    }
 
     if (!req->IsInitialized())
     {
-        qWarning("Missing required fields in request");
-        qDebug("%s", req->InitializationErrorString().c_str());
+        qWarning("Missing required fields in request <----");
+        qDebug("method = %d\n"
+               "req = \n%s"
+               "missing = \n%s----->",
+                method, req->DebugString().c_str(),
+                req->InitializationErrorString().c_str());
         qFatal("exiting");
         delete req;
         delete resp;
 
         goto _error_exit2;
     }
-    //qDebug("Server(%s): successfully parsed as <%s>", __FUNCTION__, 
-        //resp->DebugString().c_str());
+    
+    if (method != 13) {
+        qDebug("Server(%s): successfully received/parsed msg <----", __FUNCTION__);
+        qDebug("method = %d\n"
+               "req = \n%s---->",
+                method,
+                req->DebugString().c_str());
+    }
 
     controller = new PbRpcController(req, resp);
 
diff --git a/rpc/rpcconn.h b/rpc/rpcconn.h
index ce5e5bd..6d19d12 100644
--- a/rpc/rpcconn.h
+++ b/rpc/rpcconn.h
@@ -65,6 +65,11 @@ private:
 
     bool isPending;
     int pendingMethodId;
+
+    bool parsing;
+    quint16 type;
+    quint16 method;
+    quint32 len;
 };
 
 #endif
diff --git a/server/winpcapport.cpp b/server/winpcapport.cpp
index bbd49d8..f42adaa 100644
--- a/server/winpcapport.cpp
+++ b/server/winpcapport.cpp
@@ -140,7 +140,7 @@ void WinPcapPort::PortMonitor::run()
     quint64 lastTxPkts = 0;
     quint64 lastTxBytes = 0;
 
-    qWarning("in %s", __PRETTY_FUNCTION__);
+    qDebug("in %s", __PRETTY_FUNCTION__);
 
     lastTs.tv_sec = 0;
     lastTs.tv_usec = 0;