1 files changed, 61 insertions, 0 deletions
diff --git a/CDAL/AsyncCommunication.h b/CDAL/AsyncCommunication.h
new file mode 100755
index 0000000..36ce5c7
--- /dev/null
+++ b/CDAL/AsyncCommunication.h
@@ -0,0 +1,61 @@
+/*
+ * AsyncCommunication.h
+ *
+ * Copyright (C) ST-Ericsson SA 2011
+ * Authors: Srimanta Panda <srimanta.panda@stericsson.com>,
+ *          Ola Borgelin <ola.borgelin@stericsson.com>,
+ *          Karin Hedlund <karin.hedlund@stericsson.com>,
+ *          Markus Andersson <markus.m.andersson@stericsson.com> for ST-Ericsson.
+ * License terms: 3-clause BSD license
+ *
+ */
+
+#pragma once
+
+#include "CDAL.h"
+#include "Event.h"
+#include "Thread.h"
+#include "CriticalSection.h"
+
+struct commRequest {
+    void* buf;
+    int length;
+    DataCallback_t callback;
+    void* param;
+    bool isShutdown;
+    bool isActive;
+};
+
+class AsyncCommunication
+{
+public:
+    AsyncCommunication(CommDevice* device);
+    ~AsyncCommunication();
+
+    int readNoWait(void* buf, int len, DataCallback_t fn, void* param);
+    int writeNoWait(void* buf, int len, DataCallback_t fn, void* param);
+
+    bool isReadActive() {
+        return readRequest_.isActive;
+    }
+    void waitReadCanceled();
+private:
+    CommDevice* device_;
+    bool isReadInvoked_;
+    bool isWriteInvoked_;
+
+    commRequest readRequest_;
+    CriticalSection readCs_;
+
+    commRequest writeRequest_;
+    CriticalSection writeCs_;
+
+    Thread* readerThread_;
+    static void* threadReadProc(void*);
+    Event readRequestEvent_;
+    Event readCanceledEvent_;
+
+    Thread* writerThread_;
+    static void* threadWriteProc(void*);
+    Event writeRequestEvent_;
+};