#include <joedb/concurrency/Writable_Connection.h>
|
| Writable_Connection (Writable &writable) |
|
int64_t | handshake (Readonly_Journal &client_journal, bool contentcheck) override |
| Called during Client construction.
|
|
int64_t | push_until (Readonly_Journal &client_journal, int64_t from_position, int64_t until_position, bool unlock_after) override |
| Push new data to the connection.
|
|
virtual int64_t | pull (Writable_Journal &client_journal, std::chrono::milliseconds wait=std::chrono::milliseconds(0)) |
| Pull new data from the connection.
|
|
virtual int64_t | lock_pull (Writable_Journal &client_journal, std::chrono::milliseconds wait=std::chrono::milliseconds(0)) |
| Fused lock_pull, executed at the start of a write transaction.
|
|
virtual int64_t | get_checkpoint (Readonly_Journal &client_journal, std::chrono::milliseconds wait=std::chrono::milliseconds(0)) |
| Get new connection checkpoint without pulling.
|
|
int64_t | push (Readonly_Journal &client_journal, int64_t from_checkpoint, bool unlock_after) |
| Shortcut to call push_until until the client checkpoint.
|
|
virtual void | unlock () |
| Can be used to cancel a transaction without pushing.
|
|
virtual | ~Connection () |
|
Definition at line 9 of file Writable_Connection.h.
◆ Writable_Connection()
joedb::Writable_Connection::Writable_Connection |
( |
Writable & |
writable | ) |
|
|
inline |
◆ handshake()
int64_t joedb::Writable_Connection::handshake |
( |
Readonly_Journal & |
client_journal, |
|
|
bool |
content_check |
|
) |
| |
|
inlineoverridevirtual |
- Parameters
-
client_journal | may be used to check matching content |
content_check | indicates whether matching content is tested |
- Return values
-
Reimplemented from joedb::Connection.
Definition at line 23 of file Writable_Connection.h.
◆ push_until()
int64_t joedb::Writable_Connection::push_until |
( |
Readonly_Journal & |
client_journal, |
|
|
int64_t |
from_checkpoint, |
|
|
int64_t |
until_checkpoint, |
|
|
bool |
unlock_after |
|
) |
| |
|
inlineoverridevirtual |
The documentation for this class was generated from the following file: