watchCtx

Author: matteocontrini

.github/workflows/test.yml

@@ -4,13 +4,15 @@ on:
   push:
     branches:
       - "main"
+      - "debug"
   pull_request:
     branches:
       - "**"
   workflow_dispatch:
 
 jobs:
   tests:
+    if: false
     name: Tests
     runs-on: ubuntu-latest
     services:

storage.go

@@ -154,9 +154,28 @@ func (s *PostgresStorage) ensureTableExists(ctx context.Context) error {
 	return err
 }
 
+func watchCtx(ctx context.Context, kind, name string, log *zap.Logger) {
+	go func() {
+		<-ctx.Done()
+		// Go 1.20+: context.Cause gives you the *reason* (deadline, cancel, or custom)
+		err := context.Cause(ctx)
+		if err == nil {
+			err = ctx.Err()
+		} // fallback
+		if dl, ok := ctx.Deadline(); ok {
+			log.Debug("ctx done", zap.String("kind", kind), zap.String("name", name),
+				zap.Error(err), zap.Time("deadline", dl), zap.Duration("until_deadline", time.Until(dl)))
+		} else {
+			log.Debug("ctx done", zap.String("kind", kind), zap.String("name", name), zap.Error(err))
+		}
+	}()
+}
+
 func (s *PostgresStorage) Lock(ctx context.Context, name string) error {
 	s.logger.Debug("acquiring lock", zap.String("name", name))
 
+	watchCtx(ctx, "acquire", name, s.logger)
+
 	lock, err := s.pglock.AcquireContext(ctx, name)
 	if err != nil {
 		return fmt.Errorf("could not acquire pglock: %w", err)