diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-05-04 11:36:04 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-05-04 11:36:04 +0000 |
commit | 040eee1aa49b49df4698d83a05af57c220127fd1 (patch) | |
tree | f635435954e6ccde5eee9893889e24f30ca68346 /src/lib/dhcpsrv/testutils/dhcp4o6_test_ipc.cc | |
parent | Initial commit. (diff) | |
download | isc-kea-040eee1aa49b49df4698d83a05af57c220127fd1.tar.xz isc-kea-040eee1aa49b49df4698d83a05af57c220127fd1.zip |
Adding upstream version 2.2.0.upstream/2.2.0upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/lib/dhcpsrv/testutils/dhcp4o6_test_ipc.cc')
-rw-r--r-- | src/lib/dhcpsrv/testutils/dhcp4o6_test_ipc.cc | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/src/lib/dhcpsrv/testutils/dhcp4o6_test_ipc.cc b/src/lib/dhcpsrv/testutils/dhcp4o6_test_ipc.cc new file mode 100644 index 0000000..a50a5c2 --- /dev/null +++ b/src/lib/dhcpsrv/testutils/dhcp4o6_test_ipc.cc @@ -0,0 +1,41 @@ +// Copyright (C) 2015-2020 Internet Systems Consortium, Inc. ("ISC") +// +// 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/. + +#include <config.h> +#include <dhcp/iface_mgr.h> +#include <dhcpsrv/testutils/dhcp4o6_test_ipc.h> +#include <functional> + +namespace isc { +namespace dhcp { +namespace test { + +Dhcp4o6TestIpc::Dhcp4o6TestIpc(uint16_t port, EndpointType endpoint_type) + : desired_port_(port), endpoint_type_(endpoint_type), pkt_received_() { +} + +void +Dhcp4o6TestIpc::open() { + // Use the base IPC to open the socket. + socket_fd_ = Dhcp4o6IpcBase::open(desired_port_, endpoint_type_); + // If the socket has been opened correctly, register it in the @c IfaceMgr. + // BTW if it has not an exception has been thrown so it is only + // a sanity / recommended check. + if (socket_fd_ != -1) { + IfaceMgr& iface_mgr = IfaceMgr::instance(); + iface_mgr.addExternalSocket(socket_fd_, + std::bind(&Dhcp4o6TestIpc::receiveHandler, this)); + } +} + +void +Dhcp4o6TestIpc::receiveHandler() { + pkt_received_ = receive(); +} + +} // end of isc::dhcp::test namespace +} // end of isc::dhcp namespace +} // end of isc namespace |