da36506b89
P0 fixes: - ModelError.Is(): use exact matching instead of substring contains() - shouldClearStickySession: add context param for cancellation/tracing P1 fixes: - TODO stubs: return 501 Not Implemented errors - validateInstanceSignature: deduplicate to shared validateCodeSignature() - Error messages: standardize to English only - http.go: remove pseudo if-else with duplicate branches
47 lines
919 B
Go
47 lines
919 B
Go
package service
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"hash/fnv"
|
|
"time"
|
|
)
|
|
|
|
func hashAdvisoryLockID(key string) int64 {
|
|
h := fnv.New64a()
|
|
_, _ = h.Write([]byte(key))
|
|
return int64(h.Sum64())
|
|
}
|
|
|
|
func tryAcquireDBAdvisoryLock(ctx context.Context, db *sql.DB, lockID int64) (func(), bool) {
|
|
if db == nil {
|
|
return nil, false
|
|
}
|
|
if ctx == nil {
|
|
ctx = context.Background()
|
|
}
|
|
|
|
conn, err := db.Conn(ctx)
|
|
if err != nil {
|
|
return nil, false
|
|
}
|
|
|
|
acquired := false
|
|
if err := conn.QueryRowContext(ctx, "SELECT pg_try_advisory_lock($1)", lockID).Scan(&acquired); err != nil {
|
|
_ = conn.Close()
|
|
return nil, false
|
|
}
|
|
if !acquired {
|
|
_ = conn.Close()
|
|
return nil, false
|
|
}
|
|
|
|
release := func() {
|
|
unlockCtx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
|
|
defer cancel()
|
|
_, _ = conn.ExecContext(unlockCtx, "SELECT pg_advisory_unlock($1)", lockID)
|
|
_ = conn.Close()
|
|
}
|
|
return release, true
|
|
}
|