remove sleeps

libp2p/protocols/pubsub/gossipsub.nim

@@ -413,8 +413,9 @@ method start*(g: GossipSub) {.async.} =
 
   # setup the heartbeat interval
   g.heartbeatCancel = addInterval(GossipSubHeartbeatInterval,
-                                  proc (arg: pointer = nil) {.gcsafe, locks: 0.} =
-    asyncCheck g.heartbeat)
+                                  proc (arg: pointer = nil)
+                                    {.gcsafe, locks: 0.} =
+                                    asyncCheck g.heartbeat)
 
 method stop*(g: GossipSub) {.async.} =
   ## stopt pubsub

libp2p/stream/bufferstream.nim

@@ -107,11 +107,6 @@ proc pushTo*(s: BufferStream, data: seq[byte]) {.async.} =
     await s.lock.acquire()
     var index = 0
     while true:
-      # give readers a chance free up the buffer
-      # it it's full.
-      if s.readBuf.len >= s.maxSize:
-        await sleepAsync(1.millis)
-
       while index < data.len and s.readBuf.len < s.maxSize:
         s.readBuf.addLast(data[index])
         inc(index)

tests/pubsub/testfloodsub.nim

@@ -190,7 +190,7 @@ suite "FloodSub":
         await node.publish("foobar", cast[seq[byte]]("Hello!"))
         await sleepAsync(100.millis)
 
-      await sleepAsync(5000.millis)
+      await sleepAsync(1.minutes)
       await allFutures(nodes.mapIt(it.stop()))
       await allFutures(awaitters)
 
@@ -223,7 +223,7 @@ suite "FloodSub":
         await node.publish("foobar", cast[seq[byte]]("Hello!"))
         await sleepAsync(100.millis)
 
-      await sleepAsync(5000.millis)
+      await sleepAsync(1.minutes)
       await allFutures(nodes.mapIt(it.stop()))
       await allFutures(awaitters)
 

tests/pubsub/testpubsub.nim

@@ -1,4 +1,4 @@
 include ../../libp2p/protocols/pubsub/gossipsub
-import testfloodsub,
-       testgossipsub,
+import testgossipsub,
+       testfloodsub,
        testmcache