#include <joedb/concurrency/File_Connection.h>
|
| 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 () |
|
Definition at line 54 of file File_Connection.h.
◆ Journal_Connection()
joedb::Journal_Connection::Journal_Connection |
( |
Writable_Journal & |
server_journal | ) |
|
|
inline |
◆ ~Journal_Connection()
joedb::Journal_Connection::~Journal_Connection |
( |
| ) |
|
◆ lock_pull()
int64_t joedb::Journal_Connection::lock_pull |
( |
Writable_Journal & |
client_journal, |
|
|
std::chrono::milliseconds |
wait |
|
) |
| |
|
overridevirtual |
◆ push_until()
int64_t joedb::Journal_Connection::push_until |
( |
Readonly_Journal & |
client_journal, |
|
|
const int64_t |
from_checkpoint, |
|
|
const int64_t |
until_checkpoint, |
|
|
bool |
unlock_after |
|
) |
| |
|
overridevirtual |
◆ unlock()
void joedb::Journal_Connection::unlock |
( |
| ) |
|
|
overridevirtual |
The documentation for this class was generated from the following files: