kde-playground/akonadi/server/control/agentprocessinstance.cpp
2015-09-23 09:37:02 +00:00

104 lines
3.1 KiB
C++

/*
Copyright (c) 2008 Volker Krause <vkrause@kde.org>
Copyright (c) 2010 Bertjan Broeksema <broeksema@kde.org>
This library is free software; you can redistribute it and/or modify it
under the terms of the GNU Library General Public License as published by
the Free Software Foundation; either version 2 of the License, or (at your
option) any later version.
This library is distributed in the hope that it will be useful, but WITHOUT
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
FITNESS FOR A PARTICULAR PURPOSE. See the GNU Library General Public
License for more details.
You should have received a copy of the GNU Library General Public License
along with this library; see the file COPYING.LIB. If not, write to the
Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
02110-1301, USA.
*/
#include "agentprocessinstance.h"
#include "agenttype.h"
#include "processcontrol.h"
#include "libs/xdgbasedirs_p.h"
#include "shared/akdebug.h"
using namespace Akonadi;
AgentProcessInstance::AgentProcessInstance( AgentManager *manager )
: AgentInstance( manager )
, mController( 0 )
{
}
bool AgentProcessInstance::start( const AgentType &agentInfo )
{
Q_ASSERT( !identifier().isEmpty() );
if ( identifier().isEmpty() ) {
return false;
}
setAgentType( agentInfo.identifier );
Q_ASSERT( agentInfo.launchMethod == AgentType::Process ||
agentInfo.launchMethod == AgentType::Launcher );
const QString executable = ( agentInfo.launchMethod == AgentType::Process )
? XdgBaseDirs::findExecutableFile( agentInfo.exec ) : agentInfo.exec;
if ( executable.isEmpty() ) {
akError() << Q_FUNC_INFO << "Unable to find agent executable" << agentInfo.exec;
return false;
}
mController = new Akonadi::ProcessControl( this );
connect( mController, SIGNAL(unableToStart()), SLOT(failedToStart()) );
if ( agentInfo.launchMethod == AgentType::Process ) {
QStringList arguments;
arguments << QLatin1String( "--identifier" ) << identifier();
mController->start( executable, arguments );
} else {
Q_ASSERT( agentInfo.launchMethod == AgentType::Launcher );
const QStringList arguments = QStringList() << executable << identifier();
const QString agentLauncherExec = XdgBaseDirs::findExecutableFile( QLatin1String( "akonadi_agent_launcher" ) );
mController->start( agentLauncherExec, arguments );
}
return true;
}
void AgentProcessInstance::quit()
{
mController->setCrashPolicy( Akonadi::ProcessControl::StopOnCrash );
AgentInstance::quit();
}
void AgentProcessInstance::cleanup()
{
mController->setCrashPolicy( Akonadi::ProcessControl::StopOnCrash );
AgentInstance::cleanup();
}
void AgentProcessInstance::restartWhenIdle()
{
if ( mController->isRunning() ) {
if ( status() != 1 ) {
mController->restartOnceWhenFinished();
quit();
}
} else {
mController->start();
}
}
void Akonadi::AgentProcessInstance::configure( qlonglong windowId )
{
controlInterface()->configure( windowId );
}
void AgentProcessInstance::failedToStart()
{
statusChanged( 2 /*Broken*/, QLatin1String( "Unable to start." ) );
}