Add debug logging (#121)

Co-authored-by: raulk <[email protected]>
ipfs · Mar 4, 2021 · 0f89d34 · 0f89d34
1 parent fcb8c29
commit 0f89d34
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/responsemanager/queryexecutor.go b/responsemanager/queryexecutor.go
@@ -72,6 +72,7 @@ func (qe *queryExecutor) processQueriesWorker() {
  log.Info("Empty task on peer request stack")
  continue
  }
+ log.Debugw("beginning response execution", "id", key.requestID, "peer", key.p.String(), "root_cid", taskData.request.Root().String())
  status, err := qe.executeTask(key, taskData)
  isCancelled := err != nil && isContextErr(err)
  if isCancelled {
@@ -81,6 +82,7 @@ func (qe *queryExecutor) processQueriesWorker() {
  case qe.messages <- &finishTaskRequest{key, status, err}:
  case <-qe.ctx.Done():
  }
+ log.Debugw("finishing response execution", "id", key.requestID, "peer", key.p.String(), "root_cid", taskData.request.Root().String())
  }
  qe.queryQueue.TasksDone(pid, tasks...)