#include <container_ipc.hpp>

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

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

	PeMessageQueue ()
	The PeMessageQueue class is a thread-safe queue for PeScan messages.

	~PeMessageQueue ()

Detailed Description

Definition at line 10 of file container_ipc.hpp.

Constructor & Destructor Documentation

◆ PeMessageQueue()

PeMessageQueue::PeMessageQueue ( )

The PeMessageQueue class is a thread-safe queue for PeScan messages.

Parameters

message The PeScan message to enqueue.

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

Definition at line 13 of file ext_server.cpp.

                               {
    InitializeCriticalSection(&cs_);
    InitializeConditionVariable(&cv_);
}

◆ ~PeMessageQueue()

PeMessageQueue::~PeMessageQueue ( )

inline

Definition at line 15 of file container_ipc.hpp.

                      {
        DeleteCriticalSection(&cs_);
    }

Member Function Documentation

◆ dequeue()

PeScan PeMessageQueue::dequeue ( )

The dequeue function dequeues a PeScan messages from the queue.

Returns: The PeScan message that is dequeued.

Definition at line 31 of file ext_server.cpp.

                               {
    EnterCriticalSection(&cs_);
    while (queue_.empty()) {
        std::cout << "Queue empty, waiting..." << std::endl;
        SleepConditionVariableCS(&cv_, &cs_, INFINITE);
    }
    PeScan message = queue_.front();
    queue_.pop();
    // std::cout << "Dequeued item. Remaining queue size: " << queue_.size() << std::endl;
    LeaveCriticalSection(&cs_);
    return message;
}

Referenced by MessageQueueThread().

◆ enqueue()

void PeMessageQueue::enqueue ( const PeScan & message )

The enqueue function is a function that enqueues a PeScan message to the queue.