diff options
author | Steven Murdoch <Steven.Murdoch@cl.cam.ac.uk> | 2011-08-24 21:34:13 +0100 |
---|---|---|
committer | Steven Murdoch <Steven.Murdoch@cl.cam.ac.uk> | 2011-08-24 21:34:13 +0100 |
commit | 1da5081ae0cfaf52f11c0d93c42efa211ead35af (patch) | |
tree | f2626a4dc9837937fd380fdc72a9c916574f9a5d /src | |
parent | 50b48c3ea7b9601c1ab29f786bb0d88eb4149474 (diff) | |
download | tor-1da5081ae0cfaf52f11c0d93c42efa211ead35af.tar tor-1da5081ae0cfaf52f11c0d93c42efa211ead35af.tar.gz |
Appease "make check-spaces"
Diffstat (limited to 'src')
-rw-r--r-- | src/common/util.c | 83 | ||||
-rw-r--r-- | src/common/util.h | 3 | ||||
-rw-r--r-- | src/test/test_util.c | 9 |
3 files changed, 51 insertions, 44 deletions
diff --git a/src/common/util.c b/src/common/util.c index c18458355..d69d8f108 100644 --- a/src/common/util.c +++ b/src/common/util.c @@ -3063,16 +3063,16 @@ tor_spawn_background(const char *const filename, const char **argv) HANDLE stderr_pipe_write = NULL; STARTUPINFO siStartInfo; - BOOL retval = FALSE; - + BOOL retval = FALSE; + SECURITY_ATTRIBUTES saAttr; smartlist_t *argv_list; char *joined_argv; int i; - - saAttr.nLength = sizeof(SECURITY_ATTRIBUTES); - saAttr.bInheritHandle = TRUE; - saAttr.lpSecurityDescriptor = NULL; + + saAttr.nLength = sizeof(SECURITY_ATTRIBUTES); + saAttr.bInheritHandle = TRUE; + saAttr.lpSecurityDescriptor = NULL; /* Assume failure to start process */ memset(&process_handle, 0, sizeof(process_handle)); @@ -3087,8 +3087,8 @@ tor_spawn_background(const char *const filename, const char **argv) } if (!SetHandleInformation(stdout_pipe_read, HANDLE_FLAG_INHERIT, 0)) { log_warn(LD_GENERAL, - "Failed to configure pipe for stdout communication with child process: %s", - format_win32_error(GetLastError())); + "Failed to configure pipe for stdout communication with child " + "process: %s", format_win32_error(GetLastError())); return process_handle; } @@ -3101,14 +3101,15 @@ tor_spawn_background(const char *const filename, const char **argv) } if (!SetHandleInformation(stderr_pipe_read, HANDLE_FLAG_INHERIT, 0)) { log_warn(LD_GENERAL, - "Failed to configure pipe for stderr communication with child process: %s", - format_win32_error(GetLastError())); + "Failed to configure pipe for stderr communication with child " + "process: %s", format_win32_error(GetLastError())); return process_handle; } /* Create the child process */ - /* Windows expects argv to be a whitespace delimited string, so join argv up */ + /* Windows expects argv to be a whitespace delimited string, so join argv up + */ argv_list = smartlist_create(); for (i=0; argv[i] != NULL; i++) { smartlist_add(argv_list, (void *)argv[i]); @@ -3118,39 +3119,41 @@ tor_spawn_background(const char *const filename, const char **argv) ZeroMemory(&process_handle.pid, sizeof(PROCESS_INFORMATION)); ZeroMemory(&siStartInfo, sizeof(STARTUPINFO)); - siStartInfo.cb = sizeof(STARTUPINFO); + siStartInfo.cb = sizeof(STARTUPINFO); siStartInfo.hStdError = stderr_pipe_write; siStartInfo.hStdOutput = stdout_pipe_write; siStartInfo.hStdInput = NULL; siStartInfo.dwFlags |= STARTF_USESTDHANDLES; - + /* Create the child process */ retval = CreateProcess(filename, // module name - joined_argv, // command line - NULL, // process security attributes - NULL, // primary thread security attributes - TRUE, // handles are inherited - 0, // creation flags (TODO: set CREATE_NEW CONSOLE/PROCESS_GROUP to make GetExitCodeProcess() work?) - NULL, // use parent's environment - NULL, // use parent's current directory - &siStartInfo, // STARTUPINFO pointer + joined_argv, // command line + NULL, // process security attributes + NULL, // primary thread security attributes + TRUE, // handles are inherited + /*(TODO: set CREATE_NEW CONSOLE/PROCESS_GROUP to make GetExitCodeProcess() + * work?) */ + 0, // creation flags + NULL, // use parent's environment + NULL, // use parent's current directory + &siStartInfo, // STARTUPINFO pointer &process_handle.pid); // receives PROCESS_INFORMATION - tor_free(joined_argv); - + tor_free(joined_argv); + if (!retval) { log_warn(LD_GENERAL, "Failed to create child process %s: %s", filename?filename:argv[0], format_win32_error(GetLastError())); } else { - // TODO: Close hProcess and hThread in process_handle.pid? + /* TODO: Close hProcess and hThread in process_handle.pid? */ process_handle.stdout_pipe = stdout_pipe_read; process_handle.stderr_pipe = stderr_pipe_read; process_handle.status = 1; } - // TODO: Close pipes on exit + /* TODO: Close pipes on exit */ return process_handle; #else // MS_WINDOWS @@ -3353,7 +3356,7 @@ tor_get_exit_code(const process_handle_t process_handle, retval = WaitForSingleObject(process_handle.pid.hProcess, INFINITE); if (retval != WAIT_OBJECT_0) { log_warn(LD_GENERAL, "WaitForSingleObject() failed (%d): %s", - (int)retval, format_win32_error(GetLastError())); + (int)retval, format_win32_error(GetLastError())); return -1; } } else { @@ -3367,7 +3370,7 @@ tor_get_exit_code(const process_handle_t process_handle, return -1; } } - + if (exit_code != NULL) { success = GetExitCodeProcess(process_handle.pid.hProcess, (PDWORD)exit_code); @@ -3392,7 +3395,8 @@ tor_get_exit_code(const process_handle_t process_handle, } if (!WIFEXITED(stat_loc)) { - log_warn(LD_GENERAL, "Process %d did not exit normally", process_handle.pid); + log_warn(LD_GENERAL, "Process %d did not exit normally", + process_handle.pid); return -1; } @@ -3478,7 +3482,7 @@ tor_read_all_from_process_stdout(const process_handle_t process_handle, return read_all(process_handle.stdout_pipe, buf, count, 0); #endif } - + /* Read from stdout of a process until the process exits. */ ssize_t tor_read_all_from_process_stderr(const process_handle_t process_handle, @@ -3529,14 +3533,14 @@ log_from_handle(HANDLE *pipe, int severity) /* On Windows \r means end of line */ if ('\r' == buf[cur]) { buf[cur] = '\0'; - next = cur + 1; - /* If \n follows, remove it too */ + next = cur + 1; + /* If \n follows, remove it too */ if ((cur + 1) < pos && '\n' == buf[cur+1]) { - buf[cur + 1] = '\0'; + buf[cur + 1] = '\0'; next = cur + 2; - } - /* Line starts at start and ends with a null (was \r\n) */ - break; + } + /* Line starts at start and ends with a null (was \r\n) */ + break; } /* Line starts at start and ends at the end of a string but we already added a null in earlier */ @@ -3544,7 +3548,7 @@ log_from_handle(HANDLE *pipe, int severity) log_fn(severity, LD_GENERAL, "Port forwarding helper says: %s", buf+start); } return 0; -} +} #else /** Read from stream, and send lines to log at the specified log level. @@ -3630,7 +3634,8 @@ tor_check_port_forwarding(const char *filename, int dir_port, int or_port, { /* When fw-helper succeeds, how long do we wait until running it again */ #define TIME_TO_EXEC_FWHELPER_SUCCESS 300 -/* When fw-helper failed to start, how long do we wait until running it again */ +/* When fw-helper failed to start, how long do we wait until running it again + */ #define TIME_TO_EXEC_FWHELPER_FAIL 60 /* Static variables are initialized to zero, so child_handle.status=0 @@ -3702,9 +3707,9 @@ tor_check_port_forwarding(const char *filename, int dir_port, int or_port, retval = 0; #else stdout_status = log_from_pipe(child_handle.stdout_handle, - LOG_INFO, filename, &retval); + LOG_INFO, filename, &retval); stderr_status = log_from_pipe(child_handle.stderr_handle, - LOG_WARN, filename, &retval); + LOG_WARN, filename, &retval); #endif if (retval) { /* There was a problem in the child process */ diff --git a/src/common/util.h b/src/common/util.h index 2602628ab..442001f48 100644 --- a/src/common/util.h +++ b/src/common/util.h @@ -375,7 +375,8 @@ process_handle_t tor_spawn_background(const char *const filename, int tor_get_exit_code(const process_handle_t process_handle, int block, int *exit_code); #ifdef MS_WINDOWS -ssize_t tor_read_all_handle(HANDLE h, char *buf, size_t count, HANDLE hProcess); +ssize_t tor_read_all_handle(HANDLE h, char *buf, size_t count, + HANDLE hProcess); #endif ssize_t tor_read_all_from_process_stdout(const process_handle_t process_handle, char *buf, size_t count); diff --git a/src/test/test_util.c b/src/test/test_util.c index 5d3f95c8c..cb98030cc 100644 --- a/src/test/test_util.c +++ b/src/test/test_util.c @@ -1395,7 +1395,7 @@ run_util_spawn_background(const char *argv[], const char *expected_out, #endif tt_int_op(process_handle.status, ==, expected_status); - + /* If the process failed to start, don't bother continuing */ if (process_handle.status == -1) return; @@ -1405,7 +1405,7 @@ run_util_spawn_background(const char *argv[], const char *expected_out, /* Check stdout */ pos = tor_read_all_from_process_stdout(process_handle, stdout_buf, - sizeof(stdout_buf) - 1); + sizeof(stdout_buf) - 1); tt_assert(pos >= 0); stdout_buf[pos] = '\0'; tt_str_op(stdout_buf, ==, expected_out); @@ -1419,7 +1419,7 @@ run_util_spawn_background(const char *argv[], const char *expected_out, /* Check stderr */ pos = tor_read_all_from_process_stderr(process_handle, stderr_buf, - sizeof(stderr_buf) - 1); + sizeof(stderr_buf) - 1); tt_assert(pos >= 0); stderr_buf[pos] = '\0'; tt_str_op(stderr_buf, ==, expected_err); @@ -1469,7 +1469,8 @@ test_util_spawn_background_fail(void *ptr) (void)ptr; - run_util_spawn_background(argv, expected_out, expected_err, 255, expected_status); + run_util_spawn_background(argv, expected_out, expected_err, 255, + expected_status); } /** Helper function for testing tor_spawn_background */ |