feat: add client request log (#1069)
Signed-off-by: Gaius <gaius.qi@gmail.com>
This commit is contained in:
parent
f15a04ec73
commit
76dbfcfc5c
|
|
@ -210,8 +210,8 @@ func (ptm *peerTaskManager) newPeerTaskConductor(ctx context.Context, request *s
|
||||||
|
|
||||||
// register to scheduler, if error and disable auto back source, return error, otherwise return nil
|
// register to scheduler, if error and disable auto back source, return error, otherwise return nil
|
||||||
func (pt *peerTaskConductor) register() error {
|
func (pt *peerTaskConductor) register() error {
|
||||||
logger.Debugf("request overview, pid: %s, url: %s, filter: %s, meta: %s, tag: %s",
|
logger.Debugf("request overview, pid: %s, url: %s, filter: %s, tag: %s, range: %s, digest: %s, header: %#v",
|
||||||
pt.request.PeerId, pt.request.Url, pt.request.UrlMeta.Filter, pt.request.UrlMeta, pt.request.UrlMeta.Tag)
|
pt.request.PeerId, pt.request.Url, pt.request.UrlMeta.Filter, pt.request.UrlMeta.Tag, pt.request.UrlMeta.Range, pt.request.UrlMeta.Digest, pt.request.UrlMeta.Header)
|
||||||
// trace register
|
// trace register
|
||||||
regCtx, cancel := context.WithTimeout(pt.ctx, pt.peerTaskManager.schedulerOption.ScheduleTimeout.Duration)
|
regCtx, cancel := context.WithTimeout(pt.ctx, pt.peerTaskManager.schedulerOption.ScheduleTimeout.Duration)
|
||||||
defer cancel()
|
defer cancel()
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue