diff --git a/src/communicator/__init__.py b/src/communicator/__init__.py index e729a541..d863c57e 100755 --- a/src/communicator/__init__.py +++ b/src/communicator/__init__.py @@ -213,7 +213,7 @@ class OnionrCommunicatorDaemon: self, announcenode.announce_node, 3600, my_args=[self], requires_peer=True, max_threads=1) - announceTimer.count = (announceTimer.frequency - 120) + announceTimer.count = (announceTimer.frequency - 60) else: logger.debug('Will not announce node.') @@ -233,7 +233,7 @@ class OnionrCommunicatorDaemon: shared_state.add(self) - if config.get('general.use_bootstrap', True): + if config.get('general.use_bootstrap_list', True): bootstrappeers.add_bootstrap_list_to_peer_list( self, [], db_only=True) diff --git a/src/communicatorutils/uploadblocks/__init__.py b/src/communicatorutils/uploadblocks/__init__.py index d0a53108..7be780e7 100755 --- a/src/communicatorutils/uploadblocks/__init__.py +++ b/src/communicatorutils/uploadblocks/__init__.py @@ -95,8 +95,8 @@ def upload_blocks_from_communicator(comm_inst: 'OnionrCommunicatorDaemon'): session.fail_peer(peer) comm_inst.getPeerProfileInstance(peer).addScore(-5) logger.warn( - f'Failed to upload {bl[:8]}, reason: {resp[:15]}', - terminal=True) + f'Failed to upload {bl[:8]}, reason: {resp}', + terminal=True) else: session.fail() session_manager.clean_session() diff --git a/src/communicatorutils/uploadblocks/mixmate/__init__.py b/src/communicatorutils/uploadblocks/mixmate/__init__.py index 4160b0ec..446ac44a 100644 --- a/src/communicatorutils/uploadblocks/mixmate/__init__.py +++ b/src/communicatorutils/uploadblocks/mixmate/__init__.py @@ -1,6 +1,6 @@ """Onionr - Private P2P Communication. -Delay block uploads, optionally mixing them together +Perform block mixing """ import time from typing import List @@ -41,12 +41,5 @@ def block_mixer(upload_list: List[onionrtypes.BlockHash], if time.time() - bl.claimedTime > onionrvalues.BLOCK_POOL_MAX_AGE: raise ValueError - - try: - # add the new block to pool - upload_pool.add_to_pool(block_to_mix) - except PoolFullException: - # If the pool is full, move into upload queue - upload_list.extend(upload_pool.get_pool()) - # then finally begin new pool with new block - upload_pool.add_to_pool(block_to_mix) + if block_to_mix: + upload_list.append(block_to_mix)