better logs
This commit is contained in:
@@ -81,7 +81,6 @@ func (g *RemoteHost) GetCartMappings() ([]CartId, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (r *RemoteHost) ConfirmChange(id CartId, host string) error {
|
func (r *RemoteHost) ConfirmChange(id CartId, host string) error {
|
||||||
log.Printf("Confirming change %s to %s", id, host)
|
|
||||||
reply, err := r.Call(RemoteGrainChanged, AckChange, []byte(fmt.Sprintf("%s;%s", id, host)))
|
reply, err := r.Call(RemoteGrainChanged, AckChange, []byte(fmt.Sprintf("%s;%s", id, host)))
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -105,7 +105,7 @@ func (p *SyncedPool) GrainOwnerChangeHandler(data []byte) (PoolMessage, []byte,
|
|||||||
}
|
}
|
||||||
id := ToCartId(idAndHostParts[0])
|
id := ToCartId(idAndHostParts[0])
|
||||||
host := idAndHostParts[1]
|
host := idAndHostParts[1]
|
||||||
log.Println("Handling grain owner change to %s for id %s\n", host, id)
|
log.Printf("Handling remote grain owner change to %s for id %s\n", host, id)
|
||||||
for _, r := range p.remotes {
|
for _, r := range p.remotes {
|
||||||
if r.Host == host {
|
if r.Host == host {
|
||||||
// log.Printf("Remote grain %s changed to %s\n", id, host)
|
// log.Printf("Remote grain %s changed to %s\n", id, host)
|
||||||
|
|||||||
Reference in New Issue
Block a user