io.cpp 8.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230
  1. #include "nssm.h"
  2. /* Get path, share mode, creation disposition and flags for a stream. */
  3. int get_createfile_parameters(HKEY key, TCHAR *prefix, TCHAR *path, unsigned long *sharing, unsigned long default_sharing, unsigned long *disposition, unsigned long default_disposition, unsigned long *flags, unsigned long default_flags) {
  4. TCHAR value[NSSM_STDIO_LENGTH];
  5. /* Path. */
  6. if (_sntprintf_s(value, _countof(value), _TRUNCATE, _T("%s"), prefix) < 0) {
  7. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, prefix, _T("get_createfile_parameters()"), 0);
  8. return 1;
  9. }
  10. switch (expand_parameter(key, value, path, MAX_PATH, true, false)) {
  11. case 0: if (! path[0]) return 0; break; /* OK. */
  12. default: return 2; /* Error. */
  13. }
  14. /* ShareMode. */
  15. if (_sntprintf_s(value, _countof(value), _TRUNCATE, _T("%s%s"), prefix, NSSM_REG_STDIO_SHARING) < 0) {
  16. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, NSSM_REG_STDIO_SHARING, _T("get_createfile_parameters()"), 0);
  17. return 3;
  18. }
  19. switch (get_number(key, value, sharing, false)) {
  20. case 0: *sharing = default_sharing; break; /* Missing. */
  21. case 1: break; /* Found. */
  22. case -2: return 4; break; /* Error. */
  23. }
  24. /* CreationDisposition. */
  25. if (_sntprintf_s(value, _countof(value), _TRUNCATE, _T("%s%s"), prefix, NSSM_REG_STDIO_DISPOSITION) < 0) {
  26. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, NSSM_REG_STDIO_DISPOSITION, _T("get_createfile_parameters()"), 0);
  27. return 5;
  28. }
  29. switch (get_number(key, value, disposition, false)) {
  30. case 0: *disposition = default_disposition; break; /* Missing. */
  31. case 1: break; /* Found. */
  32. case -2: return 6; break; /* Error. */
  33. }
  34. /* Flags. */
  35. if (_sntprintf_s(value, _countof(value), _TRUNCATE, _T("%s%s"), prefix, NSSM_REG_STDIO_FLAGS) < 0) {
  36. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, NSSM_REG_STDIO_FLAGS, _T("get_createfile_parameters()"), 0);
  37. return 7;
  38. }
  39. switch (get_number(key, value, flags, false)) {
  40. case 0: *flags = default_flags; break; /* Missing. */
  41. case 1: break; /* Found. */
  42. case -2: return 8; break; /* Error. */
  43. }
  44. return 0;
  45. }
  46. int set_createfile_parameter(HKEY key, TCHAR *prefix, TCHAR *suffix, unsigned long number) {
  47. TCHAR value[NSSM_STDIO_LENGTH];
  48. if (_sntprintf_s(value, _countof(value), _TRUNCATE, _T("%s%s"), prefix, suffix) < 0) {
  49. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, suffix, _T("set_createfile_parameter()"), 0);
  50. return 1;
  51. }
  52. return set_number(key, value, number);
  53. }
  54. HANDLE append_to_file(TCHAR *path, unsigned long sharing, SECURITY_ATTRIBUTES *attributes, unsigned long disposition, unsigned long flags) {
  55. HANDLE ret;
  56. /* Try to append to the file first. */
  57. ret = CreateFile(path, FILE_APPEND_DATA, sharing, attributes, disposition, flags, 0);
  58. if (ret) {
  59. SetEndOfFile(ret);
  60. return ret;
  61. }
  62. unsigned long error = GetLastError();
  63. if (error != ERROR_FILE_NOT_FOUND) {
  64. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_CREATEFILE_FAILED, path, error_string(error), 0);
  65. return (HANDLE) 0;
  66. }
  67. /* It didn't exist. Create it. */
  68. return CreateFile(path, FILE_WRITE_DATA, sharing, attributes, disposition, flags, 0);
  69. }
  70. void rotate_file(TCHAR *service_name, TCHAR *path, unsigned long seconds, unsigned long low, unsigned long high) {
  71. unsigned long error;
  72. /* Now. */
  73. SYSTEMTIME st;
  74. GetSystemTime(&st);
  75. BY_HANDLE_FILE_INFORMATION info;
  76. /* Try to open the file to check if it exists and to get attributes. */
  77. HANDLE file = CreateFile(path, 0, FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, 0);
  78. if (file) {
  79. /* Get file attributes. */
  80. if (! GetFileInformationByHandle(file, &info)) {
  81. /* Reuse current time for rotation timestamp. */
  82. seconds = low = high = 0;
  83. SystemTimeToFileTime(&st, &info.ftLastWriteTime);
  84. }
  85. CloseHandle(file);
  86. }
  87. else {
  88. error = GetLastError();
  89. if (error == ERROR_FILE_NOT_FOUND) return;
  90. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_ROTATE_FILE_FAILED, service_name, path, _T("CreateFile()"), path, error_string(error), 0);
  91. /* Reuse current time for rotation timestamp. */
  92. seconds = low = high = 0;
  93. SystemTimeToFileTime(&st, &info.ftLastWriteTime);
  94. }
  95. /* Check file age. */
  96. if (seconds) {
  97. FILETIME ft;
  98. SystemTimeToFileTime(&st, &ft);
  99. ULARGE_INTEGER s;
  100. s.LowPart = ft.dwLowDateTime;
  101. s.HighPart = ft.dwHighDateTime;
  102. s.QuadPart -= seconds * 10000000LL;
  103. ft.dwLowDateTime = s.LowPart;
  104. ft.dwHighDateTime = s.HighPart;
  105. if (CompareFileTime(&info.ftLastWriteTime, &ft) > 0) return;
  106. }
  107. /* Check file size. */
  108. if (low || high) {
  109. if (info.nFileSizeHigh < high) return;
  110. if (info.nFileSizeHigh == high && info.nFileSizeLow < low) return;
  111. }
  112. /* Get new filename. */
  113. FileTimeToSystemTime(&info.ftLastWriteTime, &st);
  114. TCHAR buffer[MAX_PATH];
  115. memmove(buffer, path, sizeof(buffer));
  116. TCHAR *ext = PathFindExtension(buffer);
  117. TCHAR extension[MAX_PATH];
  118. _sntprintf_s(extension, _countof(extension), _TRUNCATE, _T("-%04u%02u%02uT%02u%02u%02u.%03u%s"), st.wYear, st.wMonth, st.wDay, st.wHour, st.wMinute, st.wSecond, st.wMilliseconds, ext);
  119. *ext = _T('\0');
  120. TCHAR rotated[MAX_PATH];
  121. _sntprintf_s(rotated, _countof(rotated), _TRUNCATE, _T("%s%s"), buffer, extension);
  122. /* Rotate. */
  123. if (MoveFile(path, rotated)) return;
  124. error = GetLastError();
  125. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_ROTATE_FILE_FAILED, service_name, path, _T("MoveFile()"), rotated, error_string(error), 0);
  126. return;
  127. }
  128. int get_output_handles(nssm_service_t *service, HKEY key, STARTUPINFO *si) {
  129. TCHAR path[MAX_PATH];
  130. TCHAR stdout_path[MAX_PATH];
  131. unsigned long sharing, disposition, flags;
  132. bool set_flags = false;
  133. /* Standard security attributes allowing inheritance. */
  134. SECURITY_ATTRIBUTES attributes;
  135. ZeroMemory(&attributes, sizeof(attributes));
  136. attributes.bInheritHandle = true;
  137. /* stdin */
  138. if (get_createfile_parameters(key, NSSM_REG_STDIN, path, &sharing, NSSM_STDIN_SHARING, &disposition, NSSM_STDIN_DISPOSITION, &flags, NSSM_STDIN_FLAGS)) return 1;
  139. if (path[0]) {
  140. si->hStdInput = CreateFile(path, FILE_READ_DATA, sharing, &attributes, disposition, flags, 0);
  141. if (! si->hStdInput) {
  142. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_CREATEFILE_FAILED, path, error_string(GetLastError()));
  143. return 2;
  144. }
  145. set_flags = true;
  146. }
  147. /* stdout */
  148. if (get_createfile_parameters(key, NSSM_REG_STDOUT, path, &sharing, NSSM_STDOUT_SHARING, &disposition, NSSM_STDOUT_DISPOSITION, &flags, NSSM_STDOUT_FLAGS)) return 3;
  149. if (path[0]) {
  150. /* Remember path for comparison with stderr. */
  151. if (_sntprintf_s(stdout_path, _countof(stdout_path), _TRUNCATE, _T("%s"), path) < 0) {
  152. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, _T("stdout_path"), _T("get_output_handles"), 0);
  153. return 4;
  154. }
  155. if (service->rotate_files) rotate_file(service->name, path, service->rotate_seconds, service->rotate_bytes_low, service->rotate_bytes_high);
  156. si->hStdOutput = append_to_file(path, sharing, &attributes, disposition, flags);
  157. if (! si->hStdOutput) return 5;
  158. set_flags = true;
  159. }
  160. else ZeroMemory(stdout_path, sizeof(stdout_path));
  161. /* stderr */
  162. if (get_createfile_parameters(key, NSSM_REG_STDERR, path, &sharing, NSSM_STDERR_SHARING, &disposition, NSSM_STDERR_DISPOSITION, &flags, NSSM_STDERR_FLAGS)) return 6;
  163. if (path[0]) {
  164. /* Same as stdout? */
  165. if (str_equiv(path, stdout_path)) {
  166. /* Two handles to the same file will create a race. */
  167. if (! DuplicateHandle(GetCurrentProcess(), si->hStdOutput, GetCurrentProcess(), &si->hStdError, 0, true, DUPLICATE_SAME_ACCESS)) {
  168. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_DUPLICATEHANDLE_FAILED, NSSM_REG_STDOUT, error_string(GetLastError()), 0);
  169. return 7;
  170. }
  171. }
  172. else {
  173. if (service->rotate_files) rotate_file(service->name, path, service->rotate_seconds, service->rotate_bytes_low, service->rotate_bytes_high);
  174. si->hStdError = append_to_file(path, sharing, &attributes, disposition, flags);
  175. if (! si->hStdError) {
  176. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_CREATEFILE_FAILED, path, error_string(GetLastError()), 0);
  177. return 8;
  178. }
  179. SetEndOfFile(si->hStdError);
  180. }
  181. set_flags = true;
  182. }
  183. if (! set_flags) return 0;
  184. /*
  185. We need to set the startup_info flags to make the new handles
  186. inheritable by the new process.
  187. */
  188. si->dwFlags |= STARTF_USESTDHANDLES;
  189. return 0;
  190. }
  191. void close_output_handles(STARTUPINFO *si) {
  192. if (si->hStdInput) CloseHandle(si->hStdInput);
  193. if (si->hStdOutput) CloseHandle(si->hStdOutput);
  194. if (si->hStdError) CloseHandle(si->hStdError);
  195. }