18#include <boost/pointer_cast.hpp>
37 garbageCollectListeners(0);
51 boost::dynamic_pointer_cast<CtrlAgentController>(
53 controller->registerCommands();
61 garbageCollectListeners(1);
65 garbageCollectListeners(0);
67 }
catch (
const std::exception& ex) {
75 "Process run method failed: " << ex.
what());
81 boost::dynamic_pointer_cast<CtrlAgentController>(
83 controller->deregisterCommands();
84 }
catch (
const std::exception&) {
92CtrlAgentProcess::runIO() {
106 "Control Agent is shutting down"));
127 ctx = boost::dynamic_pointer_cast<CtrlAgentCfgContext>(base_ctx);
136 server_address =
IOAddress(ctx->getHttpHost());
140 <<
" to IP address:" << e.
what());
143 uint16_t server_port = ctx->getHttpPort();
144 bool use_https =
false;
147 if (http_listeners_.empty() ||
148 (http_listeners_.back()->getLocalAddress() != server_address) ||
149 (http_listeners_.back()->getLocalPort() != server_port)) {
153 if (!ctx->getCertFile().empty()) {
154 TlsContext::configure(tls_context,
156 ctx->getTrustAnchor(),
159 ctx->getCertRequired());
172 server_port, tls_context, rcf,
178 http_listener->start();
183 http_listeners_.push_back(http_listener);
184 }
else if (!http_listeners_.empty()) {
186 if (http_listeners_.back()->getTlsContext()) {
188 .arg(server_address.toText())
192 .arg(server_address.toText())
201 .arg(server_address.toText())
205 .arg(server_address.toText())
217 }
catch (
const std::exception& ex) {
218 std::ostringstream err;
219 err <<
"Error initializing hooks: "
228CtrlAgentProcess::garbageCollectListeners(
size_t leaving) {
232 if (http_listeners_.size() > leaving) {
234 for (
auto l = http_listeners_.begin(); l != http_listeners_.end() - leaving; ++l) {
244 http_listeners_.erase(http_listeners_.begin(),
245 http_listeners_.end() - leaving);
251 return (boost::dynamic_pointer_cast<CtrlAgentCfgMgr>(
getCfgMgr()));
258 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)
An exception that is thrown if an error occurs within the IO module.
static IOServiceMgr & instance()
Access the IOServiceMgr singleton instance.
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.
bool shouldShutdown() const
Checks if the process has been instructed to shut down.
asiolink::IOServicePtr & getIOService()
Fetches the controller's IOService.
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.
const isc::log::MessageID CTRL_AGENT_HTTP_SERVICE_REUSED
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
const isc::log::MessageID CTRL_AGENT_HTTPS_SERVICE_REUSED
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.
const int CONTROL_RESULT_ERROR
Status code indicating a general failure.
ConstElementPtr createAnswer()
Creates a standard config/command level success answer message (i.e.
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.