90
case <-w.backlogMgr.tqCtx.Done():
91
return errShutdown
93
// noop
94
}
95
97
>
ch := make(chan error, 1)
98
>
req := &writeTaskRequest{
99
>
taskInfo: taskInfo,
100
>
responseCh: ch,
101
>
}
102
>
103
>
select {
104
>
case w.appendCh <- req:
105
>
select {
106
>
case err := <-ch:
107
>
metrics.TaskWriteLatencyPerTaskQueue.With(w.backlogMgr.metricsHandler).Record(time.Since(startTime))
108
>
return err
109
case <-w.backlogMgr.tqCtx.Done():
110
// if we are shutting down, this request will never make