joedb::Connection Class Reference

#include <joedb/concurrency/Connection.h>

Inheritance diagram for joedb::Connection:

Public Member Functions
virtual int64_t	handshake (const Readonly_Journal &client_journal, Content_Check content_check)
	Called during Client construction.
virtual int64_t	pull (Lock_Action lock_action, Data_Transfer data_transfer, Writable_Journal &client_journal, std::chrono::milliseconds wait=std::chrono::milliseconds(0))
	Pull from the connection.
virtual int64_t	push (const Readonly_Journal &client_journal, int64_t from, int64_t until, Unlock_Action unlock_action)
	Push new data to the connection.
virtual void	unlock ()
	Unlock the connection.
virtual	~Connection ()

Static Protected Member Functions
static void	content_mismatch ()
	Called by handshake when the file and the connection do not match.

Detailed Description

Definition at line 47 of file Connection.h.

Constructor & Destructor Documentation

~Connection()

joedb::Connection::~Connection ( )

virtualdefault

Member Function Documentation

content_mismatch()

void joedb::Connection::content_mismatch ( )

staticprotected

Definition at line 12 of file Connection.cpp.

handshake()

int64_t joedb::Connection::handshake ( const Readonly_Journal &  client_journal, Content_Check  content_check  )

virtual

Parameters

client_journal	may be used to check matching content
content_check	indicates how matching content is tested

Return values

connection

checkpoint

Reimplemented in joedb::Pullonly_Journal_Connection, joedb::Robust_Connection, joedb::Server_Connection, and joedb::Server_File.

Definition at line 17 of file Connection.cpp.

pull()

int64_t joedb::Connection::pull ( Lock_Action  lock_action, Data_Transfer  data_transfer, Writable_Journal &  client_journal, std::chrono::milliseconds  wait = std::chrono::milliseconds(0)  )

virtual

Parameters

lock_action	whether the connection should be locked before pulling
data_transfer	whether data should be transferred
client_journal	journal to pull into
wait	duration during which the connection may wait for new data if the pull would otherwise be empty

Return values

server

checkpoint

Reimplemented in joedb::Pullonly_Journal_Connection, joedb::Journal_Connection, joedb::Robust_Connection, joedb::Server_File, and joedb::Server_Connection.

Definition at line 26 of file Connection.cpp.

push()

int64_t joedb::Connection::push ( const Readonly_Journal &  client_journal, int64_t  from, int64_t  until, Unlock_Action  unlock_action  )

virtual

Return values

server

checkpoint

Reimplemented in joedb::Pullonly_Journal_Connection, joedb::Journal_Connection, joedb::Server_Connection, joedb::Robust_Connection, and joedb::Server_File.

Definition at line 37 of file Connection.cpp.

unlock()

void joedb::Connection::unlock ( )

virtual

Reimplemented in joedb::Journal_Connection, joedb::Robust_Connection, and joedb::Server_Connection.

Definition at line 48 of file Connection.cpp.

---

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

• /home/rcoulom/repos/joedb/src/joedb/concurrency/Connection.h
• /home/rcoulom/repos/joedb/src/joedb/concurrency/Connection.cpp