1 files changed, 93 insertions, 0 deletions
diff --git a/judge/event_exec.cpp b/judge/event_exec.cpp
new file mode 100644
index 0000000..7723f74
--- /dev/null
+++ b/judge/event_exec.cpp
@@ -0,0 +1,93 @@
+#ifdef HAVE_CONFIG_H
+# include<judge_conf.h>
+#endif
+
+#include "event_exec.h"
+
+#define EVENT_BUFLEN 1005
+#define EVENT_URL "http://localhost/toj/php/event.php"
+
+struct event_handle
+{
+    int init, plen, blen;
+    char *post, *buf;
+    pthread_mutex_t mutex;
+    CURL *handle;
+};
+
+static struct event_handle conn;
+
+size_t event_write_cb(void *in, size_t siz, size_t nb, void *buf)
+{
+    int len;
+    len = siz*nb+1;
+    if(len > conn.blen)
+    {
+	len = conn.blen-1;
+    }
+    memcpy(buf, in, len);
+    ((char*)buf)[len] = 0;
+    return siz*nb;
+}
+
+int event_init()
+{
+    if(conn.init)
+    {
+	return 0;
+    }
+    conn.plen = conn.blen = EVENT_BUFLEN;
+    conn.post = (char*)malloc(EVENT_BUFLEN);
+    conn.buf = (char*)malloc(EVENT_BUFLEN);
+    curl_global_init(CURL_GLOBAL_ALL);
+    conn.handle = curl_easy_init();
+    curl_easy_setopt(conn.handle, CURLOPT_URL, EVENT_URL);
+    curl_easy_setopt(conn.handle, CURLOPT_WRITEFUNCTION, event_write_cb);
+    curl_easy_setopt(conn.handle, CURLOPT_WRITEDATA, conn.buf);
+    pthread_mutex_init(&conn.mutex, NULL);
+    conn.init = 1;
+    return 1;
+}
+
+int event_exec(const char *fname, const char *name, const char *arg)
+{
+    int res, len;
+    char *t;
+    event_init();
+    if(pthread_mutex_lock(&conn.mutex) == 0)
+    {
+	len = 0;
+	len += strlen(fname)+6;
+	len += strlen(name)+6;
+	len += strlen(arg)+6;
+	if(len > conn.plen)
+	{
+	    t = (char*)malloc(len);
+	    if(!t)
+	    {
+		pthread_mutex_unlock(&conn.mutex);
+		return 0;
+	    }
+	    free(conn.post);
+	    conn.post = t;
+	    conn.plen = len;
+	}
+	sprintf(conn.post, "fname=%s&name=%s&arg=%s", fname, name, arg);
+	curl_easy_setopt(conn.handle, CURLOPT_POSTFIELDS, conn.post);
+	res = curl_easy_perform(conn.handle);
+	if(res)
+	{
+	    pthread_mutex_unlock(&conn.mutex);
+	    return 0;
+	}
+	fprintf(stderr, "%s\n", conn.buf);
+	if(!strcmp(conn.buf, "true"))
+	{
+	    pthread_mutex_unlock(&conn.mutex);
+	    return 1;
+	}
+
+	pthread_mutex_unlock(&conn.mutex);
+    }
+    return 0;
+}