From 9b75b872ee11a71afb95ed5115a588af096e28a1 Mon Sep 17 00:00:00 2001 From: matst80 Date: Sun, 10 Nov 2024 00:03:45 +0100 Subject: [PATCH] test --- rpc-pool.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/rpc-pool.go b/rpc-pool.go index d290882..c1d6ed3 100644 --- a/rpc-pool.go +++ b/rpc-pool.go @@ -3,6 +3,7 @@ package main import ( "fmt" "io" + "log" "net" "strings" "sync" @@ -33,9 +34,6 @@ type RemoteGrain struct { } func NewRemoteGrain(id CartId, address string) *RemoteGrain { - if !strings.Contains(address, ":") { - address = fmt.Sprintf("[%s]:1337", address) - } return &RemoteGrain{ Id: id, Address: address, @@ -44,7 +42,12 @@ func NewRemoteGrain(id CartId, address string) *RemoteGrain { func (g *RemoteGrain) Connect() error { if g.connection == nil { - client, err := net.Dial("tcp", g.Address) + addr := g.Address + if !strings.Contains(addr, ":") { + addr = fmt.Sprintf("%s:1337", addr) + } + log.Println("Connecting to", addr) + client, err := net.Dial("tcp", addr) if err != nil { return err }