Function holdResourceWriteLock

internal/resources/kernel_test.go:1243–1276

(ctx context.Context, t *testing.T, db *sql.DB)

}

func holdResourceWriteLock(ctx context.Context, t *testing.T, db *sql.DB) {
	t.Helper()

	lockConn, err := db.Conn(ctx)
	if err != nil {
		t.Fatalf("db.Conn() error = %v", err)
	}
	t.Cleanup(func() {
		if closeErr := lockConn.Close(); closeErr != nil {
			t.Fatalf("lockConn.Close() error = %v", closeErr)
		}
	})

	if _, err := lockConn.ExecContext(ctx, "BEGIN IMMEDIATE"); err != nil {
		t.Fatalf("BEGIN IMMEDIATE lock error = %v", err)
	}

	releaseDone := make(chan error, 1)
	timer := time.AfterFunc(10*time.Millisecond, func() {
		_, commitErr := lockConn.ExecContext(ctx, "COMMIT")
		releaseDone <- commitErr
	})
	t.Cleanup(func() {
		if timer.Stop() {
			if _, err := lockConn.ExecContext(ctx, "COMMIT"); err != nil {
				t.Fatalf("manual lock release error = %v", err)
			}
			return
		}
		if err := <-releaseDone; err != nil {
			t.Fatalf("timed lock release error = %v", err)
		}
	})
}

func testDaemonActor() MutationActor {
	return MutationActor{