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,