MADARA  3.1.8
RCWThread.cpp
Go to the documentation of this file.
1 #include "RCWThread.h"
2 
3 using namespace madara::threads;
4 using namespace madara::knowledge;
5 using namespace madara::knowledge::rcw;
6 
7 void RCWThread::init (KnowledgeBase &kb)
8 {
9  tx_.reset(new Transaction(kb));
10  setup(*tx_);
11 }
12 
13 void RCWThread::run (void)
14 {
15  tx_->pull();
16  compute(*tx_);
17  tx_->push();
18 }
19 
20 void RCWThread::cleanup (void)
21 {
22  finalize(*tx_);
23 }
madara::knowledge::rcw::Transaction
Manages a Read-Compute-Write cycle for registered variables.
Definition: Transaction.h:43
madara::knowledge::rcw
Namespace holding Read-Compute-Write based abstractions for knowledge base access.
Definition: BaseTracker.h:29
madara::threads
Provides a quality-of-service-enabled threading library.
Definition: BaseThread.h:27
madara::knowledge::KnowledgeBase
This class provides a distributed knowledge base to users.
Definition: KnowledgeBase.h:44
madara::threads::RCWThread::init
virtual void init(knowledge::KnowledgeBase &kb) overridefinal
Initializes thread with a MADARA context.
Definition: RCWThread.cpp:7
madara::threads::RCWThread::cleanup
virtual void cleanup(void) overridefinal
Cleans up any thread residue (usually instances created in init).
Definition: RCWThread.cpp:20
madara::knowledge
Provides functions and classes for the distributed knowledge base.
Definition: AggregateFilter.h:32
madara::threads::RCWThread::run
virtual void run(void) overridefinal
Executes the main thread logic.
Definition: RCWThread.cpp:13