2 Commits

Author SHA1 Message Date
matst80
b5475fa6c5 strange
Some checks failed
Build and Publish / BuildAndDeploy (push) Has been cancelled
2024-11-10 00:12:17 +01:00
matst80
f45c40a1f2 less logs 2024-11-10 00:05:45 +01:00
2 changed files with 2 additions and 3 deletions

View File

@@ -46,7 +46,7 @@ func (g *RemoteGrain) Connect() error {
if !strings.Contains(addr, ":") { if !strings.Contains(addr, ":") {
addr = fmt.Sprintf("%s:1337", 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) client, err := net.Dial("tcp", addr)
if err != nil { if err != nil {
return err return err

View File

@@ -79,7 +79,6 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
if d != nil { if d != nil {
go func() { go func() {
for range time.Tick(time.Second * 5) { for range time.Tick(time.Second * 5) {
log.Printf("Looking for new nodes")
hosts, err := d.Discover() hosts, err := d.Discover()
if err != nil { if err != nil {
log.Printf("Error discovering hosts: %v", err) log.Printf("Error discovering hosts: %v", err)
@@ -485,7 +484,7 @@ func (p *SyncedPool) AddRemote(address string) error {
return err return err
} }
pool := NewRemoteGrainPool(fmt.Sprintf(address, 1337)) pool := NewRemoteGrainPool(address)
remote := RemoteHost{ remote := RemoteHost{
connection: connection, connection: connection,
queue: NewPacketQueue(connection), queue: NewPacketQueue(connection),