Changeset 8:dba41f33ddce in xplcommon for test/testevent.cc

Timestamp:

12/29/12 08:01:50 (11 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

Phase:

public

Message:

Clarified the blocking and non-blocking behaviour and extended the test program to test both

File:

• test/testevent.cc (modified) (3 diffs)

test/testevent.cc

@@ -89 +89 @@
 //------------------------------------------------------------------------------
 
+class BlockingServerThread : public Thread
+{
+private:
+    WaitableEvent event;
+
+public:
+    WaitableEvent& getEvent();
+
+    virtual void run();
+};
+
+//------------------------------------------------------------------------------
+
+inline WaitableEvent& BlockingServerThread::getEvent()
+{
+    return event;
+}
+
+//------------------------------------------------------------------------------
+
+void BlockingServerThread::run()
+{
+    printf("BlockingServerThread::run: waiting...\n");
+    if (event.check()) {
+        printf("BlockingServerThread::run: waiting done\n");
+    } else {
+        printf("BlockingServerThread::run: waiting failed\n");
+    }
+    printf("BlockingServerThread::run: finished\n");
+}
+
+
+//------------------------------------------------------------------------------
+//------------------------------------------------------------------------------
+
 class ClientThread : public Thread
 {
@@ -120 +155 @@
 //------------------------------------------------------------------------------
 
-int main()
+template <class Server> void runTest()
 {
-    ServerThread serverThread;
+    Server serverThread;
     ClientThread clientThread(serverThread.getEvent());
 
@@ -134 +169 @@
     serverThread.join();
     printf("Both threads returned\n");
+}
+
+//------------------------------------------------------------------------------
+//------------------------------------------------------------------------------
+
+int main()
+{
+    printf("Running the event test with a non-blocking WaitableEvent\n\n");
+    runTest<ServerThread>();
+
+    printf("\n\nRunning the event test with a blocking WaitableEvent\n\n");
+    runTest<BlockingServerThread>();
 
     return 0;