code: func (q *queue) ExpireBodies(timeout time.Duration) map[string]int {
  	q.lock.Lock()
  	defer q.lock.Unlock()
  
  	return q.expire(timeout, q.blockPendPool, q.blockTaskQueue, bodyTimeoutMeter)
  }
docs: // ExpireBodies checks for in flight block body requests that exceeded a timeout
  // allowance, canceling them and returning the responsible peers for penalisation.