We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see ourdocumentation.
There was an error while loading.Please reload this page.
1 parentb20fb2f commit31c3351Copy full SHA for 31c3351
coderd/database/dbpurge/dbpurge.go
@@ -31,7 +31,8 @@ func New(ctx context.Context, logger slog.Logger, db database.Store, clk quartz.
31
//nolint:gocritic // The system purges old db records without user input.
32
ctx=dbauthz.AsSystemRestricted(ctx)
33
34
-ticker:=clk.NewTicker(time.Nanosecond)
+// Start the ticker with the initial delay.
35
+ticker:=clk.NewTicker(delay)
36
doTick:=func(start time.Time) {
37
deferticker.Reset(delay)
38
// Start a transaction to grab advisory lock, we don't want to run
@@ -74,6 +75,8 @@ func New(ctx context.Context, logger slog.Logger, db database.Store, clk quartz.
74
75
gofunc() {
76
deferclose(closed)
77
deferticker.Stop()
78
+// Force an initial tick immediately.
79
+ticker.Reset(time.Nanosecond)
80
for {
81
select {
82
case<-ctx.Done():