MADARA  3.4.1
ZMQContext.cpp
Go to the documentation of this file.
1 #include "ZMQContext.h"
2 #include <zmq.h>
3 #include "madara/logger/GlobalLogger.h"
4 
5 madara::transport::ZMQContext madara::transport::zmq_context;
6 
7 madara::transport::ZMQContext::ZMQContext() : context_(0), references_(0) {}
8 
9 void madara::transport::ZMQContext::set_context(void* context)
10 {
11  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
12  "ZMQContext::set_context:"
13  " setting the context\n");
14 
15  if (context != context_)
16  {
17  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
18  "ZMQContext::set_context:"
19  " context is different from new context. Destroying old context.\n");
20 
21  destroy_context();
22 
23  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
24  "ZMQContext::set_context:"
25  " updating context and reference count.\n");
26 
27  context_ = context;
28  references_ = 1;
29 
30  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
31  "ZMQContext::set_context:"
32  " result: context=%p, references=%d\n",
33  context_, int(references_));
34  }
35 }
36 
37 void madara::transport::ZMQContext::add_ref(void)
38 {
39  if (context_ == 0)
40  {
41  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
42  "ZMQContext::add_ref:"
43  " context didn't exist. Creating new context.\n",
44  context_, int(references_));
45 
46  references_ = 1;
47  context_ = zmq_ctx_new();
48  }
49  else
50  {
51  ++references_;
52  }
53 
54  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
55  "ZMQContext::add_ref:"
56  " result: context=%p, references=%d\n",
57  context_, int(references_));
58 }
59 
60 void madara::transport::ZMQContext::rem_ref(void)
61 {
62  if (references_ > 0)
63  {
64  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
65  "ZMQContext::rem_ref:"
66  " removing reference from context.\n",
67  context_, int(references_));
68 
69  --references_;
70 
71  if (references_ == 0)
72  {
73  destroy_context();
74  }
75  }
76 
77  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
78  "ZMQContext::rem_ref:"
79  " result: context=%p, references=%d\n",
80  context_, int(references_));
81 }
82 
83 void madara::transport::ZMQContext::destroy_context(void)
84 {
85  if (context_ != 0)
86  {
87  madara_logger_ptr_log(logger::global_logger.get(), logger::LOG_MAJOR,
88  "ZMQContext::destroy_context:"
89  " destroying context.\n",
90  context_, int(references_));
91 
92  zmq_ctx_destroy(context_);
93  context_ = 0;
94  references_ = 0;
95  }
96 }
97 
101 madara::transport::ZMQContext::~ZMQContext()
102 {
103  destroy_context();
104 }
madara_logger_ptr_log
#define madara_logger_ptr_log(loggering, level,...)
Fast version of the madara::logger::log method for Logger pointers.
Definition: Logger.h:41
context_
const ThreadSafeContext * context_
Definition: ThreadSafeContext.cpp:2517
madara::transport::ZMQContext
A class that manages a ZMQ context.
Definition: ZMQContext.h:24
madara::transport::ZMQContext::rem_ref
void rem_ref(void)
Removes a reference to the context.
Definition: ZMQContext.cpp:60
madara::transport::ZMQContext::destroy_context
void destroy_context(void)
Destroys the underlying context.
Definition: ZMQContext.cpp:83
madara::transport::ZMQContext::set_context
void set_context(void *context)
Retrieves the underlying ZMQ context.
Definition: ZMQContext.cpp:9
madara::transport::ZMQContext::add_ref
void add_ref(void)
Adds a reference to the context.
Definition: ZMQContext.cpp:37
madara::knowledge::get
T get(const KnowledgeRecord &kr)
Get the value of a KnowlegeRecord.
Definition: GetRecord.h:121
madara::logger::global_logger
MADARA_EXPORT utility::Refcounter< logger::Logger > global_logger
madara::transport::zmq_context
MADARA_EXPORT ZMQContext zmq_context
Definition: ZMQContext.cpp:5