18#include <boost/pointer_cast.hpp>
49 boost::dynamic_pointer_cast<CtrlAgentController>(
51 controller->registerCommands();
61 }
catch (
const std::exception& ex) {
69 "Process run method failed: " << ex.what());
75 boost::dynamic_pointer_cast<CtrlAgentController>(
77 controller->deregisterCommands();
78 }
catch (
const std::exception&) {
86CtrlAgentProcess::runIO() {
100 "Control Agent is shutting down"));
121 ctx = boost::dynamic_pointer_cast<CtrlAgentCfgContext>(base_ctx);
130 server_address =
IOAddress(ctx->getHttpHost());
134 <<
" to IP address:" << e.
what());
137 uint16_t server_port = ctx->getHttpPort();
140 auto it = sockets_.find(std::make_pair(server_address, server_port));
141 if (it != sockets_.end()) {
142 auto listener = it->second->listener_;
145 if (listener->getTlsContext()) {
146 if (ctx->getTrustAnchor().empty()) {
149 .arg(server_address.
toText())
152 "Can not switch from HTTPS to HTTP sockets using the same address and port.");
156 TlsContext::configure(tls_context,
158 ctx->getTrustAnchor(),
161 ctx->getCertRequired());
163 it->second->config_->setAuthConfig(ctx->getAuthConfig());
164 it->second->config_->setHttpHeaders(ctx->getHttpHeaders());
165 listener->setTlsContext(tls_context);
167 .arg(server_address.
toText())
171 if (!ctx->getTrustAnchor().empty()) {
174 .arg(server_address.
toText())
177 "Can not switch from HTTP to HTTPS sockets using the same address and port.");
180 it->second->config_->setAuthConfig(ctx->getAuthConfig());
181 it->second->config_->setHttpHeaders(ctx->getHttpHeaders());
183 .arg(server_address.
toText())
189 it->second->usable_ =
true;
194 bool use_https =
false;
196 if (!ctx->getCertFile().empty()) {
197 TlsContext::configure(tls_context,
199 ctx->getTrustAnchor(),
202 ctx->getCertRequired());
224 http_listener->start();
227 socket_info->config_ = ctx;
228 socket_info->listener_ = http_listener;
230 sockets_[std::make_pair(server_address, server_port)] = socket_info;
235 .arg(server_address.
toText())
239 .arg(server_address.
toText())
244 auto copy = sockets_;
245 for (
auto const& data :
copy) {
246 if (data.second->usable_) {
250 data.second->usable_ =
false;
253 data.second->listener_->stop();
254 auto it = sockets_.find(std::make_pair(data.second->config_->getHttpHost(),
255 data.second->config_->getHttpPort()));
256 if (it != sockets_.end()) {
270 }
catch (
const std::exception& ex) {
271 std::ostringstream err;
272 err <<
"Error initializing hooks: "
282 for (
auto const& data : sockets_) {
283 data.second->listener_->stop();
296 return (boost::dynamic_pointer_cast<CtrlAgentCfgMgr>(
getCfgMgr()));
303 auto it = sockets_.find(std::make_pair(info->config_->getHttpHost(), info->config_->getHttpPort()));
304 if (it != sockets_.end()) {
305 return (it->second->listener_);
307 }
else if (sockets_.size()) {
308 return (sockets_.begin()->second->listener_);
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.
isc::http::ConstHttpListenerPtr getHttpListener(HttpSocketInfoPtr info=HttpSocketInfoPtr()) const
Returns a const pointer to the HTTP listener.
virtual isc::data::ConstElementPtr shutdown(isc::data::ConstElementPtr args)
Initiates the process's shutdown process.
virtual ~CtrlAgentProcess()
Destructor.
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.
void closeCommandSockets()
Close http control sockets.
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.
static IOServiceMgr & instance()
Access the IOServiceMgr singleton instance.
void pollIOServices()
Poll IOService objects.
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_ERROR(LOGGER, MESSAGE)
Macro to conveniently test error output and log it.
#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_HTTPS_SERVICE_UPDATED
boost::shared_ptr< CtrlAgentCfgContext > CtrlAgentCfgContextPtr
Pointer to a configuration context.
const isc::log::MessageID CTRL_AGENT_HTTP_SERVICE_REUSE_FAILED
const isc::log::MessageID CTRL_AGENT_HTTP_SERVICE_UPDATED
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
boost::shared_ptr< HttpSocketInfo > HttpSocketInfoPtr
Pointer to a HttpSocketInfo object.
const isc::log::MessageID CTRL_AGENT_HTTPS_SERVICE_STARTED
const isc::log::MessageID CTRL_AGENT_RUN_EXIT
const isc::log::MessageID CTRL_AGENT_HTTPS_SERVICE_REUSE_FAILED
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.
ConstElementPtr parseAnswer(int &rcode, const ConstElementPtr &msg)
Parses a standard config/command level answer and returns arguments or text status code.
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.
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.
ElementPtr copy(ConstElementPtr from, int level)
Copy the data up to a nesting level.
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.
Structure used to store HTTP/HTTPS connection data.
HTTP request timeout value.