RealmConnection Class Reference

#include <RealmConnection.h>

List of all members.

Public Member Functions

RealmConnection (const std::string &ca_file, const std::string &address, int port, const std::string &cookie, UT_sint64 doc_id, bool master, const std::string &session_id, boost::function< void(RealmConnection &)> sig)

bool connect ()

void disconnect ()

bool isConnected ()

void addBuddy (RealmBuddyPtr buddy_ptr)

void removeBuddy (UT_uint8 realm_connection_id)

RealmBuddyPtr getBuddy (UT_uint8 realm_connection_id)

std::vector< RealmBuddyPtr > & getBuddies ()

UT_sint64 doc_id ()

bool master ()

const std::string & session_id ()

SynchronizedQueue< PacketPtr > & queue ()

asio::ip::tcp::socket & socket ()

void loadDocumentStart (AP_Dialog_GenericProgress *pDlg, PD_Document **pDoc_, XAP_Frame *pFrame_, const std::string &filename_)

boost::shared_ptr
< PendingDocumentProperties > getPendingDocProps ()

void loadDocumentEnd ()

Private Member Functions

void _disconnect ()

void _signal ()

bool _login ()

void _receive ()

void _message (const asio::error_code &e, std::size_t bytes_transferred, boost::shared_ptr< std::string > msg_ptr)

void _complete_packet (PacketPtr packet_ptr)

void _complete (const asio::error_code &e, std::size_t bytes_transferred, PacketPtr packet_ptr)

Private Attributes

asio::io_service m_io_service

std::string m_ca_file

std::string m_address

int m_port

asio::ip::tcp::socket m_socket

boost::shared_ptr< asio::thread > m_thread_ptr

std::string m_cookie

UT_sint64 m_doc_id

bool m_master

std::string m_session_id

realm::GrowBuffer m_buf

SynchronizedQueue< PacketPtr > m_packet_queue

boost::function< void(RealmConnection &)> m_sig

std::vector< RealmBuddyPtr > m_buddies

boost::shared_ptr
< PendingDocumentProperties > m_pdp_ptr

boost::shared_ptr
< tls_tunnel::ClientProxy > m_tls_tunnel_ptr

Constructor & Destructor Documentation

RealmConnection::RealmConnection	(	const std::string &	ca_file,
		const std::string &	address,
		int	port,
		const std::string &	cookie,
		UT_sint64	doc_id,
		bool	master,
		const std::string &	session_id,
		boost::function< void(RealmConnection &)>	sig
	)

Member Function Documentation

bool RealmConnection::connect ( )

References _disconnect(), _login(), _receive(), m_address, m_ca_file, m_io_service, m_port, m_socket, m_thread_ptr, m_tls_tunnel_ptr, tls_tunnel::Exception::message(), tls_tunnel::Proxy::run(), UT_DEBUGMSG, and UT_return_val_if_fail.

void RealmConnection::disconnect ( void )

References m_socket, and UT_DEBUGMSG.

Referenced by ServiceAccountHandler::_handleMessages().

bool RealmConnection::isConnected ( )

References m_socket.

Referenced by ServiceAccountHandler::_handleRealmPacket().

void RealmConnection::addBuddy ( RealmBuddyPtr buddy_ptr )

References m_buddies.

Referenced by ServiceAccountHandler::_handleMessages().

void RealmConnection::removeBuddy ( UT_uint8 realm_connection_id )

References m_buddies, UT_ASSERT_HARMLESS, UT_continue_if_fail, and UT_SHOULD_NOT_HAPPEN.

Referenced by ServiceAccountHandler::_handleMessages().

RealmBuddyPtr RealmConnection::getBuddy ( UT_uint8 realm_connection_id )

References m_buddies, and UT_continue_if_fail.

Referenced by ServiceAccountHandler::_handleMessages().

std::vector<RealmBuddyPtr>& RealmConnection::getBuddies ( ) [inline]

References m_buddies.

Referenced by ServiceAccountHandler::_handleRealmPacket().

UT_sint64 RealmConnection::doc_id ( ) [inline]

References m_doc_id.

bool RealmConnection::master ( ) [inline]

References m_master.

Referenced by ServiceAccountHandler::_handleMessages(), and ServiceAccountHandler::_handleRealmPacket().

const std::string& RealmConnection::session_id ( ) [inline]

References m_session_id.

Referenced by ServiceAccountHandler::_handleMessages(), and ServiceAccountHandler::_handleRealmPacket().

SynchronizedQueue<PacketPtr>& RealmConnection::queue ( ) [inline]

References m_packet_queue.

Referenced by ServiceAccountHandler::_handleMessages().

asio::ip::tcp::socket& RealmConnection::socket ( ) [inline]

References m_socket.

void RealmConnection::loadDocumentStart	(	AP_Dialog_GenericProgress *	pDlg,
		PD_Document **	pDoc_,
		XAP_Frame *	pFrame_,
		const std::string &	filename_
	)			`[inline]`

References m_pdp_ptr, and UT_return_if_fail.

boost::shared_ptr<PendingDocumentProperties> RealmConnection::getPendingDocProps ( ) [inline]

References m_pdp_ptr.

Referenced by ServiceAccountHandler::_handleMessages().

void RealmConnection::loadDocumentEnd ( ) [inline]

References m_pdp_ptr.

void RealmConnection::_disconnect ( ) [private]

References m_io_service, m_packet_queue, m_socket, m_thread_ptr, m_tls_tunnel_ptr, Synchronizer::signal(), and UT_DEBUGMSG.

Referenced by _complete(), _message(), and connect().

void RealmConnection::_signal ( ) [private]

References m_sig.

bool RealmConnection::_login ( ) [private]

References realm::protocol::HANDSHAKE_BAD_IDENTIFIER, realm::protocol::HANDSHAKE_INVALID_COOKIE, realm::protocol::HANDSHAKE_OK, realm::protocol::HANDSHAKE_RESERVED, realm::protocol::HANDSHAKE_UNSUPPORTED_PROTOCOL, m_cookie, m_socket, tls_tunnel::read(), UT_ASSERT_HARMLESS, UT_DEBUGMSG, UT_SHOULD_NOT_HAPPEN, and tls_tunnel::write().

Referenced by connect().

void RealmConnection::_receive ( ) [private]

References _message(), realm::GrowBuffer::clear(), abicollab::service::error(), m_buf, m_socket, and UT_DEBUGMSG.

Referenced by _complete_packet(), and connect().

void RealmConnection::_message	(	const asio::error_code &	e,
		std::size_t	bytes_transferred,
		boost::shared_ptr< std::string >	msg_ptr
	)			`[private]`

References _complete_packet(), _disconnect(), realm::protocolv1::Packet::construct(), and UT_DEBUGMSG.

Referenced by _receive().

void RealmConnection::_complete_packet ( PacketPtr packet_ptr ) [private]

References _complete(), _receive(), realm::GrowBuffer::data(), abicollab::service::error(), m_buf, m_packet_queue, m_socket, realm::GrowBuffer::prepare(), SynchronizedQueue< T >::push(), realm::GrowBuffer::size(), UT_DEBUGMSG, and UT_return_if_fail.

Referenced by _complete(), and _message().

void RealmConnection::_complete	(	const asio::error_code &	e,
		std::size_t	bytes_transferred,
		PacketPtr	packet_ptr
	)			`[private]`

References _complete_packet(), _disconnect(), realm::GrowBuffer::commit(), m_buf, and UT_DEBUGMSG.

Referenced by _complete_packet().

Member Data Documentation

asio::io_service RealmConnection::m_io_service [private]

Referenced by _disconnect(), and connect().

std::string RealmConnection::m_ca_file [private]

Referenced by connect().

std::string RealmConnection::m_address [private]

Referenced by connect().

int RealmConnection::m_port [private]

Referenced by connect().

asio::ip::tcp::socket RealmConnection::m_socket [private]

Referenced by _complete_packet(), _disconnect(), _login(), _receive(), connect(), disconnect(), isConnected(), and socket().

boost::shared_ptr<asio::thread> RealmConnection::m_thread_ptr [private]

Referenced by _disconnect(), and connect().

std::string RealmConnection::m_cookie [private]

Referenced by _login().

UT_sint64 RealmConnection::m_doc_id [private]

Referenced by doc_id().

bool RealmConnection::m_master [private]

Referenced by master().

std::string RealmConnection::m_session_id [private]

Referenced by session_id().

realm::GrowBuffer RealmConnection::m_buf [private]

Referenced by _complete(), _complete_packet(), and _receive().

SynchronizedQueue<PacketPtr> RealmConnection::m_packet_queue [private]

Referenced by _complete_packet(), _disconnect(), and queue().

boost::function<void (RealmConnection&)> RealmConnection::m_sig [private]

Referenced by _signal().

std::vector<RealmBuddyPtr> RealmConnection::m_buddies [private]

Referenced by addBuddy(), getBuddies(), getBuddy(), and removeBuddy().

boost::shared_ptr<PendingDocumentProperties> RealmConnection::m_pdp_ptr [private]

Referenced by getPendingDocProps(), loadDocumentEnd(), and loadDocumentStart().

boost::shared_ptr<tls_tunnel::ClientProxy> RealmConnection::m_tls_tunnel_ptr [private]

Referenced by _disconnect(), and connect().

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


Public Member Functions
	RealmConnection (const std::string &ca_file, const std::string &address, int port, const std::string &cookie, UT_sint64 doc_id, bool master, const std::string &session_id, boost::function< void(RealmConnection &)> sig)
bool	connect ()
void	disconnect ()
bool	isConnected ()
void	addBuddy (RealmBuddyPtr buddy_ptr)
void	removeBuddy (UT_uint8 realm_connection_id)
RealmBuddyPtr	getBuddy (UT_uint8 realm_connection_id)
std::vector< RealmBuddyPtr > &	getBuddies ()
UT_sint64	doc_id ()
bool	master ()
const std::string &	session_id ()
SynchronizedQueue< PacketPtr > &	queue ()
asio::ip::tcp::socket &	socket ()
void	loadDocumentStart (AP_Dialog_GenericProgress pDlg, PD_Document pDoc_, XAP_Frame pFrame_, const std::string &filename_)
boost::shared_ptr < PendingDocumentProperties >	getPendingDocProps ()
void	loadDocumentEnd ()
Private Member Functions
void	_disconnect ()
void	_signal ()
bool	_login ()
void	_receive ()
void	_message (const asio::error_code &e, std::size_t bytes_transferred, boost::shared_ptr< std::string > msg_ptr)
void	_complete_packet (PacketPtr packet_ptr)
void	_complete (const asio::error_code &e, std::size_t bytes_transferred, PacketPtr packet_ptr)
Private Attributes
asio::io_service	m_io_service
std::string	m_ca_file
std::string	m_address
int	m_port
asio::ip::tcp::socket	m_socket
boost::shared_ptr< asio::thread >	m_thread_ptr
std::string	m_cookie
UT_sint64	m_doc_id
bool	m_master
std::string	m_session_id
realm::GrowBuffer	m_buf
SynchronizedQueue< PacketPtr >	m_packet_queue
boost::function< void(RealmConnection &)>	m_sig
std::vector< RealmBuddyPtr >	m_buddies
boost::shared_ptr < PendingDocumentProperties >	m_pdp_ptr
boost::shared_ptr < tls_tunnel::ClientProxy >	m_tls_tunnel_ptr