#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.
|
|
|
|
|
|
|
1.3.8