Commit 2114e6db authored by Julien Muchembled's avatar Julien Muchembled

Remove unused Barrier packet

parent 9d8081f5
...@@ -1058,9 +1058,6 @@ class Application(object): ...@@ -1058,9 +1058,6 @@ class Application(object):
psThreadedPoll() psThreadedPoll()
close = __del__ close = __del__
def invalidationBarrier(self):
self._askPrimary(Packets.AskBarrier())
def pack(self, t): def pack(self, t):
tid = repr(TimeStamp(*time.gmtime(t)[:5] + (t % 60, ))) tid = repr(TimeStamp(*time.gmtime(t)[:5] + (t % 60, )))
if tid == ZERO_TID: if tid == ZERO_TID:
......
...@@ -133,12 +133,6 @@ class EventHandler(object): ...@@ -133,12 +133,6 @@ class EventHandler(object):
def notify(self, conn, message): def notify(self, conn, message):
neo.lib.logging.info('notification from %r: %s', conn, message) neo.lib.logging.info('notification from %r: %s', conn, message)
def askBarrier(self, conn):
conn.answer(Packets.AnswerBarrier())
def answerBarrier(self, conn):
pass
# Error packet handlers. # Error packet handlers.
def error(self, conn, code, message): def error(self, conn, code, message):
......
...@@ -1245,15 +1245,6 @@ class CheckCurrentSerial(Packet): ...@@ -1245,15 +1245,6 @@ class CheckCurrentSerial(Packet):
PTID('serial'), PTID('serial'),
) )
class Barrier(Packet):
"""
Initates a "network barrier", allowing the node sending this packet to know
when all packets sent previously on the same connection have been handled
by its peer.
"""
_answer = PFEmpty
class Pack(Packet): class Pack(Packet):
""" """
Request a pack at given TID. Request a pack at given TID.
...@@ -1525,8 +1516,7 @@ class Packets(dict): ...@@ -1525,8 +1516,7 @@ class Packets(dict):
0x002B, TIDListFrom) 0x002B, TIDListFrom)
AskObjectHistoryFrom, AnswerObjectHistoryFrom = register( AskObjectHistoryFrom, AnswerObjectHistoryFrom = register(
0x002C, ObjectHistoryFrom) 0x002C, ObjectHistoryFrom)
AskBarrier, AnswerBarrier = register( # 2D
0x002D, Barrier)
AskPack, AnswerPack = register( AskPack, AnswerPack = register(
0x002E, Pack, ignore_when_closed=False) 0x002E, Pack, ignore_when_closed=False)
AskCheckTIDRange, AnswerCheckTIDRange = register( AskCheckTIDRange, AnswerCheckTIDRange = register(
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment