fix: push block after panic (#183)

Co-authored-by: caojiawen <[email protected]>
finogeeks · Nov 10, 2021 · e5bf47c · e5bf47c
1 parent 3907f98
commit e5bf47c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/syncserver/consumers/push.go b/syncserver/consumers/push.go
@@ -319,8 +319,8 @@ func (s *PushConsumer) OnEvent(input *gomatrixserverlib.ClientEvent, eventOffset
 					log.Errorf("PushConsumer OnEvent process panic recovered err %#v", e)
 				}
 			}()
+			defer wg.Done()
 			s.preProcessPush(&member, helperEvent, memCount, eventOffset, redactOffset, eventJson, pushContents, isRelatesContent, static, pushData)
-			wg.Done()
 		}(member, &helperEvent, memCount, eventOffset, redactOffset, &eventJson, &pushContents, isRelatesContent, static, pushData)
 	}
 	wg.Wait()