Commit 09425005 authored by Aurel's avatar Aurel

fix import and add checkfor packet type


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@160 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent a6dd40a9
...@@ -14,7 +14,7 @@ from neo.protocol import Packet, INVALID_UUID, INVALID_TID, \ ...@@ -14,7 +14,7 @@ from neo.protocol import Packet, INVALID_UUID, INVALID_TID, \
TEMPORARILY_DOWN_STATE, \ TEMPORARILY_DOWN_STATE, \
UP_TO_DATE_STATE, FEEDING_STATE, INVALID_SERIAL UP_TO_DATE_STATE, FEEDING_STATE, INVALID_SERIAL
from neo.client.handler import ClientEventHandler from neo.client.handler import ClientEventHandler
from neo.client.NEOStorage import NEOStorageError, NEOStorageConflictError, \ from neo.client.Storage import NEOStorageError, NEOStorageConflictError, \
NEOStorageNotFoundError NEOStorageNotFoundError
from neo.util import makeChecksum, dump from neo.util import makeChecksum, dump
...@@ -202,7 +202,7 @@ class Application(object): ...@@ -202,7 +202,7 @@ class Application(object):
finally: finally:
conn.unlock() conn.unlock()
if target_conn is conn and msg_id == packet.getId(): if target_conn is conn and msg_id == packet.getId() and packet.getType() & 0x8000:
break break
def registerDB(self, db, limit): def registerDB(self, db, limit):
......
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