io.cpp 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158
  1. #include "nssm.h"
  2. /* Get path, share mode, creation disposition and flags for a stream. */
  3. int get_createfile_parameters(HKEY key, char *prefix, char *path, unsigned long *sharing, unsigned long default_sharing, unsigned long *disposition, unsigned long default_disposition, unsigned long *flags, unsigned long default_flags) {
  4. char value[NSSM_STDIO_LENGTH];
  5. /* Path. */
  6. if (_snprintf_s(value, sizeof(value), _TRUNCATE, "%s", prefix) < 0) {
  7. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, prefix, "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 (_snprintf_s(value, sizeof(value), _TRUNCATE, "%s%s", prefix, NSSM_REG_STDIO_SHARING) < 0) {
  16. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, NSSM_REG_STDIO_SHARING, "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 (_snprintf_s(value, sizeof(value), _TRUNCATE, "%s%s", prefix, NSSM_REG_STDIO_DISPOSITION) < 0) {
  26. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, NSSM_REG_STDIO_DISPOSITION, "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 (_snprintf_s(value, sizeof(value), _TRUNCATE, "%s%s", prefix, NSSM_REG_STDIO_FLAGS) < 0) {
  36. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, NSSM_REG_STDIO_FLAGS, "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, char *prefix, char *suffix, unsigned long number) {
  47. char value[NSSM_STDIO_LENGTH];
  48. if (_snprintf_s(value, sizeof(value), _TRUNCATE, "%s%s", prefix, suffix) < 0) {
  49. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, suffix, "set_createfile_parameter()", 0);
  50. return 1;
  51. }
  52. return set_number(key, value, number);
  53. }
  54. HANDLE append_to_file(char *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));
  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. int get_output_handles(HKEY key, STARTUPINFO *si) {
  71. char path[MAX_PATH];
  72. char stdout_path[MAX_PATH];
  73. unsigned long sharing, disposition, flags;
  74. bool set_flags = false;
  75. /* Standard security attributes allowing inheritance. */
  76. SECURITY_ATTRIBUTES attributes;
  77. ZeroMemory(&attributes, sizeof(attributes));
  78. attributes.bInheritHandle = true;
  79. /* stdin */
  80. if (get_createfile_parameters(key, NSSM_REG_STDIN, path, &sharing, NSSM_STDIN_SHARING, &disposition, NSSM_STDIN_DISPOSITION, &flags, NSSM_STDIN_FLAGS)) return 1;
  81. if (path[0]) {
  82. si->hStdInput = CreateFile(path, FILE_READ_DATA, sharing, &attributes, disposition, flags, 0);
  83. if (! si->hStdInput) {
  84. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_CREATEFILE_FAILED, path, error_string(GetLastError()));
  85. return 2;
  86. }
  87. set_flags = true;
  88. }
  89. /* stdout */
  90. if (get_createfile_parameters(key, NSSM_REG_STDOUT, path, &sharing, NSSM_STDOUT_SHARING, &disposition, NSSM_STDOUT_DISPOSITION, &flags, NSSM_STDOUT_FLAGS)) return 3;
  91. if (path[0]) {
  92. /* Remember path for comparison with stderr. */
  93. if (_snprintf_s(stdout_path, sizeof(stdout_path), _TRUNCATE, "%s", path) < 0) {
  94. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_OUT_OF_MEMORY, "stdout_path", "get_output_handles", 0);
  95. return 4;
  96. }
  97. si->hStdOutput = append_to_file(path, sharing, &attributes, disposition, flags);
  98. if (! si->hStdOutput) return 5;
  99. set_flags = true;
  100. }
  101. else ZeroMemory(stdout_path, sizeof(stdout_path));
  102. /* stderr */
  103. if (get_createfile_parameters(key, NSSM_REG_STDERR, path, &sharing, NSSM_STDERR_SHARING, &disposition, NSSM_STDERR_DISPOSITION, &flags, NSSM_STDERR_FLAGS)) return 6;
  104. if (path[0]) {
  105. /* Same as stdin? */
  106. if (str_equiv(path, stdout_path)) {
  107. /* Two handles to the same file will create a race. */
  108. if (! DuplicateHandle(GetCurrentProcess(), si->hStdOutput, GetCurrentProcess(), &si->hStdError, 0, true, DUPLICATE_SAME_ACCESS)) {
  109. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_DUPLICATEHANDLE_FAILED, NSSM_REG_STDOUT, error_string(GetLastError()));
  110. return 7;
  111. }
  112. }
  113. else {
  114. si->hStdError = append_to_file(path, sharing, &attributes, disposition, flags);
  115. if (! si->hStdError) {
  116. log_event(EVENTLOG_ERROR_TYPE, NSSM_EVENT_CREATEFILE_FAILED, path, error_string(GetLastError()));
  117. return 8;
  118. }
  119. SetEndOfFile(si->hStdError);
  120. }
  121. set_flags = true;
  122. }
  123. if (! set_flags) return 0;
  124. /*
  125. We need to set the startup_info flags to make the new handles
  126. inheritable by the new process.
  127. */
  128. si->dwFlags |= STARTF_USESTDHANDLES;
  129. return 0;
  130. }
  131. void close_output_handles(STARTUPINFO *si) {
  132. if (si->hStdInput) CloseHandle(si->hStdInput);
  133. if (si->hStdOutput) CloseHandle(si->hStdOutput);
  134. if (si->hStdError) CloseHandle(si->hStdError);
  135. }