![]() |
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 |