StormByte::Buffer::Producer Class Reference

A write-only interface for accessing a shared buffer. More...

#include <producer.hxx>

Public Member Functions
	Producer () noexcept
	Default constructor.
	Producer (const Shared &shared) noexcept
	Producer (Shared &&shared) noexcept
	Producer (const Producer &other)=default
	Deleted copy constructor.
	Producer (Producer &&other) noexcept=default
	Default move constructor.
	~Producer () noexcept=default
	Destructor.
Producer &	operator= (const Producer &other)=default
	Deleted copy assignment operator.
Producer &	operator= (Producer &&other) noexcept=default
	Default move assignment operator.
Producer &	operator<< (const Status &status)
	Sets the buffer status.
Producer &	operator<< (const Simple &buffer)
	Appends a buffer to the current buffer.
Producer &	operator<< (Simple &&buffer)
	Moves a buffer and appends it to the current buffer.
Producer &	operator<< (const std::string &data)
	Appends a string to the current shared buffer.
Producer &	operator<< (const Buffer::Data &data)
	Appends a byte vector to the current shared buffer.
Producer &	operator<< (Buffer::Data &&data)
	Moves a byte vector and appends it to the current shared buffer.
Consumer	Consumer () const
	Gets the consumer interface to consume this buffer.
void	Lock ()
	Locks the shared buffer for exclusive access. Prevents other threads from reading or writing to the buffer until Unlock() is called.
void	Reserve (const std::size_t &size)
	Reserves shared buffer size.
void	Unlock ()
	Unlocks the shared buffer, releasing exclusive access. Allows other threads to access the buffer after it has been locked using Lock().
Write::Status	Write (const Simple &buffer)
	Writes a simple buffer to the current shared buffer.
Write::Status	Write (Simple &&buffer)
	Moves a simple buffer and writes it to the current shared buffer.
Write::Status	Write (const std::string &data)
	Writes a string to the current shared buffer.
Write::Status	Write (const Buffer::Data &data)
	Writes a byte vector to the current shared buffer.
Write::Status	Write (Buffer::Data &&data)
	Moves a byte vector and writes it to the current shared buffer.

Detailed Description

A write-only interface for accessing a shared buffer.

Forward declaration of the Producer class.

The Producer class provides a thread-safe, write-only interface for modifying data in a shared buffer. Unlike Consumer, empty Producer instances can be created directly. This allows for flexibility in scenarios where a producer needs to be initialized without an associated shared buffer.

Key Features:

• Write-Only Access: Allows only write operations on the buffer.
• Non-Copyable: Instances of Producer cannot be copied to ensure data integrity.
• Thread-Safe: All operations are thread-safe and synchronized using the underlying Shared buffer.
• Buffer Status Management: Producers are responsible for setting the buffer status (e.g., Status::EoF or Status::Error) to indicate to consumers that they should stop processing. Failing to do so might cause consumers to wait indefinitely for incoming data.
• Consumer Creation: The only way to create a Consumer instance is via the Consumer method of this class, which returns a Consumer instance bound to this producer's buffer.
• Shared Buffer Behavior: While the class is designed to have only one producer and one consumer instance, if Producer instances are copied, they will share the same buffer. This is allowed, but it is up to the user to ensure that the produced-consumed data flow remains in sync.

Constructor & Destructor Documentation

Producer() [1/3]

StormByte::Buffer::Producer::Producer ( )

noexcept

Default constructor.

Initializes an empty producer buffer. Unlike Consumer, empty Producer instances can be created directly. This allows for flexibility in scenarios where a producer needs to be initialized without an associated shared buffer.

Producer() [2/3]

StormByte::Buffer::Producer::Producer ( const Producer &  other )

default

Deleted copy constructor.

The Producer class cannot be copied to ensure data integrity and prevent unintended sharing of the buffer.

Producer() [3/3]

StormByte::Buffer::Producer::Producer ( Producer &&  other )

defaultnoexcept

Default move constructor.

Allows moving a Producer instance. The moved-from instance is left in a valid but unspecified state.

~Producer()

StormByte::Buffer::Producer::~Producer ( )

defaultnoexcept

Destructor.

Cleans up the Producer instance. The destructor ensures that any resources held by the Producer are properly released.

Member Function Documentation

Consumer()

Consumer StormByte::Buffer::Producer::Consumer

(

)

const

Gets the consumer interface to consume this buffer.

Creates and returns a Consumer instance that is bound to this producer's shared buffer. The returned Consumer instance allows read-only access to the buffer.

Returns

A Consumer instance bound to this producer's buffer.

operator<<() [1/6]

Producer & StormByte::Buffer::Producer::operator<<

(

Buffer::Data &&

data

)

Moves a byte vector and appends it to the current shared buffer.

Parameters

data	The byte vector to append.

Returns

Reference to the updated producer.

operator<<() [2/6]

Producer & StormByte::Buffer::Producer::operator<<

(

const Buffer::Data &

data

)

Appends a byte vector to the current shared buffer.

Parameters

data	The byte vector to append.

Returns

Reference to the updated producer.

operator<<() [3/6]

Producer & StormByte::Buffer::Producer::operator<<

(

const Simple &

buffer

)

Appends a buffer to the current buffer.

Parameters

buffer

The buffer to append.

Returns

Reference to the updated producer.

operator<<() [4/6]

Producer & StormByte::Buffer::Producer::operator<<

(

const Status &

status

)

Sets the buffer status.

See also

Buffer::Status

operator<<() [5/6]

Producer & StormByte::Buffer::Producer::operator<<

(

const std::string &

data

)

Appends a string to the current shared buffer.

Parameters

data	The string to append.

Returns

Reference to the updated producer.

operator<<() [6/6]

Producer & StormByte::Buffer::Producer::operator<<

(

Simple &&

buffer

)

Moves a buffer and appends it to the current buffer.

Parameters

buffer

The buffer to append.

Returns

Reference to the updated producer.

operator=() [1/2]

Producer & StormByte::Buffer::Producer::operator= ( const Producer &  other )

default

Deleted copy assignment operator.

The Producer class cannot be copied to ensure data integrity and prevent unintended sharing of the buffer.

operator=() [2/2]

Producer & StormByte::Buffer::Producer::operator= ( Producer &&  other )

defaultnoexcept

Default move assignment operator.

Allows moving a Producer instance. The moved-from instance is left in a valid but unspecified state.

Reserve()

void StormByte::Buffer::Producer::Reserve

(

const std::size_t &

size

)

Reserves shared buffer size.

Parameters

size	The size to reserve.

Write() [1/5]

Write::Status StormByte::Buffer::Producer::Write

(

Buffer::Data &&

data

)

Moves a byte vector and writes it to the current shared buffer.

Parameters

data	The byte vector to write.

Returns

Write::Status of the operation.

Write() [2/5]

Write::Status StormByte::Buffer::Producer::Write

(

const Buffer::Data &

data

)

Writes a byte vector to the current shared buffer.

Parameters

data	The byte vector to write.

Returns

Write::Status of the operation.

Write() [3/5]

Write::Status StormByte::Buffer::Producer::Write

(

const Simple &

buffer

)

Writes a simple buffer to the current shared buffer.

Parameters

buffer

The simple buffer to write.

Returns

Write::Status of the operation.

Write() [4/5]

Write::Status StormByte::Buffer::Producer::Write

(

const std::string &

data

)

Writes a string to the current shared buffer.

Parameters

data	The string to write.

Returns

Write::Status of the operation.

Write() [5/5]

Write::Status StormByte::Buffer::Producer::Write

(

Simple &&

buffer

)

Moves a simple buffer and writes it to the current shared buffer.

Parameters

buffer

The simple buffer to write.

Returns

Write::Status of the operation.

---

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

• /home/runner/work/StormByte/StormByte/lib/public/StormByte/buffer/producer.hxx