StopAndKill.cpp
Go to the documentation of this file.
1/*
2 * This file is part of ArmarX.
3 *
4 * Copyright (C) 2011-2016, High Performance Humanoid Technologies (H2T), Karlsruhe Institute of Technology (KIT), all rights reserved.
5 *
6 * ArmarX is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License version 2 as
8 * published by the Free Software Foundation.
9 *
10 * ArmarX is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
14 *
15 * You should have received a copy of the GNU General Public License
16 * along with this program. If not, see <http://www.gnu.org/licenses/>.
17 *
18 * @package ArmarXCore::core
19 * @author Nicola Miskowiec
20 * @date 2016
21 * @copyright http://www.gnu.org/licenses/gpl-2.0.txt
22 * GNU General Public License
23 */
24
25
26#include "StopAndKill.h"
27
28#include <chrono>
29#include <thread>
30
31#include "ProcessUtil.h"
32
33using namespace ScenarioManager;
34using namespace Data_Structure;
35using namespace Exec;
36
41
42void
44{
45 const int previousPid = application->getPid();
46 stopper->stop(application);
47
48 // Give the application the configured grace period to shut down on its own. Polling instead of
49 // sleeping through it keeps a clean shutdown fast.
50 if (!ProcessUtil::WaitForExit(previousPid, std::chrono::milliseconds(timer)))
51 {
52 //Check if the application got restartet while waiting for the Kill timer
53 if (application->getPid() == previousPid)
54 {
55 stopper->kill(application);
56 }
57 }
58
59 awaitTermination(application, previousPid);
60}
61
64{
65 return this->stopper;
66}
ApplicationStopperPtr getStopper()
Returns the stopper used by this StopStrategy.
void stop(Data_Structure::ApplicationInstancePtr application) override
Stops an application.
StopAndKill(ApplicationStopperPtr stopper, int delay)
Constructor that sets the ApplicationStopper used by this StopStrategy.
void awaitTermination(const Data_Structure::ApplicationInstancePtr &application, int signalledPid)
Waits until the process that was signalled has terminated, then clears the application's pid.
StopStrategy(ApplicationStopperPtr stopper)
std::shared_ptr< ApplicationInstance > ApplicationInstancePtr
bool WaitForExit(int pid, std::chrono::milliseconds timeout, std::chrono::milliseconds pollInterval)
Blocks until the process with the given pid has disappeared, at most for timeout.
std::shared_ptr< ApplicationStopper > ApplicationStopperPtr