Merge pull request #332 from pipermerriam/piper/increate-number-of-de…

…fault-ads Increase default number of remote adds and quite logs
ethereum · Dec 19, 2020 · 7a3882a · 7a3882a
2 parents 218b44b + 4bd718e
commit 7a3882a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/ddht/v5_1/alexandria/constants.py b/ddht/v5_1/alexandria/constants.py
@@ -41,7 +41,7 @@
 
 
 # Default maximum number of advertisements
-DEFAULT_MAX_ADVERTISEMENTS = 65536
+DEFAULT_MAX_ADVERTISEMENTS = 1048576
 
 
 MAX_RADIUS = 2 ** 256 - 1
diff --git a/ddht/v5_1/session.py b/ddht/v5_1/session.py
@@ -260,13 +260,13 @@ async def handle_outbound_message(self, message: AnyOutboundMessage) -> None:
             try:
                 self._outbound_message_buffer_send_channel.send_nowait(message)
             except trio.WouldBlock:
-                self.logger.debug(
+                self.logger.debug2(
                     "%s: Discarding message due to full outbound message buffer: %s",
                     self,
                     message,
                 )
         elif self.is_before_handshake:
-            self.logger.debug(
+            self.logger.debug2(
                 "%s: outbound message triggered handshake initiation: %s",
                 self,
                 message,
@@ -495,7 +495,7 @@ async def handle_outbound_message(self, message: AnyOutboundMessage) -> None:
             try:
                 self._outbound_message_buffer_send_channel.send_nowait(message)
             except trio.WouldBlock:
-                self.logger.warning(
+                self.logger.debug(
                     "%s: Discarding message due to full outbound message buffer: %s",
                     self,
                     message,
@@ -560,11 +560,11 @@ async def handle_inbound_envelope(self, envelope: InboundEnvelope) -> bool:
                     await self._process_message_buffers()
                     return True
             elif envelope.packet.is_message:
-                self.logger.debug("%s: Buffering Message: %s", self, envelope)
+                self.logger.debug2("%s: Buffering Message: %s", self, envelope)
                 try:
                     self._inbound_envelope_buffer_send_channel.send_nowait(envelope)
                 except trio.WouldBlock:
-                    self.logger.debug(
+                    self.logger.debug2(
                         "%s: Discarding inbound envelope due to full buffer: %s",
                         self,
                         envelope,