apache/maven-mvnd
1
0
Fork 0
mirror of https://github.com/apache/maven-mvnd.git synced 2025-09-10 04:59:54 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Provides option to list and kill daemons, fixes #6

Browse Source
This commit is contained in:
Guillaume Nodet
2019-10-01 12:24:13 +02:00
parent d28c066f53
commit 23549ebe14
1 changed files with 30 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/main/java/org/jboss/fuse/mvnd/daemon/Client.java
View File

@@ -30,6 +30,7 @@ import org.jboss.fuse.mvnd.daemon.Message.BuildEvent;
import org.jboss.fuse.mvnd.daemon.Message.BuildMessage; import org.jboss.fuse.mvnd.daemon.Message.BuildMessage;
import org.jboss.fuse.mvnd.daemon.Message.MessageSerializer; import org.jboss.fuse.mvnd.daemon.Message.MessageSerializer;
import org.jboss.fuse.mvnd.jpm.Process; import org.jboss.fuse.mvnd.jpm.Process;
import org.jboss.fuse.mvnd.jpm.ProcessImpl;
import org.jboss.fuse.mvnd.jpm.ScriptUtils; import org.jboss.fuse.mvnd.jpm.ScriptUtils;
import org.jline.terminal.Size; import org.jline.terminal.Size;
import org.jline.terminal.Terminal; import org.jline.terminal.Terminal;
@@ -39,22 +40,49 @@ import org.jline.utils.Display;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import static org.apache.maven.shared.utils.logging.MessageUtils.buffer;
public class Client { public class Client {
private static final Logger LOGGER = LoggerFactory.getLogger(Client.class); private static final Logger LOGGER = LoggerFactory.getLogger(Client.class);
public static final String DAEMON_DEBUG = "daemon.debug"; public static final String DAEMON_DEBUG = "daemon.debug";
public static void main(String[] args) throws Exception { public static void main(String[] argv) throws Exception {
LOGGER.debug("Starting client"); LOGGER.debug("Starting client");
List<String> args = new ArrayList<>(Arrays.asList(argv));
Path javaHome = Layout.javaHome(); Path javaHome = Layout.javaHome();
DaemonRegistry registry = DaemonRegistry.getDefault(); DaemonRegistry registry = DaemonRegistry.getDefault();
boolean status = args.remove("--status");
if (status) {
System.out.println(String.format(" %36s %5s %5s %7s %s",
"UUID", "PID", "Port", "Status", "Timestamp"));
registry.getAll().forEach(d ->
System.out.println(String.format(" %36s %5s %5s %7s %s",
d.getUid(), d.getPid(), d.getAddress(), d.getState(),
new Date(Math.max(d.getLastIdle(), d.getLastBusy())).toString())));
return;
}
boolean stop = args.remove("--stop");
if (stop) {
DaemonInfo[] dis = registry.getAll().toArray(new DaemonInfo[0]);
if (dis.length > 0) {
System.out.println("Stopping " + dis.length + " running daemons");
for (DaemonInfo di : dis) {
new ProcessImpl(di.getPid()).destroy();
registry.remove(di.getUid());
}
}
return;
}
DaemonConnector connector = new DaemonConnector(registry, Client::startDaemon, new MessageSerializer()); DaemonConnector connector = new DaemonConnector(registry, Client::startDaemon, new MessageSerializer());
List<String> opts = new ArrayList<>(); List<String> opts = new ArrayList<>();
DaemonClientConnection daemon = connector.connect(new DaemonCompatibilitySpec(javaHome.toString(), opts)); DaemonClientConnection daemon = connector.connect(new DaemonCompatibilitySpec(javaHome.toString(), opts));
daemon.dispatch(new Message.BuildRequest( daemon.dispatch(new Message.BuildRequest(
Arrays.asList(args), args,
Layout.getProperty("user.dir"), Layout.getProperty("user.dir"),
Layout.getProperty("maven.multiModuleProjectDirectory"))); Layout.getProperty("maven.multiModuleProjectDirectory")));