| 255 | namespace internal { |
| 256 | |
| 257 | static void cleanup( |
| 258 | const Future<Option<int>>& result, |
| 259 | Promise<Option<int>>* promise, |
| 260 | const Subprocess& subprocess) |
| 261 | { |
| 262 | CHECK(!result.isPending()); |
| 263 | CHECK(!result.isDiscarded()); |
| 264 | |
| 265 | if (result.isFailed()) { |
| 266 | promise->fail(result.failure()); |
| 267 | } else { |
| 268 | promise->set(result.get()); |
| 269 | } |
| 270 | |
| 271 | delete promise; |
| 272 | } |
| 273 | |
| 274 | |
| 275 | static void close(std::initializer_list<int_fd> fds) |