mirror of
https://gitlab.isc.org/isc-projects/kea
synced 2025-09-01 14:35:29 +00:00
[trac4000] Unit-tests for process spawn + errno, verbose exceptions added.
This commit is contained in:
@@ -16,6 +16,7 @@
|
|||||||
#include <string>
|
#include <string>
|
||||||
|
|
||||||
#include <exceptions/exceptions.h>
|
#include <exceptions/exceptions.h>
|
||||||
|
#include <sstream>
|
||||||
|
|
||||||
#include <gtest/gtest.h>
|
#include <gtest/gtest.h>
|
||||||
|
|
||||||
@@ -47,4 +48,24 @@ TEST_F(ExceptionTest, stdInheritance) {
|
|||||||
EXPECT_EQ(std::string(ex.what()), std::string(teststring));
|
EXPECT_EQ(std::string(ex.what()), std::string(teststring));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Tests whether verbose is disabled by default and can be enabled, if
|
||||||
|
// needed.
|
||||||
|
TEST_F(ExceptionTest, verbose) {
|
||||||
|
|
||||||
|
// This code is line numbers sensitive. Make sure no edits are done between
|
||||||
|
// this line and isc_throw below. Update that +3 offset, if needed.
|
||||||
|
std::stringstream expected;
|
||||||
|
expected << teststring << "[" << std::string(__FILE__)
|
||||||
|
<< ":" << int(__LINE__ + 3) << "]";
|
||||||
|
|
||||||
|
try {
|
||||||
|
isc_throw(Exception, teststring);
|
||||||
|
} catch (const isc::Exception& ex) {
|
||||||
|
EXPECT_EQ(std::string(ex.what()), std::string(teststring));
|
||||||
|
EXPECT_EQ(std::string(ex.what(false)), std::string(teststring));
|
||||||
|
EXPECT_EQ(expected.str(), std::string(ex.what(true)));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
@@ -16,6 +16,7 @@
|
|||||||
#include <gtest/gtest.h>
|
#include <gtest/gtest.h>
|
||||||
#include <signal.h>
|
#include <signal.h>
|
||||||
#include <stdint.h>
|
#include <stdint.h>
|
||||||
|
#include <errno.h>
|
||||||
#include <sys/types.h>
|
#include <sys/types.h>
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
|
|
||||||
@@ -36,24 +37,67 @@ std::string getApp() {
|
|||||||
return (s.str());
|
return (s.str());
|
||||||
}
|
}
|
||||||
|
|
||||||
/// @brief Waits for the specified process to finish.
|
/// @brief Waits for the specified process to finish (using sleep)
|
||||||
///
|
///
|
||||||
/// @param process An object which started the process.
|
/// @param process An object which started the process.
|
||||||
/// @param pid ID of the spawned process.
|
/// @param pid ID of the spawned process.
|
||||||
/// @param timeout Timeout in seconds.
|
/// @param timeout Timeout in seconds.
|
||||||
|
/// @param sleep specifies whether usleep(1ms) should be used or not.
|
||||||
|
///
|
||||||
|
/// This method uses usleep() to wait between checks. For an alternative,
|
||||||
|
/// see waitForProcessFast(). Note: If the signal comes in when the
|
||||||
|
/// loop calls usleep(), usleep() will be aborted and errno will be set
|
||||||
|
/// to EINTR to indicate that interruption. Therefore this method is not
|
||||||
|
/// suitable for tests that want to observe errno value. See
|
||||||
|
/// @ref waitForProcessFast as an alternative.
|
||||||
///
|
///
|
||||||
/// @return true if the process ended, false otherwise
|
/// @return true if the process ended, false otherwise
|
||||||
bool waitForProcess(const ProcessSpawn& process, const pid_t pid,
|
bool waitForProcess(const ProcessSpawn& process, const pid_t pid,
|
||||||
const uint8_t timeout) {
|
const uint8_t timeout) {
|
||||||
uint32_t iterations = 0;
|
uint32_t iterations = 0;
|
||||||
const uint32_t iterations_max = timeout * 1000;
|
const uint32_t iterations_max = timeout * 1000;
|
||||||
|
|
||||||
|
int errno_save = errno;
|
||||||
while (process.isRunning(pid) && (iterations < iterations_max)) {
|
while (process.isRunning(pid) && (iterations < iterations_max)) {
|
||||||
usleep(1000);
|
usleep(1000);
|
||||||
++iterations;
|
++iterations;
|
||||||
}
|
}
|
||||||
|
errno = errno_save;
|
||||||
return (iterations < iterations_max);
|
return (iterations < iterations_max);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// @brief Waits for the specified process to finish (using fast loop)
|
||||||
|
///
|
||||||
|
/// @param process An object which started the process.
|
||||||
|
/// @param pid ID of the spawned process.
|
||||||
|
/// @param timeout Timeout in seconds.
|
||||||
|
/// @param sleep specifies whether usleep(1ms) should be used or not.
|
||||||
|
///
|
||||||
|
/// This method does not use any sleep() calls, but rather iterates through
|
||||||
|
/// the loop very fast. This is not recommended in general, but is necessary
|
||||||
|
/// to avoid updating errno by sleep() after receving a signal.
|
||||||
|
///
|
||||||
|
/// Note: the timeout is only loosely accurate. Depending on the fraction
|
||||||
|
/// of second it was started on, it may terminate later by up to almost
|
||||||
|
/// whole second.
|
||||||
|
///
|
||||||
|
/// @return true if the process ended, false otherwise
|
||||||
|
bool waitForProcessFast(const ProcessSpawn& process, const pid_t pid,
|
||||||
|
const uint8_t timeout) {
|
||||||
|
time_t before = time(NULL);
|
||||||
|
while (process.isRunning(pid)) {
|
||||||
|
time_t now = time(NULL);
|
||||||
|
|
||||||
|
// The difference before we started and now is greater than
|
||||||
|
// the timeout, we should give up.
|
||||||
|
if (now - before > timeout) {
|
||||||
|
return (false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return (true);
|
||||||
|
}
|
||||||
|
|
||||||
// This test verifies that the external application can be ran with
|
// This test verifies that the external application can be ran with
|
||||||
// arguments and that the exit code is gathered.
|
// arguments and that the exit code is gathered.
|
||||||
TEST(ProcessSpawn, spawnWithArgs) {
|
TEST(ProcessSpawn, spawnWithArgs) {
|
||||||
@@ -169,4 +213,30 @@ TEST(ProcessSpawn, isRunning) {
|
|||||||
ASSERT_TRUE(waitForProcess(process, pid, 2));
|
ASSERT_TRUE(waitForProcess(process, pid, 2));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// This test verifies that the signal handler does not modify value of
|
||||||
|
// errno.
|
||||||
|
TEST(ProcessSpawn, errnoInvariance) {
|
||||||
|
|
||||||
|
// Set errno to an arbitrary value. We'll later check that it was not
|
||||||
|
// stumped on.
|
||||||
|
errno = 123;
|
||||||
|
|
||||||
|
std::vector<std::string> args;
|
||||||
|
args.push_back("-e");
|
||||||
|
args.push_back("64");
|
||||||
|
ProcessSpawn process(getApp(), args);
|
||||||
|
pid_t pid = 0;
|
||||||
|
ASSERT_NO_THROW(pid = process.spawn());
|
||||||
|
|
||||||
|
ASSERT_TRUE(waitForProcessFast(process, pid, 2));
|
||||||
|
|
||||||
|
EXPECT_EQ(64, process.getExitStatus(pid));
|
||||||
|
|
||||||
|
// errno value should NOT be set to be preserved, despite the SIGCHILD
|
||||||
|
// handler (ProcessSpawnImpl::waitForProcess) calling waitpid(), which
|
||||||
|
// will likely set errno to ECHILD. See trac4000 and support 8785.
|
||||||
|
EXPECT_EQ(123, errno);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
} // end of anonymous namespace
|
} // end of anonymous namespace
|
||||||
|
Reference in New Issue
Block a user