add logs to grpclb on send and recv (#1235)
diff --git a/grpclb.go b/grpclb.go
index b9d7073..0e4d269 100644
--- a/grpclb.go
+++ b/grpclb.go
@@ -152,6 +152,7 @@
func (b *balancer) watchAddrUpdates(w naming.Watcher, ch chan []remoteBalancerInfo) error {
updates, err := w.Next()
if err != nil {
+ grpclog.Printf("grpclb: failed to get next addr update from watcher: %v", err)
return err
}
b.mu.Lock()
@@ -306,6 +307,7 @@
ClientStats: &stats,
},
}); err != nil {
+ grpclog.Printf("grpclb: failed to send load report: %v", err)
return
}
}
@@ -316,7 +318,7 @@
defer cancel()
stream, err := lbc.BalanceLoad(ctx)
if err != nil {
- grpclog.Printf("Failed to perform RPC to the remote balancer %v", err)
+ grpclog.Printf("grpclb: failed to perform RPC to the remote balancer %v", err)
return
}
b.mu.Lock()
@@ -333,17 +335,19 @@
},
}
if err := stream.Send(initReq); err != nil {
+ grpclog.Printf("grpclb: failed to send init request: %v", err)
// TODO: backoff on retry?
return true
}
reply, err := stream.Recv()
if err != nil {
+ grpclog.Printf("grpclb: failed to recv init response: %v", err)
// TODO: backoff on retry?
return true
}
initResp := reply.GetInitialResponse()
if initResp == nil {
- grpclog.Println("Failed to receive the initial response from the remote balancer.")
+ grpclog.Println("grpclb: reply from remote balancer did not include initial response.")
return
}
// TODO: Support delegation.
@@ -364,6 +368,7 @@
for {
reply, err := stream.Recv()
if err != nil {
+ grpclog.Printf("grpclb: failed to recv server list: %v", err)
break
}
b.mu.Lock()
@@ -397,6 +402,7 @@
w, err := b.r.Resolve(target)
if err != nil {
b.mu.Unlock()
+ grpclog.Printf("grpclb: failed to resolve address: %v, err: %v", target, err)
return err
}
b.w = w
@@ -406,7 +412,7 @@
go func() {
for {
if err := b.watchAddrUpdates(w, balancerAddrsCh); err != nil {
- grpclog.Printf("grpc: the naming watcher stops working due to %v.\n", err)
+ grpclog.Printf("grpclb: the naming watcher stops working due to %v.\n", err)
close(balancerAddrsCh)
return
}
@@ -497,7 +503,7 @@
if creds := config.DialCreds; creds != nil {
if rb.name != "" {
if err := creds.OverrideServerName(rb.name); err != nil {
- grpclog.Printf("Failed to override the server name in the credentials: %v", err)
+ grpclog.Printf("grpclb: failed to override the server name in the credentials: %v", err)
continue
}
}
@@ -512,7 +518,7 @@
ccError = make(chan struct{})
cc, err = Dial(rb.addr, dopts...)
if err != nil {
- grpclog.Printf("Failed to setup a connection to the remote balancer %v: %v", rb.addr, err)
+ grpclog.Printf("grpclb: failed to setup a connection to the remote balancer %v: %v", rb.addr, err)
close(ccError)
continue
}
