Kea 2.7.0
unix_control_socket.cc
Go to the documentation of this file.
1// Copyright (C) 2018-2024 Internet Systems Consortium, Inc. ("ISC")
2//
3// This Source Code Form is subject to the terms of the Mozilla Public
4// License, v. 2.0. If a copy of the MPL was not distributed with this
5// file, You can obtain one at http://mozilla.org/MPL/2.0/.
6
9
10#include <config.h>
11
13#include <asiolink/io_service.h>
15#include <cc/json_feed.h>
17#include <config/timeouts.h>
19
20using namespace std;
21using namespace isc::asiolink;
22using namespace isc::config;
23using namespace isc::data;
24
25namespace isc {
26namespace netconf {
27
32
36
38UnixControlSocket::configGet(const string& /*service*/) {
39 return (sendCommand(createCommand("config-get")));
40}
41
44 const string& /*service*/) {
45 return (sendCommand(createCommand("config-test", config)));
46}
47
50 const string& /*service*/) {
51 return (sendCommand(createCommand("config-set", config)));
52}
53
55UnixControlSocket::sendCommand(ConstElementPtr command) {
56 // We are using our own IO service because this method is synchronous.
57 IOServicePtr io_service(new IOService());
58 ClientConnection conn(io_service);
59 boost::system::error_code received_ec;
60 ConstJSONFeedPtr received_feed;
61
63 ClientConnection::ControlCommand(command->toWire()),
64 [&io_service, &received_ec, &received_feed]
65 (const boost::system::error_code& ec, ConstJSONFeedPtr feed) {
66 // Capture error code and parsed data.
67 received_ec = ec;
68 received_feed = feed;
69 // Got the IO service so stop IO service. This causes to
70 // stop IO service when all handlers have been invoked.
71 io_service->stopWork();
72 },
74
75 // Perform this synchronously.
76 io_service->run();
77
78 if (received_ec) {
79 // Got an error.
80 isc_throw(ControlSocketError, "communication error: "
81 << received_ec.message());
82 }
83
84 if (!received_feed) {
85 // Failed to get the answer.
86 isc_throw(ControlSocketError, "empty response");
87 }
88
89 try {
90 return (received_feed->toElement());
91 } catch (exception const& ex) {
92 isc_throw(ControlSocketError, "unparsable response: " << ex.what());
93 }
94}
95
96} // namespace netconf
97} // namespace isc
Represents client side connection over the unix domain socket.
Base class for control socket communication.
const std::string getName() const
Returns the Unix socket name.
Exception thrown when the error during communication.
Class for control socket communication over UNIX socket.
data::ConstElementPtr configTest(data::ElementPtr config, const std::string &service) override final
Test configuration.
UnixControlSocket(CfgControlSocketPtr ctrl_sock)
Constructor.
data::ConstElementPtr configGet(const std::string &service) override final
Get configuration.
data::ConstElementPtr configSet(data::ElementPtr config, const std::string &service) override final
Set configuration.
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.
boost::shared_ptr< const JSONFeed > ConstJSONFeedPtr
Pointer to the const JSONFeed.
Definition json_feed.h:27
ConstElementPtr createCommand(const std::string &command)
Creates a standard command message with no argument (of the form { "command": "my_command" })
constexpr long TIMEOUT_AGENT_FORWARD_COMMAND
Timeout for the Control Agent to forward command to a Kea server, e.g.
Definition timeouts.h:31
boost::shared_ptr< const Element > ConstElementPtr
Definition data.h:29
boost::shared_ptr< Element > ElementPtr
Definition data.h:28
std::shared_ptr< ControlSocketBase > ControlSocketBasePtr
Type definition for the pointer to the ControlSocketBase.
ControlSocketBasePtr createControlSocket< CfgControlSocket::Type::UNIX >(CfgControlSocketPtr ctrl_sock)
Factory template specialization for unix control sockets.
std::shared_ptr< CfgControlSocket > CfgControlSocketPtr
Defines a pointer for CfgControlSocket instances.
std::shared_ptr< UnixControlSocket > UnixControlSocketPtr
Type definition for the pointer to the UnixControlSocket.
Defines the logger used by the top-level component of kea-lfc.
Contains declarations for UNIX control socket communication.