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
|
#include "xorg/gtest/process.h"
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#include <algorithm>
#include <cerrno>
#include <csignal>
#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <stdexcept>
#include <vector>
struct xorg::testing::Process::Private {
pid_t pid;
};
xorg::testing::Process::Process() : d_(new Private) {
d_->pid = -1;
}
void xorg::testing::Process::Start(const std::string& program, va_list args) {
if (d_->pid != -1)
throw std::runtime_error("Attempting to start an already started process");
d_->pid = vfork();
if (d_->pid == -1) {
throw std::runtime_error("Failed to fork child process");
} else if (d_->pid == 0) { /* Child */
close(0);
close(1);
close(2);
std::vector<char*> argv;
char* arg;
do {
arg = va_arg(args, char*);
if (arg) {
arg = strdup(arg);
if (!arg) {
std::for_each(argv.begin(), argv.end(), free);
throw std::bad_alloc();
}
}
argv.push_back(arg);
} while (arg);
execvp(program.c_str(), &argv[0]);
std::for_each(argv.begin(), argv.end(), free);
throw std::runtime_error("Failed to start process");
}
}
void xorg::testing::Process::Start(const std::string& program, ...) {
va_list list;
va_start(list, program);
Start(program, list);
va_end(list); /* Shouldn't get here */
}
bool xorg::testing::Process::Terminate() {
if (d_->pid == -1) {
return false;
} else if (d_->pid == 0) {
/* Child */
throw std::runtime_error("Child process tried to terminate itself");
} else { /* Parent */
if (kill(d_->pid, SIGTERM) < 0) {
return false;
}
}
return true;
}
bool xorg::testing::Process::Kill() {
if (d_->pid == -1) {
return false;
} else if (d_->pid == 0) {
/* Child */
throw std::runtime_error("Child process tried to kill itself");
} else { /* Parent */
if (kill(d_->pid, SIGKILL) < 0) {
return false;
}
}
return true;
}
void xorg::testing::Process::SetEnv(const char* name, const char* value,
bool overwrite) {
if (setenv(name, value, overwrite) != 0)
throw std::runtime_error("Failed to set environment variable in process");
return;
}
const char* xorg::testing::Process::GetEnv(const char* name) {
return getenv(name);
}
pid_t xorg::testing::Process::Pid() const {
return d_->pid;
}
|
