41019023168

Committed 30 Oct 2026 07:15AM UTC coverage: 58.191% (+0.002%) from 58.189%

Build # 41019023168

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #6951 from eXist-db/dependabot/maven/maven-plugins-tools-9d8b030d75

Bump org.jacoco:jacoco-maven-plugin from 0.8.15 to 0.8.16 in the maven-plugins-tools group

Coverage Stats

32497 of 61720 branches covered (52.65%)

Branch coverage included in aggregate %.

85590 of 141211 relevant lines covered (60.61%)

2.73 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

90.91

/exist-core/src/main/java/org/exist/http/ws/EvalSession.java

/*
 * eXist-db Open Source Native XML Database
 * Copyright (C) 2001 The eXist-db Authors
 *
 * info@exist-db.org
 * http://www.exist-db.org
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 */
package org.exist.http.ws;

import org.exist.security.Subject;
import org.exist.xquery.XQueryWatchDog;

import javax.annotation.Nullable;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * Per-connection state for the /ws/eval WebSocket endpoint.
 *
 * Tracks the authenticated user and all running queries for cancellation.
 */
public final class EvalSession {

    private final Subject subject;
    private final Map<String, XQueryWatchDog> runningQueries = new ConcurrentHashMap<>();

    public EvalSession(final Subject subject) {
        this.subject = subject;
    }

    public Subject getSubject() {
        return subject;
    }

    /**
     * Register a running query's watchdog for cancellation.
     */
    public void registerQuery(final String queryId, final XQueryWatchDog watchDog) {
        runningQueries.put(queryId, watchDog);
    }

    /**
     * Unregister a completed or cancelled query.
     */
    public void unregisterQuery(final String queryId) {
        runningQueries.remove(queryId);
    }

    /**
     * Cancel a running query by its ID.
     *
     * @return true if the query was found and cancelled
     */
    public boolean cancelQuery(final String queryId) {
        final XQueryWatchDog watchDog = runningQueries.get(queryId);
        if (watchDog != null) {
            watchDog.kill(0);
            return true;
        }
        return false;
    }

    /**
     * Cancel all running queries (called on session close).
     */
    public void cancelAll() {
        for (final XQueryWatchDog watchDog : runningQueries.values()) {
            watchDog.kill(0);
        }
        runningQueries.clear();
    }
}

1	/*
2	* eXist-db Open Source Native XML Database
3	* Copyright (C) 2001 The eXist-db Authors
4	*
5	* info@exist-db.org
6	* http://www.exist-db.org
7	*
8	* This library is free software; you can redistribute it and/or
9	* modify it under the terms of the GNU Lesser General Public
10	* License as published by the Free Software Foundation; either
11	* version 2.1 of the License, or (at your option) any later version.
12	*
13	* This library is distributed in the hope that it will be useful,
14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16	* Lesser General Public License for more details.
17	*
18	* You should have received a copy of the GNU Lesser General Public
19	* License along with this library; if not, write to the Free Software
20	* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
21	*/
22	package org.exist.http.ws;
23
24	import org.exist.security.Subject;
25	import org.exist.xquery.XQueryWatchDog;
26
27	import javax.annotation.Nullable;
28	import java.util.Map;
29	import java.util.concurrent.ConcurrentHashMap;
30
31	/**
32	* Per-connection state for the /ws/eval WebSocket endpoint.
33	*
34	* Tracks the authenticated user and all running queries for cancellation.
35	*/
36	public final class EvalSession {
37
38	private final Subject subject;
39	private final Map<String, XQueryWatchDog> runningQueries = new ConcurrentHashMap<>();	5 ✔
40
41	public EvalSession(final Subject subject) {	2 ✔
42	this.subject = subject;	3 ✔
43	}	1 ✔
44
45	public Subject getSubject() {
46	return subject;	3 ✔
47	}
48
49	/**
50	* Register a running query's watchdog for cancellation.
51	*/
52	public void registerQuery(final String queryId, final XQueryWatchDog watchDog) {
53	runningQueries.put(queryId, watchDog);	6 ✔
54	}	1 ✔
55
56	/**
57	* Unregister a completed or cancelled query.
58	*/
59	public void unregisterQuery(final String queryId) {
60	runningQueries.remove(queryId);	5 ✔
61	}	1 ✔
62
63	/**
64	* Cancel a running query by its ID.
65	*
66	* @return true if the query was found and cancelled
67	*/
68	public boolean cancelQuery(final String queryId) {
69	final XQueryWatchDog watchDog = runningQueries.get(queryId);	6 ✔
70	if (watchDog != null) {	2 !
71	watchDog.kill(0);	3 ✔
72	return true;	2 ✔
73	}
74	return false;	×
75	}
76
77	/**
78	* Cancel all running queries (called on session close).
79	*/
80	public void cancelAll() {
81	for (final XQueryWatchDog watchDog : runningQueries.values()) {	13 ✔
82	watchDog.kill(0);	3 ✔
83	}
84	runningQueries.clear();	3 ✔
85	}	1 ✔
86	}

eXist-db / exist / 41019023168

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous