1 /* Hacky parallelism; Ian Jackson */
22 typedef enum { hp_idle, hp_compute, hp_deferring, hp_fail } HPState;
27 static void checkchild(void)
33 r= waitpid(child,&status,WNOHANG); if (!r) return;
35 Message(M_ERR,"hacky_par: waitpid: %s\n",strerror(errno));
40 if (WIFSIGNALED(status)) {
41 Message(M_ERR,"hacky_par: signaled! %s\n",strsignal(WTERMSIG(status)));
42 } else if (!WIFEXITED(status)) {
43 Message(M_ERR,"hacky_par: unexpected status! %d\n", r);
47 static HPState start(void)
53 Message(M_ERR,"hacky_par: fork failed: %s\n",strerror(errno));
57 if (!child) { /* we are the child */
61 Message(M_INFO,"hacky_par: started, punting\n");
65 int hacky_par_start_failnow(void)
71 Message(M_INFO,"hacky_par: busy, punting\n");
77 int hacky_par_mid_failnow(void)
80 return state != hp_compute;
83 bool_t (*packy_par_gen)(struct site *st);
85 void hacky_par_end(int *ok,
86 int32_t retries, int32_t timeout,
87 bool_t (*send_msg)(struct site *st), struct site *st)
103 Message(M_ERR,"hacky_par: compute failed\n");
106 Message(M_INFO,"hacky_par: got result, sending\n");
107 for (i=1; i<retries; i++) {
108 sleep((timeout + 999)/1000);
110 Message(M_ERR,"hacky_par: retry failed\n");
118 #else /*!HACKY_PARALLEL*/
120 int hacky_par_start_failnow(void) { return 0; }
121 int hacky_par_mid_failnow(void) { return 0; }
122 void hacky_par_end(int *ok,
123 int32_t retries, int32_t timeout,
124 bool_t (*send_msg)(struct site *st), struct site *st) { }
126 #endif /*HACKY_PARALLEL...else*/