request_worker.h

Go to the documentation of this file.

// Copyright (c) 2018, Smart Projects Holdings Ltd
// All rights reserved.
// See LICENSE file for license details.

#ifndef _UGCS_VSM_REQUEST_WORKER_H_
#define _UGCS_VSM_REQUEST_WORKER_H_

#include <ugcs/vsm/request_context.h>

#include <thread>

namespace ugcs {
namespace vsm {

class Request_worker: public Request_completion_context {
    DEFINE_COMMON_CLASS(Request_worker, Request_container)

public:
    Request_worker(const std::string& name) :
        Request_completion_context(name) {}

    Request_worker(
            const std::string& name,
            const std::initializer_list<Request_container::Ptr> &containers);

    Request_worker(
            const std::string& name,
            const std::list<Request_container::Ptr> &containers);

    virtual Type
    Get_type() const override
    {
        return Type::ANY;
    }

    void
    Enable_containers();

    void
    Disable_containers();

private:
    std::thread thread;
    std::list<Request_container::Ptr> containers;

    virtual void
    On_enable() override;

    virtual void
    On_disable() override;

    virtual void
    On_wait_and_process() override;

    virtual void
    Process_request(Request::Ptr request) override;
};

} /* namespace vsm */
} /* namespace ugcs */

#endif /* _UGCS_VSM_REQUEST_WORKER_H_ */