Small cleanup

dgomezferro · May 2, 2012 · 6e04725 · 6e04725
1 parent 69aaaaa
commit 6e04725
Showing 1 changed file with 8 additions and 11 deletions.
diff --git a/src/main/java/com/yahoo/omid/tso/TSOHandler.java b/src/main/java/com/yahoo/omid/tso/TSOHandler.java
@@ -204,17 +204,14 @@ public void handle(TimestampRequest msg, ChannelHandlerContext ctx) {
         synchronized (messageBuffersMap) {
             buffer = messageBuffersMap.get(ctx.getChannel());
             if (buffer == null) {
-//                synchronized (sharedState) {
-                    synchronized (sharedMsgBufLock) {
-                        bootstrap = true;
-                        channel = ctx.getChannel();
-                        buffer = sharedState.sharedMessageBuffer.new ReadingBuffer(channel);
-                        messageBuffersMap.put(channel, buffer);
-                        channelGroup.add(channel);
-//                        clientChannels.add(channel);
-                        LOG.warn("Channel connected: " + messageBuffersMap.size());
-                    }
-//                }
+                 synchronized (sharedMsgBufLock) {
+                     bootstrap = true;
+                     channel = ctx.getChannel();
+                     buffer = sharedState.sharedMessageBuffer.new ReadingBuffer(channel);
+                     messageBuffersMap.put(channel, buffer);
+                     channelGroup.add(channel);
+                     LOG.warn("Channel connected: " + messageBuffersMap.size());
+                 }
             }
         }
         if (bootstrap) {