From a8385472fc7d341aeedc7432e38080d7310dccd8 Mon Sep 17 00:00:00 2001 From: Yevhenii Babichenko Date: Tue, 14 May 2019 13:05:39 +0300 Subject: [PATCH] temporary logs to determine the message that causes the failure (hanging validator) --- validator/sawtooth_validator/networking/dispatch.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/validator/sawtooth_validator/networking/dispatch.py b/validator/sawtooth_validator/networking/dispatch.py index fdb2cce847..68985b58df 100644 --- a/validator/sawtooth_validator/networking/dispatch.py +++ b/validator/sawtooth_validator/networking/dispatch.py @@ -196,12 +196,16 @@ def set_message_priority(self, message_type, priority): def _process(self, message_id): message_info = self._message_information[message_id] + LOGGER.debug("Received a message {} with contents {}".format(message_id, message_info)) + try: preprocessor = self._preprocessors[message_info.message_type] except KeyError: self._process_next(message_id) return + LOGGER.debug("Message processors: {}".format(preprocessor)) + def do_next(result): message_info = self._message_information[message_id] @@ -283,6 +287,8 @@ def do_next(result): LOGGER.exception( "Unhandled exception while determining next") + LOGGER.debug("Processing message with content {} and handler {}".format(message_info.content, handler_manager.handler)) + handler_manager.execute( message_info.connection_id, message_info.content,