summaryrefslogtreecommitdiff
path: root/gnuradio-runtime/lib/controlport/rpcmanager.cc
diff options
context:
space:
mode:
Diffstat (limited to 'gnuradio-runtime/lib/controlport/rpcmanager.cc')
-rw-r--r--gnuradio-runtime/lib/controlport/rpcmanager.cc52
1 files changed, 24 insertions, 28 deletions
diff --git a/gnuradio-runtime/lib/controlport/rpcmanager.cc b/gnuradio-runtime/lib/controlport/rpcmanager.cc
index fee255498e..aa9fc08cde 100644
--- a/gnuradio-runtime/lib/controlport/rpcmanager.cc
+++ b/gnuradio-runtime/lib/controlport/rpcmanager.cc
@@ -24,40 +24,36 @@
#include <iostream>
#include <stdexcept>
-rpcmanager::rpcmanager() {;}
+rpcmanager::rpcmanager() { ; }
-rpcmanager::~rpcmanager() {;}
+rpcmanager::~rpcmanager() { ; }
-rpcserver_booter_base*
-rpcmanager::get()
+rpcserver_booter_base* rpcmanager::get()
{
- if(aggregator_registered) {
- return aggregator.get();
- }
- else if(booter_registered) {
+ if (aggregator_registered) {
+ return aggregator.get();
+ } else if (booter_registered) {
+ return boot.get();
+ }
+ assert(booter_registered || aggregator_registered);
return boot.get();
- }
- assert(booter_registered || aggregator_registered);
- return boot.get();
}
-void
-rpcmanager::register_booter(rpcserver_booter_base* booter)
+void rpcmanager::register_booter(rpcserver_booter_base* booter)
{
- if(make_aggregator && !aggregator_registered) {
- aggregator.reset(new rpcserver_booter_aggregator());
- aggregator_registered = true;
- }
+ if (make_aggregator && !aggregator_registered) {
+ aggregator.reset(new rpcserver_booter_aggregator());
+ aggregator_registered = true;
+ }
- if(aggregator_registered) {
- rpcmanager::rpcserver_booter_base_sptr bootreg(booter);
- aggregator->agg()->registerServer(bootreg);
- }
- else if(!booter_registered) {
- boot.reset(booter);
- booter_registered = true;
- }
- else {
- throw std::runtime_error("rpcmanager: Aggregator not in use, and a rpc booter is already registered\n");
- }
+ if (aggregator_registered) {
+ rpcmanager::rpcserver_booter_base_sptr bootreg(booter);
+ aggregator->agg()->registerServer(bootreg);
+ } else if (!booter_registered) {
+ boot.reset(booter);
+ booter_registered = true;
+ } else {
+ throw std::runtime_error("rpcmanager: Aggregator not in use, and a rpc booter is "
+ "already registered\n");
+ }
}