Tweaks

federationapi/routing/send.go

@@ -311,7 +311,6 @@ func (t *inputWorker) run() {
 	}
 	defer t.running.Store(false)
 	for {
-		<-t.input.wait()
 		task, ok := t.input.pop()
 		if !ok {
 			return

federationapi/routing/send_fifo.go

@@ -49,16 +49,3 @@ func (q *fifoQueue) pop() (*inputTask, bool) {
 	}
 	return frame, true
 }
-
-// wait returns a channel which can be used to detect when an
-// item is waiting in the queue.
-func (q *fifoQueue) wait() <-chan struct{} {
-	q.mutex.Lock()
-	defer q.mutex.Unlock()
-	if q.count > 0 && len(q.notifs) == 0 {
-		ch := make(chan struct{})
-		close(ch)
-		return ch
-	}
-	return q.notifs
-}