Compare commits

...

2 Commits

View File

@@ -139,15 +139,10 @@ int lua_platform_exec_parallel(lua_State* L)
{ {
char buf[64]; char buf[64];
// Read the std. streams into the output vectors // Read the std. streams into the output vectors
// TODO: Errors out here
fprintf(stderr, "p->out = %p\n", p->out);
while (fgets(buf, sizeof(buf), p->out) != NULL) while (fgets(buf, sizeof(buf), p->out) != NULL)
std_outs[p->userdata].append(buf); std_outs[p->userdata].append(buf);
fprintf(stderr, "C: %llu\n", cmd_idx);
fprintf(stderr, "p->err = %p\n", p->err);
while (fgets(buf, sizeof(buf), p->err) != NULL) while (fgets(buf, sizeof(buf), p->err) != NULL)
std_errs[p->userdata].append(buf); std_errs[p->userdata].append(buf);
fprintf(stderr, "D: %llu\n", cmd_idx);
// Add the process return code to retcode array // Add the process return code to retcode array
uniproc_await_processes(p, retcodes + p->userdata, 1); uniproc_await_processes(p, retcodes + p->userdata, 1);
// Close the process and zero it // Close the process and zero it