/****************************************************************************** * Icinga 2 * * Copyright (C) 2012-2014 Icinga Development Team (http://www.icinga.org) * * * * This program is free software; you can redistribute it and/or * * modify it under the terms of the GNU General Public License * * as published by the Free Software Foundation; either version 2 * * of the License, or (at your option) any later version. * * * * This program is distributed in the hope that it will be useful, * * but WITHOUT ANY WARRANTY; without even the implied warranty of * * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * * GNU General Public License for more details. * * * * You should have received a copy of the GNU General Public License * * along with this program; if not, write to the Free Software Foundation * * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. * ******************************************************************************/ #ifndef APILISTENER_H #define APILISTENER_H #include "remote/apilistener.thpp" #include "remote/apiclient.hpp" #include "remote/endpoint.hpp" #include "remote/messageorigin.hpp" #include "base/dynamicobject.hpp" #include "base/timer.hpp" #include "base/workqueue.hpp" #include "base/tcpsocket.hpp" #include "base/tlsstream.hpp" #include namespace icinga { class ApiClient; /** * @ingroup remote */ class I2_REMOTE_API ApiListener : public ObjectImpl { public: DECLARE_PTR_TYPEDEFS(ApiListener); DECLARE_TYPENAME(ApiListener); static boost::signals2::signal OnMasterChanged; static ApiListener::Ptr GetInstance(void); shared_ptr GetSSLContext(void) const; Endpoint::Ptr GetMaster(void) const; bool IsMaster(void) const; static String GetApiDir(void); void RelayMessage(const MessageOrigin& origin, const DynamicObject::Ptr& secobj, const Dictionary::Ptr& message, bool log); static Value StatsFunc(Dictionary::Ptr& status, Dictionary::Ptr& perfdata); std::pair GetStatus(void); void AddAnonymousClient(const ApiClient::Ptr& aclient); void RemoveAnonymousClient(const ApiClient::Ptr& aclient); std::set GetAnonymousClients(void) const; static Value ConfigUpdateHandler(const MessageOrigin& origin, const Dictionary::Ptr& params); protected: virtual void OnConfigLoaded(void); virtual void Start(void); private: shared_ptr m_SSLContext; std::set m_Servers; std::set m_AnonymousClients; Timer::Ptr m_Timer; void ApiTimerHandler(void); void AddListener(const String& service); void AddConnection(const String& node, const String& service); void NewClientHandler(const Socket::Ptr& client, ConnectionRole role); void ListenerThreadProc(const Socket::Ptr& server); void MessageHandler(const TlsStream::Ptr& sender, const String& identity, const Dictionary::Ptr& message); WorkQueue m_RelayQueue; WorkQueue m_LogQueue; boost::mutex m_LogLock; Stream::Ptr m_LogFile; size_t m_LogMessageCount; void SyncRelayMessage(const MessageOrigin& origin, const DynamicObject::Ptr& secobj, const Dictionary::Ptr& message, bool log); void PersistMessage(const Dictionary::Ptr& message); void OpenLogFile(void); void RotateLogFile(void); void CloseLogFile(void); static void LogGlobHandler(std::vector& files, const String& file); void ReplayLog(const ApiClient::Ptr& client); static Dictionary::Ptr LoadConfigDir(const String& dir); static bool UpdateConfigDir(const Dictionary::Ptr& oldConfig, const Dictionary::Ptr& newConfig, const String& configDir); void SyncZoneDirs(void) const; void SyncZoneDir(const Zone::Ptr& zone) const; bool IsConfigMaster(const Zone::Ptr& zone) const; static void ConfigGlobHandler(const Dictionary::Ptr& config, const String& path, const String& file); void SendConfigUpdate(const ApiClient::Ptr& aclient); }; } #endif /* APILISTENER_H */