diff --git a/discovery/discovery.go b/discovery/discovery.go index 8ec9713c4..9fe2631a6 100644 --- a/discovery/discovery.go +++ b/discovery/discovery.go @@ -106,7 +106,9 @@ func (o *orchestratorPool) GetOrchestrators(ctx context.Context, numOrchestrator return caps.CompatibleWith(info.Capabilities) } getOrchInfo := func(ctx context.Context, od common.OrchestratorDescriptor, infoCh chan common.OrchestratorDescriptor, errCh chan error) { + start := time.Now() info, err := serverGetOrchInfo(ctx, o.bcast, od.LocalInfo.URL, caps.ToNetCapabilities()) + clog.V(common.DEBUG).Infof(ctx, "Received GetOrchInfo RPC Response from uri=%v, latency=%v", od.LocalInfo.URL, time.Since(start)) if err == nil && !isBlacklisted(info) && isCompatible(info) { od.RemoteInfo = info infoCh <- od