Code Review
/
ric-plt
/
xapp-frame-cpp.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add API allowing xAPPs to send alarm messages
[ric-plt/xapp-frame-cpp.git]
/
src
/
messaging
/
messenger.hpp
diff --git
a/src/messaging/messenger.hpp
b/src/messaging/messenger.hpp
index
0fa7899
..
173426c
100644
(file)
--- a/
src/messaging/messenger.hpp
+++ b/
src/messaging/messenger.hpp
@@
-39,15
+39,17
@@
#include <rmr/rmr.h>
#include <rmr/rmr.h>
-//#include "callback.hpp"
-//#include "default_cb.hpp" // default callback prototypes
#include "message.hpp"
#include "message.hpp"
+#include "alarm.hpp"
#ifndef RMR_FALSE
#define RMR_FALSE 0
#define RMR_TRUE 1
#endif
#ifndef RMR_FALSE
#define RMR_FALSE 0
#define RMR_TRUE 1
#endif
+namespace xapp {
+
+
class Messenger {
private:
class Messenger {
private:
@@
-58,21
+60,36
@@
class Messenger {
void* mrc; // message router context
char* listen_port; // port we ask msg router to listen on
void* mrc; // message router context
char* listen_port; // port we ask msg router to listen on
+ // copy and assignment are PRIVATE so that they fail if xapp tries; messenger cannot be copied!
+ Messenger( const Messenger& soi );
+ Messenger& operator=( const Messenger& soi );
+
public:
// -- constants which need an instance; that happens as a global in the .cpp file (wtf C++)
static const int MAX_PAYLOAD; // max message size we'll handle
static const int DEFAULT_CALLBACK; // parm for add callback to set default
public:
// -- constants which need an instance; that happens as a global in the .cpp file (wtf C++)
static const int MAX_PAYLOAD; // max message size we'll handle
static const int DEFAULT_CALLBACK; // parm for add callback to set default
- Messenger( char* port, bool wait4table ); // builder
+ Messenger( const char* port, bool wait4table ); // builder
+ Messenger( Messenger&& soi ); // move construction
+ Messenger& operator=( Messenger&& soi ); // move operator
~Messenger(); // destroyer
void Add_msg_cb( int mtype, user_callback fun_name, void* data );
~Messenger(); // destroyer
void Add_msg_cb( int mtype, user_callback fun_name, void* data );
+
std::unique_ptr<Message> Alloc_msg( int payload_size ); // message allocation
std::unique_ptr<Message> Alloc_msg( int payload_size ); // message allocation
+
+ std::unique_ptr<xapp::Alarm> Alloc_alarm( ); // alarm allocation
+ std::unique_ptr<xapp::Alarm> Alloc_alarm( std::string meid );
+ std::unique_ptr<xapp::Alarm> Alloc_alarm( int prob_id, std::string meid );
+
void Listen( ); // lisen driver
std::unique_ptr<Message> Receive( int timeout ); // receive 1 message
void Stop( ); // force to stop
void Listen( ); // lisen driver
std::unique_ptr<Message> Receive( int timeout ); // receive 1 message
void Stop( ); // force to stop
- void Release_mbuf( void* vmbuf );
bool Wait_for_cts( int max_wait );
bool Wait_for_cts( int max_wait );
+
+ int Wormhole_open( std::string endpoint );
};
};
+
+} // namespace
#endif
#endif