ShmemInputStreamImpl Class Reference

#include <shmem_carrier/ShmemInputStream.h>

Public Member Functions
	ShmemInputStreamImpl ()
	~ShmemInputStreamImpl ()
bool	isOk () const
bool	open (int port, ACE_SOCK_Stream *pSock, int size=4096)
yarp::conf::ssize_t	read (yarp::os::Bytes &b)
void	close ()

Protected Member Functions
int	read (char *data, int len)
bool	Resize ()

Protected Attributes
bool	m_bOpen
int	m_ResizeNum
int	m_Port
ACE_Process_Mutex *	m_pAccessMutex
ACE_Process_Mutex *	m_pWaitDataMutex
std::mutex	m_ReadSerializerMutex
ACE_Shared_Memory *	m_pMap
char *	m_pData
ShmemHeader_t *	m_pHeader
ACE_SOCK_Stream *	m_pSock

Detailed Description

Definition at line 40 of file ShmemInputStream.h.

Constructor & Destructor Documentation

ShmemInputStreamImpl()

ShmemInputStreamImpl::ShmemInputStreamImpl

(

)

Definition at line 24 of file ShmemInputStream.cpp.

~ShmemInputStreamImpl()

ShmemInputStreamImpl::~ShmemInputStreamImpl

(

)

Definition at line 37 of file ShmemInputStream.cpp.

Member Function Documentation

close()

void ShmemInputStreamImpl::close

(

)

Definition at line 233 of file ShmemInputStream.cpp.

isOk()

bool ShmemInputStreamImpl::isOk

(

)

const

Definition at line 42 of file ShmemInputStream.cpp.

open()

bool ShmemInputStreamImpl::open	(	int	port,
		ACE_SOCK_Stream *	pSock,
		int	size = 4096
	)

Definition at line 47 of file ShmemInputStream.cpp.

read() [1/2]

int ShmemInputStreamImpl::read ( char *  data, int  len  )

protected

Definition at line 159 of file ShmemInputStream.cpp.

read() [2/2]

yarp::conf::ssize_t ShmemInputStreamImpl::read

(

yarp::os::Bytes &

b

)

Definition at line 196 of file ShmemInputStream.cpp.

Resize()

bool ShmemInputStreamImpl::Resize ( )

protected

Definition at line 106 of file ShmemInputStream.cpp.

Member Data Documentation

m_bOpen

bool ShmemInputStreamImpl::m_bOpen

protected

Definition at line 54 of file ShmemInputStream.h.

m_pAccessMutex

ACE_Process_Mutex* ShmemInputStreamImpl::m_pAccessMutex

protected

Definition at line 63 of file ShmemInputStream.h.

m_pData

char* ShmemInputStreamImpl::m_pData

protected

Definition at line 70 of file ShmemInputStream.h.

m_pHeader

ShmemHeader_t* ShmemInputStreamImpl::m_pHeader

protected

Definition at line 71 of file ShmemInputStream.h.

m_pMap

ACE_Shared_Memory* ShmemInputStreamImpl::m_pMap

protected

Definition at line 69 of file ShmemInputStream.h.

m_Port

int ShmemInputStreamImpl::m_Port

protected

Definition at line 57 of file ShmemInputStream.h.

m_pSock

ACE_SOCK_Stream* ShmemInputStreamImpl::m_pSock

protected

Definition at line 73 of file ShmemInputStream.h.

m_pWaitDataMutex

ACE_Process_Mutex* ShmemInputStreamImpl::m_pWaitDataMutex

protected

Definition at line 64 of file ShmemInputStream.h.

m_ReadSerializerMutex

std::mutex ShmemInputStreamImpl::m_ReadSerializerMutex

protected

Definition at line 67 of file ShmemInputStream.h.

m_ResizeNum

int ShmemInputStreamImpl::m_ResizeNum

protected

Definition at line 56 of file ShmemInputStream.h.

---

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

• src/carriers/shmem_carrier/ShmemInputStream.h
• src/carriers/shmem_carrier/ShmemInputStream.cpp