add test for true async

Author: kpedro88

Core/test/DummyClient.h

@@ -5,6 +5,7 @@
 #include "FWCore/ParameterSet/interface/ParameterSetDescription.h"
 #include "SonicCMS/Core/interface/SonicClientSync.h"
 #include "SonicCMS/Core/interface/SonicClientPseudoAsync.h"
+#include "SonicCMS/Core/interface/SonicClientAsync.h"
 
 #include <vector>
 #include <thread>
@@ -42,6 +43,13 @@ class DummyClient : public Client {
 
 typedef DummyClient<SonicClientSync<int>> DummyClientSync;
 typedef DummyClient<SonicClientPseudoAsync<int>> DummyClientPseudoAsync;
-//test of true Async omitted
+typedef DummyClient<SonicClientAsync<int>> DummyClientAsync;
+
+//specialization for true async
+template <>
+void DummyClientAsync::predictImpl() {
+	this->output_ = this->input_*factor_;
+	this->finish();
+}
 
 #endif

Core/test/SonicDummyProducer.cc

@@ -44,13 +44,17 @@ namespace edmtest {
 
 	typedef SonicDummyProducer<DummyClientSync> SonicDummyProducerSync;
 	typedef SonicDummyProducer<DummyClientPseudoAsync> SonicDummyProducerPseudoAsync;
+	typedef SonicDummyProducer<DummyClientAsync> SonicDummyProducerAsync;
 
 	template<> std::string SonicDummyProducerSync::getCfiName() { return "SonicDummyProducerSync"; }
 	template<> std::string SonicDummyProducerPseudoAsync::getCfiName() { return "SonicDummyProducerPseudoAsync"; }
+	template<> std::string SonicDummyProducerAsync::getCfiName() { return "SonicDummyProducerAsync"; }
 }
 
 using edmtest::SonicDummyProducerSync;
 DEFINE_FWK_MODULE(SonicDummyProducerSync);
 using edmtest::SonicDummyProducerPseudoAsync;
 DEFINE_FWK_MODULE(SonicDummyProducerPseudoAsync);
+using edmtest::SonicDummyProducerAsync;
+DEFINE_FWK_MODULE(SonicDummyProducerAsync);
 

Core/test/sonicTest_cfg.py

@@ -27,7 +27,15 @@
     ),
 )
 
-process.task = cms.Task(process.dummySync,process.dummyPseudoAsync)
+process.dummyAsync = cms.EDProducer("SonicDummyProducerAsync",
+    input = cms.int32(3),
+    Client = cms.PSet(
+        factor = cms.int32(5),
+        wait = cms.int32(10),
+    ),
+)
+
+process.task = cms.Task(process.dummySync,process.dummyPseudoAsync,process.dummyAsync)
 
 process.testerSync = cms.EDAnalyzer("IntTestAnalyzer",
     valueMustMatch = cms.untracked.int32(-1),
@@ -39,5 +47,11 @@
     moduleLabel = cms.untracked.string("dummyPseudoAsync"),
 )
 
+process.testerAsync = cms.EDAnalyzer("IntTestAnalyzer",
+    valueMustMatch = cms.untracked.int32(15),
+    moduleLabel = cms.untracked.string("dummyAsync"),
+)
+
 process.p1 = cms.Path(process.testerSync, process.task)
 process.p2 = cms.Path(process.testerPseudoAsync, process.task)
+process.p3 = cms.Path(process.testerAsync, process.task)