"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "lib/remote/jsonrpcconnection.hpp" between
icinga2-2.11.5.tar.gz and icinga2-2.12.0.tar.gz

About: Icinga 2 is an enterprise grade monitoring system which keeps watch over networks and any conceivable network resource.

jsonrpcconnection.hpp  (icinga2-2.11.5):jsonrpcconnection.hpp  (icinga2-2.12.0)
skipping to change at line 45 skipping to change at line 45
/** /**
* An API client connection. * An API client connection.
* *
* @ingroup remote * @ingroup remote
*/ */
class JsonRpcConnection final : public Object class JsonRpcConnection final : public Object
{ {
public: public:
DECLARE_PTR_TYPEDEFS(JsonRpcConnection); DECLARE_PTR_TYPEDEFS(JsonRpcConnection);
JsonRpcConnection(const String& identity, bool authenticated, const std:: shared_ptr<AsioTlsStream>& stream, ConnectionRole role); JsonRpcConnection(const String& identity, bool authenticated, const Share d<AsioTlsStream>::Ptr& stream, ConnectionRole role);
void Start(); void Start();
double GetTimestamp() const; double GetTimestamp() const;
String GetIdentity() const; String GetIdentity() const;
bool IsAuthenticated() const; bool IsAuthenticated() const;
Endpoint::Ptr GetEndpoint() const; Endpoint::Ptr GetEndpoint() const;
std::shared_ptr<AsioTlsStream> GetStream() const; Shared<AsioTlsStream>::Ptr GetStream() const;
ConnectionRole GetRole() const; ConnectionRole GetRole() const;
void Disconnect(); void Disconnect();
void SendMessage(const Dictionary::Ptr& request); void SendMessage(const Dictionary::Ptr& request);
void SendRawMessage(const String& request); void SendRawMessage(const String& request);
static Value HeartbeatAPIHandler(const intrusive_ptr<MessageOrigin>& orig in, const Dictionary::Ptr& params); static Value HeartbeatAPIHandler(const intrusive_ptr<MessageOrigin>& orig in, const Dictionary::Ptr& params);
static double GetWorkQueueRate(); static double GetWorkQueueRate();
static void SendCertificateRequest(const JsonRpcConnection::Ptr& aclient, const intrusive_ptr<MessageOrigin>& origin, const String& path); static void SendCertificateRequest(const JsonRpcConnection::Ptr& aclient, const intrusive_ptr<MessageOrigin>& origin, const String& path);
private: private:
String m_Identity; String m_Identity;
bool m_Authenticated; bool m_Authenticated;
Endpoint::Ptr m_Endpoint; Endpoint::Ptr m_Endpoint;
std::shared_ptr<AsioTlsStream> m_Stream; Shared<AsioTlsStream>::Ptr m_Stream;
ConnectionRole m_Role; ConnectionRole m_Role;
double m_Timestamp; double m_Timestamp;
double m_Seen; double m_Seen;
double m_NextHeartbeat; double m_NextHeartbeat;
boost::asio::io_context::strand m_IoStrand; boost::asio::io_context::strand m_IoStrand;
std::vector<String> m_OutgoingMessagesQueue; std::vector<String> m_OutgoingMessagesQueue;
AsioConditionVariable m_OutgoingMessagesQueued; AsioConditionVariable m_OutgoingMessagesQueued;
AsioConditionVariable m_WriterDone; AsioConditionVariable m_WriterDone;
bool m_ShuttingDown; bool m_ShuttingDown;
boost::asio::deadline_timer m_CheckLivenessTimer, m_HeartbeatTimer; boost::asio::deadline_timer m_CheckLivenessTimer, m_HeartbeatTimer;
JsonRpcConnection(const String& identity, bool authenticated, const std:: shared_ptr<AsioTlsStream>& stream, ConnectionRole role, boost::asio::io_context& io); JsonRpcConnection(const String& identity, bool authenticated, const Share d<AsioTlsStream>::Ptr& stream, ConnectionRole role, boost::asio::io_context& io) ;
void HandleIncomingMessages(boost::asio::yield_context yc); void HandleIncomingMessages(boost::asio::yield_context yc);
void WriteOutgoingMessages(boost::asio::yield_context yc); void WriteOutgoingMessages(boost::asio::yield_context yc);
void HandleAndWriteHeartbeats(boost::asio::yield_context yc); void HandleAndWriteHeartbeats(boost::asio::yield_context yc);
void CheckLiveness(boost::asio::yield_context yc); void CheckLiveness(boost::asio::yield_context yc);
bool ProcessMessage(); bool ProcessMessage();
void MessageHandler(const String& jsonString); void MessageHandler(const String& jsonString);
void CertificateRequestResponseHandler(const Dictionary::Ptr& message); void CertificateRequestResponseHandler(const Dictionary::Ptr& message);
 End of changes. 4 change blocks. 
4 lines changed or deleted 4 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)