Fixed read from closed channel

A premature waitgroup .Done resulted in reading from closed channel.
This caused a nil-pointer deref & crash.

Added additional debugging when closing routines.

1 files changed, 7 insertions, 3 deletions

diff --git a/receive.go b/receive.go
index 96ba08d..1045cee 100644
--- a/receive.go
+++ b/receive.go
@@ -500,8 +500,8 @@ func (peer *Peer) RoutineSequentialReceiver() {
 	logError := device.log.Error
 	logDebug := device.log.Debug
 
-	func() {
-		defer peer.routines.stopping.Done()
+	defer func() {
+		peer.routines.stopping.Done()
 		logDebug.Println(peer.String(), ": Routine, Sequential Receiver, Stopped")
 	}()
 
@@ -516,7 +516,11 @@ func (peer *Peer) RoutineSequentialReceiver() {
 		case <-peer.routines.stop.Wait():
 			return
 
-		case elem := <-peer.queue.inbound:
+		case elem, ok := <-peer.queue.inbound:
+
+			if !ok {
+				return
+			}
 
 			// wait for decryption