IpcBlockingPriorityQueue.hpp

/*
Copyright (c) 2017-2018,
Battelle Memorial Institute; Lawrence Livermore National Security, LLC; Alliance for Sustainable
Energy, LLC All rights reserved. See LICENSE file and DISCLAIMER for more details.
*/
#pragma once
 
#include "helics/external/optional.hpp"
 
#include <boost/interprocess/mapped_region.hpp>
#include <boost/interprocess/shared_memory_object.hpp>
#include <boost/interprocess/sync/interprocess_condition.hpp>
#include <boost/interprocess/sync/interprocess_mutex.hpp>
#include <boost/interprocess/sync/scoped_lock.hpp>
#include <chrono>
#include <utility>
 
namespace helics {
namespace ipc {
 
    class IpcBlockingPriorityQueue {
      private:
      public:
        IpcBlockingPriorityQueue(void* dataBlock, size_t blockSize);
 
        void clear();
 
        IpcBlockingPriorityQueue(const IpcBlockingPriorityQueue&) = delete;
        IpcBlockingPriorityQueue& operator=(const IpcBlockingPriorityQueue&) = delete;
 
        void push(const unsigned char* data, size_t size);
        void pushPriority(const unsigned char* data, size_t size);
        bool try_push(const unsigned char* data, size_t size);
 
        bool try_pushPriority(const unsigned char* data, size_t size);
 
        stx::optional<std::pair<unsigned char*, int>> try_peek() const;
 
        bool try_pop(unsigned char* data, int maxSize);
 
        int pop(unsigned char* data, int maxSize);
 
        void pop(std::chrono::milliseconds timeout, unsigned char* data, int maxSize);
 
        bool empty() const;
    };
 
}  // namespace ipc
}  // namespace helics