cmlabs::NetworkConnection Class Reference


Public Member Functions
	NetworkConnection (JSocket con, NetProtocol netProtocol, TCPReceiver *rec)
	Constructor with an existing socket.
	NetworkConnection (const TCPLocation &loc, NetProtocol netProtocol, TCPReceiver rec)
	Constructor to connect to a remote server.
	NetworkConnection (const JString &addr, int port, NetProtocol netProtocol, TCPReceiver rec)
	Constructor to connect to a remote server.
bool	restart (JSocket con, NetProtocol netProtocol, TCPReceiver *rec)
	Restarting... almost constructor...
bool	restart (const TCPLocation &loc, NetProtocol netProtocol, TCPReceiver rec)
	Restarting... almost constructor...
bool	restart (const JString &addr, int port, NetProtocol netProtocol, TCPReceiver rec)
	Restarting... almost constructor...
virtual	~NetworkConnection ()
Object *	clone () const
JString	getLocalHostname ()
JString	getLocalIPAddress ()
JString	getRemoteHostname ()
TCPLocation	getRemoteLocation ()
TCPLocation	getLastConnectedTo ()
bool	unitTest ()
void	init (TCPReceiver *rec)
bool	initializeAsReceiver (TCPReceiver *rec)
void	run ()
bool	terminate ()
bool	isErrorRecoverable ()
bool	isConnected ()
bool	isConnectedTo (const TCPLocation &loc)
bool	isConnectedTo (const JString &name)
bool	isPersistent ()
bool	hasTerminated ()
bool	isReset ()
bool	isBroken ()
int	read (char *buffer, int maxcount, long timeout)
JString	readString (unsigned int numBytes, unsigned int msTimeout)
JString	readln (unsigned int msTimeout)
bool	write (char *buffer, int length)
bool	writeString (const JString &str)
bool	writeln (const JString &str)
Message *	sendReceiveObject (Message *msg, unsigned int msTimeout)
Message *	receiveObject (unsigned int msTimeout)
bool	sendObject (Message *msg, bool isReply)
bool	sendObjectWhenReady (Message *msg, int timeout=3000)
double	getSendProgress ()
double	getReceiveProgress ()
long	msSinceLastRead ()
long	msSinceLastWrite ()
long	msSinceLastActivity ()
bool	hasNoParent ()
bool	reset ()
JString	print ()
bool	isReceiver ()
bool	isLocalCallback ()
bool	isRemoteCallback ()
bool	isIncomingConnection ()
bool	setKeepAliveTimeout (long timeout)
long	getKeepAliveTimeout ()
bool	useKeepAlive (bool doKeepAlive)
bool	sendKeepAlive ()
bool	ping (const JString &from, const JString &to, int timeout=5000)
bool	trainNetworkProfile ()
bool	trainNetworkProfile (ConnectionProfile *profile)
Message *	performBenchmark (Message *msg)
long	pingRemotePeer ()
long	uploadServerTest (long size)
long	downloadServerTest (long size)
bool	sendLocalProfile ()
bool	getRemoteProfile ()
bool	allowMessageDropping (bool allow)
Public Attributes
bool	shouldContinue
bool	isDoneRunning
bool	isTerminated
long	timeout
Network *	parent
TCPReceiver *	receiver
NetProtocol *	netprotocol
JString	conID
JString	remoteName
bool	createdAsReceiver
HTTPRequest *	recHTTP
ConnectionProfile	localProfile
ConnectionProfile	remoteProfile
Private Member Functions
void	resetBuffer ()
Private Attributes
int	count
JSocket *	mySocket
JMutex	conMutex
bool	passive
JTime	lastRead
JTime	lastWrite
long	keepAliveTimeout
TCPLocation	lastConnectedTo
ObjectQueue	receivedMessages
ObjectQueue	toSendMessages
JSemaphore	toSendSemaphore
int	toSendMaxQueueSize
bool	allowMessageDrop