diff --git a/rpc-pool.go b/rpc-pool.go index c1d6ed3..f2bb1c1 100644 --- a/rpc-pool.go +++ b/rpc-pool.go @@ -46,7 +46,7 @@ func (g *RemoteGrain) Connect() error { if !strings.Contains(addr, ":") { addr = fmt.Sprintf("%s:1337", addr) } - log.Println("Connecting to", addr) + log.Printf("Connecting to %s %s", addr, g.Address) client, err := net.Dial("tcp", addr) if err != nil { return err diff --git a/synced-pool.go b/synced-pool.go index 71173fd..8a5b9e0 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -484,7 +484,7 @@ func (p *SyncedPool) AddRemote(address string) error { return err } - pool := NewRemoteGrainPool(fmt.Sprintf(address, 1337)) + pool := NewRemoteGrainPool(address) remote := RemoteHost{ connection: connection, queue: NewPacketQueue(connection),