ChertDatabaseReplicator Class Reference

#include <chert_databasereplicator.h>

Inheritance diagram for ChertDatabaseReplicator:

Collaboration diagram for ChertDatabaseReplicator:

Public Member Functions
	ChertDatabaseReplicator (const std::string &db_dir_)
bool	check_revision_at_least (const std::string &rev, const std::string &target) const
	Virtual methods of DatabaseReplicator. More...
std::string	apply_changeset_from_conn (RemoteConnection &conn, double end_time, bool valid) const
	Read and apply the next changeset. More...
std::string	get_uuid () const
	Get a UUID for the replica. More...
Public Member Functions inherited from Xapian::DatabaseReplicator
virtual	~DatabaseReplicator ()
	Destroy the replicator. More...

Private Member Functions
void	process_changeset_chunk_base (const std::string &tablename, std::string &buf, RemoteConnection &conn, double end_time, int changes_fd) const
	Process a chunk which holds a base block. More...
void	process_changeset_chunk_blocks (const std::string &tablename, std::string &buf, RemoteConnection &conn, double end_time, int changes_fd) const
	Process a chunk which holds a list of changed blocks in the database. More...

Private Attributes
std::string	db_dir
	Path of database. More...
unsigned int	max_changesets
	The maximum number of changesets which should be kept in the database. More...

Additional Inherited Members
Static Public Member Functions inherited from Xapian::DatabaseReplicator
static DatabaseReplicator *	open (const std::string &path)
	Open a DatabaseReplicator for the given path. More...
Protected Member Functions inherited from Xapian::DatabaseReplicator
	DatabaseReplicator ()
	Constructor to allow construction of subclasses from the open() method. More...

Detailed Description

Definition at line 29 of file chert_databasereplicator.h.

Constructor & Destructor Documentation

ChertDatabaseReplicator()

ChertDatabaseReplicator::ChertDatabaseReplicator ( const std::string &  db_dir_ )

explicit

Definition at line 61 of file chert_databasereplicator.cc.

References max_changesets.

Member Function Documentation

apply_changeset_from_conn()

string ChertDatabaseReplicator::apply_changeset_from_conn ( RemoteConnection &  conn, double  end_time, bool  db_valid  ) const

virtual

Read and apply the next changeset.

Parameters

conn	The remote connection manager.
end_time	The time to timeout at.
db_valid	Whether the database is known to be valid at the start of the changeset. If this is true, some additional checks are performed.

Implements Xapian::DatabaseReplicator.

Definition at line 211 of file chert_databasereplicator.cc.

References AssertEq, CHANGES_MAGIC_STRING, CHANGES_VERSION, CONST_STRLEN, create_changeset_file(), db_dir, RealTime::end_time(), RemoteConnection::get_message_chunk(), RemoteConnection::get_message_chunked(), ChertTable::get_open_revision_number(), FlintLock::lock(), LOGCALL, max_changesets, ChertTable::open(), pack_uint(), process_changeset_chunk_base(), process_changeset_chunk_blocks(), REASONABLE_CHANGESET_SIZE, REPL_REPLY_CHANGESET, RETURN, startswith(), Xapian::Internal::str(), FlintLock::SUCCESS, throw_connection_closed_unexpectedly(), FlintLock::throw_databaselockerror(), unpack_string(), unpack_uint(), and write_and_clear_changes().

check_revision_at_least()

bool ChertDatabaseReplicator::check_revision_at_least ( const std::string &  rev, const std::string &  target  ) const

virtual

Virtual methods of DatabaseReplicator.

Implements Xapian::DatabaseReplicator.

Definition at line 71 of file chert_databasereplicator.cc.

References LOGCALL, RETURN, and unpack_uint().

get_uuid()

string ChertDatabaseReplicator::get_uuid ( ) const

virtual

Get a UUID for the replica.

If the UUID cannot be read (for example, because the database is not valid), this should return the empty string, rather than raising an exception.

Implements Xapian::DatabaseReplicator.

Definition at line 349 of file chert_databasereplicator.cc.

References db_dir, ChertVersion::get_uuid_string(), LOGCALL, ChertVersion::read_and_check(), and RETURN.

process_changeset_chunk_base()

void ChertDatabaseReplicator::process_changeset_chunk_base ( const std::string &  tablename, std::string &  buf, RemoteConnection &  conn, double  end_time, int  changes_fd  ) const

private

Process a chunk which holds a base block.

Definition at line 95 of file chert_databasereplicator.cc.

References db_dir, RealTime::end_time(), RemoteConnection::get_message_chunk(), io_sync(), io_tmp_rename(), io_write(), O_CLOEXEC, posixy_open, throw_connection_closed_unexpectedly(), unpack_uint(), and write_and_clear_changes().

Referenced by apply_changeset_from_conn().

process_changeset_chunk_blocks()

void ChertDatabaseReplicator::process_changeset_chunk_blocks ( const std::string &  tablename, std::string &  buf, RemoteConnection &  conn, double  end_time, int  changes_fd  ) const

private

Process a chunk which holds a list of changed blocks in the database.

Definition at line 156 of file chert_databasereplicator.cc.

References db_dir, RealTime::end_time(), RemoteConnection::get_message_chunk(), io_sync(), io_write_block(), O_CLOEXEC, posixy_open, REASONABLE_CHANGESET_SIZE, throw_connection_closed_unexpectedly(), unpack_uint(), and write_and_clear_changes().

Referenced by apply_changeset_from_conn().

Member Data Documentation

db_dir

std::string ChertDatabaseReplicator::db_dir

private

Path of database.

Definition at line 33 of file chert_databasereplicator.h.

Referenced by apply_changeset_from_conn(), get_uuid(), process_changeset_chunk_base(), and process_changeset_chunk_blocks().

max_changesets

unsigned int ChertDatabaseReplicator::max_changesets

private

The maximum number of changesets which should be kept in the database.

Definition at line 37 of file chert_databasereplicator.h.

Referenced by apply_changeset_from_conn(), and ChertDatabaseReplicator().

---

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

• backends/chert/chert_databasereplicator.h
• backends/chert/chert_databasereplicator.cc