Migrate to KCP backend.

main.go

@@ -2,15 +2,12 @@ package main
 
 import (
 	"flag"
-	"fmt"
 	"strings"
 
 	"github.com/golang/glog"
 	"github.com/perlin-network/noise/crypto"
-	"github.com/perlin-network/noise/grpc_utils"
 	"github.com/perlin-network/noise/network/builders"
 	"github.com/perlin-network/noise/network/discovery"
-	"time"
 )
 
 func main() {
@@ -49,11 +46,6 @@ func main() {
 	go net.Listen()
 
 	if len(peers) > 0 {
-		blockTimeout := 10 * time.Second
-		if err := grpc_utils.BlockUntilConnectionReady(host, port, blockTimeout); err != nil {
-			glog.Warningf(fmt.Sprintf("Error: port was not available, cannot bootstrap peers, err=%+v", err))
-		}
-
 		net.Bootstrap(peers...)
 	}
 

network/builders/network.go

@@ -39,7 +39,7 @@ func (builder *NetworkBuilder) SetPort(port int) {
 func (builder *NetworkBuilder) AddProcessor(message proto.Message, processor network.MessageProcessor) {
 	// Initialize map if not exist.
 	if builder.processors == nil {
-		builder.processors = &network.StringMessageProcessorSyncMap {}
+		builder.processors = &network.StringMessageProcessorSyncMap{}
 	}
 
 	name := reflect.TypeOf(message).String()
@@ -67,7 +67,7 @@ func (builder *NetworkBuilder) BuildNetwork() (*network.Network, error) {
 
 	// Initialize map if not exist.
 	if builder.processors == nil {
-		builder.processors = &network.StringMessageProcessorSyncMap {}
+		builder.processors = &network.StringMessageProcessorSyncMap{}
 	}
 
 	unifiedHost, err := network.ToUnifiedHost(builder.host)
@@ -87,7 +87,7 @@ func (builder *NetworkBuilder) BuildNetwork() (*network.Network, error) {
 
 		Routes: dht.CreateRoutingTable(id),
 
-		Peers: &network.StringPeerClientSyncMap {},
+		Peers: &network.StringPeerClientSyncMap{},
 	}
 
 	return network, nil