mirror of
https://github.com/1f349/dendrite.git
synced 2024-11-22 11:41:38 +00:00
Don't use request context for input room event queued tasks (#1640)
This commit is contained in:
parent
f5869daaab
commit
2885eb0422
@ -116,7 +116,7 @@ func (r *Inputer) WriteOutputEvents(roomID string, updates []api.OutputEvent) er
|
|||||||
|
|
||||||
// InputRoomEvents implements api.RoomserverInternalAPI
|
// InputRoomEvents implements api.RoomserverInternalAPI
|
||||||
func (r *Inputer) InputRoomEvents(
|
func (r *Inputer) InputRoomEvents(
|
||||||
ctx context.Context,
|
_ context.Context,
|
||||||
request *api.InputRoomEventsRequest,
|
request *api.InputRoomEventsRequest,
|
||||||
response *api.InputRoomEventsResponse,
|
response *api.InputRoomEventsResponse,
|
||||||
) {
|
) {
|
||||||
@ -148,7 +148,7 @@ func (r *Inputer) InputRoomEvents(
|
|||||||
// the wait group, so that the worker can notify us when this specific
|
// the wait group, so that the worker can notify us when this specific
|
||||||
// task has been finished.
|
// task has been finished.
|
||||||
tasks[i] = &inputTask{
|
tasks[i] = &inputTask{
|
||||||
ctx: ctx,
|
ctx: context.Background(),
|
||||||
event: &request.InputRoomEvents[i],
|
event: &request.InputRoomEvents[i],
|
||||||
wg: wg,
|
wg: wg,
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user