when node is closing, avoid creating new port or new connections

channel_provider.go

@@ -7,16 +7,20 @@ import (
 type channelProvider struct {
 	n   *Node
 	eca endpointChannelProvider
+
+	terminate chan struct{}
 }
 
 func newChannelProvider(n *Node, eca endpointChannelProvider) (*channelProvider, error) {
 	return &channelProvider{
 		n:   n,
 		eca: eca,
+		terminate: make(chan struct{}),
 	}, nil
 }
 
 func (cp *channelProvider) close() {
+	close(cp.terminate)
 	cp.eca.close()
 }
 
@@ -49,7 +53,8 @@ func (cp *channelProvider) run() {
 			// before creating another channel
 			select {
 			case <-ch.done:
-			case <-cp.n.terminate:
+			case <-cp.terminate:
+				return
 			}
 		}
 	}

endpoint_serial_test.go

@@ -14,15 +14,20 @@ var _ endpointChannelProvider = (*endpointSerial)(nil)
 
 func TestEndpointSerial(t *testing.T) {
 	done := make(chan struct{})
-	first := false
+	n := 0
 
 	serialOpenFunc = func(name string, baud int) (io.ReadWriteCloser, error) {
 		remote, local := newDummyReadWriterPair()
 
-		// skip first call to serialOpenFunc()
-		if !first {
-			first = true
+		n++
+		switch n {
+		case 1:
 			return remote, nil
+
+		case 2:
+
+		default:
+			t.Errorf("should not happen")
 		}
 
 		go func() {