summaryrefslogtreecommitdiff
path: root/src/net.moon
diff options
context:
space:
mode:
Diffstat (limited to 'src/net.moon')
-rw-r--r--src/net.moon6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/net.moon b/src/net.moon
index acd75c7..3d2a1cb 100644
--- a/src/net.moon
+++ b/src/net.moon
@@ -188,7 +188,8 @@ rewrite_events = {
net.pump = () ->
msg_ = net.pull_peers!
- log.info("Processing " .. tostring(#msg_) .. " peer messages", {"net"})
+ if #msg_ > 0
+ log.info("Processing " .. tostring(#msg_) .. " peer messages", {"net"})
for message in *msg_
log.info(tostring(message), {"net", message.data.peer})
if rewrite_events[message.data.e]
@@ -203,7 +204,8 @@ net.pump = () ->
assert(callback, "Failed to find callback " .. message.message .. " on peer " .. message.data.peer)
callback(peer,message.data)
msg_ = net.pull_connections!
- log.info("Processing " .. tostring(#msg_) .. " connection messages", {"net"})
+ if #msg_ > 0
+ log.info("Processing " .. tostring(#msg_) .. " connection messages", {"net"})
for message in *msg_
log.info(tostring(message), {"net", message.data.peer})
connection = Connection\get(message.dest, message.peer)