.

neo/lib/event.py

@@ -109,7 +109,7 @@ class EpollEventManager(object):
             self.wakeup()
         else:
             self.epoll.register(fd)
-            self.addReader(conn)        # FIXME implicitly adding addReader
+            self.addReader(conn)        # FIXME implicitly setting "ready to read"
 
     def unregister(self, conn, close=False):
         new_pending_processing = [x for x in self._pending_processing

neo/lib/util.py

@@ -199,7 +199,7 @@ class ReadBuffer(object):
             keep, let = last_chunk[:to_read], last_chunk[to_read:]
             self.content.appendleft(let)
             chunk_list[-1] = keep
-        # join all chunks (one copy)    // XXX only 1 chunk -> no copy at all
+        # join all chunks (one copy)
         data = ''.join(chunk_list)
         assert len(data) == size
         return data

neo/master/app.py

@@ -267,7 +267,7 @@ class Application(BaseApplication):
                         raise RuntimeError("No upstream cluster to backup"
                                            " defined in configuration")
                     truncate = Packets.Truncate(
-                        self.backup_app.provideService())   # NOTE enter to backup main loop
+                        self.backup_app.provideService())
                 except StoppedOperation, e:
                     logging.critical('No longer operational')
                     truncate = Packets.Truncate(*e.args) if e.args else None
@@ -522,7 +522,7 @@ class Application(BaseApplication):
                 client_node.send(Packets.AnswerTransactionFinished(ttid, tid),
                                  msg_id=txn.getMessageId())                       # NOTE msgid: out-of-order answer
             else:
-                # NOTE notifies clients irregardless of whether client was subscribed
+                # NOTE notifies all clients irregardless of whether who was subscribed
                 client_node.send(invalidate_objects)
 
         # Unlock Information to relevant storage nodes.

neo/master/handlers/administration.py

@@ -72,7 +72,7 @@ class AdministrationHandler(MasterHandler):
                         'entering cluster' % (node, ))
             app._startup_allowed = True
             state = app.cluster_state
-        elif state == ClusterStates.STARTING_BACKUP:    # NOTE
+        elif state == ClusterStates.STARTING_BACKUP:
             if app.tm.hasPending() or app.nm.getClientList(True):
                 raise ProtocolError("Can not switch to %s state with pending"
                     " transactions or connected clients" % state)