diff --git a/components/net/cpp/src/peer.cpp b/components/net/cpp/src/peer.cpp
index f3f875ae8e648c176159417adf9711318ae3cb7d..aa5d6e958bb225c2cc45733ff707cf4b68cdc4bb 100644
--- a/components/net/cpp/src/peer.cpp
+++ b/components/net/cpp/src/peer.cpp
@@ -429,7 +429,7 @@ void Peer::data() {
 	}
 	lk.unlock();
 
-	//LOG(INFO) << "Received " << rc << " bytes";
+	LOG(INFO) << "Received " << rc << " bytes";
 }
 
 bool Peer::_data() {
@@ -467,10 +467,10 @@ bool Peer::_data() {
 
 		// CHECK Safe to unlock here?
 		is_waiting_ = true;
-		lk.unlock();
+		//lk.unlock();
 		disp_->dispatch(*this, obj);
 		// Relock before next loop of while
-		lk.lock();
+		//lk.lock();
 		is_waiting_ = false;
 
 		if (scheme_ == ftl::URI::SCHEME_WS && recv_buf_.nonparsed_size() > 0) {
diff --git a/components/rgbd-sources/src/streamer.cpp b/components/rgbd-sources/src/streamer.cpp
index 49b5f3077a541278ed809f9e8464ce37622cd097..8273a6fbd9b91888c7bcd7b7f651fdda3e5138b8 100644
--- a/components/rgbd-sources/src/streamer.cpp
+++ b/components/rgbd-sources/src/streamer.cpp
@@ -299,7 +299,7 @@ void Streamer::_schedule() {
 					vector<int> pngparams = {cv::IMWRITE_PNG_COMPRESSION, 1}; // Default is 1 for fast, 9 = small but slow.
 					cv::imencode(".png", d2, d_buf, pngparams);
 
-					LOG(INFO) << "Sending chunk " << chunk;
+					LOG(INFO) << "Sending chunk " << chunk << " : size = " << chunkRGB.cols << "," << chunkRGB.rows;
 
 					UNIQUE_LOCK(src->mutex,lk);
 					auto i = src->clients[0].begin();
@@ -312,6 +312,7 @@ void Streamer::_schedule() {
 						} catch(...) {
 							(*i).txcount = (*i).txmax;
 						}
+						i++;
 					}
 				}