27struct D2ProcessHooks {
28 int hooks_index_d2_srv_configured_;
32 hooks_index_d2_srv_configured_ = HooksManager::registerHook(
"d2_srv_configured");
54 reconf_queue_flag_(false), shutdown_type_(SD_NORMAL) {
86 controller->registerCommands();
110 "Primary IO service stopped unexpectedly");
113 }
catch (
const std::exception& ex) {
115 controller->deregisterCommands();
117 "Process run method failed: " << ex.
what());
124 controller->deregisterCommands();
142 boost::asio::io_service& asio_io_service = io->get_io_service();
146 size_t cnt = asio_io_service.poll();
151 cnt = asio_io_service.run_one();
159 bool all_clear =
false;
163 switch (shutdown_type_) {
169 && (update_mgr_->getTransactionCount() == 0));
177 && (queue_mgr_->getQueueSize() == 0)
178 && (update_mgr_->getTransactionCount() == 0));
206 .arg(args ? args->str() :
"(no arguments)");
214 args->contains(
"type")) {
215 type_str = args->get(
"type")->stringValue();
226 "Invalid Shutdown type: " +
235 "Shutdown initiated, type is: " +
242 .arg(check_only ?
"check" :
"update")
246 answer =
getCfgMgr()->simpleParseConfig(config_set, check_only,
260 reconf_queue_flag_ =
false;
275 reconf_queue_flag_ =
true;
282 std::string
error(
"");
283 if (HooksManager::calloutsPresent(
Hooks.hooks_index_d2_srv_configured_)) {
286 callout_handle->setArgument(
"io_context",
getIoService());
287 callout_handle->setArgument(
"json_config", config_set);
288 callout_handle->setArgument(
"server_config",
290 callout_handle->setArgument(
"error",
error);
292 HooksManager::callCallouts(
Hooks.hooks_index_d2_srv_configured_,
296 if (callout_handle->getStatus() == CalloutHandle::NEXT_STEP_DROP) {
297 callout_handle->getArgument(
"error",
error);
300 reconf_queue_flag_ =
false;
314 switch (queue_mgr_->getMgrState()){
324 .arg(reconf_queue_flag_ ?
"reconfiguration" :
"shutdown");
325 queue_mgr_->stopListening();
339 size_t threshold = (((queue_mgr_->getMaxQueueSize()
341 if (queue_mgr_->getQueueSize() <= threshold) {
343 .arg(threshold).arg(queue_mgr_->getMaxQueueSize());
345 queue_mgr_->startListening();
380 if (reconf_queue_flag_) {
400 reconf_queue_flag_ =
false;
403 queue_mgr_->removeListener();
410 std::string ip_address = d2_params->getIpAddress().toText();
411 if (ip_address ==
"0.0.0.0" || ip_address ==
"::") {
413 }
else if (ip_address !=
"127.0.0.1" && ip_address !=
"::1") {
419 queue_mgr_->initUDPListener(d2_params->getIpAddress(),
420 d2_params->getPort(),
421 d2_params->getNcrFormat(),
true);
434 queue_mgr_->startListening();
451 return (boost::dynamic_pointer_cast<D2CfgMgr>(
getCfgMgr()));
482 bool sock_changed = (sock_cfg && current_control_socket_ &&
483 !sock_cfg->equals(*current_control_socket_));
490 if (!sock_cfg || !current_control_socket_ || sock_changed) {
492 if (current_control_socket_) {
494 current_control_socket_.reset();
504 current_control_socket_ = sock_cfg;
This is a base class for exceptions thrown from the DNS library module.
virtual const char * what() const
Returns a C-style character string of the cause of the exception.
void closeCommandSocket()
Shuts down any open control sockets.
static CommandMgr & instance()
CommandMgr is a singleton class.
void setIOService(const asiolink::IOServicePtr &io_service)
Sets IO service to be used by the command manager.
void openCommandSocket(const isc::data::ConstElementPtr &socket_info)
Opens control socket with parameters specified in socket_info.
DHCP-DDNS Configuration Manager.
static process::DControllerBasePtr & instance()
Static singleton instance method.
D2Process(const char *name, const asiolink::IOServicePtr &io_service)
Constructor.
static const unsigned int QUEUE_RESTART_PERCENT
Defines the point at which to resume receiving requests.
virtual bool canShutdown() const
Indicates whether or not the process can perform a shutdown.
virtual void checkQueueStatus()
Monitors current queue manager state, takes action accordingly.
virtual ~D2Process()
Destructor.
virtual void run()
Implements the process's event loop.
virtual void init()
Called after instantiation to perform initialization unique to D2.
D2CfgMgrPtr getD2CfgMgr()
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 reconfigureCommandChannel()
(Re-)Configure the command channel.
virtual void reconfigureQueueMgr()
Initializes then starts the queue manager.
ShutdownType
Defines the shutdown types supported by D2Process.
virtual isc::data::ConstElementPtr shutdown(isc::data::ConstElementPtr args)
Initiates the D2Process shutdown process.
static const char * getShutdownTypeStr(const ShutdownType &type)
Returns a text label for the given shutdown type.
virtual size_t runIO()
Allows IO processing to run until at least callback is invoked.
D2QueueMgr creates and manages a queue of DNS update requests.
static void init()
Initialize D2 statistics.
D2UpdateMgr creates and manages update transactions.
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.
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_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_WARN(LOGGER, MESSAGE)
Macro to conveniently test warn 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< IOService > IOServicePtr
Defines a smart pointer to an IOService instance.
const int CONTROL_RESULT_ERROR
Status code indicating a general failure.
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.
boost::shared_ptr< D2CfgMgr > D2CfgMgrPtr
Defines a shared pointer to D2CfgMgr.
const isc::log::MessageID DHCP_DDNS_QUEUE_MGR_RECOVERING
const isc::log::MessageID DHCP_DDNS_QUEUE_MGR_STOP_ERROR
const isc::log::MessageID DHCP_DDNS_FAILED
const isc::log::MessageID DHCP_DDNS_LISTENING_ON_ALL_INTERFACES
const isc::log::MessageID DHCP_DDNS_QUEUE_MGR_START_ERROR
const isc::log::MessageID DHCP_DDNS_SHUTDOWN_COMMAND
const isc::log::MessageID DHCP_DDNS_CONFIGURE
const isc::log::MessageID DHCP_DDNS_CLEARED_FOR_SHUTDOWN
const isc::log::MessageID DHCP_DDNS_QUEUE_MGR_RECONFIGURING
const isc::log::MessageID DHCP_DDNS_RUN_EXIT
const isc::log::MessageID DHCP_DDNS_CONFIGURED_CALLOUT_DROP
const isc::log::MessageID DHCP_DDNS_QUEUE_MGR_RESUME_ERROR
const isc::log::MessageID DHCP_DDNS_STARTED
boost::shared_ptr< D2Controller > D2ControllerPtr
Pointer to a process controller.
isc::log::Logger d2_logger("dhcpddns")
Defines the logger used within D2.
const isc::log::MessageID DHCP_DDNS_QUEUE_MGR_RESUMING
boost::shared_ptr< D2Params > D2ParamsPtr
Defines a pointer for D2Params instances.
const isc::log::MessageID DHCP_DDNS_QUEUE_MGR_STOPPING
const isc::log::MessageID DHCP_DDNS_NOT_ON_LOOPBACK
boost::shared_ptr< const Element > ConstElementPtr
std::string ncrProtocolToString(NameChangeProtocol protocol)
Function which converts NameChangeProtocol enums to text labels.
boost::shared_ptr< CalloutHandle > CalloutHandlePtr
A shared pointer to a CalloutHandle object.
const int DBGLVL_TRACE_BASIC
Trace basic operations.
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.
ConstElementPtr redactConfig(ConstElementPtr const &element, list< string > const &json_path)
Redact a configuration.
Defines the logger used by the top-level component of kea-lfc.