X-Git-Url: http://git.iain.cx/?a=blobdiff_plain;f=service.cpp;h=b8b99921a7fafd5f3e16d609e7ede562c02f1a6d;hb=4440946eccf1cb14e16f8d29c54fb4acecbd44ff;hp=9dbb310523b450c956b72c526a1d689ee50b76c2;hpb=d007ff22cecf2ce85cc68a1de81a010d4a65badc;p=nssm.git diff --git a/service.cpp b/service.cpp index 9dbb310..b8b9992 100644 --- a/service.cpp +++ b/service.cpp @@ -4,44 +4,145 @@ SERVICE_STATUS service_status; SERVICE_STATUS_HANDLE service_handle; HANDLE wait_handle; HANDLE pid; +static char service_name[MAX_PATH]; char exe[MAX_PATH]; char flags[MAX_PATH]; char dir[MAX_PATH]; +static enum { NSSM_EXIT_RESTART, NSSM_EXIT_IGNORE, NSSM_EXIT_REALLY } exit_actions; +static const char *exit_action_strings[] = { "Restart", "Ignore", "Exit", 0 }; + /* Connect to the service manager */ SC_HANDLE open_service_manager() { SC_HANDLE ret = OpenSCManager(0, SERVICES_ACTIVE_DATABASE, SC_MANAGER_ALL_ACCESS); if (! ret) { - eventprintf(EVENTLOG_ERROR_TYPE, "Unable to connect to service manager!\nPerhaps you need to be an administrator..."); + log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OPENSCMANAGER_FAILED, 0); return 0; } return ret; } +/* About to install the service */ +int pre_install_service(int argc, char **argv) { + /* Show the dialogue box if we didn't give the */ + if (argc < 2) return nssm_gui(IDD_INSTALL, argv[0]); + + /* Arguments are optional */ + char *flags; + if (argc == 2) flags = ""; + else flags = argv[2]; + + return install_service(argv[0], argv[1], flags); +} + +/* About to remove the service */ +int pre_remove_service(int argc, char **argv) { + /* Show dialogue box if we didn't pass service name and "confirm" */ + if (argc < 2) return nssm_gui(IDD_REMOVE, argv[0]); + if (str_equiv(argv[1], "confirm")) return remove_service(argv[0]); + fprintf(stderr, "To remove a service without confirmation: nssm remove confirm\n"); + return 100; +} + /* Install the service */ -int install_service(char *name) { -#ifdef GUI - /* Show the dialogue box */ - return nssm_gui(IDD_INSTALL, name); -#else - fprintf(stderr, "Unimplemented\n"); - return 1; -#endif +int install_service(char *name, char *exe, char *flags) { + /* Open service manager */ + SC_HANDLE services = open_service_manager(); + if (! services) { + fprintf(stderr, "Error opening service manager!\n"); + return 2; + } + + /* Get path of this program */ + char path[MAX_PATH]; + GetModuleFileName(0, path, MAX_PATH); + + /* Construct command */ + char command[MAX_PATH]; + size_t runlen = strlen(NSSM_RUN); + size_t pathlen = strlen(path); + if (pathlen + runlen + 2 >= MAX_PATH) { + fprintf(stderr, "The full path to " NSSM " is too long!\n"); + return 3; + } + if (snprintf(command, sizeof(command), "\"%s\" %s", path, NSSM_RUN) < 0) { + fprintf(stderr, "Out of memory for ImagePath!\n"); + return 4; + } + + /* Work out directory name */ + size_t len = strlen(exe); + size_t i; + for (i = len; i && exe[i] != '\\' && exe[i] != '/'; i--); + char dir[MAX_PATH]; + memmove(dir, exe, i); + dir[i] = '\0'; + + /* Create the service */ + SC_HANDLE service = CreateService(services, name, name, SC_MANAGER_ALL_ACCESS, SERVICE_WIN32_OWN_PROCESS, SERVICE_AUTO_START, SERVICE_ERROR_NORMAL, command, 0, 0, 0, 0, 0); + if (! service) { + fprintf(stderr, "Error creating service!\n"); + CloseServiceHandle(services); + return 5; + } + + /* Now we need to put the parameters into the registry */ + if (create_parameters(name, exe, flags, dir)) { + fprintf(stderr, "Error setting startup parameters for the service!\n"); + DeleteService(service); + CloseServiceHandle(services); + return 6; + } + + /* Cleanup */ + CloseServiceHandle(service); + CloseServiceHandle(services); + + printf("Service \"%s\" installed successfully!\n", name); + return 0; } /* Remove the service */ int remove_service(char *name) { -#ifdef GUI - return nssm_gui(IDD_REMOVE, name); -#else - fprintf(stderr, "Unimplemented\n"); - return 1; -#endif + /* Open service manager */ + SC_HANDLE services = open_service_manager(); + if (! services) { + fprintf(stderr, "Error opening service manager!\n"); + return 2; + } + + /* Try to open the service */ + SC_HANDLE service = OpenService(services, name, SC_MANAGER_ALL_ACCESS); + if (! service) { + fprintf(stderr, "Can't open service!"); + CloseServiceHandle(services); + return 3; + } + + /* Try to delete the service */ + if (! DeleteService(service)) { + fprintf(stderr, "Error deleting service!\n"); + CloseServiceHandle(service); + CloseServiceHandle(services); + return 4; + } + + /* Cleanup */ + CloseServiceHandle(service); + CloseServiceHandle(services); + + printf("Service \"%s\" removed successfully!\n", name); + return 0; } /* Service initialisation */ void WINAPI service_main(unsigned long argc, char **argv) { + if (_snprintf(service_name, sizeof(service_name), "%s", argv[0]) < 0) { + log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, "service_name", "service_main()", 0); + return; + } + /* Initialise status */ ZeroMemory(&service_status, sizeof(service_status)); service_status.dwServiceType = SERVICE_WIN32_OWN_PROCESS | SERVICE_INTERACTIVE_PROCESS; @@ -58,17 +159,20 @@ void WINAPI service_main(unsigned long argc, char **argv) { /* Get startup parameters */ int ret = get_parameters(argv[0], exe, sizeof(exe), flags, sizeof(flags), dir, sizeof(dir)); if (ret) { - eventprintf(EVENTLOG_ERROR_TYPE, "service_main(): Can't get startup parameters: error %d", ret); + log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_GET_PARAMETERS_FAILED, argv[0], 0); return; } /* Register control handler */ service_handle = RegisterServiceCtrlHandlerEx(NSSM, service_control_handler, 0); if (! service_handle) { - eventprintf(EVENTLOG_ERROR_TYPE, "service_main(): RegisterServiceCtrlHandlerEx() failed: %s", error_string(GetLastError())); + log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_REGISTERSERVICECTRLHANDER_FAILED, GetLastError(), 0); return; } + /* Try to create the exit action parameters; we don't care if it fails */ + create_exit_action(argv[0], exit_action_strings[0]); + monitor_service(); } @@ -76,14 +180,16 @@ int monitor_service() { /* Set service status to started */ int ret = start_service(); if (ret) { - eventprintf(EVENTLOG_ERROR_TYPE, "Can't start service: error code %d", ret); + char code[16]; + snprintf(code, sizeof(code), "%d", ret); + log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_START_SERVICE_FAILED, exe, service_name, ret, 0); return ret; } - eventprintf(EVENTLOG_INFORMATION_TYPE, "Started process %s %s in %s", exe, flags, dir); + log_event(EVENTLOG_INFORMATION_TYPE, NSSM_EVENT_STARTED_SERVICE, exe, flags, service_name, dir, 0); /* Monitor service service */ if (! RegisterWaitForSingleObject(&wait_handle, pid, end_service, 0, INFINITE, WT_EXECUTEONLYONCE | WT_EXECUTELONGFUNCTION)) { - eventprintf(EVENTLOG_WARNING_TYPE, "RegisterWaitForSingleObject() returned %s - service may claim to be still running when %s exits ", error_string(GetLastError()), exe); + log_event(EVENTLOG_WARNING_TYPE, NSSM_EVENT_REGISTERWAITFORSINGLEOBJECT_FAILED, service_name, exe, GetLastError(), 0); } return 0; @@ -118,11 +224,11 @@ int start_service() { /* Launch executable with arguments */ char cmd[MAX_PATH]; if (_snprintf(cmd, sizeof(cmd), "%s %s", exe, flags) < 0) { - eventprintf(EVENTLOG_ERROR_TYPE, "Error constructing command line"); + log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, "command line", "start_service", 0); return stop_service(2); } if (! CreateProcess(0, cmd, 0, 0, 0, 0, 0, dir, &si, &pi)) { - eventprintf(EVENTLOG_ERROR_TYPE, "Can't launch %s. CreateProcess() returned %s", exe, error_string(GetLastError())); + log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_CREATEPROCESS_FAILED, service_name, exe, GetLastError(), 0); return stop_service(3); } pid = pi.hProcess; @@ -143,9 +249,11 @@ int stop_service(unsigned long exitcode) { /* Nothing to do if server isn't running */ if (pid) { /* Shut down server */ + log_event(EVENTLOG_INFORMATION_TYPE, NSSM_EVENT_TERMINATEPROCESS, service_name, exe, 0); TerminateProcess(pid, 0); pid = 0; } + else log_event(EVENTLOG_INFORMATION_TYPE, NSSM_EVENT_PROCESS_ALREADY_STOPPED, service_name, exe, 0); /* Signal we stopped */ service_status.dwCurrentState = SERVICE_STOPPED; @@ -168,17 +276,43 @@ void CALLBACK end_service(void *arg, unsigned char why) { unsigned long ret = 0; GetExitCodeProcess(pid, &ret); - /* Force an error code if none given, so system can restart this service */ - /*if (! ret) { - eventprintf(EVENTLOG_INFORMATION_TYPE, "Process exited with return code 0 - overriding with return code 111 so the service manager will notice the failure"); - ret = 111; + char code[16]; + _snprintf(code, sizeof(code), "%d", ret); + log_event(EVENTLOG_INFORMATION_TYPE, NSSM_EVENT_ENDED_SERVICE, exe, service_name, code, 0); + + /* What action should we take? */ + int action = NSSM_EXIT_RESTART; + unsigned char action_string[ACTION_LEN]; + if (! get_exit_action(service_name, &ret, action_string)) { + for (int i = 0; exit_action_strings[i]; i++) { + if (! _strnicmp((const char *) action_string, exit_action_strings[i], ACTION_LEN)) { + action = i; + break; + } + } } - else */eventprintf(EVENTLOG_INFORMATION_TYPE, "Process %s exited with return code %u", exe, ret); - /* Try to restart the service or return failure code to service manager */ pid = 0; - while (monitor_service()) { - eventprintf(EVENTLOG_INFORMATION_TYPE, "Failed to restart %s - sleeping ", exe, ret); - Sleep(30000); + switch (action) { + /* Try to restart the service or return failure code to service manager */ + case NSSM_EXIT_RESTART: + log_event(EVENTLOG_INFORMATION_TYPE, NSSM_EVENT_EXIT_RESTART, service_name, code, exit_action_strings[action], exe, 0); + while (monitor_service()) { + log_event(EVENTLOG_WARNING_TYPE, NSSM_EVENT_RESTART_SERVICE_FAILED, exe, service_name, 0); + Sleep(30000); + } + break; + + /* Do nothing, just like srvany would */ + case NSSM_EXIT_IGNORE: + log_event(EVENTLOG_INFORMATION_TYPE, NSSM_EVENT_EXIT_IGNORE, service_name, code, exit_action_strings[action], exe, 0); + Sleep(INFINITE); + break; + + /* Tell the service manager we are finished */ + case NSSM_EXIT_REALLY: + log_event(EVENTLOG_INFORMATION_TYPE, NSSM_EVENT_EXIT_REALLY, service_name, code, exit_action_strings[action], 0); + stop_service(ret); + break; } }