X-Git-Url: http://winboard.nl/cgi-bin?p=polyglot.git;a=blobdiff_plain;f=engine.c;fp=engine.c;h=af6555a68fd77eb2eba7bf6330ad88fdf910aefe;hp=5cfea0757d63e933e016984b548da6b79d5e2dba;hb=de010509fa0e57ba955da6512c714fbff8606af3;hpb=60900035e6d0309705f2326ee50edc52386305e9

diff --git a/engine.c b/engine.c
index 5cfea07..af6555a 100644
--- a/engine.c
+++ b/engine.c
@@ -51,12 +51,26 @@ void engine_send(engine_t * engine, const char *format, ...) {
 
 void engine_close(engine_t * engine){
     char string[StringSize];
+    int elapsed_time;
+    int ret;
+    int close_timeout=500;
+    my_log("POLYGLOT Closing engine.\n");
     pipex_send_eof(engine->pipex);
         // TODO: Timeout
-    while (!engine_eof(engine)) { 
-      engine_get(engine,string);
+
+    elapsed_time=0;
+    while (!engine_eof(engine) && (elapsed_time<close_timeout)) { 
+      ret=engine_get_non_blocking(engine,string);
+      if(!ret  && !engine_eof(engine)){
+	my_log("POLYGLOT Engine does not reply. Sleeping %dms.\n", WAIT_GRANULARITY);
+	my_sleep(WAIT_GRANULARITY);
+	elapsed_time+=WAIT_GRANULARITY;
+      }
+    }
+    if(elapsed_time>=close_timeout){
+      my_log("POLYGLOT Waited more than %dms. Moving on.\n",close_timeout); 
     }
-    pipex_exit(engine->pipex);
+    pipex_exit(engine->pipex,200);
 }
 
 // engine_open()