#include <container_ipc.hpp>

Public Member Functions
void	enqueue (const MemScan &message)
	The enqueue function enqueues a MemScan message to the queue.

MemScan	dequeue ()
	The dequeue function dequeues a MemScan messages from the queue.

Public Attributes
std::condition_variable	cv

Detailed Description

Definition at line 24 of file container_ipc.hpp.

Member Function Documentation

◆ dequeue()

MemScan MemoryMessageQueue::dequeue ( )

The dequeue function dequeues a MemScan messages from the queue.

Returns: The MemScan message that is dequeued.

Definition at line 55 of file ext_server.cpp.

                                    {
    std::unique_lock<std::mutex> lock(mutex_);
    cv_.wait(lock, [this] { return !queue_.empty(); });
    MemScan message = queue_.front();
    queue_.pop();
 
    return message;
}

◆ enqueue()

void MemoryMessageQueue::enqueue ( const MemScan & message )

The enqueue function enqueues a MemScan message to the queue.

Parameters

message The MemScan message to enqueue.

Returns: True if the message is enqueued successfully, false otherwise.

Definition at line 47 of file ext_server.cpp.

                                                       {
    std::unique_lock<std::mutex> lock(mutex_);
    queue_.push(message);
    cv_.notify_one();
}

Member Data Documentation

◆ cv

std::condition_variable MemoryMessageQueue::cv

Definition at line 26 of file container_ipc.hpp.

The documentation for this class was generated from the following files:

/home/runner/work/Panoptes/Panoptes/src/container/include/container_ipc.hpp
/home/runner/work/Panoptes/Panoptes/src/container/src/ext_server.cpp