Update portbase
This commit is contained in:
@@ -26,7 +26,7 @@ func connectionCleaner(ctx context.Context) error {
|
||||
case <-ctx.Done():
|
||||
ticker.Stop()
|
||||
return nil
|
||||
case <-ticker.Read():
|
||||
case <-ticker.Wait():
|
||||
// clean connections and processes
|
||||
activePIDs := cleanConnections()
|
||||
process.CleanProcessStorage(activePIDs)
|
||||
|
||||
@@ -91,7 +91,7 @@ func openDNSRequestWriter(ctx context.Context) error {
|
||||
select {
|
||||
case <-ctx.Done():
|
||||
return nil
|
||||
case <-ticker.Read():
|
||||
case <-ticker.Wait():
|
||||
writeOpenDNSRequestsToDB()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user