X-Git-Url: http://winboard.nl/cgi-bin?p=polyglot.git;a=blobdiff_plain;f=engine.cpp;h=f86f0fb4af450fe047ac5140cc708a465c917cbc;hp=f5c53c673a7f8d8f179d58bd0543591b813d1d3f;hb=acb140befabd8b0f1a8606470013b420d05b4fb7;hpb=5cd5185613348b13625e257efcd7b2f11ca85276

diff --git a/engine.cpp b/engine.cpp
index f5c53c6..f86f0fb 100644
--- a/engine.cpp
+++ b/engine.cpp
@@ -321,6 +321,23 @@ engine_t Engine[1];
 
 // functions
 
+void set_affinity(engine_t *engine, int affin){
+	if(affin==-1) return;
+
+    typedef void (WINAPI *SPAM)(HANDLE, int);
+    SPAM pSPAM;
+    pSPAM = (SPAM) GetProcAddress(
+        GetModuleHandle(TEXT("kernel32.dll")), 
+        "SetProcessAffinityMask");
+    if(NULL != pSPAM){
+            // [HGM] avoid crash on Win95 by first checking if API call exists
+        my_log("POLYGLOT Setting process affinity to %d\n",affin);
+        pSPAM((engine->io).hProcess,affin);
+    }else{
+        my_log("POLYGLOT API call \"SetProcessAffinityMask\" not available\n");
+    }
+}
+
 DWORD GetWin32Priority(int nice)
 {
 /*
@@ -338,21 +355,11 @@ IDLE_PRIORITY_CLASS         0x00000040
 	return 0x00000040;
 }
 
-
-
-void set_affinity(engine_t *engine, int affin){
-	if(affin==-1) return;
-    SetProcessAffinityMask((engine->io).hProcess,affin);
-}
-
-// Eric Mullins!
-
 void engine_set_nice_value(engine_t *engine, int value){
     SetPriorityClass((engine->io).hProcess,
                      GetWin32Priority(value));
 }
 
-
 void engine_send_queue(engine_t * engine,const char *szFormat, ...) {
     nQueuePtr += vsprintf(szQueueString + nQueuePtr, szFormat, (va_list) (&szFormat + 1));
 }
@@ -368,14 +375,12 @@ void engine_close(engine_t * engine){
     char string[StringSize];
     (engine->io).Close();
         // TODO: Timeout
-    while (!engine_eof(Engine)) { 
-        engine_get_non_blocking(Engine,string,StringSize);
-        Idle();
+    while (!engine_eof(engine)) { 
+      engine_get(Engine,string,StringSize);
     }
     (engine->io).Kill();
 }
 
-
 void engine_open(engine_t * engine){
     int affinity;
     char *my_dir;
@@ -410,13 +415,14 @@ bool engine_eof(engine_t *engine){
 
 bool engine_get_non_blocking(engine_t * engine, char *szLineStr, int size){
     if(engine_eof(engine)){ return false;}
-	if ((engine->io).GetBuffer(szLineStr)) {
+    if ((engine->io).GetBuffer(szLineStr)) {
         my_log("Engine->Adapter: %s\n",szLineStr);
         return true;
     } else {
         szLineStr[0]='\0';
         if(engine->io.EOF_()){
             engine->state|=ENGINE_EOF;
+	    my_log("POLYGLOT *** EOF from Engine ***\n");
         }
         return false;
     }
@@ -425,7 +431,10 @@ bool engine_get_non_blocking(engine_t * engine, char *szLineStr, int size){
 void engine_get(engine_t * engine, char *szLineStr, int size){
     (engine->io).LineInput(szLineStr);
     if(engine->io.EOF_()){
-        engine->state|=ENGINE_EOF;
+      engine->state|=ENGINE_EOF;
+      my_log("POLYGLOT *** EOF from Engine ***\n");
+    }else{
+      my_log("Engine->Adapter: %s\n",szLineStr);
     }
 }