Joedb 9.1.4
The Journal-Only Embedded Database
|
#include <joedb/concurrency/File_Connection.h>
Public Member Functions | |
File_Connection (Buffered_File &server_file, Readonly_Journal::Check check=Readonly_Journal::Check::all, Commit_Level commit_level=Commit_Level::no_commit) | |
![]() | |
Journal_Connection (Writable_Journal &server_journal) | |
int64_t | lock_pull (Writable_Journal &client_journal, std::chrono::milliseconds) override |
Fused lock_pull, executed at the start of a write transaction. | |
int64_t | push_until (Readonly_Journal &client_journal, const int64_t from_checkpoint, const int64_t until_checkpoint, bool unlock_after) override |
Push new data to the connection. | |
void | unlock () override |
Can be used to cancel a transaction without pushing. | |
~Journal_Connection () | |
![]() | |
Pullonly_Journal_Connection (Readonly_Journal &server_journal) | |
int64_t | handshake (Readonly_Journal &client_journal, bool content_check) override |
Called during Client construction. | |
int64_t | pull (Writable_Journal &client_journal, std::chrono::milliseconds) override |
Pull new data from the connection. | |
int64_t | get_checkpoint (Readonly_Journal &client_journal, std::chrono::milliseconds) override |
Get new connection checkpoint without pulling. | |
int64_t | lock_pull (Writable_Journal &client_journal, std::chrono::milliseconds) override |
Fused lock_pull, executed at the start of a write transaction. | |
int64_t | push_until (Readonly_Journal &client_journal, const int64_t from_checkpoint, const int64_t until_checkpoint, bool unlock_after) override |
Push new data to the connection. | |
![]() | |
int64_t | push (Readonly_Journal &client_journal, int64_t from_checkpoint, bool unlock_after) |
Shortcut to call push_until until the client checkpoint. | |
virtual | ~Connection () |
Additional Inherited Members | |
![]() | |
static void | content_mismatch () |
![]() | |
Readonly_Journal & | server_journal |
Definition at line 112 of file File_Connection.h.
|
inline |
Definition at line 118 of file File_Connection.h.