"Framework/git@code.ornl.gov:mantidproject/mantid.git" did not exist on "91231681f00ec697e1e67139367569333119142e"
Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
#ifndef REMOTEJOBMANAGERFACTORYTEST_H_
#define REMOTEJOBMANAGERFACTORYTEST_H_
#include "MantidAPI/RemoteJobManagerFactory.h"
#include "MantidKernel/ConfigService.h"
#include "MantidKernel/FacilityInfo.h"
using namespace Mantid::API;
using namespace Mantid::Kernel;
// Just a minimal implementation of IRemoteJobManager, sufficient for the
// factory
class TestJM : public Mantid::Kernel::IRemoteJobManager {
public:
virtual void authenticate(std::string &username, std::string &password) {
UNUSED_ARG(username);
UNUSED_ARG(password);
}
virtual std::string
submitRemoteJob(const std::string &transactionID, const std::string &runnable,
const std::string ¶m, const std::string &taskName = "",
const int numNodes = 1, const int coresPerNode = 1) {
UNUSED_ARG(transactionID);
UNUSED_ARG(runnable);
UNUSED_ARG(param);
UNUSED_ARG(taskName);
UNUSED_ARG(numNodes);
UNUSED_ARG(coresPerNode);
return "";
}
virtual void downloadRemoteFile(const std::string &transactionID,
const std::string &remoteFileName,
const std::string &localFileName) {
UNUSED_ARG(transactionID);
UNUSED_ARG(remoteFileName);
UNUSED_ARG(localFileName);
}
virtual std::vector<RemoteJobInfo> queryAllRemoteJobs() const {
return std::vector<RemoteJobInfo>();
}
virtual std::vector<std::string>
queryRemoteFile(const std::string &transactionID) const {
UNUSED_ARG(transactionID);
return std::vector<std::string>();
}
virtual RemoteJobInfo queryRemoteJob(const std::string &jobID) const {
UNUSED_ARG(jobID);
return RemoteJobInfo();
}
virtual std::string startRemoteTransaction() { return ""; }
virtual void stopRemoteTransaction(const std::string &transactionID) {
UNUSED_ARG(transactionID);
}
virtual void abortRemoteJob(const std::string &jobID) { UNUSED_ARG(jobID); }
virtual void uploadRemoteFile(const std::string &transactionID,
const std::string &remoteFileName,
const std::string &localFileName) {
UNUSED_ARG(transactionID);
UNUSED_ARG(remoteFileName);
UNUSED_ARG(localFileName);
}
};
class RemoteJobManagerFactoryTest : public CxxTest::TestSuite {
public:
void test_unsubscribed() {
IRemoteJobManager_sptr jobManager;
TS_ASSERT_THROWS(
jobManager = RemoteJobManagerFactory::Instance().create("Inexistent"),
std::runtime_error);
TS_ASSERT_THROWS(jobManager =
RemoteJobManagerFactory::Instance().create("TestJM"),
std::runtime_error);
}
// minimal positive test
void test_createTestJM() {
RemoteJobManagerFactory::Instance().subscribe<TestJM>("TestJM");
TS_ASSERT_THROWS_NOTHING(
Mantid::Kernel::IRemoteJobManager_sptr jobManager =
Mantid::API::RemoteJobManagerFactory::Instance().create("TestJM"));
}
// this must fail, resource not found in the current facility
void test_createAlienResource() {
// save facility, do this before any changes
const Mantid::Kernel::FacilityInfo &prevFac =
Mantid::Kernel::ConfigService::Instance().getFacility();
Mantid::Kernel::ConfigService::Instance().setFacility("ISIS");
TS_ASSERT_THROWS_NOTHING(
Mantid::Kernel::IRemoteJobManager_sptr jobManager =
Mantid::API::RemoteJobManagerFactory::Instance().create("Fermi"));
Mantid::Kernel::ConfigService::Instance().setFacility("SNS");
TS_ASSERT_THROWS_NOTHING(
Mantid::Kernel::IRemoteJobManager_sptr jobManager =
Mantid::API::RemoteJobManagerFactory::Instance().create(
"SCARF@LSF"));
// restore facility, always do this at the end
Mantid::Kernel::ConfigService::Instance().setFacility(prevFac.name());
}
// a simple positive test
void test_createRemoteManagers() {
// save facility, do this before any changes
const Mantid::Kernel::FacilityInfo &prevFac =
Mantid::Kernel::ConfigService::Instance().getFacility();
Mantid::Kernel::ConfigService::Instance().setFacility("SNS");
TS_ASSERT_THROWS_NOTHING(
Mantid::Kernel::IRemoteJobManager_sptr jobManager =
Mantid::API::RemoteJobManagerFactory::Instance().create("Fermi"));
Mantid::Kernel::ConfigService::Instance().setFacility("ISIS");
TS_ASSERT_THROWS_NOTHING(
Mantid::Kernel::IRemoteJobManager_sptr jobManager =
Mantid::API::RemoteJobManagerFactory::Instance().create(
"SCARF@LSF"));
// restore facility, always do this at the end
Mantid::Kernel::ConfigService::Instance().setFacility(prevFac.name());
}
private:
Mantid::Kernel::IRemoteJobManager_sptr jm;
};
#endif /* REMOTEJOBMANAGERFACTORYTEST_H_ */