git init1.1.103

1 files changed, 238 insertions, 0 deletions

diff --git a/lib/configuration.c b/lib/configuration.c
new file mode 100644
index 0000000..7f51896
--- /dev/null
+++ b/lib/configuration.c
@@ -0,0 +1,238 @@
+/*
+ * configuration.c
+ *
+ * See the README file for copyright information and how to reach the author.
+ *
+ */
+
+#include "configuration.h"
+
+time_t cSystemNotification::lastWatchdogAt = time(0);
+const char* cSystemNotification::pidfile = "";
+
+//***************************************************************************
+// Class cSystemNotification
+//***************************************************************************
+
+cSystemNotification::cSystemNotification()
+   : cThread("SystemNotification", yes)
+{
+   interval = 0;
+   stop = no;
+}
+
+//***************************************************************************
+// System Watchdog Check / notify
+//***************************************************************************
+
+void cSystemNotification::check(int force)
+{
+   if (interval && (force || lastWatchdogAt <= time(0) - interval))
+   {
+      // notify all 'n' seconds
+
+      notify(evKeepalive);
+      lastWatchdogAt = time(0);
+   }
+}
+
+//***************************************************************************
+// Start / Stop notification thread
+//***************************************************************************
+
+int cSystemNotification::startNotifyThread(int timeout)
+{
+   threadTimeout = timeout;
+   Start(yes);
+   return success;
+}
+
+int cSystemNotification::stopNotifyThread()
+{
+   stop = yes;
+   waitCondition.Broadcast();
+   Cancel(3);
+   return success;
+}
+
+//***************************************************************************
+// action
+//***************************************************************************
+
+void cSystemNotification::action()
+{
+   cMyMutex mutex;
+   time_t timeoutAt = time(0) + threadTimeout;
+
+   stop = no;
+   mutex.Lock();
+
+   while (time(0) < timeoutAt && Running() && !stop)
+   {
+      // tell(0, "loop ...");
+
+      waitCondition.TimedWait(mutex, interval*1000);
+
+      if (!stop)
+         check();
+   }
+
+   if (time(0) >= timeoutAt)
+      tell(0, "Warning: Ending notification thread, timeout reached!");
+}
+
+//***************************************************************************
+// Notify System Deamon :o :(
+//***************************************************************************
+
+int cSystemNotification::notify(int event, const char* format, ...)
+{
+#ifdef USESYSD
+   char* message;
+   char* tmp;
+   va_list ap;
+
+   if (isEmpty(format))
+      format = "";
+
+   va_start(ap, format);
+   vasprintf(&tmp, format, ap);
+
+   switch (event)
+   {
+      case evStatus:    asprintf(&message, "%s", tmp);               break;
+      case evStopping:  asprintf(&message, "STOPPING=1\n%s", tmp);   break;
+      case evReady:     asprintf(&message, "READY=1\nSTATUS=Ready\nMAINPID=%d\n%s", getpid(), tmp);  break;
+      case evKeepalive: asprintf(&message, "WATCHDOG=1\n%s", tmp);   break;
+   }
+
+   tell(event == evKeepalive ? 2 : 1, "Calling sd_notify(%s)", message);
+   sd_notify(0, message);
+
+   free(tmp);
+   free(message);
+#endif
+
+   // handle pidfile at evReady / evStopping
+
+   if (!isEmpty(pidfile))
+   {
+      if (event == evReady)
+      {
+         FILE* f = fopen(pidfile, "w");
+
+         if (f)
+         {
+            pid_t pid = getpid();
+            tell(1, "Creating pidfile '%s'; pid %d", pidfile, pid);
+            fprintf(f, "%d\n", pid);
+            fclose(f);
+         }
+         else
+            tell(0, "Error: Can't create pid file '%s' error was (%d) '%s'",
+                 pidfile, errno, strerror(errno));
+      }
+      else if (event == evStopping)
+      {
+         if (fileExists(pidfile))
+         {
+            tell(1, "Removing pidfile '%s'", pidfile);
+            removeFile(pidfile);
+         }
+      }
+   }
+
+   return done;
+}
+
+//***************************************************************************
+// Get Watchdog State
+//***************************************************************************
+
+int cSystemNotification::getWatchdogState(int minInterval)
+{
+   interval = 0;
+
+#ifdef USESYSD
+
+#  ifdef SYSDWDIFO
+   uint64_t us = 0;
+   int sec;
+
+   if (sd_watchdog_enabled(0, &us) > 0 && us > 0)
+   {
+      sec = us / tmeUsecondsPerSecond;
+
+      if (sec < minInterval*2)
+      {
+         tell(0, "Warning: Systemd watchdog configured to (%ds) but min %ds are required,"
+              "  ignoring watchdog", sec, minInterval * 2);
+         return no;
+      }
+
+      interval = sec / 2;
+
+      tell(0, "Info: Systemd watchdog request interval"
+           " of at least(%ds), using (%ds) now!", sec, interval);
+
+      return yes;
+   }
+
+   tell(0, "Info: Systemd watchdog not configured, epgd won't be sending keep-alive messages!");
+
+#  else
+   interval = defaultInterval;
+   return yes;
+#  endif
+
+#else
+   tell(0, "Info: Systemd support not enabled, epgd won't be sending notifications!");
+#endif
+
+   return no;
+}
+
+//***************************************************************************
+// Class Frame
+//***************************************************************************
+
+//***************************************************************************
+// Send Mail
+//***************************************************************************
+
+int cFrame::sendMail(const char* mimeType, const char* receivers,
+                     const char* subject, const char* body)
+{
+   int res;
+   char* command = 0;
+   char mailScript[255+TB] = "";
+   std::string mailBody;
+
+   getParameter("epgd", "mailScript", mailScript);
+
+   if (isEmpty(mailScript) || isEmpty(receivers))
+      return done;
+
+   // ' Zeichen maskieren sonst knallt es beim Versenden
+
+   mailBody = strReplace("\"", "'", body);
+   // mailBody = strReplace("!", "", mailBody);
+
+   tell(0, "Send mail '%s' with [%s] to '%s'", subject, body, receivers);
+
+   asprintf(&command, "%s \"%s\" \"%s\" \"%s\" %s", mailScript,
+            subject, mailBody.c_str(), mimeType, receivers);
+
+   if ((res = system(command)) != 0)
+   {
+      if (res == -1)
+         tell(0, "Error: Command '%s' failed, can't fork process, result was (%s)",
+              command, strerror(errno));
+      else
+         tell(0, "Error: Result of command '%s' was (%d)", mailScript, res);
+   }
+
+   free(command);
+
+   return success;
+}