log response
This commit is contained in:
@@ -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
|
||||
}
|
||||
|
||||
|
||||
@@ -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
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user