Log ping events. Investigate "Message over the maximum transmission l…

…imit was not sent.".
KomodoPlatform · Aug 18, 2020 · 1f7ad5e · 1f7ad5e
1 parent ba4c257
commit 1f7ad5e
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 4 deletions.
diff --git a/etomic_build/seed/sell_ONE_ANOTHER b/etomic_build/seed/sell_ONE_ANOTHER
@@ -1,3 +1,3 @@
 #!/bin/bash
 source userpass
-curl --url "http://127.0.0.1:7783" --data "{\"userpass\":\"$userpass\",\"method\":\"setprice\",\"base\":\"$1\",\"rel\":\"$2\",\"price\":2}"
+curl --url "http://127.0.0.1:7783" --data "{\"userpass\":\"pass\",\"method\":\"setprice\",\"base\":\"RICK\",\"rel\":\"MORTY\",\"price\":2,\"volume\":1}"
diff --git a/mm2src/gossipsub/src/handler.rs b/mm2src/gossipsub/src/handler.rs
@@ -234,11 +234,14 @@ impl ProtocolsHandler for GossipsubHandler {
                 },
                 Some(OutboundSubstreamState::PendingSend(mut substream, message)) => {
                     match Sink::poll_ready(Pin::new(&mut substream), cx) {
-                        Poll::Ready(Ok(())) => match Sink::start_send(Pin::new(&mut substream), message) {
+                        Poll::Ready(Ok(())) => match Sink::start_send(Pin::new(&mut substream), message.clone()) {
                             Ok(()) => self.outbound_substream = Some(OutboundSubstreamState::PendingFlush(substream)),
                             Err(e) => {
                                 if let io::ErrorKind::PermissionDenied = e.kind() {
-                                    error!("Message over the maximum transmission limit was not sent.");
+                                    error!(
+                                        "Message over the maximum transmission limit was not sent. Message: {:?}",
+                                        message
+                                    );
                                     self.outbound_substream = Some(OutboundSubstreamState::WaitingOutput(substream));
                                 } else {
                                     return Poll::Ready(ProtocolsHandlerEvent::Close(e));

diff --git a/mm2src/mm2_libp2p/src/atomicdex_behaviour.rs b/mm2src/mm2_libp2p/src/atomicdex_behaviour.rs
@@ -219,7 +219,9 @@ impl NetworkBehaviourEventProcess<GossipsubEvent> for AtomicDexBehavior {
 
 // TODO: in this impl we might want to save ping statistics and possibly choose the peers to which we have good ping
 impl NetworkBehaviourEventProcess<PingEvent> for AtomicDexBehavior {
-    fn inject_event(&mut self, _event: PingEvent) {}
+    fn inject_event(&mut self, event: PingEvent) {
+        println!("Ping event: {:?}", event);
+    }
 }
 
 /// Creates and spawns new AdexBehavior Swarm returning: