![]() |
Fledge
An open source edge computing platform for industrial users
|
This class handles per thread started transaction boundaries: More...
#include <readings_catalogue.h>
Public Member Functions | |
unsigned long | GetMinReadingId () |
Fetch the minimum safe global reading id among all UNCOMMITTED per thread transactions. More... | |
void | SetThreadTransactionStart (std::thread::id tid, unsigned long id) |
Set BEGIN of a transaction for a given thread, reading id. More... | |
void | ClearThreadTransaction (std::thread::id) |
Remove committed TRANSACTION for the given thread. More... | |
This class handles per thread started transaction boundaries:
void TransactionBoundary::ClearThreadTransaction | ( | std::thread::id | tid | ) |
Remove committed TRANSACTION for the given thread.
tid | The thread id that just committed a transaction |
unsigned long TransactionBoundary::GetMinReadingId | ( | ) |
Fetch the minimum safe global reading id among all UNCOMMITTED per thread transactions.
void TransactionBoundary::SetThreadTransactionStart | ( | std::thread::id | tid, |
unsigned long | id | ||
) |
Set BEGIN of a transaction for a given thread, reading id.
tid | The thread id that just started a transaction |
id | The global reading id that starts the transaction |