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

diff --git a/engine.cpp b/engine.cpp
index b674272..f86f0fb 100644
--- a/engine.cpp
+++ b/engine.cpp
@@ -200,6 +200,18 @@ void engine_close(engine_t * engine) {
 
 }
 
+// engine_get_non_blocking()
+
+bool engine_get_non_blocking(engine_t * engine, char string[], int size){
+    if(io_line_ready(engine->io)){
+        engine_get(engine,string,StringSize);
+        return true;
+    }else{
+        string[0]='\0';
+        return false;
+    }
+}
+
 // engine_get()
 
 void engine_get(engine_t * engine, char string[], int size) {
@@ -309,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)
 {
 /*
@@ -326,52 +355,41 @@ IDLE_PRIORITY_CLASS         0x00000040
 	return 0x00000040;
 }
 
-
-
-void set_affinity(engine_t *engine, int affin){
-	if(affin==-1) return;
-    SetProcessAffinityMask((engine->pipeEngine).hProcess,affin);
-}
-
-// Eric Mullins!
-
 void engine_set_nice_value(engine_t *engine, int value){
-    SetPriorityClass((engine->pipeEngine).hProcess,
+    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));
+    nQueuePtr += vsprintf(szQueueString + nQueuePtr, szFormat, (va_list) (&szFormat + 1));
 }
 
 void engine_send(engine_t * engine, const char *szFormat, ...) {
     vsprintf(szQueueString + nQueuePtr, szFormat, (va_list) (&szFormat + 1));
-    (engine->pipeEngine).LineOutput(szQueueString);
+    (engine->io).LineOutput(szQueueString);
     my_log("Adapter->Engine: %s\n",szQueueString);
     nQueuePtr = 0;
 }
 
 void engine_close(engine_t * engine){
     char string[StringSize];
-    (engine->pipeEngine).Close();
+    (engine->io).Close();
         // TODO: Timeout
-    while (!engine_eof(Engine)) {
-            engine_get(Engine,string,StringSize); 
-        }
-    (engine->pipeEngine).Kill();
+    while (!engine_eof(engine)) { 
+      engine_get(Engine,string,StringSize);
+    }
+    (engine->io).Kill();
 }
 
-
 void engine_open(engine_t * engine){
-   int affinity;
+    int affinity;
     char *my_dir;
     engine->state=0;
     if( (my_dir = _getcwd( NULL, 0 )) == NULL )
         my_fatal("Can't build path: %s\n",strerror(errno));
     SetCurrentDirectory(option_get_string("EngineDir"));
-    (engine->pipeEngine).Open(option_get_string("EngineCommand"));
-    if((engine->pipeEngine).Active()){
+    (engine->io).Open(option_get_string("EngineCommand"));
+    if((engine->io).Active()){
         engine->state|=ENGINE_ACTIVE;
             //play with affinity (bad idea)
         affinity=option_get_int("Affinity");
@@ -397,29 +415,26 @@ 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->pipeEngine).LineInput(szLineStr)) {
+    if ((engine->io).GetBuffer(szLineStr)) {
         my_log("Engine->Adapter: %s\n",szLineStr);
         return true;
     } else {
         szLineStr[0]='\0';
-        if(engine->pipeEngine.EOF_()){
-            my_log("POLYGLOT EOF received from engine\n");
+        if(engine->io.EOF_()){
             engine->state|=ENGINE_EOF;
+	    my_log("POLYGLOT *** EOF from Engine ***\n");
         }
         return false;
     }
 }
 
 void engine_get(engine_t * engine, char *szLineStr, int size){
-    bool data_available;
-    if(engine_eof(engine))return;
-    while(true){
-        data_available=engine_get_non_blocking(engine,szLineStr,size);
-        if(!data_available && !engine_eof(engine)){
-            Idle();
-        }else{
-            break;
-        }
+    (engine->io).LineInput(szLineStr);
+    if(engine->io.EOF_()){
+      engine->state|=ENGINE_EOF;
+      my_log("POLYGLOT *** EOF from Engine ***\n");
+    }else{
+      my_log("Engine->Adapter: %s\n",szLineStr);
     }
 }