+static int watchdog_open(bool cloexec)
+{
+ char *env = getenv("WDTFD");
+
+ if (wdt_fd >= 0)
+ return wdt_fd;
+
+ if (env) {
+ DEBUG(2, "Watchdog handover: fd=%s\n", env);
+ wdt_fd = atoi(env);
+ unsetenv("WDTFD");
+ } else {
+ wdt_fd = open(WDT_PATH, O_WRONLY);
+ }
+
+ if (wdt_fd < 0)
+ return wdt_fd;
+
+ if (cloexec)
+ fcntl(wdt_fd, F_SETFD, fcntl(wdt_fd, F_GETFD) | FD_CLOEXEC);
+
+ return wdt_fd;
+}
+
+static void watchdog_close(void)
+{
+ if (wdt_fd < 0)
+ return;
+
+ if (write(wdt_fd, "V", 1) < 0)
+ ERROR("WDT failed to write release: %s\n", strerror(errno));
+
+ if (close(wdt_fd) == -1)
+ ERROR("WDT failed to close watchdog: %s\n", strerror(errno));
+
+ wdt_fd = -1;
+}
+
+void watchdog_set_magicclose(bool val)
+{
+ wdt_magicclose = val;
+}
+
+bool watchdog_get_magicclose(void)
+{
+ return wdt_magicclose;
+}
+
+void watchdog_set_stopped(bool val)
+{
+ if (val) {
+ uloop_timeout_cancel(&wdt_timeout);
+
+ if (wdt_magicclose)
+ watchdog_close();
+ }
+ else {
+ watchdog_open(true);
+ watchdog_timeout_cb(&wdt_timeout);
+ }
+}
+
+bool watchdog_get_stopped(void)
+{
+ return !wdt_timeout.pending;
+}
+