d_controller.cc 23.1 KB
Newer Older
1
// Copyright (C) 2013-2017 Internet Systems Consortium, Inc. ("ISC")
2
//
3 4 5
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
6

7
#include <config.h>
8
#include <cc/command_interpreter.h>
9 10
#include <cfgrpt/config_report.h>
#include <exceptions/exceptions.h>
11
#include <log/logger.h>
12
#include <log/logger_support.h>
13
#include <process/daemon.h>
14
#include <process/d_log.h>
15
#include <process/d_controller.h>
16
#include <process/config_base.h>
17
#include <kea_version.h>
18

19 20 21 22 23 24
#ifdef HAVE_MYSQL
#include <dhcpsrv/mysql_lease_mgr.h>
#endif
#ifdef HAVE_PGSQL
#include <dhcpsrv/pgsql_lease_mgr.h>
#endif
Tomek Mrugalski's avatar
Tomek Mrugalski committed
25 26
#ifdef HAVE_CQL
#include <dhcpsrv/cql_lease_mgr.h>
27
#endif
28 29
#include <dhcpsrv/memfile_lease_mgr.h>

30
#include <sstream>
31
#include <unistd.h>
32

Francis Dupont's avatar
Francis Dupont committed
33 34 35
using namespace isc::data;
using namespace isc::config;

36
namespace isc {
37
namespace process {
38 39 40 41

DControllerBasePtr DControllerBase::controller_;

// Note that the constructor instantiates the controller's primary IOService.
42
DControllerBase::DControllerBase(const char* app_name, const char* bin_name)
43
    : app_name_(app_name), bin_name_(bin_name),
44
      verbose_(false), check_only_(false),
45
      io_service_(new isc::asiolink::IOService()),
46
      io_signal_queue_() {
47 48
}

49
void
50
DControllerBase::setController(const DControllerBasePtr& controller) {
51 52 53 54 55 56 57
    if (controller_) {
        // This shouldn't happen, but let's make sure it can't be done.
        // It represents a programmatic error.
        isc_throw (DControllerBaseError,
                "Multiple controller instances attempted.");
    }

58
    controller_ = controller;
59 60
}

Francis Dupont's avatar
Francis Dupont committed
61
ConstElementPtr
62
DControllerBase::parseFile(const std::string&) {
Francis Dupont's avatar
Francis Dupont committed
63
    ConstElementPtr elements;
64 65 66
    return (elements);
}

67
void
68
DControllerBase::launch(int argc, char* argv[], const bool test_mode) {
69

70 71 72 73 74
    // Step 1 is to parse the command line arguments.
    try {
        parseArgs(argc, argv);
    } catch (const InvalidUsage& ex) {
        usage(ex.what());
75 76
        // rethrow it with an empty message
        isc_throw(InvalidUsage, "");
77 78
    }

79
    setProcName(bin_name_);
80

81 82
    if (isCheckOnly()) {
        checkConfigOnly();
83
        return;
84
    }
85

86 87 88
    // It is important that we set a default logger name because this name
    // will be used when the user doesn't provide the logging configuration
    // in the Kea configuration file.
89
    Daemon::setDefaultLoggerName(bin_name_);
90 91 92 93

    // Logger's default configuration depends on whether we are in the
    // verbose mode or not. CfgMgr manages the logger configuration so
    // the verbose mode is set for CfgMgr.
94
    Daemon::setVerbose(verbose_);
95

96 97 98 99
    // Do not initialize logger here if we are running unit tests. It would
    // replace an instance of unit test specific logger.
    if (!test_mode) {
        // Now that we know what the mode flags are, we can init logging.
100
        Daemon::loggerInit(bin_name_.c_str(), verbose_);
101
    }
102

103 104
    try {
        createPIDFile();
105
    } catch (const DaemonPIDExists& ex) {
106
        LOG_FATAL(dctl_logger, DCTL_ALREADY_RUNNING)
107 108 109
                  .arg(bin_name_).arg(ex.what());
        isc_throw (LaunchError, "Launch Failed: " << ex.what());
    } catch (const std::exception& ex) {
110
        LOG_FATAL(dctl_logger, DCTL_PID_FILE_ERROR)
111 112 113 114
                  .arg(app_name_).arg(ex.what());
        isc_throw (LaunchError, "Launch failed: " << ex.what());
    }

115 116 117
    // Log the starting of the service.
    LOG_INFO(dctl_logger, DCTL_STARTING)
        .arg(app_name_).arg(getpid()).arg(VERSION);
118
    try {
119
        // Step 2 is to create and initialize the application process object.
120
        initProcess();
121
    } catch (const std::exception& ex) {
122 123 124
        LOG_FATAL(dctl_logger, DCTL_INIT_PROCESS_FAIL)
                  .arg(app_name_).arg(ex.what());
        isc_throw (ProcessInitError,
125
                   "Application Process initialization failed: " << ex.what());
126
    }
127

Francis Dupont's avatar
Francis Dupont committed
128 129
    LOG_DEBUG(dctl_logger, isc::log::DBGLVL_START_SHUT, DCTL_STANDALONE)
        .arg(app_name_);
130 131 132

    // Step 3 is to load configuration from file.
    int rcode;
Francis Dupont's avatar
Francis Dupont committed
133
    ConstElementPtr comment = parseAnswer(rcode, configFromFile());
134 135 136
    if (rcode != 0) {
        LOG_FATAL(dctl_logger, DCTL_CONFIG_FILE_LOAD_FAIL)
                  .arg(app_name_).arg(comment->stringValue());
Vincent Legout's avatar
Vincent Legout committed
137
        isc_throw (ProcessInitError, "Could Not load configuration file: "
138
                   << comment->stringValue());
139
    }
140

141 142 143
    // Everything is clear for launch, so start the application's
    // event loop.
    try {
144 145
        // Now that we have a proces, we can set up signal handling.
        initSignalHandling();
146 147
        runProcess();
    } catch (const std::exception& ex) {
148 149 150
        LOG_FATAL(dctl_logger, DCTL_PROCESS_FAILED)
                  .arg(app_name_).arg(ex.what());
        isc_throw (ProcessRunError,
151
                   "Application process event loop failed: " << ex.what());
152 153
    }

154 155 156
    // All done, so bail out.
    LOG_INFO(dctl_logger, DCTL_SHUTDOWN)
        .arg(app_name_).arg(getpid()).arg(VERSION);
157 158
}

159 160 161 162 163 164 165
void
DControllerBase::checkConfigOnly() {
    try {
        // We need to initialize logging, in case any error
        // messages are to be printed.
        // This is just a test, so we don't care about lockfile.
        setenv("KEA_LOCKFILE_DIR", "none", 0);
166 167
        Daemon::setDefaultLoggerName(bin_name_);
        Daemon::setVerbose(verbose_);
168 169 170 171 172 173 174 175
        Daemon::loggerInit(bin_name_.c_str(), verbose_);

        // Check the syntax first.
        std::string config_file = getConfigFile();
        if (config_file.empty()) {
            // Basic sanity check: file name must not be empty.
            isc_throw(InvalidUsage, "JSON configuration file not specified");
        }
Francis Dupont's avatar
Francis Dupont committed
176
        ConstElementPtr whole_config = parseFile(config_file);
177 178 179 180 181 182 183 184 185
        if (!whole_config) {
            // No fallback to fromJSONFile
            isc_throw(InvalidUsage, "No configuration found");
        }
        if (verbose_) {
            std::cerr << "Syntax check OK" << std::endl;
        }

        // Check the logic next.
Francis Dupont's avatar
Francis Dupont committed
186
        ConstElementPtr module_config;
187 188 189 190 191 192 193 194 195
        module_config = whole_config->get(getAppName());
        if (!module_config) {
            isc_throw(InvalidUsage, "Config file " << config_file <<
                      " does not include '" << getAppName() << "' entry");
        }

        // Get an application process object.
        initProcess();

Francis Dupont's avatar
Francis Dupont committed
196
        ConstElementPtr answer = checkConfig(module_config);
197
        int rcode = 0;
Francis Dupont's avatar
Francis Dupont committed
198
        answer = parseAnswer(rcode, answer);
199 200 201 202 203 204 205 206 207 208 209 210 211 212
        if (rcode != 0) {
            isc_throw(InvalidUsage, "Error encountered: "
                      << answer->stringValue());
        }
    } catch (const VersionMessage&) {
        throw;
    } catch (const InvalidUsage&) {
        throw;
    } catch (const std::exception& ex) {
        isc_throw(InvalidUsage, "Syntax check failed with: " << ex.what());
    }
    return;
}

213 214 215
void
DControllerBase::parseArgs(int argc, char* argv[])
{
216
    // Iterate over the given command line options. If its a stock option
217
    // ("c" or "d") handle it here.  If its a valid custom option, then
218 219
    // invoke customOption.
    int ch;
220
    opterr = 0;
221
    optind = 1;
222
    std::string opts("dvVWc:t:" + getCustomOpts());
223 224
    while ((ch = getopt(argc, argv, opts.c_str())) != -1) {
        switch (ch) {
225
        case 'd':
226 227 228 229
            // Enables verbose logging.
            verbose_ = true;
            break;

230
        case 'v':
231 232 233 234
            // gather Kea version and throw so main() can catch and return
            // rather than calling exit() here which disrupts gtest.
            isc_throw(VersionMessage, getVersion(false));
            break;
235 236

        case 'V':
237 238 239 240
            // gather Kea version and throw so main() can catch and return
            // rather than calling exit() here which disrupts gtest.
            isc_throw(VersionMessage, getVersion(true));
            break;
241

242 243 244 245 246 247
        case 'W':
            // gather Kea config report and throw so main() can catch and
            // return rather than calling exit() here which disrupts gtest.
            isc_throw(VersionMessage, isc::detail::getConfigReport());
            break;

248
        case 'c':
249
        case 't':
250 251 252 253 254
            // config file name
            if (optarg == NULL) {
                isc_throw(InvalidUsage, "configuration file name missing");
            }

255
            setConfigFile(optarg);
256 257 258 259

            if (ch == 't') {
                check_only_ = true;
            }
260 261 262 263
            break;

        case '?': {
            // We hit an invalid option.
264
            isc_throw(InvalidUsage, "unsupported option: ["
265 266
                      << static_cast<char>(optopt) << "] "
                      << (!optarg ? "" : optarg));
267 268 269

            break;
            }
270

271 272 273
        default:
            // We hit a valid custom option
            if (!customOption(ch, optarg)) {
274
                // This would be a programmatic error.
275
                isc_throw(InvalidUsage, " Option listed but implemented?: ["
276 277
                          << static_cast<char>(ch) << "] "
                          << (!optarg ? "" : optarg));
278 279 280 281 282 283 284
            }
            break;
        }
    }

    // There was too much information on the command line.
    if (argc > optind) {
285
        isc_throw(InvalidUsage, "extraneous command line information");
286 287 288
    }
}

289
bool
290 291 292 293 294 295 296 297
DControllerBase::customOption(int /* option */, char* /*optarg*/)
{
    // Default implementation returns false.
    return (false);
}

void
DControllerBase::initProcess() {
Francis Dupont's avatar
Francis Dupont committed
298 299
    LOG_DEBUG(dctl_logger, isc::log::DBGLVL_START_SHUT, DCTL_INIT_PROCESS)
        .arg(app_name_);
300 301

    // Invoke virtual method to instantiate the application process.
302
    try {
303
        process_.reset(createProcess());
304
    } catch (const std::exception& ex) {
305
        isc_throw(DControllerBaseError, std::string("createProcess failed: ")
306
                  + ex.what());
307 308 309 310
    }

    // This is pretty unlikely, but will test for it just to be safe..
    if (!process_) {
311
        isc_throw(DControllerBaseError, "createProcess returned NULL");
312
    }
313

314 315
    // Invoke application's init method (Note this call should throw
    // DProcessBaseError if it fails).
316 317 318
    process_->init();
}

Francis Dupont's avatar
Francis Dupont committed
319
ConstElementPtr
320
DControllerBase::configFromFile() {
321 322
    // Rollback any previous staging configuration. For D2, only a
    // logger configuration is used here.
323 324 325
    // We're not using cfgmgr to store logging configuration anymore.
    // isc::dhcp::CfgMgr::instance().rollback();

326
    // Will hold configuration.
Francis Dupont's avatar
Francis Dupont committed
327
    ConstElementPtr module_config;
328
    // Will receive configuration result.
Francis Dupont's avatar
Francis Dupont committed
329
    ConstElementPtr answer;
330
    try {
331
        std::string config_file = getConfigFile();
332 333 334 335 336 337
        if (config_file.empty()) {
            // Basic sanity check: file name must not be empty.
            isc_throw(BadValue, "JSON configuration file not specified. Please "
                                "use -c command line option.");
        }

338 339
        // If parseFile returns an empty pointer, then pass the file onto the
        // original JSON parser.
Francis Dupont's avatar
Francis Dupont committed
340
        ConstElementPtr whole_config = parseFile(config_file);
341 342
        if (!whole_config) {
            // Read contents of the file and parse it as JSON
Francis Dupont's avatar
Francis Dupont committed
343
            whole_config = Element::fromJSONFile(config_file, true);
344
        }
345

346 347 348 349
        // Let's configure logging before applying the configuration,
        // so we can log things during configuration process.

        // Temporary storage for logging configuration
350
        ConfigPtr storage = process_->getCfgMgr()->getContext();
351

Tomek Mrugalski's avatar
Tomek Mrugalski committed
352 353
        // Get 'Logging' element from the config and use it to set up
        // logging. If there's no such element, we'll just pass NULL.
354
        Daemon::configureLogger(whole_config->get("Logging"), storage);
355

356 357 358 359 360 361 362
        // Extract derivation-specific portion of the configuration.
        module_config = whole_config->get(getAppName());
        if (!module_config) {
            isc_throw(BadValue, "Config file " << config_file <<
                                " does not include '" <<
                                 getAppName() << "' entry.");
        }
363

364
        answer = updateConfig(module_config);
365
        int rcode = 0;
Francis Dupont's avatar
Francis Dupont committed
366
        parseAnswer(rcode, answer);
367 368 369
        if (!rcode) {
            // Configuration successful, so apply the logging configuration
            // to log4cplus.
370
            storage->applyLoggingCfg();
371 372
        }

373
    } catch (const std::exception& ex) {
374
        // Rollback logging configuration.
375 376 377
        // We don't use CfgMgr to store logging information anymore.
        // isc::dhcp::CfgMgr::instance().rollback();

378
        // build an error result
Francis Dupont's avatar
Francis Dupont committed
379 380
        ConstElementPtr error = createAnswer(COMMAND_ERROR,
                 std::string("Configuration parsing failed: ") + ex.what());
381
        return (error);
382 383
    }

384
    return (answer);
385 386 387 388
}

void
DControllerBase::runProcess() {
Francis Dupont's avatar
Francis Dupont committed
389 390
    LOG_DEBUG(dctl_logger, isc::log::DBGLVL_START_SHUT, DCTL_RUN_PROCESS)
        .arg(app_name_);
391 392 393 394 395
    if (!process_) {
        // This should not be possible.
        isc_throw(DControllerBaseError, "Process not initialized");
    }

396 397
    // Invoke the application process's run method. This may throw
    // DProcessBaseError
398 399 400
    process_->run();
}

401
// Instance method for handling new config
Francis Dupont's avatar
Francis Dupont committed
402 403
ConstElementPtr
DControllerBase::updateConfig(ConstElementPtr new_config) {
404 405 406 407
    return (process_->configure(new_config, false));
}

// Instance method for checking new config
Francis Dupont's avatar
Francis Dupont committed
408 409
ConstElementPtr
DControllerBase::checkConfig(ConstElementPtr new_config) {
410
    return (process_->configure(new_config, true));
411 412
}

Francis Dupont's avatar
Francis Dupont committed
413
ConstElementPtr
Francis Dupont's avatar
Francis Dupont committed
414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451
DControllerBase::configGetHandler(const std::string&,
                                  ConstElementPtr /*args*/) {
    ConstElementPtr config = process_->getCfgMgr()->getContext()->toElement();

    return (createAnswer(COMMAND_SUCCESS, config));
}

ConstElementPtr
DControllerBase::configWriteHandler(const std::string&,
                                    ConstElementPtr args) {
    std::string filename;

    if (args) {
        if (args->getType() != Element::map) {
            return (createAnswer(COMMAND_ERROR, "Argument must be a map"));
        }
        ConstElementPtr filename_param = args->get("filename");
        if (filename_param) {
            if (filename_param->getType() != Element::string) {
                return (createAnswer(COMMAND_ERROR,
                                     "passed parameter 'filename' "
                                     "is not a string"));
            }
            filename = filename_param->stringValue();
        }
    }

    if (filename.empty()) {
        // filename parameter was not specified, so let's use
        // whatever we remember
        filename = getConfigFile();
        if (filename.empty()) {
            return (createAnswer(COMMAND_ERROR,
                                 "Unable to determine filename."
                                 "Please specify filename explicitly."));
        }
    }

452

Francis Dupont's avatar
Francis Dupont committed
453 454
    // Ok, it's time to write the file.
    size_t size = 0;
455 456 457 458 459 460 461 462 463 464 465 466
    ElementPtr cfg = process_->getCfgMgr()->getContext()->toElement();

    // Logging storage is messed up in CA. During its configuration (see
    // DControllerBase::configFromFile() it calls Daemon::configureLogger()
    // that stores the logging info in isc::dhcp::CfgMgr::getStagingCfg().
    // This is later moved to getCurrentCfg() when the configuration is
    // commited. All control-agent specific configuration is stored in
    // a structure accessible by process_->getCfgMgr()->getContext(). Note
    // logging information is not stored there.
    //
    // As a result, we need to extract the CA configuration from one
    // place and logging from another.
467 468 469 470 471 472 473 474 475 476 477 478
    if (!cfg->contains("Logging")) {
        ConfigPtr base_cfg = process_->getCfgMgr()->getContext();

        ConstElementPtr loginfo = base_cfg->toElement();
        if (loginfo) {
            // If there was a config stored in dhcp::CfgMgr, try to get Logging info from it.
            loginfo = loginfo->get("Logging");
        }
        if (loginfo) {
            // If there is some logging information, add it to our config.
            cfg->set("Logging", loginfo);
        }
479 480
    }

Francis Dupont's avatar
Francis Dupont committed
481
    try {
482
        size = writeConfigFile(filename, cfg);
Francis Dupont's avatar
Francis Dupont committed
483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503
    } catch (const isc::Exception& ex) {
        return (createAnswer(COMMAND_ERROR,
                             std::string("Error during write-config:")
                             + ex.what()));
    }
    if (size == 0) {
        return (createAnswer(COMMAND_ERROR,
                             "Error writing configuration to " + filename));
    }

    // Ok, it's time to return the successful response.
    ElementPtr params = Element::createMap();
    params->set("size", Element::create(static_cast<long long>(size)));
    params->set("filename", Element::create(filename));

    return (createAnswer(CONTROL_RESULT_SUCCESS, "Configuration written to "
                         + filename + " successful", params));
}

ConstElementPtr
DControllerBase::configTestHandler(const std::string&, ConstElementPtr args) {
504 505
    const int status_code = COMMAND_ERROR; // 1 indicates an error
    ConstElementPtr module_config;
506
    std::string app_name = getAppName();
Francis Dupont's avatar
Francis Dupont committed
507 508 509
    std::string message;

    // Command arguments are expected to be:
510 511
    // { "Module": { ... }, "Logging": { ... } }
    // The Logging component is technically optional. If it's not supplied
Francis Dupont's avatar
Francis Dupont committed
512 513 514 515
    // logging will revert to default logging.
    if (!args) {
        message = "Missing mandatory 'arguments' parameter.";
    } else {
516
      module_config = args->get(app_name);
517
        if (!module_config) {
518
            message = "Missing mandatory '" + app_name + "' parameter.";
519
        } else if (module_config->getType() != Element::map) {
520
            message = "'" + app_name + "' parameter expected to be a map.";
Francis Dupont's avatar
Francis Dupont committed
521 522 523 524 525 526 527 528 529 530 531 532 533
        }
    }

    if (!message.empty()) {
        // Something is amiss with arguments, return a failure response.
        ConstElementPtr result = isc::config::createAnswer(status_code,
                                                           message);
        return (result);
    }

    // We are starting the configuration process so we should remove any
    // staging configuration that has been created during previous
    // configuration attempts.
534 535
    // We're not using cfgmgr to store logging information anymore.
    // isc::dhcp::CfgMgr::instance().rollback();
Francis Dupont's avatar
Francis Dupont committed
536 537

    // Now we check the server proper.
538
    return (checkConfig(module_config));
Francis Dupont's avatar
Francis Dupont committed
539 540
}

Francis Dupont's avatar
Francis Dupont committed
541
ConstElementPtr
Francis Dupont's avatar
Francis Dupont committed
542
DControllerBase::versionGetHandler(const std::string&, ConstElementPtr) {
Francis Dupont's avatar
Francis Dupont committed
543
    ConstElementPtr answer;
544

Francis Dupont's avatar
Francis Dupont committed
545 546 547 548 549
    // For version-get put the extended version in arguments
    ElementPtr extended = Element::create(getVersion(true));
    ElementPtr arguments = Element::createMap();
    arguments->set("extended", extended);
    answer = createAnswer(COMMAND_SUCCESS, getVersion(false), arguments);
550 551 552
    return (answer);
}

Francis Dupont's avatar
Francis Dupont committed
553
ConstElementPtr
554
DControllerBase::buildReportHandler(const std::string&, ConstElementPtr) {
Francis Dupont's avatar
Francis Dupont committed
555 556
    return (createAnswer(COMMAND_SUCCESS, isc::detail::getConfigReport()));
}
557

Francis Dupont's avatar
Francis Dupont committed
558 559 560 561 562 563 564
ConstElementPtr
DControllerBase::shutdownHandler(const std::string&, ConstElementPtr args) {
    // Shutdown is universal.  If its not that, then try it as
    // a custom command supported by the derivation.  If that
    // doesn't pan out either, than send to it the application
    // as it may be supported there.
    return (shutdownProcess(args));
565 566
}

Francis Dupont's avatar
Francis Dupont committed
567 568
ConstElementPtr
DControllerBase::shutdownProcess(ConstElementPtr args) {
569
    if (process_) {
570
        return (process_->shutdown(args));
571
    }
572

573 574 575
    // Not really a failure, but this condition is worth noting. In reality
    // it should be pretty hard to cause this.
    LOG_WARN(dctl_logger, DCTL_NOT_RUNNING).arg(app_name_);
Francis Dupont's avatar
Francis Dupont committed
576
    return (createAnswer(COMMAND_SUCCESS, "Process has not been initialized"));
577 578
}

579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620
void
DControllerBase::initSignalHandling() {
    /// @todo block everything we don't handle

    // Create our signal queue.
    io_signal_queue_.reset(new IOSignalQueue(io_service_));

    // Install the on-receipt handler
    util::SignalSet::setOnReceiptHandler(boost::bind(&DControllerBase::
                                                     osSignalHandler,
                                                     this, _1));
    // Register for the signals we wish to handle.
    signal_set_.reset(new util::SignalSet(SIGHUP,SIGINT,SIGTERM));
}

bool
DControllerBase::osSignalHandler(int signum) {
    // Create a IOSignal to propagate the signal to IOService.
    io_signal_queue_->pushSignal(signum, boost::bind(&DControllerBase::
                                                     ioSignalHandler,
                                                     this, _1));
    return (true);
}

void
DControllerBase::ioSignalHandler(IOSignalId sequence_id) {
    // Pop the signal instance off the queue.  This should make us
    // the only one holding it, so when we leave it should be freed.
    // (note that popSignal will throw if signal is not found, which
    // in turn will caught, logged, and swallowed by IOSignal callback
    // invocation code.)
    IOSignalPtr io_signal = io_signal_queue_->popSignal(sequence_id);

    // Now call virtual signal processing method.
    processSignal(io_signal->getSignum());
}

void
DControllerBase::processSignal(int signum) {
    switch (signum) {
        case SIGHUP:
        {
621
            LOG_INFO(dctl_logger, DCTL_CFG_FILE_RELOAD_SIGNAL_RECVD)
622 623
                     .arg(signum).arg(getConfigFile());
            int rcode;
Francis Dupont's avatar
Francis Dupont committed
624
            ConstElementPtr comment = parseAnswer(rcode, configFromFile());
625
            if (rcode != 0) {
626
                LOG_ERROR(dctl_logger, DCTL_CFG_FILE_RELOAD_ERROR)
627 628 629 630 631 632 633 634 635
                          .arg(comment->stringValue());
            }

            break;
        }

        case SIGINT:
        case SIGTERM:
        {
Francis Dupont's avatar
Francis Dupont committed
636
            LOG_DEBUG(dctl_logger, isc::log::DBGLVL_START_SHUT,
637
                      DCTL_SHUTDOWN_SIGNAL_RECVD).arg(signum);
Francis Dupont's avatar
Francis Dupont committed
638 639
            ElementPtr arg_set;
            shutdownHandler(SHUT_DOWN_COMMAND, arg_set);
640 641 642 643
            break;
        }

        default:
644
            LOG_WARN(dctl_logger, DCTL_UNSUPPORTED_SIGNAL).arg(signum);
645 646 647 648
            break;
    }
}

649 650 651 652
void
DControllerBase::usage(const std::string & text)
{
    if (text != "") {
653
        std::cerr << "Usage error: " << text << std::endl;
654 655
    }

656
    std::cerr << "Usage: " << bin_name_ <<  std::endl
657 658
              << "  -v: print version number and exit" << std::endl
              << "  -V: print extended version information and exit"
659 660
              << std::endl
              << "  -W: display the configuration report and exit"
661 662 663
              << std::endl
              << "  -d: optional, verbose output " << std::endl
              << "  -c <config file name> : mandatory,"
664 665 666
              << " specify name of configuration file" << std::endl
              << "  -t <config file name> : check the"
              << " configuration file and exit" << std::endl;
667

668
    // add any derivation specific usage
669
    std::cerr << getUsageText() << std::endl;
670 671 672 673 674
}

DControllerBase::~DControllerBase() {
}

675 676 677
// Refer to config_report so it will be embedded in the binary
const char* const* d2_config_report = isc::detail::config_report;

Tomek Mrugalski's avatar
Tomek Mrugalski committed
678
std::string
679
DControllerBase::getVersion(bool extended) {
Tomek Mrugalski's avatar
Tomek Mrugalski committed
680 681 682 683
    std::stringstream tmp;

    tmp << VERSION;
    if (extended) {
684
        tmp << std::endl << EXTENDED_VERSION << std::endl;
685 686
        tmp << "linked with:" << std::endl;
        tmp << isc::log::Logger::getVersion() << std::endl;
687
        tmp << getVersionAddendum();
Tomek Mrugalski's avatar
Tomek Mrugalski committed
688 689 690 691
    }

    return (tmp.str());
}
692

693
}; // namespace isc::process
694 695

}; // namespace isc