17#include <boost/pointer_cast.hpp>
49 boost::dynamic_pointer_cast<CtrlAgentController>(
51 controller->registerCommands();
59 garbageCollectListeners(1);
63 garbageCollectListeners(0);
65 }
catch (
const std::exception& ex) {
73 "Process run method failed: " << ex.
what());
79 boost::dynamic_pointer_cast<CtrlAgentController>(
81 controller->deregisterCommands();
82 }
catch (
const std::exception&) {
90CtrlAgentProcess::runIO() {
102 "Control Agent is shutting down"));
123 ctx = boost::dynamic_pointer_cast<CtrlAgentCfgContext>(base_ctx);
132 server_address =
IOAddress(ctx->getHttpHost());
136 <<
" to IP address:" << e.
what());
139 uint16_t server_port = ctx->getHttpPort();
140 bool use_https =
false;
143 if (http_listeners_.empty() ||
144 (http_listeners_.back()->getLocalAddress() != server_address) ||
145 (http_listeners_.back()->getLocalPort() != server_port)) {
149 if (!ctx->getCertFile().empty()) {
150 TlsContext::configure(tls_context,
152 ctx->getTrustAnchor(),
155 ctx->getCertRequired());
168 server_port, tls_context, rcf,
174 http_listener->start();
179 http_listeners_.push_back(http_listener);
185 .arg(server_address.
toText()).arg(server_port);
188 .arg(server_address.
toText()).arg(server_port);
198CtrlAgentProcess::garbageCollectListeners(
size_t leaving) {
202 if (http_listeners_.size() > leaving) {
204 for (
auto l = http_listeners_.begin();
205 l != http_listeners_.end() - leaving;
213 http_listeners_.erase(http_listeners_.begin(),
214 http_listeners_.end() - leaving);
221 return (boost::dynamic_pointer_cast<CtrlAgentCfgMgr>(
getCfgMgr()));
228 http_listeners_.back());
A generic exception that is thrown if a parameter given to a method is considered invalid in that con...
virtual const char * what() const
Returns a C-style character string of the cause of the exception.
A generic exception that is thrown when an unexpected error condition occurs.
Ctrl Agent Configuration Manager.
static process::DControllerBasePtr & instance()
Static singleton instance method.
bool isListening() const
Checks if the process is listening to the HTTP requests.
virtual isc::data::ConstElementPtr shutdown(isc::data::ConstElementPtr args)
Initiates the process's shutdown process.
virtual ~CtrlAgentProcess()
Destructor.
http::ConstHttpListenerPtr getHttpListener() const
Returns a const pointer to the HTTP listener used by the process.
CtrlAgentProcess(const char *name, const asiolink::IOServicePtr &io_service)
Constructor.
virtual void init()
Initialize the Control Agent process.
CtrlAgentCfgMgrPtr getCtrlAgentCfgMgr()
Returns a pointer to the configuration manager.
virtual isc::data::ConstElementPtr configure(isc::data::ConstElementPtr config_set, bool check_only=false)
Processes the given configuration.
virtual void run()
Implements the process's event loop.
HTTP response creator factory for Control Agent.
The IOAddress class represents an IP addresses (version agnostic)
std::string toText() const
Convert the address to a string.
An exception that is thrown if an error occurs within the IO module.
Exception thrown if the process encountered an operational error.
Application Process Interface.
void setShutdownFlag(bool value)
Sets the process shut down flag to the given value.
void stopIOService()
Convenience method for stopping IOservice processing.
asiolink::IOServicePtr & getIoService()
Fetches the controller's IOService.
bool shouldShutdown() const
Checks if the process has been instructed to shut down.
DCfgMgrBasePtr & getCfgMgr()
Fetches the process's configuration manager.
This file contains several functions and constants that are used for handling commands and responses ...
#define isc_throw(type, stream)
A shortcut macro to insert known values into exception arguments.
#define LOG_INFO(LOGGER, MESSAGE)
Macro to conveniently test info output and log it.
#define LOG_FATAL(LOGGER, MESSAGE)
Macro to conveniently test fatal output and log it.
#define LOG_DEBUG(LOGGER, LEVEL, MESSAGE)
Macro to conveniently test debug output and log it.
boost::shared_ptr< CtrlAgentCfgContext > CtrlAgentCfgContextPtr
Pointer to a configuration context.
const isc::log::MessageID CTRL_AGENT_HTTP_SERVICE_STARTED
const isc::log::MessageID CTRL_AGENT_STARTED
isc::log::Logger agent_logger("ctrl-agent")
Control Agent logger.
boost::shared_ptr< CtrlAgentCfgMgr > CtrlAgentCfgMgrPtr
Defines a shared pointer to CtrlAgentCfgMgr.
boost::shared_ptr< CtrlAgentController > CtrlAgentControllerPtr
const isc::log::MessageID CTRL_AGENT_HTTPS_SERVICE_STARTED
const isc::log::MessageID CTRL_AGENT_RUN_EXIT
const isc::log::MessageID CTRL_AGENT_FAILED
boost::shared_ptr< TlsContext > TlsContextPtr
The type of shared pointers to TlsContext objects.
boost::shared_ptr< IOService > IOServicePtr
Defines a smart pointer to an IOService instance.
constexpr long TIMEOUT_AGENT_IDLE_CONNECTION_TIMEOUT
Timeout for the idle connection to be closed.
ConstElementPtr createAnswer(const int status_code, const std::string &text, const ConstElementPtr &arg)
ConstElementPtr parseAnswer(int &rcode, const ConstElementPtr &msg)
const int CONTROL_RESULT_SUCCESS
Status code indicating a successful operation.
constexpr long TIMEOUT_AGENT_RECEIVE_COMMAND
Timeout for the Control Agent to receive command over the RESTful interface.
boost::shared_ptr< const Element > ConstElementPtr
boost::shared_ptr< const HttpListener > ConstHttpListenerPtr
Pointer to the const HttpListener.
boost::shared_ptr< HttpListener > HttpListenerPtr
Pointer to the HttpListener.
boost::shared_ptr< HttpResponseCreatorFactory > HttpResponseCreatorFactoryPtr
Pointer to the HttpResponseCreatorFactory.
const int DBGLVL_START_SHUT
This is given a value of 0 as that is the level selected if debugging is enabled without giving a lev...
boost::shared_ptr< DCfgMgrBase > DCfgMgrBasePtr
Defines a shared pointer to DCfgMgrBase.
boost::shared_ptr< ConfigBase > ConfigPtr
Non-const pointer to the ConfigBase.
Defines the logger used by the top-level component of kea-lfc.
HTTP request timeout value.