I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit 2d1ac7b2 authored by zzz's avatar zzz
Browse files

Wrapper: Listen for Windows Service shutdown events and shutdown router hard.

As a result, event log will now show "shutdown" instead of "crashed".
parent 2852383e
No related branches found
No related tags found
No related merge requests found
...@@ -160,8 +160,7 @@ public class ConfigServiceHandler extends FormHandler { ...@@ -160,8 +160,7 @@ public class ConfigServiceHandler extends FormHandler {
* @since 0.8.13 * @since 0.8.13
*/ */
synchronized static void registerSignalHandler(RouterContext ctx) { synchronized static void registerSignalHandler(RouterContext ctx) {
if (ctx.hasWrapper() && _wrapperListener == null && if (ctx.hasWrapper() && _wrapperListener == null) {
!SystemVersion.isWindows()) {
String wv = System.getProperty("wrapper.version"); String wv = System.getProperty("wrapper.version");
if (wv != null && VersionComparator.comp(wv, LISTENER_AVAILABLE) >= 0) { if (wv != null && VersionComparator.comp(wv, LISTENER_AVAILABLE) >= 0) {
try { try {
......
...@@ -3,9 +3,11 @@ package net.i2p.router.web; ...@@ -3,9 +3,11 @@ package net.i2p.router.web;
import net.i2p.router.Router; import net.i2p.router.Router;
import net.i2p.router.RouterContext; import net.i2p.router.RouterContext;
import net.i2p.util.Log; import net.i2p.util.Log;
import net.i2p.util.SystemVersion;
import org.tanukisoftware.wrapper.WrapperManager; import org.tanukisoftware.wrapper.WrapperManager;
import org.tanukisoftware.wrapper.event.WrapperControlEvent; import org.tanukisoftware.wrapper.event.WrapperControlEvent;
import org.tanukisoftware.wrapper.event.WrapperServiceControlEvent;
import org.tanukisoftware.wrapper.event.WrapperEvent; import org.tanukisoftware.wrapper.event.WrapperEvent;
import org.tanukisoftware.wrapper.event.WrapperEventListener; import org.tanukisoftware.wrapper.event.WrapperEventListener;
...@@ -28,7 +30,9 @@ class WrapperListener { ...@@ -28,7 +30,9 @@ class WrapperListener {
*/ */
public WrapperListener(RouterContext ctx) { public WrapperListener(RouterContext ctx) {
_listener = new SignalHandler(ctx); _listener = new SignalHandler(ctx);
long mask = WrapperEventListener.EVENT_FLAG_CONTROL; long mask = SystemVersion.isWindows() ? WrapperEventListener.EVENT_FLAG_SERVICE :
WrapperEventListener.EVENT_FLAG_CONTROL;
WrapperManager.addWrapperEventListener(_listener, mask); WrapperManager.addWrapperEventListener(_listener, mask);
} }
...@@ -55,10 +59,37 @@ class WrapperListener { ...@@ -55,10 +59,37 @@ class WrapperListener {
} }
public void fired(WrapperEvent event) { public void fired(WrapperEvent event) {
if (!(event instanceof WrapperControlEvent)) Log log = _ctxt.logManager().getLog(ConfigServiceHandler.class);
if (SystemVersion.isWindows() && (event instanceof WrapperServiceControlEvent)) {
WrapperServiceControlEvent wcse = (WrapperServiceControlEvent) event;
int code = wcse.getServiceControlCode();
switch (code) {
case WrapperManager.SERVICE_CONTROL_CODE_STOP: // 1
case WrapperManager.SERVICE_CONTROL_CODE_SHUTDOWN: // 5
log.log(Log.CRIT, "Hard shutdown initiated by Windows service control: " + code);
// JVM will call ShutdownHook if we don't do it ourselves
ConfigServiceHandler.registerWrapperNotifier(_ctxt, Router.EXIT_HARD, false);
_ctxt.router().shutdown(Router.EXIT_HARD);
break;
// TODO Power suspend/resume?
// Warning, definitions not available in 3.2.0, use integers
// Tanuki doesn't usually mark things with @since, sadly
// case 35xx // WrapperManager.SERVICE_CONTROL_POWEREVENT_ ...
// break;
default:
if (log.shouldWarn())
log.warn("Unhandled control event code: " + code);
break;
}
return;
} else if (!(event instanceof WrapperControlEvent)) {
if (log.shouldWarn())
log.warn("Got unhandled event: " + event);
return; return;
}
WrapperControlEvent wce = (WrapperControlEvent) event; WrapperControlEvent wce = (WrapperControlEvent) event;
Log log = _ctxt.logManager().getLog(ConfigServiceHandler.class);
if (log.shouldLog(Log.WARN)) if (log.shouldLog(Log.WARN))
log.warn("Got signal: " + wce.getControlEventName()); log.warn("Got signal: " + wce.getControlEventName());
int sig = wce.getControlEvent(); int sig = wce.getControlEvent();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment