diff --git a/grain-pool.go b/grain-pool.go index 991cec8..58ed856 100644 --- a/grain-pool.go +++ b/grain-pool.go @@ -150,9 +150,6 @@ func (p *GrainLocalPool) Process(id CartId, messages ...Message) (*FrameWithPayl result, err = grain.HandleMessage(&message, false) } } - if err != nil { - return result, err - } return result, err } diff --git a/synced-pool.go b/synced-pool.go index 1fbb4cb..331f9de 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -62,7 +62,7 @@ var ( ) var ( - PongResponse = MakeFrameWithPayload(Pong, 200, nil) + PongResponse = MakeFrameWithPayload(Pong, 200, []byte{}) ) func (p *SyncedPool) PongHandler(data *FrameWithPayload, resultChan chan<- FrameWithPayload) error { @@ -373,7 +373,7 @@ func (p *SyncedPool) AddRemote(host string) error { client := NewConnection(fmt.Sprintf("%s:1338", host)) response, err := client.Call(Ping, nil) if err != nil || response.StatusCode != 200 || response.Type != Pong { - log.Printf("Error connecting to remote %s: %v\n", host, err) + log.Printf("Error connecting to remote %s: %v\n", host, response) return err }