// NOLINTBEGIN(*)

#include "cxx_common.h"

#undef SUITE_NAME
#define SUITE_NAME PollAdminTestSuite__loop

class PollAdminTestSuite__loop : public CxxTest::TestSuite
{
  protected:
    DeviceProxy *device1, *dserver;
    string device1_name, device2_name, dserver_name;

  public:
    SUITE_NAME()
    {
        //
        // Arguments check -------------------------------------------------
        //

        device1_name = CxxTest::TangoPrinter::get_param("device1");
        device2_name = CxxTest::TangoPrinter::get_param("device2");
        dserver_name = "dserver/" + CxxTest::TangoPrinter::get_param("fulldsname");

        CxxTest::TangoPrinter::get_param_opt("loop");
        CxxTest::TangoPrinter::get_param_opt("suiteloop");

        CxxTest::TangoPrinter::validate_args();

        //
        // Initialization --------------------------------------------------
        //

        try
        {
            device1 = new DeviceProxy(device1_name);
            dserver = new DeviceProxy(dserver_name);
            device1->ping();
            dserver->ping();
        }
        catch(CORBA::Exception &e)
        {
            Except::print_exception(e);
            exit(-1);
        }
    }

    virtual ~SUITE_NAME()
    {
        //
        // Clean up --------------------------------------------------------
        //

        // clean up in case test suite terminates before polling state is restored to defaults
        if(CxxTest::TangoPrinter::is_restore_set("polling"))
        {
            try
            {
                dserver->command_inout("StartPolling");
            }
            catch(DevFailed &e)
            {
                TEST_LOG << endl << "Exception in suite tearDown():" << endl;
                Except::print_exception(e);
            }
        }

        // clean up in case test suite terminates before 'IOStr1'
        // command polling state is restored to defaults for device1
        if(CxxTest::TangoPrinter::is_restore_set("dev1_IOStr1_polling"))
        {
            DeviceData din;
            DevVarStringArray rem_cmd_poll;
            rem_cmd_poll.length(3);
            rem_cmd_poll[0] = device1_name.c_str();
            rem_cmd_poll[1] = "command";
            rem_cmd_poll[2] = "IOStr1";
            din << rem_cmd_poll;
            try
            {
                dserver->command_inout("RemObjPolling", din);
            }
            catch(DevFailed &e)
            {
                TEST_LOG << endl << "Exception in suite tearDown():" << endl;
                Except::print_exception(e);
            }
        }

        // clean up in case test suite terminates before 'Double_attr'
        // attribute polling state is restored to defaults for device1
        if(CxxTest::TangoPrinter::is_restore_set("dev1_double_attr_polling"))
        {
            DeviceData din;
            DevVarStringArray rem_attr_poll;
            rem_attr_poll.length(3);
            rem_attr_poll[0] = device1_name.c_str();
            rem_attr_poll[1] = "attribute";
            rem_attr_poll[2] = "Double_attr";
            din << rem_attr_poll;
            try
            {
                dserver->command_inout("RemObjPolling", din);
            }
            catch(DevFailed &e)
            {
                TEST_LOG << endl << "Exception in suite tearDown():" << endl;
                Except::print_exception(e);
            }
        }

        // clean up in case test suite terminates before 'IOStr1'
        // command polling state is restored to defaults for device2
        if(CxxTest::TangoPrinter::is_restore_set("dev2_IOStr1_polling"))
        {
            DeviceData din;
            DevVarStringArray rem_cmd_poll;
            rem_cmd_poll.length(3);
            rem_cmd_poll[0] = device2_name.c_str();
            rem_cmd_poll[1] = "command";
            rem_cmd_poll[2] = "IOStr1";
            din << rem_cmd_poll;
            try
            {
                dserver->command_inout("RemObjPolling", din);
            }
            catch(DevFailed &e)
            {
                TEST_LOG << endl << "Exception in suite tearDown():" << endl;
                Except::print_exception(e);
            }
        }

        // clean up in case test suite terminates before 'Double_attr'
        // attribute polling state is restored to defaults for device2
        if(CxxTest::TangoPrinter::is_restore_set("dev2_double_attr_polling"))
        {
            DeviceData din;
            DevVarStringArray rem_attr_poll;
            rem_attr_poll.length(3);
            rem_attr_poll[0] = device2_name.c_str();
            rem_attr_poll[1] = "attribute";
            rem_attr_poll[2] = "Double_attr";
            din << rem_attr_poll;
            try
            {
                dserver->command_inout("RemObjPolling", din);
            }
            catch(DevFailed &e)
            {
                TEST_LOG << endl << "Exception in suite tearDown():" << endl;
                Except::print_exception(e);
            }
        }

        // clean up in case test suite terminates before 'attr_wrong_size'
        // attribute polling state is restored to defaults for device1
        if(CxxTest::TangoPrinter::is_restore_set("dev1_attr_wrong_size_polling"))
        {
            DeviceData din;
            DevVarStringArray rem_attr_poll;
            rem_attr_poll.length(3);
            rem_attr_poll[0] = device1_name.c_str();
            rem_attr_poll[1] = "attribute";
            rem_attr_poll[2] = "attr_wrong_size";
            din << rem_attr_poll;
            try
            {
                dserver->command_inout("RemObjPolling", din);
            }
            catch(DevFailed &e)
            {
                TEST_LOG << endl << "Exception in suite tearDown():" << endl;
                Except::print_exception(e);
            }
        }

        // clean up in case test suite terminates before 'IOPollStr1'
        // command polling state is restored to defaults for device1
        if(CxxTest::TangoPrinter::is_restore_set("dev1_IOPollStr1_polling"))
        {
            DeviceData din;
            DevVarStringArray rem_cmd_poll;
            rem_cmd_poll.length(3);
            rem_cmd_poll[0] = device1_name.c_str();
            rem_cmd_poll[1] = "command";
            rem_cmd_poll[2] = "IOPollStr1";
            din << rem_cmd_poll;
            try
            {
                dserver->command_inout("RemObjPolling", din);
            }
            catch(DevFailed &e)
            {
                TEST_LOG << endl << "Exception in suite tearDown():" << endl;
                Except::print_exception(e);
            }
        }

        delete device1;
        delete dserver;
    }

    static SUITE_NAME *createSuite()
    {
        return new SUITE_NAME();
    }

    static void destroySuite(SUITE_NAME *suite)
    {
        delete suite;
    }

    //
    // Tests -------------------------------------------------------
    //

    // Test Start, Stop polling

    void test_Start_Stop_polling(void)
    {
        DeviceData dout;
        string status;

        // check if the devices are not polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices).length(), 0u);

        // check if polling is available
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("Status"));
        dout >> status;
        TS_ASSERT_EQUALS(status, "The device is ON\nThe polling is ON");

        // stop polling and check status
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("StopPolling"));
        CxxTest::TangoPrinter::restore_set("polling");
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("Status"));
        dout >> status;
        TS_ASSERT_EQUALS(status, "The device is ON\nThe polling is OFF");

        // start polling and check status
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("StartPolling"));
        CxxTest::TangoPrinter::restore_unset("polling");
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("Status"));
        dout >> status;
        TS_ASSERT_EQUALS(status, "The device is ON\nThe polling is ON");
    }

    // Test polling status for a non polled device

    void test_get_polling_status_for_a_non_polled_device(void)
    {
        DeviceData din, dout;

        // get polling status for a non existing device
        string mock_device = "toto";
        din << mock_device;
        TS_ASSERT_THROWS_ASSERT(dserver->command_inout("DevPollStatus", din),
                                Tango::DevFailed & e,
                                TS_ASSERT_EQUALS(string(e.errors[0].reason.in()), API_DeviceNotFound);
                                TS_ASSERT_EQUALS(e.errors[0].severity, Tango::ERR));

        // get polling status for a non polled device
        string status;
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status;
        TS_ASSERT_EQUALS(status, "");
    }

    // Start polling a command

    void test_start_polling_a_command(void)
    {
        DeviceData din, dout;
        DevVarLongStringArray cmd_poll;

        cmd_poll.lvalue.length(1);
        cmd_poll.lvalue[0] = 500;
        cmd_poll.svalue.length(3);
        cmd_poll.svalue[0] = device1_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;

        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_IOStr1_polling");
    }

    // Check if command polling is started

    void test_check_if_command_polling_is_started(void)
    {
        DeviceData din, dout;

        // check if the device is polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices)[0].in(), device1_name);

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // get polling status for the device
        const DevVarStringArray *status_arr;
        string status,
            status_ref = "Polled command name = IOStr1\nPolling period (mS) = 500\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status = string((*status_arr)[0].in()).substr(0, status_ref.length());
        TS_ASSERT_EQUALS(status, status_ref);
    }

    // Update command polling period

    void test_update_command_polling_period(void)
    {
        DeviceData din, dout;

        // update polling period
        DevVarLongStringArray cmd_poll;
        cmd_poll.lvalue.length(1);
        cmd_poll.lvalue[0] = 200;
        cmd_poll.svalue.length(3);
        cmd_poll.svalue[0] = device1_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("UpdObjPollingPeriod", din));

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // check if polling status has been updated
        const DevVarStringArray *status_arr;
        string status,
            status_ref = "Polled command name = IOStr1\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status = string((*status_arr)[0].in()).substr(0, status_ref.length());
        TS_ASSERT_EQUALS(status, status_ref);
    }

    // Stop polling the command

    void test_stop_polling_the_command(void)
    {
        DeviceData din, dout;

        // stop command polling
        DevVarStringArray rem_cmd_poll;
        rem_cmd_poll.length(3);
        rem_cmd_poll[0] = device1_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_IOStr1_polling");

        // confirm that the devices are not polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices).length(), 0u);
    }

    // Start polling an attribute

    void test_start_polling_an_attribute(void)
    {
        DeviceData din, dout;
        DevVarLongStringArray attr_poll;

        attr_poll.lvalue.length(1);
        attr_poll.lvalue[0] = 200;
        attr_poll.svalue.length(3);
        attr_poll.svalue[0] = device1_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "Double_attr";
        din << attr_poll;

        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_double_attr_polling");
    }

    // Check if attribute polling is started

    void test_check_if_attribute_polling_is_started(void)
    {
        DeviceData din, dout;

        // check if the device is polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices)[0].in(), device1_name);

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // get polling status for the device
        const DevVarStringArray *status_arr;
        string status,
            status_ref =
                "Polled attribute name = Double_attr\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status = string((*status_arr)[0].in()).substr(0, status_ref.length());
        TS_ASSERT_EQUALS(status, status_ref);
    }

    // Update attribute polling period

    void test_update_attribute_polling_period(void)
    {
        DeviceData din, dout;

        // update polling period
        DevVarLongStringArray attr_poll;
        attr_poll.lvalue.length(1);
        attr_poll.lvalue[0] = 500;
        attr_poll.svalue.length(3);
        attr_poll.svalue[0] = device1_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "Double_attr";
        din << attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("UpdObjPollingPeriod", din));

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // check if polling status has been updated
        const DevVarStringArray *status_arr;
        string status,
            status_ref =
                "Polled attribute name = Double_attr\nPolling period (mS) = 500\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status = string((*status_arr)[0].in()).substr(0, status_ref.length());
        TS_ASSERT_EQUALS(status, status_ref);
    }

    // Stop polling the attribute

    void test_stop_polling_the_attribute(void)
    {
        DeviceData din, dout;

        // stop attribute polling
        DevVarStringArray rem_attr_poll;
        rem_attr_poll.length(3);
        rem_attr_poll[0] = device1_name.c_str();
        rem_attr_poll[1] = "attribute";
        rem_attr_poll[2] = "Double_attr";
        din << rem_attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_double_attr_polling");

        // confirm that the devices are not polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices).length(), 0u);
    }

    // Start polling an attribute and a command

    void test_start_polling_an_attribute_and_a_command(void)
    {
        DeviceData din, dout;
        DevVarLongStringArray attr_poll, cmd_poll;

        // start polling an attribute
        attr_poll.lvalue.length(1);
        attr_poll.lvalue[0] = 200;
        attr_poll.svalue.length(3);
        attr_poll.svalue[0] = device1_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "Double_attr";
        din << attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_double_attr_polling");

        // start polling a command
        cmd_poll.lvalue.length(1);
        cmd_poll.lvalue[0] = 500;
        cmd_poll.svalue.length(3);
        cmd_poll.svalue[0] = device1_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_IOStr1_polling");
    }

    // Check if polling is started

    void test_check_if_polling_is_started(void)
    {
        DeviceData din, dout;

        // check if the device is polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices)[0].in(), device1_name);

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // get polling status for the device
        const DevVarStringArray *status_arr;
        string status[2], status_ref[2];
        status_ref[0] = "Polled command name = IOStr1\nPolling period (mS) = 500\nPolling ring buffer depth = 10";
        status_ref[1] =
            "Polled attribute name = Double_attr\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length());
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        status[1] = string((*status_arr)[1].in()).substr(0, status_ref[1].length());
        TS_ASSERT_EQUALS(status[1], status_ref[1]);
    }

    // Stop polling the attribute and the command

    void test_stop_polling_the_attribute_and_the_command(void)
    {
        DeviceData din, dout;

        // stop attribute polling
        DevVarStringArray rem_attr_poll;
        rem_attr_poll.length(3);
        rem_attr_poll[0] = device1_name.c_str();
        rem_attr_poll[1] = "attribute";
        rem_attr_poll[2] = "Double_attr";
        din << rem_attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_double_attr_polling");

        // stop command polling
        DevVarStringArray rem_cmd_poll;
        rem_cmd_poll.length(3);
        rem_cmd_poll[0] = device1_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_IOStr1_polling");

        // confirm that the devices are not polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices).length(), 0u);
    }

    // Start polling for several devices

    void test_start_polling_for_several_devices(void)
    {
        DeviceData din, dout;
        DevVarLongStringArray attr_poll, cmd_poll;

        // start polling an attribute for device1
        attr_poll.lvalue.length(1);
        attr_poll.lvalue[0] = 200;
        attr_poll.svalue.length(3);
        attr_poll.svalue[0] = device1_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "Double_attr";
        din << attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_double_attr_polling");

        // start polling a command for device1
        cmd_poll.lvalue.length(1);
        cmd_poll.lvalue[0] = 500;
        cmd_poll.svalue.length(3);
        cmd_poll.svalue[0] = device1_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_IOStr1_polling");

        // start polling an attribute for device2
        attr_poll.lvalue[0] = 200;
        attr_poll.svalue[0] = device2_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "Double_attr";
        din << attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev2_double_attr_polling");

        // start polling a command for device2
        cmd_poll.lvalue[0] = 500;
        cmd_poll.svalue[0] = device2_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev2_IOStr1_polling");
    }

    // Check if polling for several devices is started

    void test_check_if_polling_for_serveral_devices_is_started(void)
    {
        DeviceData din, dout;

        // check if the devices are polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices)[0].in(), device1_name);
        TS_ASSERT_EQUALS((*polled_devices)[1].in(), device2_name);

        std::this_thread::sleep_for(std::chrono::seconds(3));

        const DevVarStringArray *status_arr;
        string status[2], status_ref[2];

        // get polling status for the device1
        status_ref[0] = "Polled command name = IOStr1\nPolling period (mS) = 500\nPolling ring buffer depth = 10";
        status_ref[1] =
            "Polled attribute name = Double_attr\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length());
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        status[1] = string((*status_arr)[1].in()).substr(0, status_ref[1].length());
        TS_ASSERT_EQUALS(status[1], status_ref[1]);

        // get polling status for the device2
        din << device2_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length());
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        status[1] = string((*status_arr)[1].in()).substr(0, status_ref[1].length());
        TS_ASSERT_EQUALS(status[1], status_ref[1]);
    }

    // Stop polling for several devices

    void test_stop_polling_for_several_devices(void)
    {
        DeviceData din, dout;
        DevVarStringArray rem_attr_poll, rem_cmd_poll;

        // stop attribute polling for device1
        rem_attr_poll.length(3);
        rem_attr_poll[0] = device1_name.c_str();
        rem_attr_poll[1] = "attribute";
        rem_attr_poll[2] = "Double_attr";
        din << rem_attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_double_attr_polling");

        // stop command polling for device1
        rem_cmd_poll.length(3);
        rem_cmd_poll[0] = device1_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_IOStr1_polling");

        // stop attribute polling for device2
        rem_attr_poll[0] = device2_name.c_str();
        rem_attr_poll[1] = "attribute";
        rem_attr_poll[2] = "Double_attr";
        din << rem_attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev2_double_attr_polling");

        // stop command polling for device2
        rem_cmd_poll[0] = device2_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev2_IOStr1_polling");

        // confirm that the devices are not polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices).length(), 0u);
    }

    // Test device polling after a restart

    void test_device_polling_after_a_restart(void)
    {
        DeviceData din, dout;
        DevVarLongStringArray attr_poll, cmd_poll;
        const DevVarStringArray *polled_devices;

        // start polling an attribute
        attr_poll.lvalue.length(1);
        attr_poll.lvalue[0] = 200;
        attr_poll.svalue.length(3);
        attr_poll.svalue[0] = device1_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "Double_attr";
        din << attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_double_attr_polling");

        // start polling a command
        cmd_poll.lvalue.length(1);
        cmd_poll.lvalue[0] = 500;
        cmd_poll.svalue.length(3);
        cmd_poll.svalue[0] = device1_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_IOStr1_polling");

        // restart the device
        std::this_thread::sleep_for(std::chrono::seconds(3));
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("DevRestart", din));
        std::this_thread::sleep_for(std::chrono::seconds(3));

        // check device polling after a restart
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices)[0].in(), device1_name);

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // get polling status for the device
        const DevVarStringArray *status_arr;
        string status[2], status_ref[2];
        status_ref[0] = "Polled command name = IOStr1\nPolling period (mS) = 500\nPolling ring buffer depth = 10";
        status_ref[1] =
            "Polled attribute name = Double_attr\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length());
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        status[1] = string((*status_arr)[1].in()).substr(0, status_ref[1].length());
        TS_ASSERT_EQUALS(status[1], status_ref[1]);

        // stop attribute polling
        DevVarStringArray rem_attr_poll;
        rem_attr_poll.length(3);
        rem_attr_poll[0] = device1_name.c_str();
        rem_attr_poll[1] = "attribute";
        rem_attr_poll[2] = "Double_attr";
        din << rem_attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_double_attr_polling");

        // stop command polling
        DevVarStringArray rem_cmd_poll;
        rem_cmd_poll.length(3);
        rem_cmd_poll[0] = device1_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_IOStr1_polling");

        // confirm that the device is not polled
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices).length(), 0u);
    }

    // Poll object which returns an exception

    void test_poll_object_which_returns_an_exception(void)
    {
        DeviceData din, dout;
        DevVarLongStringArray attr_poll, cmd_poll;
        const DevVarStringArray *polled_devices, *status_arr;
        string status[2], status_ref[2], status_arr_str;
        size_t pos;

        // start polling an attribute
        attr_poll.lvalue.length(1);
        attr_poll.lvalue[0] = 200;
        attr_poll.svalue.length(3);
        attr_poll.svalue[0] = device1_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "attr_wrong_size";
        din << attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_attr_wrong_size_polling");

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // get polling status for the device
        status_ref[0] =
            "Polled attribute name = attr_wrong_size\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        status_ref[1] = "Last attribute read FAILED :\n\tReason = API_AttrOptProp\n\tDesc = Data size for attribute "
                        "attr_wrong_size [1000, 1000] exceeds given limit [1, 0]";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        status_arr_str = (*status_arr)[0].in();
        // extract the first and the last 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other, middle 3 lines could also be compared
        status[0] = status_arr_str.substr(0, status_ref[0].length()); // first 3 lines
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        pos = status_arr_str.rfind("\n");
        if(pos != string::npos)
        {
            status_arr_str.erase(pos);
        }
        status[1] = status_arr_str.substr(status_arr_str.length() - status_ref[1].length(),
                                          status_ref[1].length()); // last 3 lines
        TS_ASSERT_EQUALS(status[1], status_ref[1]);

        // restart the device
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("DevRestart", din));
        std::this_thread::sleep_for(std::chrono::seconds(3));

        // again get polling status for the device
        status_ref[0] =
            "Polled attribute name = attr_wrong_size\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        status_ref[1] = "Last attribute read FAILED :\n\tReason = API_AttrOptProp\n\tDesc = Data size for attribute "
                        "attr_wrong_size [1000, 1000] exceeds given limit [1, 0]";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        status_arr_str = (*status_arr)[0].in();
        // extract the first and the last 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other, middle 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length()); // first 3 lines
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        pos = status_arr_str.rfind("\n");
        if(pos != string::npos)
        {
            status_arr_str.erase(pos);
        }
        status[1] = status_arr_str.substr(status_arr_str.length() - status_ref[1].length(),
                                          status_ref[1].length()); // last 3 lines
        TS_ASSERT_EQUALS(status[1], status_ref[1]);

        // stop attribute polling
        DevVarStringArray rem_attr_poll;
        rem_attr_poll.length(3);
        rem_attr_poll[0] = device1_name.c_str();
        rem_attr_poll[1] = "attribute";
        rem_attr_poll[2] = "attr_wrong_size";
        din << rem_attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_attr_wrong_size_polling");

        // confirm that the device is not polled
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices).length(), 0u);
    }

    // Start polling for several devices (test the ServerRestart command)

    void test_polling_for_several_devices_after_a_ServerRestart(void)
    {
        DeviceData din, dout;
        DevVarLongStringArray attr_poll, cmd_poll;
        const DevVarStringArray *status_arr, *polled_devices;
        string status[2], status_ref[2];

        // start polling an attribute for device1
        attr_poll.lvalue.length(1);
        attr_poll.lvalue[0] = 200;
        attr_poll.svalue.length(3);
        attr_poll.svalue[0] = device1_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "Double_attr";
        din << attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_double_attr_polling");

        // start polling a command for device1
        cmd_poll.lvalue.length(1);
        cmd_poll.lvalue[0] = 500;
        cmd_poll.svalue.length(3);
        cmd_poll.svalue[0] = device1_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_IOStr1_polling");

        // start polling an attribute for device2
        attr_poll.lvalue[0] = 200;
        attr_poll.svalue[0] = device2_name.c_str();
        attr_poll.svalue[1] = "attribute";
        attr_poll.svalue[2] = "Double_attr";
        din << attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev2_double_attr_polling");

        // start polling a command for device2
        cmd_poll.lvalue[0] = 500;
        cmd_poll.svalue[0] = device2_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev2_IOStr1_polling");

        // check if the devices are polled
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices)[0].in(), device1_name);
        TS_ASSERT_EQUALS((*polled_devices)[1].in(), device2_name);

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // get polling status for the device1
        status_ref[0] = "Polled command name = IOStr1\nPolling period (mS) = 500\nPolling ring buffer depth = 10";
        status_ref[1] =
            "Polled attribute name = Double_attr\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length());
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        status[1] = string((*status_arr)[1].in()).substr(0, status_ref[1].length());
        TS_ASSERT_EQUALS(status[1], status_ref[1]);

        // get polling status for the device2
        din << device2_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length());
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        status[1] = string((*status_arr)[1].in()).substr(0, status_ref[1].length());
        TS_ASSERT_EQUALS(status[1], status_ref[1]);

        // restart server
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RestartServer"));
        std::this_thread::sleep_for(std::chrono::seconds(5));

        // check if the devices are still polled
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices)[0].in(), device1_name);
        TS_ASSERT_EQUALS((*polled_devices)[1].in(), device2_name);

        std::this_thread::sleep_for(std::chrono::seconds(3));

        // get polling status for the device1
        status_ref[0] = "Polled command name = IOStr1\nPolling period (mS) = 500\nPolling ring buffer depth = 10";
        status_ref[1] =
            "Polled attribute name = Double_attr\nPolling period (mS) = 200\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length());
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        status[1] = string((*status_arr)[1].in()).substr(0, status_ref[1].length());
        TS_ASSERT_EQUALS(status[1], status_ref[1]);

        // get polling status for the device2
        din << device2_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other 3 lines could also be compared
        status[0] = string((*status_arr)[0].in()).substr(0, status_ref[0].length());
        TS_ASSERT_EQUALS(status[0], status_ref[0]);
        status[1] = string((*status_arr)[1].in()).substr(0, status_ref[1].length());
        TS_ASSERT_EQUALS(status[1], status_ref[1]);

        DevVarStringArray rem_attr_poll, rem_cmd_poll;

        // stop attribute polling for device1
        rem_attr_poll.length(3);
        rem_attr_poll[0] = device1_name.c_str();
        rem_attr_poll[1] = "attribute";
        rem_attr_poll[2] = "Double_attr";
        din << rem_attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_double_attr_polling");

        // stop command polling for device1
        rem_cmd_poll.length(3);
        rem_cmd_poll[0] = device1_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_IOStr1_polling");

        // stop attribute polling for device2
        rem_attr_poll[0] = device2_name.c_str();
        rem_attr_poll[1] = "attribute";
        rem_attr_poll[2] = "Double_attr";
        din << rem_attr_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev2_double_attr_polling");

        // stop command polling for device2
        rem_cmd_poll[0] = device2_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev2_IOStr1_polling");

        // confirm that the devices are not polled
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices).length(), 0u);
    }

    // Start a command externally triggered

    void test_start_a_command_externally_triggered(void)
    {
        DeviceData din, dout;
        const DevVarStringArray *status_arr;
        DevVarLongStringArray cmd_poll;
        DevVarStringArray rem_cmd_poll;
        string status, status_ref;

        // start externally triggered command
        cmd_poll.lvalue.length(1);
        cmd_poll.lvalue[0] = 0;
        cmd_poll.svalue.length(3);
        cmd_poll.svalue[0] = device1_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_IOStr1_polling");

        // check if the device is polled
        const DevVarStringArray *polled_devices;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("PolledDevice"));
        dout >> polled_devices;
        TS_ASSERT_EQUALS((*polled_devices)[0].in(), device1_name);

        // get polling status for the device
        status_ref = "Polled command name = IOStr1\nPolling externally triggered\nPolling ring buffer depth = 10\nNo "
                     "data recorded yet";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        status = (*status_arr)[0].in();
        TS_ASSERT_EQUALS(status, status_ref);

        // trigger polling for a non-existing command
        string mock_command = "toto";
        din << mock_command;
        TS_ASSERT_THROWS_ASSERT(device1->command_inout("IOTrigPoll", din),
                                Tango::DevFailed & e,
                                TS_ASSERT_EQUALS(string(e.errors[0].reason.in()), API_PollObjNotFound);
                                TS_ASSERT_EQUALS(e.errors[0].severity, Tango::ERR));

        // trigger polling for a non-polled command
        string non_polled_command = "IOPollStr1";
        din << non_polled_command;
        TS_ASSERT_THROWS_ASSERT(device1->command_inout("IOTrigPoll", din),
                                Tango::DevFailed & e,
                                TS_ASSERT_EQUALS(string(e.errors[0].reason.in()), API_PollObjNotFound);
                                TS_ASSERT_EQUALS(e.errors[0].severity, Tango::ERR));

        // add polling for a non externally triggered command
        cmd_poll.lvalue[0] = 500;
        cmd_poll.svalue.length(3);
        cmd_poll.svalue[0] = device1_name.c_str();
        cmd_poll.svalue[1] = "command";
        cmd_poll.svalue[2] = "IOPollStr1";
        din << cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("AddObjPolling", din));
        CxxTest::TangoPrinter::restore_set("dev1_IOPollStr1_polling");

        // trigger polling for the not externally triggered command
        string non_ext_trig_command = "IOPollStr1";
        din << non_ext_trig_command;
        TS_ASSERT_THROWS_ASSERT(device1->command_inout("IOTrigPoll", din),
                                Tango::DevFailed & e,
                                TS_ASSERT_EQUALS(string(e.errors[0].reason.in()), API_NotSupported);
                                TS_ASSERT_EQUALS(e.errors[0].severity, Tango::ERR));

        // stop polling for the non externally triggered command
        rem_cmd_poll.length(3);
        rem_cmd_poll[0] = device1_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOPollStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_IOPollStr1_polling");

        // trigger polling for the externally triggered command twice
        string ext_trig_command = "IOStr1";
        din << ext_trig_command;
        TS_ASSERT_THROWS_NOTHING(device1->command_inout("IOTrigPoll", din));
        TS_ASSERT_THROWS_NOTHING(device1->command_inout("IOTrigPoll", din));

        // get polling status
        status_ref = "Polled command name = IOStr1\nPolling externally triggered\nPolling ring buffer depth = 10";
        din << device1_name;
        TS_ASSERT_THROWS_NOTHING(dout = dserver->command_inout("DevPollStatus", din));
        dout >> status_arr;
        // extract the first 3 lines of the status and compare with the reference string
        // TODO: although device/time dependent, the other line could also be compared
        status = string((*status_arr)[0].in()).substr(0, status_ref.length());
        TS_ASSERT_EQUALS(status, status_ref);

        // stop polling for the externally triggered command
        rem_cmd_poll[0] = device1_name.c_str();
        rem_cmd_poll[1] = "command";
        rem_cmd_poll[2] = "IOStr1";
        din << rem_cmd_poll;
        TS_ASSERT_THROWS_NOTHING(dserver->command_inout("RemObjPolling", din));
        CxxTest::TangoPrinter::restore_unset("dev1_IOStr1_polling");
    }
};

// NOLINTEND(*)