From 3bb5f43c072817eb1b0e92231e7900e65135c334 Mon Sep 17 00:00:00 2001 From: Zack Scholl Date: Sat, 21 Oct 2017 15:54:51 -0600 Subject: [PATCH] Fix bug in relay --- relay.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/relay.go b/relay.go index 40c28a26..c3b6e00d 100644 --- a/relay.go +++ b/relay.go @@ -177,7 +177,8 @@ func (r *Relay) clientCommuncation(id int, connection net.Conn) { delete(r.connections.potentialReceivers, key) r.connections.Unlock() logger.Debug("deleted sender and receiver") - } else if connectionType == "r" { //receiver connection "r" + } else if connectionType == "r" || connectionType == "c" { + //receiver if r.connections.IsPotentialReceiverConnected(key) { sendMessage("no", connection) return @@ -236,7 +237,7 @@ func receiveMessage(connection net.Conn) string { "ip": connection.RemoteAddr().String(), }) messageByte := make([]byte, BUFFERSIZE) - err := connection.SetDeadline(time.Now().Add(30 * time.Second)) + err := connection.SetDeadline(time.Now().Add(60 * time.Minute)) if err != nil { logger.Warn(err) }