File_Connection.cpp

Go to the documentation of this file.

#include "joedb/concurrency/File_Connection.h"
 
namespace joedb
{
 //////////////////////////////////////////////////////////////////////////
 int64_t Pullonly_Journal_Connection::handshake
 //////////////////////////////////////////////////////////////////////////
 (
  const Readonly_Journal &client_journal,
  Content_Check content_check
 )
 {
  if (content_check != Content_Check::none)
  {
   const int64_t min = std::min
   (
    server_journal.get_checkpoint(),
    client_journal.get_checkpoint()
   );
 
   const int64_t fast_size = 1 << 11;
 
   if (content_check == Content_Check::full || min <= 2 * fast_size)
   {
    if (!client_journal.equal_to(server_journal, Header::ssize, min))
     content_mismatch();
   }
   else
   {
    if
    (
     !client_journal.equal_to(server_journal, Header::ssize, fast_size) ||
     !client_journal.equal_to(server_journal, min - fast_size, min)
    )
    {
     content_mismatch();
    }
   }
  }
 
  return server_journal.get_checkpoint();
 }
 
 //////////////////////////////////////////////////////////////////////////
 int64_t Pullonly_Journal_Connection::pull
 //////////////////////////////////////////////////////////////////////////
 (
  Lock_Action lock_action,
  Data_Transfer data_transfer,
  Writable_Journal &client_journal,
  std::chrono::milliseconds wait
 )
 {
  if (bool(lock_action))
   throw Exception("Connected to a read-only journal: can't lock");
 
  server_journal.pull();
 
  if (bool(data_transfer))
   client_journal.pull_from(server_journal);
 
  return server_journal.get_checkpoint();
 }
 
 //////////////////////////////////////////////////////////////////////////
 int64_t Pullonly_Journal_Connection::push
 //////////////////////////////////////////////////////////////////////////
 (
  const Readonly_Journal &client_journal,
  const int64_t from,
  const int64_t until,
  Unlock_Action unlock_action
 )
 {
  throw Exception("Connected to a read-only journal: can't push");
 }
 
 //////////////////////////////////////////////////////////////////////////
 Journal_Connection::Journal_Connection(Writable_Journal &server_journal):
 //////////////////////////////////////////////////////////////////////////
  Pullonly_Journal_Connection(server_journal)
 {
  JOEDB_RELEASE_ASSERT(!server_journal.is_shared());
 }
 
 //////////////////////////////////////////////////////////////////////////
 int64_t Journal_Connection::pull
 //////////////////////////////////////////////////////////////////////////
 (
  Lock_Action lock_action,
  Data_Transfer data_transfer,
  Writable_Journal &client_journal,
  std::chrono::milliseconds wait
 )
 {
  if (bool(lock_action))
   get_journal().lock_pull();
  else
   get_journal().pull();
 
  if (bool(data_transfer))
   client_journal.pull_from(server_journal);
 
  return server_journal.get_checkpoint();
 }
 
 //////////////////////////////////////////////////////////////////////////
 int64_t Journal_Connection::push
 //////////////////////////////////////////////////////////////////////////
 (
  const Readonly_Journal &client_journal,
  const int64_t from,
  const int64_t until,
  Unlock_Action unlock_action
 )
 {
  if (from != server_journal.get_checkpoint())
   throw Exception("push error: conflict");
  get_journal().pull_from(client_journal, until);
  return server_journal.get_checkpoint();
 }
 
 //////////////////////////////////////////////////////////////////////////
 void Journal_Connection::unlock()
 //////////////////////////////////////////////////////////////////////////
 {
  get_journal().unlock();
 }
 
 //////////////////////////////////////////////////////////////////////////
 Journal_Connection::~Journal_Connection()
 //////////////////////////////////////////////////////////////////////////
 {
  get_journal().unlock();
 }
}