fix: use sum64 to avoid checkptr race bug (#2645)

rudderlabs · Nov 3, 2022 · 126cbdf · 126cbdf
1 parent 3659e12
commit 126cbdf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/services/pgnotifier/pgnotifier.go b/services/pgnotifier/pgnotifier.go
@@ -643,7 +643,7 @@ func GetCurrentSQLTimestamp() string {
 // RunMaintenanceWorker (blocking - to be called from go routine) re-triggers zombie jobs
 // which were left behind by dead workers in executing state
 func (notifier *PgNotifierT) RunMaintenanceWorker(ctx context.Context) error {
-	maintenanceWorkerLockID := murmur3.Sum32([]byte(queueName))
+	maintenanceWorkerLockID := murmur3.Sum64([]byte(queueName))
 	maintenanceWorkerLock, err := pglock.NewLock(ctx, int64(maintenanceWorkerLockID), notifier.dbHandle)
 	if err != nil {
 		return err