Use new microtask function
This commit is contained in:
@@ -40,8 +40,7 @@ func connectionCleaner(ctx context.Context) error {
|
|||||||
func cleanConnections() (activePIDs map[int]struct{}) {
|
func cleanConnections() (activePIDs map[int]struct{}) {
|
||||||
activePIDs = make(map[int]struct{})
|
activePIDs = make(map[int]struct{})
|
||||||
|
|
||||||
name := "clean connections" // TODO: change to new fn
|
_ = module.RunMicroTask("clean connections", 0, func(ctx context.Context) error {
|
||||||
_ = module.RunMediumPriorityMicroTask(&name, func(ctx context.Context) error {
|
|
||||||
now := time.Now().UTC()
|
now := time.Now().UTC()
|
||||||
nowUnix := now.Unix()
|
nowUnix := now.Unix()
|
||||||
deleteOlderThan := now.Add(-DeleteConnsAfterEndedThreshold).Unix()
|
deleteOlderThan := now.Add(-DeleteConnsAfterEndedThreshold).Unix()
|
||||||
|
|||||||
Reference in New Issue
Block a user