plIpcChannel Class Reference

Base class for a communication channel between processes. More...

#include <IpcChannel.h>

Classes
struct	ConnectionState
struct	Mode

Public Types
using	ReceiveCallback = plDelegate<void(plArrayPtr<const plUInt8> message)>

Public Member Functions
void	Connect ()
	Connects async. On success, m_Events will be broadcasted.
void	Disconnect ()
	Disconnect async. On completion, m_Events will be broadcasted.
bool	IsConnected () const
	Returns whether we have a connection.
plEnum< ConnectionState >	GetConnectionState () const
	Returns the current state of the connection.
bool	Send (plArrayPtr< const plUInt8 > data)
	Sends a message. pMsg can be destroyed after the call.
void	SetReceiveCallback (ReceiveCallback callback)
plResult	WaitForMessages (plTime timeout)
	Block and wait for new messages and call ProcessMessages.

Static Public Member Functions
static plInternal::NewInstance< plIpcChannel >	CreatePipeChannel (plStringView sAddress, Mode::Enum mode)
	Creates an IPC communication channel using pipes.
static plInternal::NewInstance< plIpcChannel >	CreateNetworkChannel (plStringView sAddress, Mode::Enum mode)

Public Attributes
plEvent< const plIpcChannelEvent &, plMutex >	m_Events
	Will be sent from any thread.

Protected Types
enum	Constants : plUInt32 { HEADER_SIZE = 8 , MAGIC_VALUE = 'USED' , MAX_MESSAGE_SIZE = 1024 * 1024 * 16 }

Protected Member Functions
	plIpcChannel (plStringView sAddress, Mode::Enum mode)
virtual bool	RequiresRegularTick ()
	Override this and return true, if the surrounding infrastructure should call the 'Tick()' function.
virtual void	Tick ()
	Can implement regular updates, e.g. for polling network state.
virtual void	InternalConnect ()=0
	Called on worker thread after Connect was called.
virtual void	InternalDisconnect ()=0
	Called on worker thread after Disconnect was called.
virtual void	InternalSend ()=0
	Called on worker thread to sent pending messages.
virtual bool	NeedWakeup () const =0
	Called by Send to determine whether the message loop need to be woken up.
void	SetConnectionState (plEnum< ConnectionState > state)
void	ReceiveData (plArrayPtr< const plUInt8 > data)
	Implementation needs to call this when new data has been received. data can be invalidated after the function.
void	FlushPendingOperations ()

Protected Attributes
plThreadID	m_ThreadId = 0
plAtomicInteger< ConnectionState::Enum >	m_iConnectionState = ConnectionState::Disconnected
plString	m_sAddress
const plEnum< Mode >	m_Mode
plMessageLoop *	m_pOwner = nullptr
plMutex	m_OutputQueueMutex
plDeque< plContiguousMemoryStreamStorage >	m_OutputQueue
plDynamicArray< plUInt8 >	m_MessageAccumulator
	Message is assembled in here.
plMutex	m_ReceiveCallbackMutex
ReceiveCallback	m_ReceiveCallback
plThreadSignal	m_IncomingMessages

Friends
class	plMessageLoop

Detailed Description

Base class for a communication channel between processes.

The channel allows for byte blobs to be send back and forth between two processes. A client should only try to connect to a server once the server has changed to ConnectionState::Connecting as this indicates the server is ready to be conneccted to.

Use plIpcChannel:CreatePipeChannel to create an IPC pipe instance. To send more complex messages accross, you can create a plIpcProcessMessageProtocol on top of the channel.

Member Enumeration Documentation

Constants

enum plIpcChannel::Constants : plUInt32

protected

Enumerator
HEADER_SIZE	Magic value and size plUint32.
MAGIC_VALUE	Magic value.
MAX_MESSAGE_SIZE	Arbitrary message size limit.

Member Function Documentation

CreatePipeChannel()

plInternal::NewInstance< plIpcChannel > plIpcChannel::CreatePipeChannel ( plStringView sAddress, Mode::Enum mode )

static

Creates an IPC communication channel using pipes.

Parameters

szAddress	Name of the pipe, must be unique on a system and less than 200 characters.
mode	Whether to run in client or server mode.

---

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

• Code/Engine/Foundation/Communication/IpcChannel.h
• Code/Engine/Foundation/Communication/Implementation/IpcChannel.cpp