diff --git a/synced-pool.go b/synced-pool.go index 331f9de..2e35c98 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -61,12 +61,8 @@ var ( }) ) -var ( - PongResponse = MakeFrameWithPayload(Pong, 200, []byte{}) -) - func (p *SyncedPool) PongHandler(data *FrameWithPayload, resultChan chan<- FrameWithPayload) error { - resultChan <- PongResponse + resultChan <- MakeFrameWithPayload(Pong, 200, []byte{}) return nil } @@ -371,9 +367,9 @@ func (p *SyncedPool) AddRemote(host string) error { return nil } 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, response) + _, err := client.Call(Ping, nil) + if err != nil { + log.Printf("Error connecting to remote %s: %s\n", host, err) return err }