mongo::MessagingPort Class Reference

#include <message.h>

Inheritance diagram for mongo::MessagingPort:

Public Member Functions
bool	call (Message &toSend, Message &response)
void	clearCounters ()
bool	connect (SockAddr &farEnd)
long long	getBytesIn () const
long long	getBytesOut () const
	MessagingPort (double so_timeout=0, int logLevel=0)
	MessagingPort (int sock, const SockAddr &farEnd)
void	piggyBack (Message &toSend, int responseTo=-1)
void	recv (char *data, int len)
bool	recv (const Message &sent, Message &response)
bool	recv (Message &m)
virtual HostAndPort	remote () const
virtual unsigned	remotePort () const
void	reply (Message &received, Message &response)
void	reply (Message &received, Message &response, MSGID responseTo)
void	say (Message &toSend, int responseTo=-1)
void	send (const vector< pair< char , int > > &data, const char context)
void	send (const char data, int len, const char context)
void	shutdown ()
int	unsafe_recv (char *buf, int max)
virtual	~MessagingPort ()
Static Public Member Functions
static void	closeAllSockets (unsigned tagMask=0xffffffff)
Public Attributes
int	_logLevel
double	_timeout
SockAddr	farEnd
unsigned	tag
Private Attributes
long long	_bytesIn
long long	_bytesOut
HostAndPort	_farEndParsed
PiggyBackData *	piggyBackData
int	sock
Friends
class	PiggyBackData

Detailed Description

Definition at line 92 of file message.h.

Constructor & Destructor Documentation

mongo::MessagingPort::MessagingPort	(	int	sock,
		const SockAddr &	farEnd
	)

mongo::MessagingPort::MessagingPort	(	double	so_timeout = `0`,
		int	logLevel = `0`
	)

virtual mongo::MessagingPort::~MessagingPort ( ) [virtual]

Member Function Documentation

bool mongo::MessagingPort::call	(	Message &	toSend,
		Message &	response
	)

void mongo::MessagingPort::clearCounters ( ) [inline]

Definition at line 142 of file message.h.

static void mongo::MessagingPort::closeAllSockets ( unsigned tagMask = 0xffffffff ) [static]

bool mongo::MessagingPort::connect ( SockAddr & farEnd )

long long mongo::MessagingPort::getBytesIn ( ) const [inline]

Definition at line 143 of file message.h.

long long mongo::MessagingPort::getBytesOut ( ) const [inline]

Definition at line 144 of file message.h.

void mongo::MessagingPort::piggyBack	(	Message &	toSend,
		int	responseTo = `-1`
	)

void mongo::MessagingPort::recv	(	char *	data,
		int	len
	)

bool mongo::MessagingPort::recv	(	const Message &	sent,
		Message &	response
	)

this is used for doing 'async' queries instead of doing call( to , from ) you would do say( to ) recv( from ) Note: if you fail to call recv and someone else uses this port, horrible things will happend

bool mongo::MessagingPort::recv ( Message & m )