Commit 47046871 authored by Grégory Wisniewski's avatar Grégory Wisniewski

Fix handler class names.


git-svn-id: https://svn.erp5.org/repos/neo/branches/prototype3@789 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 33b2bcd9
...@@ -51,11 +51,11 @@ class IdentificationHandler(BaseStorageHandler): ...@@ -51,11 +51,11 @@ class IdentificationHandler(BaseStorageHandler):
raise protocol.BrokenNodeDisallowedError raise protocol.BrokenNodeDisallowedError
# choose the handler according to the node type # choose the handler according to the node type
if node_type == protocol.CLIENT_NODE_TYPE: if node_type == protocol.CLIENT_NODE_TYPE:
from neo.storage.operation import ClientOperationEventHandler from neo.storage.handlers.client import ClientOperationHandler
handler = ClientOperationEventHandler handler = ClientOperationHandler
elif node_type == protocol.STORAGE_NODE_TYPE: elif node_type == protocol.STORAGE_NODE_TYPE:
from neo.storage.operation import StorageOperationEventHandler from neo.storage.handlers.storage import StorageOperationHandler
handler = StorageOperationEventHandler handler = StorageOperationHandler
else: else:
raise protocol.protocolError('reject non-client-or-storage node') raise protocol.protocolError('reject non-client-or-storage node')
# apply the handler and set up the connection # apply the handler and set up the connection
......
...@@ -182,7 +182,7 @@ class Replicator(object): ...@@ -182,7 +182,7 @@ class Replicator(object):
self.current_connection = None self.current_connection = None
if self.current_connection is None: if self.current_connection is None:
handler = handlers.ReplicationEventHandler(app) handler = handlers.ReplicationHandler(app)
self.current_connection = ClientConnection(app.em, handler, self.current_connection = ClientConnection(app.em, handler,
addr = addr, addr = addr,
connector_handler = app.connector_handler) connector_handler = app.connector_handler)
......
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