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

Partial revert of previous commit, some files were commited by error, sorry.


git-svn-id: https://svn.erp5.org/repos/neo/trunk@1296 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent aa4ed196
...@@ -25,7 +25,6 @@ from neo.connector import ConnectorException, ConnectorTryAgainException, \ ...@@ -25,7 +25,6 @@ from neo.connector import ConnectorException, ConnectorTryAgainException, \
ConnectorInProgressException, ConnectorConnectionRefusedException, \ ConnectorInProgressException, ConnectorConnectionRefusedException, \
ConnectorConnectionClosedException ConnectorConnectionClosedException
from neo.util import dump from neo.util import dump
from neo.logger import PACKET_LOGGER
def not_closed(func): def not_closed(func):
def decorator(self, *args, **kw): def decorator(self, *args, **kw):
...@@ -358,11 +357,6 @@ class Connection(BaseConnection): ...@@ -358,11 +357,6 @@ class Connection(BaseConnection):
logging.debug('#0x%08x ERROR %-24s %s %s (%s:%d) %s', logging.debug('#0x%08x ERROR %-24s %s %s (%s:%d) %s',
packet.getId(), code, direction, dump(self.uuid), packet.getId(), code, direction, dump(self.uuid),
ip, port, message) ip, port, message)
elif packet_type == protocol.ANSWER_PRIMARY_MASTER:
primary, masters = packet.decode()
logging.debug('#0x%08x ANSWER_PRIMARY_MASTER : %s/%s %s %s (%s:%d)' %
(packet.getId(), dump(primary), masters, direction,
dump(self.uuid), ip, port))
else: else:
logging.debug('#0x%08x %-30s %s %s (%s:%d)', packet.getId(), logging.debug('#0x%08x %-30s %s %s (%s:%d)', packet.getId(),
packet_type, direction, dump(self.uuid), packet_type, direction, dump(self.uuid),
...@@ -373,8 +367,7 @@ class Connection(BaseConnection): ...@@ -373,8 +367,7 @@ class Connection(BaseConnection):
if self.connector is None: if self.connector is None:
return return
PACKET_LOGGER.log(self, packet, ' to ') self.logPacket(' to ', packet)
#self.logPacket(' to ', packet)
try: try:
self.write_buf += packet.encode() self.write_buf += packet.encode()
except PacketMalformedError, m: except PacketMalformedError, m:
......
...@@ -113,9 +113,6 @@ class ClientElectionHandler(ElectionHandler): ...@@ -113,9 +113,6 @@ class ClientElectionHandler(ElectionHandler):
app.negotiating_master_node_set.discard(addr) app.negotiating_master_node_set.discard(addr)
MasterHandler.peerBroken(self, conn) MasterHandler.peerBroken(self, conn)
def handleNotifyClusterInformation(self, conn, packet, state):
logging.warning('Ignore cluster information notification')
def handleAcceptNodeIdentification(self, conn, packet, node_type, def handleAcceptNodeIdentification(self, conn, packet, node_type,
uuid, address, num_partitions, uuid, address, num_partitions,
num_replicas, your_uuid): num_replicas, your_uuid):
......
...@@ -67,8 +67,6 @@ FUNC_TEST_MODULES = [ ...@@ -67,8 +67,6 @@ FUNC_TEST_MODULES = [
# configuration # configuration
UNIT_TESTS = True UNIT_TESTS = True
FUNCTIONAL_TESTS = True FUNCTIONAL_TESTS = True
FUNCTIONAL_TESTS = False
SEND_REPORT = True
SEND_REPORT = False SEND_REPORT = False
CONSOLE_LOG = False CONSOLE_LOG = False
ATTACH_LOG = False # for ZODB test, only the client side is logged ATTACH_LOG = False # for ZODB test, only the client side is logged
......
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