| ... | @@ -24,10 +24,6 @@ | ... | @@ -24,10 +24,6 @@ |
| 24 | #define WIN32_LEAN_AND_MEAN | 24 | #define WIN32_LEAN_AND_MEAN |
| 25 | #endif | 25 | #endif |
| 26 | | 26 | |
| 27 | #if !defined(UNICODE) | | |
| 28 | #define UNICODE | | |
| 29 | #endif | | |
| 30 | | | |
| 31 | #include <windows.h> | 27 | #include <windows.h> |
| 32 | #include <io.h> | 28 | #include <io.h> |
| 33 | #else | 29 | #else |
| ... | @@ -44,6 +40,11 @@ | ... | @@ -44,6 +40,11 @@ |
| 44 | | 40 | |
| 45 | #include <stdlib.h> | 41 | #include <stdlib.h> |
| 46 | #include <errno.h> | 42 | #include <errno.h> |
| | 43 | #include <time.h> |
| | 44 | |
| | 45 | // these implementations are lazy. But who cares, we'll make a robust |
| | 46 | // implementation in the zig standard library and then this code all gets |
| | 47 | // deleted when we self-host. it works for now. |
| 47 | | 48 | |
| 48 | | 49 | |
| 49 | #if defined(ZIG_OS_POSIX) | 50 | #if defined(ZIG_OS_POSIX) |
| ... | @@ -70,7 +71,13 @@ static void os_spawn_process_posix(const char *exe, ZigList<const char *> &args, | ... | @@ -70,7 +71,13 @@ static void os_spawn_process_posix(const char *exe, ZigList<const char *> &args, |
| 70 | | 71 | |
| 71 | #if defined(ZIG_OS_WINDOWS) | 72 | #if defined(ZIG_OS_WINDOWS) |
| 72 | static void os_spawn_process_windows(const char *exe, ZigList<const char *> &args, int *return_code) { | 73 | static void os_spawn_process_windows(const char *exe, ZigList<const char *> &args, int *return_code) { |
| 73 | zig_panic("TODO os_spawn_process_windows"); | 74 | Buf stderr_buf = BUF_INIT; |
| | 75 | Buf stdout_buf = BUF_INIT; |
| | 76 | |
| | 77 | // TODO this is supposed to inherit stdout/stderr instead of capturing it |
| | 78 | os_exec_process(exe, args, return_code, &stderr_buf, &stdout_buf); |
| | 79 | fwrite(buf_ptr(&stderr_buf), 1, buf_len(&stderr_buf), stderr); |
| | 80 | fwrite(buf_ptr(&stdout_buf), 1, buf_len(&stdout_buf), stdout); |
| 74 | } | 81 | } |
| 75 | #endif | 82 | #endif |
| 76 | | 83 | |
| ... | @@ -111,7 +118,12 @@ void os_path_join(Buf *dirname, Buf *basename, Buf *out_full_path) { | ... | @@ -111,7 +118,12 @@ void os_path_join(Buf *dirname, Buf *basename, Buf *out_full_path) { |
| 111 | | 118 | |
| 112 | int os_path_real(Buf *rel_path, Buf *out_abs_path) { | 119 | int os_path_real(Buf *rel_path, Buf *out_abs_path) { |
| 113 | #if defined(ZIG_OS_WINDOWS) | 120 | #if defined(ZIG_OS_WINDOWS) |
| 114 | zig_panic("TODO os_path_real for windows"); | 121 | buf_resize(out_abs_path, 4096); |
| | 122 | if (_fullpath(buf_ptr(out_abs_path), buf_ptr(rel_path), buf_len(out_abs_path)) == nullptr) { |
| | 123 | zig_panic("_fullpath failed"); |
| | 124 | } |
| | 125 | buf_resize(out_abs_path, strlen(buf_ptr(out_abs_path))); |
| | 126 | return ErrorNone; |
| 115 | #elif defined(ZIG_OS_POSIX) | 127 | #elif defined(ZIG_OS_POSIX) |
| 116 | buf_resize(out_abs_path, PATH_MAX + 1); | 128 | buf_resize(out_abs_path, PATH_MAX + 1); |
| 117 | char *result = realpath(buf_ptr(rel_path), buf_ptr(out_abs_path)); | 129 | char *result = realpath(buf_ptr(rel_path), buf_ptr(out_abs_path)); |
| ... | @@ -157,7 +169,7 @@ int os_fetch_file(FILE *f, Buf *out_buf) { | ... | @@ -157,7 +169,7 @@ int os_fetch_file(FILE *f, Buf *out_buf) { |
| 157 | | 169 | |
| 158 | | 170 | |
| 159 | #if defined(ZIG_OS_POSIX) | 171 | #if defined(ZIG_OS_POSIX) |
| 160 | static void os_exec_process_posix(const char *exe, ZigList<const char *> &args, | 172 | static int os_exec_process_posix(const char *exe, ZigList<const char *> &args, |
| 161 | int *return_code, Buf *out_stderr, Buf *out_stdout) | 173 | int *return_code, Buf *out_stderr, Buf *out_stdout) |
| 162 | { | 174 | { |
| 163 | int stdin_pipe[2]; | 175 | int stdin_pipe[2]; |
| ... | @@ -193,7 +205,11 @@ static void os_exec_process_posix(const char *exe, ZigList<const char *> &args, | ... | @@ -193,7 +205,11 @@ static void os_exec_process_posix(const char *exe, ZigList<const char *> &args, |
| 193 | argv[i + 1] = args.at(i); | 205 | argv[i + 1] = args.at(i); |
| 194 | } | 206 | } |
| 195 | execvp(exe, const_cast<char * const *>(argv)); | 207 | execvp(exe, const_cast<char * const *>(argv)); |
| 196 | zig_panic("execvp failed: %s", strerror(errno)); | 208 | if (errno == ENOENT) { |
| | 209 | return ErrorFileNotFound; |
| | 210 | } else { |
| | 211 | zig_panic("execvp failed: %s", strerror(errno)); |
| | 212 | } |
| 197 | } else { | 213 | } else { |
| 198 | // parent | 214 | // parent |
| 199 | close(stdin_pipe[0]); | 215 | close(stdin_pipe[0]); |
| ... | @@ -205,19 +221,158 @@ static void os_exec_process_posix(const char *exe, ZigList<const char *> &args, | ... | @@ -205,19 +221,158 @@ static void os_exec_process_posix(const char *exe, ZigList<const char *> &args, |
| 205 | os_fetch_file(fdopen(stdout_pipe[0], "rb"), out_stdout); | 221 | os_fetch_file(fdopen(stdout_pipe[0], "rb"), out_stdout); |
| 206 | os_fetch_file(fdopen(stderr_pipe[0], "rb"), out_stderr); | 222 | os_fetch_file(fdopen(stderr_pipe[0], "rb"), out_stderr); |
| 207 | | 223 | |
| | 224 | return 0; |
| 208 | } | 225 | } |
| 209 | } | 226 | } |
| 210 | #endif | 227 | #endif |
| 211 | | 228 | |
| 212 | #if defined(ZIG_OS_WINDOWS) | 229 | #if defined(ZIG_OS_WINDOWS) |
| 213 | static void os_exec_process_windows(const char *exe, ZigList<const char *> &args, | 230 | |
| | 231 | /* |
| | 232 | static void win32_panic(const char *str) { |
| | 233 | DWORD err = GetLastError(); |
| | 234 | LPSTR messageBuffer = nullptr; |
| | 235 | FormatMessageA( |
| | 236 | FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS, |
| | 237 | NULL, err, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), (LPSTR)&messageBuffer, 0, NULL); |
| | 238 | zig_panic(str, messageBuffer); |
| | 239 | LocalFree(messageBuffer); |
| | 240 | } |
| | 241 | */ |
| | 242 | |
| | 243 | static int os_exec_process_windows(const char *exe, ZigList<const char *> &args, |
| 214 | int *return_code, Buf *out_stderr, Buf *out_stdout) | 244 | int *return_code, Buf *out_stderr, Buf *out_stdout) |
| 215 | { | 245 | { |
| 216 | zig_panic("TODO implement os_exec_process_windows"); | 246 | Buf command_line = BUF_INIT; |
| | 247 | buf_resize(&command_line, 0); |
| | 248 | |
| | 249 | buf_append_char(&command_line, '\"'); |
| | 250 | buf_append_str(&command_line, exe); |
| | 251 | buf_append_char(&command_line, '\"'); |
| | 252 | |
| | 253 | for (int arg_i = 0; arg_i < args.length; arg_i += 1) { |
| | 254 | buf_append_str(&command_line, " \""); |
| | 255 | const char *arg = args.at(arg_i); |
| | 256 | int arg_len = strlen(arg); |
| | 257 | for (int c_i = 0; c_i < arg_len; c_i += 1) { |
| | 258 | if (arg[c_i] == '\"') { |
| | 259 | zig_panic("TODO"); |
| | 260 | } |
| | 261 | buf_append_char(&command_line, arg[c_i]); |
| | 262 | } |
| | 263 | buf_append_char(&command_line, '\"'); |
| | 264 | } |
| | 265 | |
| | 266 | |
| | 267 | HANDLE g_hChildStd_IN_Rd = NULL; |
| | 268 | HANDLE g_hChildStd_IN_Wr = NULL; |
| | 269 | HANDLE g_hChildStd_OUT_Rd = NULL; |
| | 270 | HANDLE g_hChildStd_OUT_Wr = NULL; |
| | 271 | HANDLE g_hChildStd_ERR_Rd = NULL; |
| | 272 | HANDLE g_hChildStd_ERR_Wr = NULL; |
| | 273 | |
| | 274 | SECURITY_ATTRIBUTES saAttr; |
| | 275 | saAttr.nLength = sizeof(SECURITY_ATTRIBUTES); |
| | 276 | saAttr.bInheritHandle = TRUE; |
| | 277 | saAttr.lpSecurityDescriptor = NULL; |
| | 278 | |
| | 279 | if (!CreatePipe(&g_hChildStd_OUT_Rd, &g_hChildStd_OUT_Wr, &saAttr, 0)) { |
| | 280 | zig_panic("StdoutRd CreatePipe"); |
| | 281 | } |
| | 282 | |
| | 283 | if (!SetHandleInformation(g_hChildStd_OUT_Rd, HANDLE_FLAG_INHERIT, 0)) { |
| | 284 | zig_panic("Stdout SetHandleInformation"); |
| | 285 | } |
| | 286 | |
| | 287 | if (!CreatePipe(&g_hChildStd_ERR_Rd, &g_hChildStd_ERR_Wr, &saAttr, 0)) { |
| | 288 | zig_panic("stderr CreatePipe"); |
| | 289 | } |
| | 290 | |
| | 291 | if (!SetHandleInformation(g_hChildStd_ERR_Rd, HANDLE_FLAG_INHERIT, 0)) { |
| | 292 | zig_panic("stderr SetHandleInformation"); |
| | 293 | } |
| | 294 | |
| | 295 | if (!CreatePipe(&g_hChildStd_IN_Rd, &g_hChildStd_IN_Wr, &saAttr, 0)) { |
| | 296 | zig_panic("Stdin CreatePipe"); |
| | 297 | } |
| | 298 | |
| | 299 | if (!SetHandleInformation(g_hChildStd_IN_Wr, HANDLE_FLAG_INHERIT, 0)) { |
| | 300 | zig_panic("Stdin SetHandleInformation"); |
| | 301 | } |
| | 302 | |
| | 303 | |
| | 304 | PROCESS_INFORMATION piProcInfo = {0}; |
| | 305 | STARTUPINFO siStartInfo = {0}; |
| | 306 | siStartInfo.cb = sizeof(STARTUPINFO); |
| | 307 | siStartInfo.hStdError = g_hChildStd_ERR_Wr; |
| | 308 | siStartInfo.hStdOutput = g_hChildStd_OUT_Wr; |
| | 309 | siStartInfo.hStdInput = g_hChildStd_IN_Rd; |
| | 310 | siStartInfo.dwFlags |= STARTF_USESTDHANDLES; |
| | 311 | |
| | 312 | BOOL success = CreateProcess(exe, buf_ptr(&command_line), nullptr, nullptr, TRUE, 0, nullptr, nullptr, |
| | 313 | &siStartInfo, &piProcInfo); |
| | 314 | |
| | 315 | if (!success) { |
| | 316 | if (GetLastError() == ERROR_FILE_NOT_FOUND) { |
| | 317 | CloseHandle(piProcInfo.hProcess); |
| | 318 | CloseHandle(piProcInfo.hThread); |
| | 319 | return ErrorFileNotFound; |
| | 320 | } |
| | 321 | zig_panic("CreateProcess failed. exe: %s command_line: %s", exe, buf_ptr(&command_line)); |
| | 322 | } |
| | 323 | |
| | 324 | if (!CloseHandle(g_hChildStd_IN_Wr)) { |
| | 325 | zig_panic("stdinwr closehandle"); |
| | 326 | } |
| | 327 | |
| | 328 | CloseHandle(g_hChildStd_IN_Rd); |
| | 329 | CloseHandle(g_hChildStd_ERR_Wr); |
| | 330 | CloseHandle(g_hChildStd_OUT_Wr); |
| | 331 | |
| | 332 | static const int BUF_SIZE = 4 * 1024; |
| | 333 | { |
| | 334 | DWORD dwRead; |
| | 335 | char chBuf[BUF_SIZE]; |
| | 336 | |
| | 337 | buf_resize(out_stdout, 0); |
| | 338 | for (;;) { |
| | 339 | success = ReadFile( g_hChildStd_OUT_Rd, chBuf, BUF_SIZE, &dwRead, NULL); |
| | 340 | if (!success || dwRead == 0) break; |
| | 341 | |
| | 342 | buf_append_mem(out_stdout, chBuf, dwRead); |
| | 343 | } |
| | 344 | CloseHandle(g_hChildStd_OUT_Rd); |
| | 345 | } |
| | 346 | { |
| | 347 | DWORD dwRead; |
| | 348 | char chBuf[BUF_SIZE]; |
| | 349 | |
| | 350 | buf_resize(out_stderr, 0); |
| | 351 | for (;;) { |
| | 352 | success = ReadFile( g_hChildStd_ERR_Rd, chBuf, BUF_SIZE, &dwRead, NULL); |
| | 353 | if (!success || dwRead == 0) break; |
| | 354 | |
| | 355 | buf_append_mem(out_stderr, chBuf, dwRead); |
| | 356 | } |
| | 357 | CloseHandle(g_hChildStd_ERR_Rd); |
| | 358 | } |
| | 359 | |
| | 360 | WaitForSingleObject(piProcInfo.hProcess, INFINITE); |
| | 361 | |
| | 362 | DWORD exit_code; |
| | 363 | if (!GetExitCodeProcess(piProcInfo.hProcess, &exit_code)) { |
| | 364 | zig_panic("GetExitCodeProcess failed"); |
| | 365 | } |
| | 366 | *return_code = exit_code; |
| | 367 | |
| | 368 | CloseHandle(piProcInfo.hProcess); |
| | 369 | CloseHandle(piProcInfo.hThread); |
| | 370 | |
| | 371 | return 0; |
| 217 | } | 372 | } |
| 218 | #endif | 373 | #endif |
| 219 | | 374 | |
| 220 | void os_exec_process(const char *exe, ZigList<const char *> &args, | 375 | int os_exec_process(const char *exe, ZigList<const char *> &args, |
| 221 | int *return_code, Buf *out_stderr, Buf *out_stdout) | 376 | int *return_code, Buf *out_stderr, Buf *out_stdout) |
| 222 | { | 377 | { |
| 223 | #if defined(ZIG_OS_WINDOWS) | 378 | #if defined(ZIG_OS_WINDOWS) |
| ... | @@ -267,7 +422,11 @@ int os_fetch_file_path(Buf *full_path, Buf *out_contents) { | ... | @@ -267,7 +422,11 @@ int os_fetch_file_path(Buf *full_path, Buf *out_contents) { |
| 267 | | 422 | |
| 268 | int os_get_cwd(Buf *out_cwd) { | 423 | int os_get_cwd(Buf *out_cwd) { |
| 269 | #if defined(ZIG_OS_WINDOWS) | 424 | #if defined(ZIG_OS_WINDOWS) |
| 270 | zig_panic("TODO os_get_cwd for windows"); | 425 | buf_resize(out_cwd, 4096); |
| | 426 | if (GetCurrentDirectory(buf_len(out_cwd), buf_ptr(out_cwd)) == 0) { |
| | 427 | zig_panic("GetCurrentDirectory failed"); |
| | 428 | } |
| | 429 | return 0; |
| 271 | #elif defined(ZIG_OS_POSIX) | 430 | #elif defined(ZIG_OS_POSIX) |
| 272 | int err = ERANGE; | 431 | int err = ERANGE; |
| 273 | buf_resize(out_cwd, 512); | 432 | buf_resize(out_cwd, 512); |
| ... | @@ -296,8 +455,12 @@ bool os_stderr_tty(void) { | ... | @@ -296,8 +455,12 @@ bool os_stderr_tty(void) { |
| 296 | | 455 | |
| 297 | #if defined(ZIG_OS_POSIX) | 456 | #if defined(ZIG_OS_POSIX) |
| 298 | static int os_buf_to_tmp_file_posix(Buf *contents, Buf *suffix, Buf *out_tmp_path) { | 457 | static int os_buf_to_tmp_file_posix(Buf *contents, Buf *suffix, Buf *out_tmp_path) { |
| | 458 | const char *tmp_dir = getenv("TMPDIR"); |
| | 459 | if (!tmp_dir) { |
| | 460 | tmp_dir = P_tmpdir; |
| | 461 | } |
| 299 | buf_resize(out_tmp_path, 0); | 462 | buf_resize(out_tmp_path, 0); |
| 300 | buf_appendf(out_tmp_path, "/tmp/XXXXXX%s", buf_ptr(suffix)); | 463 | buf_appendf(out_tmp_path, "%s/XXXXXX%s", tmp_dir, buf_ptr(suffix)); |
| 301 | | 464 | |
| 302 | int fd = mkstemps(buf_ptr(out_tmp_path), buf_len(suffix)); | 465 | int fd = mkstemps(buf_ptr(out_tmp_path), buf_len(suffix)); |
| 303 | if (fd < 0) { | 466 | if (fd < 0) { |
| ... | @@ -321,7 +484,35 @@ static int os_buf_to_tmp_file_posix(Buf *contents, Buf *suffix, Buf *out_tmp_pat | ... | @@ -321,7 +484,35 @@ static int os_buf_to_tmp_file_posix(Buf *contents, Buf *suffix, Buf *out_tmp_pat |
| 321 | | 484 | |
| 322 | #if defined(ZIG_OS_WINDOWS) | 485 | #if defined(ZIG_OS_WINDOWS) |
| 323 | static int os_buf_to_tmp_file_windows(Buf *contents, Buf *suffix, Buf *out_tmp_path) { | 486 | static int os_buf_to_tmp_file_windows(Buf *contents, Buf *suffix, Buf *out_tmp_path) { |
| 324 | zig_panic("TODO implement os_buf_to_tmp_file_windows"); | 487 | char tmp_dir[MAX_PATH + 1]; |
| | 488 | if (GetTempPath(MAX_PATH, tmp_dir) == 0) { |
| | 489 | zig_panic("GetTempPath failed"); |
| | 490 | } |
| | 491 | buf_init_from_str(out_tmp_path, tmp_dir); |
| | 492 | |
| | 493 | const char base64[] = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789-_"; |
| | 494 | assert(array_length(base64) == 64 + 1); |
| | 495 | for (int i = 0; i < 8; i += 1) { |
| | 496 | buf_append_char(out_tmp_path, base64[rand() % 64]); |
| | 497 | } |
| | 498 | |
| | 499 | buf_append_buf(out_tmp_path, suffix); |
| | 500 | |
| | 501 | FILE *f = fopen(buf_ptr(out_tmp_path), "wb"); |
| | 502 | |
| | 503 | if (!f) { |
| | 504 | zig_panic("unable to open %s: %s", buf_ptr(out_tmp_path), strerror(errno)); |
| | 505 | } |
| | 506 | |
| | 507 | size_t amt_written = fwrite(buf_ptr(contents), 1, buf_len(contents), f); |
| | 508 | if (amt_written != (size_t)buf_len(contents)) { |
| | 509 | zig_panic("write failed: %s", strerror(errno)); |
| | 510 | } |
| | 511 | |
| | 512 | if (fclose(f)) { |
| | 513 | zig_panic("fclose failed"); |
| | 514 | } |
| | 515 | return 0; |
| 325 | } | 516 | } |
| 326 | #endif | 517 | #endif |
| 327 | | 518 | |
| ... | @@ -342,3 +533,7 @@ int os_delete_file(Buf *path) { | ... | @@ -342,3 +533,7 @@ int os_delete_file(Buf *path) { |
| 342 | return 0; | 533 | return 0; |
| 343 | } | 534 | } |
| 344 | } | 535 | } |
| | 536 | |
| | 537 | void os_init(void) { |
| | 538 | srand(time(NULL)); |
| | 539 | } |