Merge branch 'mainnet' into feature/skymsg

skycoin · Jun 1, 2019 · 580642f · 580642f
2 parents 672be37 + 0c44e34
commit 580642f
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/pkg/messaging/client.go → pkg/messaging/factory.go b/pkg/messaging/client.go → pkg/messaging/factory.go
@@ -39,7 +39,7 @@ type clientLink struct {
 	chans *chanList
 }
 
-// Config configures Client.
+// Config configures MsgFactory
 type Config struct {
 	PubKey     cipher.PubKey
 	SecKey     cipher.SecKey

diff --git a/pkg/messaging/client_no_ci_test.go → pkg/messaging/factory_noci_test.go b/pkg/messaging/client_no_ci_test.go → pkg/messaging/factory_noci_test.go
diff --git a/pkg/messaging/client_test.go → pkg/messaging/factory_test.go b/pkg/messaging/client_test.go → pkg/messaging/factory_test.go
diff --git a/pkg/transport/managed_transport.go b/pkg/transport/managed_transport.go
@@ -3,6 +3,7 @@ package transport
 import (
 	"math/big"
 	"sync"
+	"sync/atomic"
 
 	"github.com/google/uuid"
 )

diff --git a/pkg/transport/manager.go b/pkg/transport/manager.go
@@ -6,6 +6,7 @@ import (
 	"math/big"
 	"strings"
 	"sync"
+	"sync/atomic"
 	"time"
 
 	"github.com/google/uuid"
@@ -58,10 +59,8 @@ func NewManager(config *ManagerConfig, factories ...Factory) (*Manager, error) {
 		factories:  fMap,
 		transports: make(map[uuid.UUID]*ManagedTransport),
 		entries:    mEntries,
-		// AcceptedTrChan: make(chan *ManagedTransport, 10),
-		// DialedTrChan:   make(chan *ManagedTransport, 10),
-		TrChan:   make(chan *ManagedTransport, 9), //IDK why it was 10 before
-		doneChan: make(chan struct{}),
+		TrChan:     make(chan *ManagedTransport, 9), // TODO: eliminate or justify buffering here
+		doneChan:   make(chan struct{}),
 	}, nil
 }