version 1.4.30b

[polyglot.git] / engine.c

diff --git a/engine.c b/engine.c
new file mode 100644 (file)
index 0000000..4dffd4a
--- /dev/null
+++ b/engine.c
@@ -0,0 +1,120 @@
+// engine.c\r
+\r
+// includes\r
+\r
+#include <stdlib.h>\r
+#include <stdarg.h>\r
+#include <string.h>\r
+#include <errno.h>\r
+\r
+\r
+#include "engine.h"\r
+#include "option.h"\r
+#include "pipex.h"\r
+#include "util.h"\r
+\r
+// defines\r
+\r
+#define StringSize 4096\r
+\r
+// variables\r
+\r
+static int write_index = 0;\r
+static char write_buffer[StringSize];\r
+engine_t Engine[1];\r
+\r
+// functions\r
+\r
+// set_affinity()\r
+\r
+void set_affinity(engine_t *engine, int value){\r
+    pipex_set_affinity(engine->pipex,value);\r
+}\r
+\r
+// engine_set_nice_value()\r
+\r
+void engine_set_nice_value(engine_t *engine, int value){\r
+    pipex_set_priority(engine->pipex,value);\r
+}\r
+\r
+// engine_send_queue()\r
+\r
+void engine_send_queue(engine_t * engine, const char *format, ...) {\r
+    if(write_index>=StringSize){\r
+        my_fatal("engine_send_queue(): write_buffer overflow\n");\r
+    }\r
+    write_index += vsnprintf(write_buffer + write_index,\r
+                            StringSize-write_index,\r
+                             format,\r
+                            (va_list) (&format + 1));\r
+}\r
+\r
+// engine_send()\r
+\r
+void engine_send(engine_t * engine, const char *format, ...) {\r
+    if(write_index>=StringSize){\r
+        my_fatal("engine_send(): write_buffer overflow\n");\r
+    }\r
+    vsnprintf(write_buffer + write_index,\r
+              StringSize-write_index,\r
+              format,\r
+              (va_list) (&format + 1));\r
+    pipex_writeln(engine->pipex,write_buffer);\r
+    write_index = 0;\r
+}\r
+\r
+// engine_close()\r
+\r
+void engine_close(engine_t * engine){\r
+    char string[StringSize];\r
+    pipex_send_eof(engine->pipex);\r
+        // TODO: Timeout\r
+    while (!engine_eof(engine)) { \r
+      engine_get(Engine,string);\r
+    }\r
+    pipex_exit(engine->pipex);\r
+}\r
+\r
+// engine_open()\r
+\r
+void engine_open(engine_t * engine){\r
+    int affinity;\r
+    char *my_dir;\r
+    if( (my_dir = my_getcwd( NULL, 0 )) == NULL )\r
+        my_fatal("engine_open(): no current directory: %s\n",strerror(errno));\r
+    if(my_chdir(option_get_string("EngineDir"))){\r
+        my_fatal("engine_open(): cannot change directory: %s\n",strerror(errno));\r
+    }\r
+    pipex_open(engine->pipex,"Engine",option_get_string("EngineCommand"));\r
+    if(pipex_active(engine->pipex)){\r
+            //play with affinity (bad idea)\r
+        affinity=option_get_int("Affinity");\r
+        if(affinity!=-1) set_affinity(engine,affinity); //AAA\r
+            //lets go back\r
+        my_chdir(my_dir);\r
+            // set a low priority\r
+        if (option_get_bool("UseNice")){\r
+            my_log("POLYGLOT Adjust Engine Piority\n");\r
+            engine_set_nice_value(engine, option_get_int("NiceValue"));\r
+        }\r
+    }\r
+    \r
+}\r
+\r
+bool engine_active(engine_t *engine){\r
+    return pipex_active(engine->pipex);\r
+}\r
+\r
+bool engine_eof(engine_t *engine){\r
+    return pipex_eof(engine->pipex);\r
+}\r
+\r
+bool engine_get_non_blocking(engine_t * engine, char *string){\r
+    return pipex_readln_nb(engine->pipex,string);\r
+ }\r
+\r
+void engine_get(engine_t * engine, char *string){\r
+    pipex_readln(engine->pipex,string);\r
+}\r
+\r
+\r