Method ReqQueueMain

src/tests/dbus/request-queue-service.cpp:112–176

    using Ptr = std::shared_ptr<ReqQueueMain>;

    ReqQueueMain(DBus::Connection::Ptr conn,
                 const std::string &path,
                 const std::string &interface,
                 std::shared_ptr<std::ostream> log_)
        : DBus::Object::Base(path, interface),
          dbuscon(conn), log(*log_)
    {
        queue = RequiresQueueDebug::Create();
        queue->QueueSetup(this,
                          "t_QueueCheckTypeGroup",
                          "t_QueueFetch",
                          "t_QueueCheck",
                          "t_ProvideResponse");
        queue->AddCallback(
            RequiresQueue::CallbackType::CHECK_TYPE_GROUP,
            [this]()
            {
                this->cb_counters[RequiresQueue::CallbackType::CHECK_TYPE_GROUP]++;
            });
        queue->AddCallback(
            RequiresQueue::CallbackType::QUEUE_CHECK,
            [this]()
            {
                this->cb_counters[RequiresQueue::CallbackType::QUEUE_CHECK]++;
            });
        queue->AddCallback(
            RequiresQueue::CallbackType::QUEUE_FETCH,
            [this]()
            {
                this->cb_counters[RequiresQueue::CallbackType::QUEUE_FETCH]++;
            });
        queue->AddCallback(
            RequiresQueue::CallbackType::PROVIDE_RESPONSE,
            [this]()
            {
                this->cb_counters[RequiresQueue::CallbackType::PROVIDE_RESPONSE]++;
            });

        init();

        AddMethod("ServerDumpResponse",
                  [this](DBus::Object::Method::Arguments::Ptr args)
                  {
                      std::lock_guard<std::mutex> lg(init_mtx);
                      queue->_DumpQueue(log);
                      args->SetMethodReturn(nullptr);
                  });

        AddMethod("Init",
                  [this](DBus::Object::Method::Arguments::Ptr args)
                  {
                      this->init();
                      args->SetMethodReturn(nullptr);
                  });

        auto validate = AddMethod("Validate",
                                  [this](DBus::Object::Method::Arguments::Ptr args)
                                  {