#include <ConsistencyMngr.h>
When sunion boxes indicate that they need to reconcile, the ConsistencyMngr manages the state reconciliation of all the boxes in the local query network.
Public Member Functions | |
ConsistencyMngr (QueryProcessor &qp) | |
Constructor The ConsistencyMngr is a part of the query processor so it accesses the query processor's state. | |
~ConsistencyMngr () | |
The destructor writes all stats to a log file. | |
void | checkForControlStreams (Query &q) |
Examines if a query has an sunion box with a control output stream If so, then starts to monitor the output of the query. | |
void | set_replicas (vector< MedusaID > replicas) |
void | add_subscription (Subscription sub) |
void | remove_subscription (Subscription sub) |
|
Constructor The ConsistencyMngr is a part of the query processor so it accesses the query processor's state.
|
|
The destructor writes all stats to a log file.
|
|
|
|
Examines if a query has an sunion box with a control output stream If so, then starts to monitor the output of the query.
|
|
|
|
|