BatchManager_eCCC::BatchManager_eCCC(const FactBatchManager * parent, const char * host,
const char * username,
CommunicationProtocolType protocolType, const char * mpiImpl)
- : BatchManager_eClient(parent, host, username, protocolType, mpiImpl),
- BatchManager(parent, host)
+ : BatchManager(parent, host),
+ BatchManager_eClient(parent, host, username, protocolType, mpiImpl)
{
// Nothing to do
}
BatchManager_eLSF::BatchManager_eLSF(const FactBatchManager * parent, const char * host,
const char * username,
CommunicationProtocolType protocolType, const char * mpiImpl)
- : BatchManager_eClient(parent, host, username, protocolType, mpiImpl),
- BatchManager(parent, host)
+ : BatchManager(parent, host),
+ BatchManager_eClient(parent, host, username, protocolType, mpiImpl)
+
{
// Nothing to do
}
istringstream iss(jobid.getReference());
iss >> id;
- // On retrouve le thread_id du thread
- pthread_t thread_id;
-
// @@@ --------> SECTION CRITIQUE <-------- @@@
pthread_mutex_lock(&_threads_mutex);
bool idFound = (_threads.find(id) != _threads.end());
// On execute la commande du fils
- int result = execve(argv[0], argv, envp);
+ execve(argv[0], argv, envp);
UNDER_LOCK( cout << "*** debug_command = " << strerror(errno) << endl );
// No need to deallocate since nothing happens after a successful exec
void BatchManager_PBS::holdJob(const JobId & jobid)
{
char * ref = const_cast< char * >(jobid.getReference().c_str());
- int rc = pbs_holdjob(_connect, ref, USER_HOLD, 0);
+ int rc = pbs_holdjob(_connect, ref, const_cast< char * >(USER_HOLD), 0);
if (rc) { // si erreur
throw APIInternalFailureException(getErrorMessage("holdjob").c_str());
}
void BatchManager_PBS::releaseJob(const JobId & jobid)
{
char * ref = const_cast< char * >(jobid.getReference().c_str());
- int rc = pbs_rlsjob(_connect, ref, USER_HOLD, 0);
+ int rc = pbs_rlsjob(_connect, ref, const_cast< char * >(USER_HOLD), 0);
if (rc) { // si erreur
throw APIInternalFailureException(getErrorMessage("rlsjob").c_str());
}
BatchManager_ePBS::BatchManager_ePBS(const FactBatchManager * parent, const char * host,
const char * username,
CommunicationProtocolType protocolType, const char * mpiImpl,
- int nb_proc_per_node)
- : BatchManager_eClient(parent, host, username, protocolType, mpiImpl),
- BatchManager(parent, host)
+ int nb_proc_per_node)
+ : BatchManager(parent, host),
+ BatchManager_eClient(parent, host, username, protocolType, mpiImpl)
{
// Nothing to do
_nb_proc_per_node = nb_proc_per_node;
BatchManager_eSGE::BatchManager_eSGE(const FactBatchManager * parent, const char * host,
const char * username,
CommunicationProtocolType protocolType, const char * mpiImpl)
- : BatchManager_eClient(parent, host, username, protocolType, mpiImpl),
- BatchManager(parent, host)
+ : BatchManager(parent, host),
+ BatchManager_eClient(parent, host, username, protocolType, mpiImpl)
{
// Nothing to do
}
BatchManager_eSSH::BatchManager_eSSH(const FactBatchManager * parent, const char * host,
const char * username,
CommunicationProtocolType protocolType, const char * mpiImpl)
- : BatchManager_eClient(parent, host, username, protocolType, mpiImpl),
- BatchManager_Local(parent, host, protocolType),
- BatchManager(parent, host)
+ : BatchManager(parent, host),
+ BatchManager_eClient(parent, host, username, protocolType, mpiImpl),
+ BatchManager_Local(parent, host, protocolType)
{
// Nothing to do
}