"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "lib/remote/jsonrpcconnection.cpp" 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.cpp  (icinga2-2.11.5):jsonrpcconnection.cpp  (icinga2-2.12.0)
skipping to change at line 33 skipping to change at line 33
#include <boost/thread/once.hpp> #include <boost/thread/once.hpp>
using namespace icinga; using namespace icinga;
static Value SetLogPositionHandler(const MessageOrigin::Ptr& origin, const Dicti onary::Ptr& params); static Value SetLogPositionHandler(const MessageOrigin::Ptr& origin, const Dicti onary::Ptr& params);
REGISTER_APIFUNCTION(SetLogPosition, log, &SetLogPositionHandler); REGISTER_APIFUNCTION(SetLogPosition, log, &SetLogPositionHandler);
static RingBuffer l_TaskStats (15 * 60); static RingBuffer l_TaskStats (15 * 60);
JsonRpcConnection::JsonRpcConnection(const String& identity, bool authenticated, JsonRpcConnection::JsonRpcConnection(const String& identity, bool authenticated,
const std::shared_ptr<AsioTlsStream>& stream, ConnectionRole role) const Shared<AsioTlsStream>::Ptr& stream, ConnectionRole role)
: JsonRpcConnection(identity, authenticated, stream, role, IoEngine::Get( ).GetIoContext()) : JsonRpcConnection(identity, authenticated, stream, role, IoEngine::Get( ).GetIoContext())
{ {
} }
JsonRpcConnection::JsonRpcConnection(const String& identity, bool authenticated, JsonRpcConnection::JsonRpcConnection(const String& identity, bool authenticated,
const std::shared_ptr<AsioTlsStream>& stream, ConnectionRole role, boost: :asio::io_context& io) const Shared<AsioTlsStream>::Ptr& stream, ConnectionRole role, boost::asi o::io_context& io)
: m_Identity(identity), m_Authenticated(authenticated), m_Stream(stream), m_Role(role), : m_Identity(identity), m_Authenticated(authenticated), m_Stream(stream), m_Role(role),
m_Timestamp(Utility::GetTime()), m_Seen(Utility::GetTime()), m_NextHeartb eat(0), m_IoStrand(io), m_Timestamp(Utility::GetTime()), m_Seen(Utility::GetTime()), m_NextHeartb eat(0), m_IoStrand(io),
m_OutgoingMessagesQueued(io), m_WriterDone(io), m_ShuttingDown(false), m_OutgoingMessagesQueued(io), m_WriterDone(io), m_ShuttingDown(false),
m_CheckLivenessTimer(io), m_HeartbeatTimer(io) m_CheckLivenessTimer(io), m_HeartbeatTimer(io)
{ {
if (authenticated) if (authenticated)
m_Endpoint = Endpoint::GetByName(identity); m_Endpoint = Endpoint::GetByName(identity);
} }
void JsonRpcConnection::Start() void JsonRpcConnection::Start()
skipping to change at line 163 skipping to change at line 163
bool JsonRpcConnection::IsAuthenticated() const bool JsonRpcConnection::IsAuthenticated() const
{ {
return m_Authenticated; return m_Authenticated;
} }
Endpoint::Ptr JsonRpcConnection::GetEndpoint() const Endpoint::Ptr JsonRpcConnection::GetEndpoint() const
{ {
return m_Endpoint; return m_Endpoint;
} }
std::shared_ptr<AsioTlsStream> JsonRpcConnection::GetStream() const Shared<AsioTlsStream>::Ptr JsonRpcConnection::GetStream() const
{ {
return m_Stream; return m_Stream;
} }
ConnectionRole JsonRpcConnection::GetRole() const ConnectionRole JsonRpcConnection::GetRole() const
{ {
return m_Role; return m_Role;
} }
void JsonRpcConnection::SendMessage(const Dictionary::Ptr& message) void JsonRpcConnection::SendMessage(const Dictionary::Ptr& message)
 End of changes. 3 change blocks. 
3 lines changed or deleted 3 lines changed or added

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