1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
#include "process.h"
struct Process {
HANDLE pipe_read, pipe_write;
PROCESS_INFORMATION process_info;
char error[200];
};
static void get_last_error_str(char *out, size_t out_sz) {
size_t size = FormatMessageA(FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS,
NULL, GetLastError(), MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), out, (DWORD)out_sz - 1, NULL);
out[size] = 0;
char *cr = strchr(out, '\r');
if (cr) *cr = '\0'; // get rid of carriage return+newline at end of error
}
bool process_run(Process *process, char const *command) {
// thanks to https://stackoverflow.com/a/35658917
bool success = false;
memset(process, 0, sizeof *process);
char *command_line = str_dup(command);
if (!command_line) {
strbuf_printf(process->error, "Out of memory.");
return false;
}
HANDLE pipe_read, pipe_write;
SECURITY_ATTRIBUTES security_attrs = {sizeof(SECURITY_ATTRIBUTES)};
security_attrs.bInheritHandle = TRUE;
if (CreatePipe(&pipe_read, &pipe_write, &security_attrs, 0)) {
STARTUPINFOA startup = {sizeof(STARTUPINFOA)};
startup.dwFlags = STARTF_USESHOWWINDOW | STARTF_USESTDHANDLES;
startup.hStdOutput = pipe_write;
startup.hStdError = pipe_write;
startup.wShowWindow = SW_HIDE;
if (CreateProcessA(NULL, command_line, NULL, NULL, TRUE, CREATE_NEW_CONSOLE,
NULL, NULL, &startup, &process->process_info)) {
process->pipe_read = pipe_read;
process->pipe_write = pipe_write;
success = true;
} else {
char buf[150];
get_last_error_str(buf, sizeof buf);
strbuf_printf(process->error, "Couldn't run `%s`: %s", command, buf);
}
free(command_line);
if (!success) {
CloseHandle(pipe_read);
CloseHandle(pipe_write);
}
} else {
char buf[150];
get_last_error_str(buf, sizeof buf);
strbuf_printf(process->error, "Couldn't create pipe: %s", buf);
}
return success;
}
char const *process_geterr(Process *p) {
return *p->error ? p->error : NULL;
}
long long process_read(Process *process, char *data, size_t size) {
DWORD bytes_read = 0, bytes_avail = 0, bytes_left = 0;
if (PeekNamedPipe(process->pipe_read, data, (DWORD)size, &bytes_read, &bytes_avail, &bytes_left)) {
if (bytes_read == 0) {
return -1;
} else {
ReadFile(process->pipe_read, data, (DWORD)size, &bytes_read, NULL); // make sure data is removed from pipe
return bytes_read;
}
} else {
char buf[150];
get_last_error_str(buf, sizeof buf);
strbuf_printf(process->error, "Couldn't read from pipe: %s", buf);
return -2;
}
}
void process_kill(Process *process) {
TerminateProcess(process->process_info.hProcess, 1);
TerminateThread(process->process_info.hThread, 1);
CloseHandle(process->pipe_read);
CloseHandle(process->pipe_write);
CloseHandle(process->process_info.hProcess);
CloseHandle(process->process_info.hThread);
}
int process_check_status(Process *process, char *message, size_t message_size) {
HANDLE hProcess = process->process_info.hProcess;
DWORD exit_code = 1;
if (GetExitCodeProcess(hProcess, &exit_code)) {
if (exit_code == STILL_ACTIVE) {
return 0;
} else {
process_kill(process);
if (exit_code == 0) {
str_printf(message, message_size, "exited successfully");
return +1;
} else {
str_printf(message, message_size, "exited with code %d", (int)exit_code);
return -1;
}
}
} else {
// something has gone wrong.
str_printf(message, message_size, "couldn't get process exit status");
process_kill(process);
return -1;
}
}
|
