Diff: operation/ReportThread.cpp

Revision:

94:61d44636f020

Child:

95:010b0f7a0a1a

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/operation/ReportThread.cpp	Mon Apr 20 15:04:23 2015 +0000
@@ -0,0 +1,23 @@
+#include "ReportThread.h"
+#include "logging.h"
+
+const char fmt2[] = "111,%ld,%s\r\n";
+
+void ReportThread::threadFunc()
+{
+    while (true) {
+        osEvent e = ipool.get();
+        if (e.status == osEventMail) {
+            Operation *op = (Operation*)e.value.p;
+            long id = op->identifier;
+            OperationState state = op->state;
+            ipool.free(op);
+            int l = snprintf(buf2, sizeof(buf2), fmt2, id, strOperationState(state));
+            l = snprintf(buf, sizeof(buf), getSmartRestFmt(), uri, l, buf2);
+            l = sock.sendOnly(buf, l);
+            if (l < 0) {
+                    aError("Report: <%ld, %s>\n", id, strOperationState(state));
+            }
+        }
+    }
+}