BatchClient.hpp

Go to the documentation of this file.

/*
 * Copyright (c) 2015 - 2024 Intel Corporation
 * SPDX-License-Identifier: BSD-3-Clause
 */
 
#ifndef BATCHCLIENT_HPP_INCLUDE
#define BATCHCLIENT_HPP_INCLUDE
 
#include <memory>
#include <vector>
#include <signal.h>
 
struct geopm_request_s;
 
namespace geopm
{
    class SharedMemory;
    class BatchStatus;
 
    class BatchClient
    {
        public:
            BatchClient() = default;
            virtual ~BatchClient() = default;
 
            static std::unique_ptr<BatchClient> make_unique(const std::string &server_key,
                                                            double timeout,
                                                            int num_signal,
                                                            int num_control);
 
            virtual std::vector<double> read_batch(void) = 0;
 
            virtual void write_batch(std::vector<double> settings) = 0;
 
            virtual void stop_batch(void) = 0;
    };
 
    class BatchClientImp : public BatchClient
    {
        public:
            BatchClientImp(const std::string &server_key, double timeout,
                           int num_signal, int num_control);
            BatchClientImp(int num_signal, int num_control,
                           std::shared_ptr<BatchStatus> batch_status,
                           std::shared_ptr<SharedMemory> signal_shmem,
                           std::shared_ptr<SharedMemory> control_shmem);
            virtual ~BatchClientImp() = default;
            std::vector<double> read_batch(void) override;
            void write_batch(std::vector<double> settings) override;
            void stop_batch(void) override;
        private:
            int m_num_signal;
            int m_num_control;
            std::shared_ptr<BatchStatus> m_batch_status;
            std::shared_ptr<SharedMemory> m_signal_shmem;
            std::shared_ptr<SharedMemory> m_control_shmem;
    };
}
 
#endif