Async_Writer.h

Go to the documentation of this file.

#ifndef joedb_Async_Writer_declared
#define joedb_Async_Writer_declared
 
#include "joedb/journal/Abstract_File.h"
 
namespace joedb
{
 /// @ingroup journal
 class Async_Writer
 {
  private:
   Abstract_File &file;
   int64_t current;
 
  public:
   //////////////////////////////////////////////////////////////////////////
   Async_Writer(Abstract_File &file, int64_t start):
   //////////////////////////////////////////////////////////////////////////
    file(file),
    current(start)
   {
   }
 
   //////////////////////////////////////////////////////////////////////////
   void write(const char *buffer, size_t size)
   //////////////////////////////////////////////////////////////////////////
   {
    file.pwrite(buffer, size, current);
    current += size;
   }
 
   //////////////////////////////////////////////////////////////////////////
   int64_t get_position() const
   //////////////////////////////////////////////////////////////////////////
   {
    return current;
   }
 };
}
 
#endif