Rotate files while the service is running.
[nssm.git] / registry.cpp
index cc871b7..b526ee5 100644 (file)
@@ -51,10 +51,26 @@ int create_parameters(nssm_service_t *service, bool editing) {
   }\r
 \r
   /* Other non-default parameters. May fail. */\r
+  if (service->priority != NORMAL_PRIORITY_CLASS) set_number(key, NSSM_REG_PRIORITY, service->priority);\r
+  else if (editing) RegDeleteValue(key, NSSM_REG_PRIORITY);\r
+  if (service->affinity) {\r
+    TCHAR *string;\r
+    if (! affinity_mask_to_string(service->affinity, &string)) {\r
+      if (RegSetValueEx(key, NSSM_REG_AFFINITY, 0, REG_SZ, (const unsigned char *) string, (unsigned long) (_tcslen(string) + 1) * sizeof(TCHAR)) != ERROR_SUCCESS) {\r
+        log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_SETVALUE_FAILED, NSSM_REG_AFFINITY, error_string(GetLastError()), 0);\r
+        HeapFree(GetProcessHeap(), 0, string);\r
+        return 5;\r
+      }\r
+    }\r
+    if (string) HeapFree(GetProcessHeap(), 0, string);\r
+  }\r
+  else if (editing) RegDeleteValue(key, NSSM_REG_AFFINITY);\r
   unsigned long stop_method_skip = ~service->stop_method;\r
   if (stop_method_skip) set_number(key, NSSM_REG_STOP_METHOD_SKIP, stop_method_skip);\r
   else if (editing) RegDeleteValue(key, NSSM_REG_STOP_METHOD_SKIP);\r
   if (service->default_exit_action < NSSM_NUM_EXIT_ACTIONS) create_exit_action(service->name, exit_action_strings[service->default_exit_action], editing);\r
+  if (service->restart_delay) set_number(key, NSSM_REG_RESTART_DELAY, service->restart_delay);\r
+  else if (editing) RegDeleteValue(key, NSSM_REG_RESTART_DELAY);\r
   if (service->throttle_delay != NSSM_RESET_THROTTLE_RESTART) set_number(key, NSSM_REG_THROTTLE, service->throttle_delay);\r
   else if (editing) RegDeleteValue(key, NSSM_REG_THROTTLE);\r
   if (service->kill_console_delay != NSSM_KILL_CONSOLE_GRACE_PERIOD) set_number(key, NSSM_REG_KILL_CONSOLE_GRACE_PERIOD, service->kill_console_delay);\r
@@ -95,6 +111,8 @@ int create_parameters(nssm_service_t *service, bool editing) {
   }\r
   if (service->rotate_files) set_number(key, NSSM_REG_ROTATE, 1);\r
   else if (editing) RegDeleteValue(key, NSSM_REG_ROTATE);\r
+  if (service->rotate_stdout_online) set_number(key, NSSM_REG_ROTATE_ONLINE, 1);\r
+  else if (editing) RegDeleteValue(key, NSSM_REG_ROTATE_ONLINE);\r
   if (service->rotate_seconds) set_number(key, NSSM_REG_ROTATE_SECONDS, service->rotate_seconds);\r
   else if (editing) RegDeleteValue(key, NSSM_REG_ROTATE_SECONDS);\r
   if (service->rotate_bytes_low) set_number(key, NSSM_REG_ROTATE_BYTES_LOW, service->rotate_bytes_low);\r
@@ -451,6 +469,32 @@ int get_parameters(nssm_service_t *service, STARTUPINFO *si) {
     log_event(EVENTLOG_WARNING_TYPE, NSSM_EVENT_NO_DIR, NSSM_REG_DIR, service->name, service->dir, 0);\r
   }\r
 \r
+  /* Try to get processor affinity - may fail. */\r
+  TCHAR buffer[512];\r
+  if (expand_parameter(key, NSSM_REG_AFFINITY, buffer, sizeof(buffer), false, false) || ! buffer[0]) service->affinity = 0LL;\r
+  else if (affinity_string_to_mask(buffer, &service->affinity)) {\r
+    log_event(EVENTLOG_WARNING_TYPE, NSSM_EVENT_BOGUS_AFFINITY_MASK, service->name, buffer);\r
+    service->affinity = 0LL;\r
+  }\r
+  else {\r
+    DWORD_PTR affinity, system_affinity;\r
+\r
+    if (GetProcessAffinityMask(GetCurrentProcess(), &affinity, &system_affinity)) {\r
+      _int64 effective_affinity = service->affinity & system_affinity;\r
+      if (effective_affinity != service->affinity) {\r
+        TCHAR *system = 0;\r
+        if (! affinity_mask_to_string(system_affinity, &system)) {\r
+          TCHAR *effective = 0;\r
+          if (! affinity_mask_to_string(effective_affinity, &effective)) {\r
+            log_event(EVENTLOG_WARNING_TYPE, NSSM_EVENT_EFFECTIVE_AFFINITY_MASK, service->name, buffer, system, effective, 0);\r
+          }\r
+          HeapFree(GetProcessHeap(), 0, effective);\r
+        }\r
+        HeapFree(GetProcessHeap(), 0, system);\r
+      }\r
+    }\r
+  }\r
+\r
   /* Try to get environment variables - may fail */\r
   set_environment(service->name, key, NSSM_REG_ENV, &service->env, &service->envlen);\r
   /* Environment variables to add to existing rather than replace - may fail. */\r
@@ -458,38 +502,70 @@ int get_parameters(nssm_service_t *service, STARTUPINFO *si) {
 \r
   if (si) {\r
     if (service->env_extra) {\r
-      /* Append these to any other environment variables set. */\r
+      TCHAR *env;\r
+      unsigned long envlen;\r
+\r
+      /* Copy our environment for the application. */\r
+      if (! service->env) {\r
+        TCHAR *rawenv = GetEnvironmentStrings();\r
+        env = rawenv;\r
+        if (env) {\r
+          /*\r
+            The environment block starts with variables of the form\r
+            =C:=C:\Windows\System32 which we ignore.\r
+          */\r
+          while (*env == _T('=')) {\r
+            for ( ; *env; env++);\r
+            env++;\r
+          }\r
+          envlen = 0;\r
+          if (*env) {\r
+            while (true) {\r
+              for ( ; env[envlen]; envlen++);\r
+              if (! env[++envlen]) break;\r
+            }\r
+            envlen++;\r
+\r
+            service->envlen = envlen * sizeof(TCHAR);\r
+            service->env = (TCHAR *) HeapAlloc(GetProcessHeap(), 0, service->envlen);\r
+            memmove(service->env, env, service->envlen);\r
+            FreeEnvironmentStrings(rawenv);\r
+          }\r
+        }\r
+      }\r
+\r
+      /* Append extra variables to configured variables. */\r
       if (service->env) {\r
-        /* Append extra variables to configured variables. */\r
-        unsigned long envlen = service->envlen + service->env_extralen - 1;\r
-        TCHAR *env = (TCHAR *) HeapAlloc(GetProcessHeap(), 0, envlen);\r
+        envlen = service->envlen + service->env_extralen - sizeof(TCHAR)/*?*/;\r
+        env = (TCHAR *) HeapAlloc(GetProcessHeap(), 0, envlen);\r
         if (env) {\r
           memmove(env, service->env, service->envlen - sizeof(TCHAR));\r
-          /* envlen is in bytes. */\r
+          /* envlen is in bytes but env[i] is in characters. */\r
           memmove(env + (service->envlen / sizeof(TCHAR)) - 1, service->env_extra, service->env_extralen);\r
 \r
           HeapFree(GetProcessHeap(), 0, service->env);\r
+          HeapFree(GetProcessHeap(), 0, service->env_extra);\r
           service->env = env;\r
           service->envlen = envlen;\r
         }\r
         else log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, _T("environment"), _T("get_parameters()"), 0);\r
       }\r
       else {\r
-        /* Append extra variables to our environment. */\r
-        TCHAR *env, *s;\r
-        size_t envlen, len;\r
-\r
-        env = service->env_extra;\r
-        len = 0;\r
-        while (*env) {\r
-          envlen = _tcslen(env) + 1;\r
-          for (s = env; *s && *s != _T('='); s++);\r
-          if (*s == _T('=')) *s++ = _T('\0');\r
-          if (! SetEnvironmentVariable(env, s)) log_event(EVENTLOG_WARNING_TYPE, NSSM_EVENT_SETENVIRONMENTVARIABLE_FAILED, env, s, error_string(GetLastError()), 0);\r
-          env += envlen;\r
-        }\r
+        /* Huh?  No environment at all? */\r
+        service->env = service->env_extra;\r
+        service->envlen = service->env_extralen;\r
       }\r
     }\r
+\r
+    service->env_extra = 0;\r
+    service->env_extralen = 0;\r
+  }\r
+\r
+  /* Try to get priority - may fail. */\r
+  unsigned long priority;\r
+  if (get_number(key, NSSM_REG_PRIORITY, &priority, false) == 1) {\r
+    if (priority == (priority & priority_mask())) service->priority = priority;\r
+    else log_event(EVENTLOG_WARNING_TYPE, NSSM_EVENT_BOGUS_PRIORITY, service->name, NSSM_REG_PRIORITY, 0);\r
   }\r
 \r
   /* Try to get file rotation settings - may fail. */\r
@@ -499,6 +575,11 @@ int get_parameters(nssm_service_t *service, STARTUPINFO *si) {
     else service->rotate_files = false;\r
   }\r
   else service->rotate_files = false;\r
+  if (get_number(key, NSSM_REG_ROTATE_ONLINE, &rotate_files, false) == 1) {\r
+    if (rotate_files) service->rotate_stdout_online = service->rotate_stderr_online = true;\r
+    else service->rotate_stdout_online = service->rotate_stderr_online = false;\r
+  }\r
+  else service->rotate_stdout_online = service->rotate_stderr_online = false;\r
   if (get_number(key, NSSM_REG_ROTATE_SECONDS, &service->rotate_seconds, false) != 1) service->rotate_seconds = 0;\r
   if (get_number(key, NSSM_REG_ROTATE_BYTES_LOW, &service->rotate_bytes_low, false) != 1) service->rotate_bytes_low = 0;\r
   if (get_number(key, NSSM_REG_ROTATE_BYTES_HIGH, &service->rotate_bytes_high, false) != 1) service->rotate_bytes_high = 0;\r
@@ -519,6 +600,9 @@ int get_parameters(nssm_service_t *service, STARTUPINFO *si) {
   /* Change back in case the startup directory needs to be deleted. */\r
   SetCurrentDirectory(cwd);\r
 \r
+  /* Try to get mandatory restart delay */\r
+  override_milliseconds(service->name, key, NSSM_REG_RESTART_DELAY, &service->restart_delay, 0, NSSM_EVENT_BOGUS_RESTART_DELAY);\r
+\r
   /* Try to get throttle restart delay */\r
   override_milliseconds(service->name, key, NSSM_REG_THROTTLE, &service->throttle_delay, NSSM_RESET_THROTTLE_RESTART, NSSM_EVENT_BOGUS_THROTTLE);\r
 \r