From 3caf7d8227676ba83404f129950ba30947408be9 Mon Sep 17 00:00:00 2001
From: Nadeem Shehzad <nadeem.shehzad@desy.de>
Date: Fri, 17 Jan 2020 11:39:17 +0100
Subject: [PATCH] added: test for Process variable recovery.
---
.../testProcessVariableRecovery.cc | 114 ++++++++++++++++++
1 file changed, 114 insertions(+)
create mode 100644 tests/executables_src/testProcessVariableRecovery.cc
diff --git a/tests/executables_src/testProcessVariableRecovery.cc b/tests/executables_src/testProcessVariableRecovery.cc
new file mode 100644
index 00000000..e7e24fc3
--- /dev/null
+++ b/tests/executables_src/testProcessVariableRecovery.cc
@@ -0,0 +1,114 @@
+#define BOOST_TEST_MODULE testProcessVariableRecovery
+
+#include <boost/test/included/unit_test.hpp>
+#include "Application.h"
+#include "ControlSystemModule.h"
+#include "DeviceModule.h"
+#include "TestFacility.h"
+#include "ExceptionDevice.h"
+#include <ChimeraTK/Device.h>
+#include <stdlib.h>
+#include "check_timeout.h"
+#include "ApplicationModule.h"
+#include "ArrayAccessor.h"
+
+using namespace boost::unit_test_framework;
+namespace ctk = ChimeraTK;
+
+static constexpr char deviceCDD[] = "(ExceptionDummy?map=test5.map)";
+
+struct TestModule : public ctk::ApplicationModule {
+ using ctk::ApplicationModule::ApplicationModule;
+
+ ctk::ScalarPushInput<int32_t> trigger{this, "trigger", "", "This is my trigger."};
+ ctk::ScalarOutput<int32_t> scalarOutput{this, "TO_DEV1", "", "Here I write a scalar"};
+ ctk::ArrayOutput<int32_t> arrayOutput{this, "TO_DEV_ARRAY1", "", 4, "Here I write an array"};
+
+ void mainLoop() override {
+ while(true)
+ {
+ trigger.read();
+ scalarOutput = int32_t(trigger);
+ scalarOutput.write();
+ for(uint i=0; i<4; i++){
+ arrayOutput[i] = int32_t(trigger);
+ }
+ arrayOutput.write();
+ }
+ }
+};
+
+/* dummy application */
+struct TestApplication : public ctk::Application {
+ TestApplication() : Application("testSuite") {}
+ ~TestApplication() { shutdown(); }
+
+ void defineConnections() {} // the setup is done in the tests
+ ctk::ControlSystemModule cs;
+ ctk::DeviceModule dev{this, deviceCDD};
+ TestModule module{this, "TEST", "The test module"};
+};
+
+/*********************************************************************************************************************/
+
+BOOST_AUTO_TEST_CASE(testProcessVariableRecovery) {
+ std::cout << "testProcessVariableRecovery" << std::endl;
+ TestApplication app;
+ app.module.connectTo(app.cs["TEST"]); // creates /TEST/TO_DEV1 and /TEST/TO/DEV/ARRAY1
+ // devices are not automatically connected (yet)
+ app.dev.connectTo(app.cs); // In TEST it connects to TO_DEV1 and TO_DEV_ARRAY1, and creates TO_DEV2, FROM_DEV1, FROM_DEV2, TO_DEV_AREA2, FROM_DEV_AREA1 and FROM_DEV_AREA2
+
+ ctk::TestFacility test(false);
+ // initial value for the direct CS->DEV register
+ test.writeScalar("/TEST/TO_DEV2",42);
+ std::vector<int32_t> array= {99,99,99,99};
+ test.writeArray("/TEST/TO_DEV_ARRAY2", array);
+
+ //test.runApplication();
+ app.run();
+ app.dumpConnections();
+
+ ctk::Device dummy;
+ dummy.open(deviceCDD);
+ //auto reg2 = dummy.getScalarRegisterAccessor<int32_t>("/TEST/TO_DEV2");
+ //CHECK_EQUAL_TIMEOUT([=]()mutable{reg2.readLatest(); return int32_t(reg2);},0,3000);
+
+ CHECK_EQUAL_TIMEOUT(dummy.read<int32_t>("/TEST/TO_DEV2"), 42, 3000);
+ //CHECK_EQUAL_TIMEOUT(dummy.read<int32_t>("/TEST/TO_DEV_ARRAY2",0,1), 99, 3000);
+
+ auto trigger = test.getScalar<int32_t>("/TEST/trigger");
+ trigger = 100;
+ trigger.write();
+ CHECK_EQUAL_TIMEOUT(dummy.read<int32_t>("/TEST/TO_DEV1"), 100, 3000);
+
+ auto dummyBackend =
+ boost::dynamic_pointer_cast<ExceptionDummy>(ctk::BackendFactory::getInstance().createBackend(deviceCDD));
+
+ //Set the device to throw.
+ dummyBackend->throwExceptionWrite = true;
+ dummyBackend->throwExceptionOpen = true;
+
+ //Verify device is in not functional anymore.
+ CHECK_EQUAL_TIMEOUT(dummyBackend->isFunctional(), 0, 1000);
+
+ //Set write exception to false so that device registers can be set to 0.
+ dummyBackend->throwExceptionWrite = false;
+
+ //Set dummy registers to 0.
+ app.dev.device.write<int32_t>("/TEST/TO_DEV1", 0);
+ app.dev.device.write<int32_t>("/TEST/TO_DEV2", 0);
+ //std::vector<int32_t> array= {0,0,0,0};
+ //app.dev.device.write<int32_t>("/AREA1", array);
+
+
+ //Set device back to normal.
+ dummyBackend->throwExceptionOpen = false;
+
+ //Verify if the device is ready.
+ CHECK_EQUAL_TIMEOUT(dummyBackend->isFunctional(), 1, 1000);
+
+ //Device should have the correct values now.
+ CHECK_EQUAL_TIMEOUT(dummy.read<int32_t>("/TEST/TO_DEV2"), 42, 5000);
+ CHECK_EQUAL_TIMEOUT(dummy.read<int32_t>("/TEST/TO_DEV1"), 100, 5000);
+
+}
--
GitLab