webmaster/signal-cli
1
0
Fork 0
mirror of https://github.com/AsamK/signal-cli synced 2025-09-03 04:50:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Refactor DaemonCommand

Browse source
This commit is contained in:
AsamK 2023-11-10 15:18:06 +01:00
parent c0aa338d7c
commit 7e9940be4a
5 changed files with 301 additions and 199 deletions
Download patch file Download diff file Expand all files Collapse all files

33
src/main/java/org/asamk/signal/http/HttpServerHandler.java
View file

@ -56,7 +56,7 @@ public class HttpServerHandler implements AutoCloseable {
if (server != null) {
throw new AssertionError("HttpServerHandler already initialized");
}
logger.info("Starting server on " + address.toString());
logger.debug("Starting HTTP server on {}", address);
server = HttpServer.create(address, 0);
server.setExecutor(Executors.newCachedThreadPool());
@ -66,6 +66,21 @@ public class HttpServerHandler implements AutoCloseable {
server.createContext("/api/v1/check", this::handleCheckEndpoint);
server.start();
logger.info("Started HTTP server on {}", address);
}
@Override
public void close() {
if (server != null) {
shutdown.set(true);
synchronized (this) {
this.notifyAll();
}
// Increase this delay when https://bugs.openjdk.org/browse/JDK-8304065 is fixed
server.stop(2);
server = null;
shutdown.set(false);
}
}
private void sendResponse(int status, Object response, HttpExchange httpExchange) throws IOException {
@ -221,7 +236,7 @@ public class HttpServerHandler implements AutoCloseable {
return List.of(manager);
}
}
return List.of();
throw new AssertionError("Unreachable state");
}
private List<Pair<Manager, Manager.ReceiveMessageHandler>> subscribeReceiveHandlers(
@ -246,20 +261,6 @@ public class HttpServerHandler implements AutoCloseable {
m.removeReceiveHandler(handler);
}
@Override
public void close() {
if (server != null) {
shutdown.set(true);
synchronized (this) {
this.notifyAll();
}
// Increase this delay when https://bugs.openjdk.org/browse/JDK-8304065 is fixed
server.stop(2);
server = null;
shutdown.set(false);
}
}
private interface Callable {
void call();