\r
const TCHAR *exit_action_strings[] = { _T("Restart"), _T("Ignore"), _T("Exit"), _T("Suicide"), 0 };\r
const TCHAR *startup_strings[] = { _T("SERVICE_AUTO_START"), _T("SERVICE_DELAYED_AUTO_START"), _T("SERVICE_DEMAND_START"), _T("SERVICE_DISABLED"), 0 };\r
+const TCHAR *priority_strings[] = { _T("REALTIME_PRIORITY_CLASS"), _T("HIGH_PRIORITY_CLASS"), _T("ABOVE_NORMAL_PRIORITY_CLASS"), _T("NORMAL_PRIORITY_CLASS"), _T("BELOW_NORMAL_PRIORITY_CLASS"), _T("IDLE_PRIORITY_CLASS"), 0 };\r
+\r
+inline unsigned long priority_mask() {\r
+ return REALTIME_PRIORITY_CLASS | HIGH_PRIORITY_CLASS | ABOVE_NORMAL_PRIORITY_CLASS | NORMAL_PRIORITY_CLASS | BELOW_NORMAL_PRIORITY_CLASS | IDLE_PRIORITY_CLASS;\r
+}\r
+\r
+int priority_constant_to_index(unsigned long constant) {\r
+ switch (constant & priority_mask()) {\r
+ case REALTIME_PRIORITY_CLASS: return NSSM_REALTIME_PRIORITY;\r
+ case HIGH_PRIORITY_CLASS: return NSSM_HIGH_PRIORITY;\r
+ case ABOVE_NORMAL_PRIORITY_CLASS: return NSSM_ABOVE_NORMAL_PRIORITY;\r
+ case BELOW_NORMAL_PRIORITY_CLASS: return NSSM_BELOW_NORMAL_PRIORITY;\r
+ case IDLE_PRIORITY_CLASS: return NSSM_IDLE_PRIORITY;\r
+ }\r
+ return NSSM_NORMAL_PRIORITY;\r
+}\r
+\r
+unsigned long priority_index_to_constant(int index) {\r
+ switch (index) {\r
+ case NSSM_REALTIME_PRIORITY: return REALTIME_PRIORITY_CLASS;\r
+ case NSSM_HIGH_PRIORITY: return HIGH_PRIORITY_CLASS;\r
+ case NSSM_ABOVE_NORMAL_PRIORITY: return ABOVE_NORMAL_PRIORITY_CLASS;\r
+ case NSSM_BELOW_NORMAL_PRIORITY: return BELOW_NORMAL_PRIORITY_CLASS;\r
+ case NSSM_IDLE_PRIORITY: return IDLE_PRIORITY_CLASS;\r
+ }\r
+ return NORMAL_PRIORITY_CLASS;\r
+}\r
\r
static inline int throttle_milliseconds(unsigned long throttle) {\r
/* pow() operates on doubles. */\r
return ret;\r
}\r
\r
+/* Open a service by name or display name. */\r
+SC_HANDLE open_service(SC_HANDLE services, TCHAR *service_name, TCHAR *canonical_name, unsigned long canonical_namelen) {\r
+ SC_HANDLE service_handle = OpenService(services, service_name, SERVICE_ALL_ACCESS);\r
+ if (service_handle) {\r
+ if (canonical_name && canonical_name != service_name) {\r
+ if (_sntprintf_s(canonical_name, canonical_namelen, _TRUNCATE, _T("%s"), service_name) < 0) {\r
+ print_message(stderr, NSSM_MESSAGE_OUT_OF_MEMORY, _T("canonical_name"), _T("open_service()"));\r
+ return 0;\r
+ }\r
+ }\r
+ return service_handle;\r
+ }\r
+\r
+ unsigned long error = GetLastError();\r
+ if (error != ERROR_SERVICE_DOES_NOT_EXIST) {\r
+ print_message(stderr, NSSM_MESSAGE_OPENSERVICE_FAILED, error_string(GetLastError()));\r
+ return 0;\r
+ }\r
+\r
+ /* We can't look for a display name because there's no buffer to store it. */\r
+ if (! canonical_name) {\r
+ print_message(stderr, NSSM_MESSAGE_OPENSERVICE_FAILED, error_string(GetLastError()));\r
+ return 0;\r
+ }\r
+\r
+ unsigned long bufsize, required, count, i;\r
+ unsigned long resume = 0;\r
+ EnumServicesStatus(services, SERVICE_DRIVER | SERVICE_FILE_SYSTEM_DRIVER | SERVICE_KERNEL_DRIVER | SERVICE_WIN32, SERVICE_STATE_ALL, 0, 0, &required, &count, &resume);\r
+ error = GetLastError();\r
+ if (error != ERROR_MORE_DATA) {\r
+ print_message(stderr, NSSM_MESSAGE_ENUMSERVICESSTATUS_FAILED, error_string(GetLastError()));\r
+ return 0;\r
+ }\r
+\r
+ ENUM_SERVICE_STATUS *status = (ENUM_SERVICE_STATUS *) HeapAlloc(GetProcessHeap(), 0, required);\r
+ if (! status) {\r
+ print_message(stderr, NSSM_MESSAGE_OUT_OF_MEMORY, _T("ENUM_SERVICE_STATUS"), _T("open_service()"));\r
+ return 0;\r
+ }\r
+\r
+ bufsize = required;\r
+ while (true) {\r
+ /*\r
+ EnumServicesStatus() returns:\r
+ 1 when it retrieved data and there's no more data to come.\r
+ 0 and sets last error to ERROR_MORE_DATA when it retrieved data and\r
+ there's more data to come.\r
+ 0 and sets last error to something else on error.\r
+ */\r
+ int ret = EnumServicesStatus(services, SERVICE_DRIVER | SERVICE_FILE_SYSTEM_DRIVER | SERVICE_KERNEL_DRIVER | SERVICE_WIN32, SERVICE_STATE_ALL, status, bufsize, &required, &count, &resume);\r
+ if (! ret) {\r
+ error = GetLastError();\r
+ if (error != ERROR_MORE_DATA) {\r
+ HeapFree(GetProcessHeap(), 0, status);\r
+ print_message(stderr, NSSM_MESSAGE_ENUMSERVICESSTATUS_FAILED, error_string(GetLastError()));\r
+ return 0;\r
+ }\r
+ }\r
+\r
+ for (i = 0; i < count; i++) {\r
+ if (str_equiv(status[i].lpDisplayName, service_name)) {\r
+ if (_sntprintf_s(canonical_name, canonical_namelen, _TRUNCATE, _T("%s"), status[i].lpServiceName) < 0) {\r
+ HeapFree(GetProcessHeap(), 0, status);\r
+ print_message(stderr, NSSM_MESSAGE_OUT_OF_MEMORY, _T("canonical_name"), _T("open_service()"));\r
+ return 0;\r
+ }\r
+\r
+ HeapFree(GetProcessHeap(), 0, status);\r
+ return open_service(services, canonical_name, 0, 0);\r
+ }\r
+ }\r
+\r
+ if (ret) break;\r
+ }\r
+\r
+ /* Recurse so we can get an error message. */\r
+ return open_service(services, service_name, 0, 0);\r
+}\r
+\r
QUERY_SERVICE_CONFIG *query_service_config(const TCHAR *service_name, SC_HANDLE service_handle) {\r
QUERY_SERVICE_CONFIG *qsc;\r
unsigned long bufsize;\r
}\r
\r
int grant_logon_as_service(const TCHAR *username) {\r
+ if (! username) return 0;\r
if (str_equiv(username, NSSM_LOCALSYSTEM_ACCOUNT)) return 0;\r
\r
/* Open Policy object. */\r
#else\r
size_t buflen;\r
mbstowcs_s(&buflen, NULL, 0, username, _TRUNCATE);\r
- lsa_username.MaximumLength = buflen * sizeof(wchar_t);\r
+ lsa_username.MaximumLength = (unsigned short) buflen * sizeof(wchar_t);\r
lsa_username.Length = lsa_username.MaximumLength - sizeof(wchar_t);\r
lsa_username.Buffer = (wchar_t *) HeapAlloc(GetProcessHeap(), 0, lsa_username.MaximumLength);\r
if (lsa_username.Buffer) mbstowcs_s(&buflen, lsa_username.Buffer, lsa_username.MaximumLength, username, _TRUNCATE);\r
if (! service) return;\r
\r
service->type = SERVICE_WIN32_OWN_PROCESS;\r
+ service->priority = NORMAL_PRIORITY_CLASS;\r
service->stdin_sharing = NSSM_STDIN_SHARING;\r
service->stdin_disposition = NSSM_STDIN_DISPOSITION;\r
service->stdin_flags = NSSM_STDIN_FLAGS;\r
}\r
\r
/* Try to open the service */\r
- service->handle = OpenService(services, service->name, SC_MANAGER_ALL_ACCESS);\r
+ service->handle = open_service(services, service->name, service->name, _countof(service->name));\r
if (! service->handle) {\r
CloseServiceHandle(services);\r
- print_message(stderr, NSSM_MESSAGE_OPENSERVICE_FAILED);\r
return 3;\r
}\r
\r
GetModuleFileName(0, service->image, _countof(service->image));\r
\r
/* Create the service - settings will be changed in edit_service() */\r
- service->handle = CreateService(services, service->name, service->name, SC_MANAGER_ALL_ACCESS, SERVICE_WIN32_OWN_PROCESS, SERVICE_AUTO_START, SERVICE_ERROR_NORMAL, service->image, 0, 0, 0, 0, 0);\r
+ service->handle = CreateService(services, service->name, service->name, SERVICE_ALL_ACCESS, SERVICE_WIN32_OWN_PROCESS, SERVICE_AUTO_START, SERVICE_ERROR_NORMAL, service->image, 0, 0, 0, 0, 0);\r
if (! service->handle) {\r
- print_message(stderr, NSSM_MESSAGE_CREATESERVICE_FAILED);\r
+ print_message(stderr, NSSM_MESSAGE_CREATESERVICE_FAILED, error_string(GetLastError()));\r
CloseServiceHandle(services);\r
return 5;\r
}\r
int control_service(unsigned long control, int argc, TCHAR **argv) {\r
if (argc < 1) return usage(1);\r
TCHAR *service_name = argv[0];\r
+ TCHAR canonical_name[SERVICE_NAME_LENGTH];\r
\r
SC_HANDLE services = open_service_manager();\r
if (! services) {\r
return 2;\r
}\r
\r
- SC_HANDLE service_handle = OpenService(services, service_name, SC_MANAGER_ALL_ACCESS);\r
+ SC_HANDLE service_handle = open_service(services, service_name, canonical_name, _countof(canonical_name));\r
if (! service_handle) {\r
- print_message(stderr, NSSM_MESSAGE_OPENSERVICE_FAILED);\r
CloseServiceHandle(services);\r
return 3;\r
}\r
CloseHandle(service_handle);\r
CloseServiceHandle(services);\r
\r
+ if (error == ERROR_IO_PENDING) {\r
+ /*\r
+ Older versions of Windows return immediately with ERROR_IO_PENDING\r
+ indicate that the operation is still in progress. Newer versions\r
+ will return it if there really is a delay. As far as we're\r
+ concerned the operation is a success. We don't claim to offer a\r
+ fully-feature service control method; it's just a quick 'n' dirty\r
+ interface.\r
+\r
+ In the future we may identify and handle this situation properly.\r
+ */\r
+ ret = 1;\r
+ error = ERROR_SUCCESS;\r
+ }\r
+\r
if (ret) {\r
_tprintf(_T("%s: %s"), canonical_name, error_string(error));\r
return 0;\r
return 0;\r
}\r
else {\r
- _ftprintf(stderr, _T("%s: %s\n"), service_name, error_string(error));\r
+ _ftprintf(stderr, _T("%s: %s\n"), canonical_name, error_string(error));\r
return 1;\r
}\r
}\r
CloseHandle(service_handle);\r
CloseServiceHandle(services);\r
\r
+ if (error == ERROR_IO_PENDING) {\r
+ ret = 1;\r
+ error = ERROR_SUCCESS;\r
+ }\r
+\r
if (ret) {\r
_tprintf(_T("%s: %s"), canonical_name, error_string(error));\r
return 0;\r
}\r
\r
/* Try to open the service */\r
- service->handle = OpenService(services, service->name, SC_MANAGER_ALL_ACCESS);\r
+ service->handle = open_service(services, service->name, service->name, _countof(service->name));\r
if (! service->handle) {\r
- print_message(stderr, NSSM_MESSAGE_OPENSERVICE_FAILED);\r
CloseServiceHandle(services);\r
return 3;\r
}\r
\r
bool inherit_handles = false;\r
if (si.dwFlags & STARTF_USESTDHANDLES) inherit_handles = true;\r
- unsigned long flags = 0;\r
+ unsigned long flags = service->priority & priority_mask();\r
#ifdef UNICODE\r
flags |= CREATE_UNICODE_ENVIRONMENT;\r
#endif\r
git://git.iain.cx/iain / nssm.git / blobdiff