Home
last modified time | relevance | path

Searched refs:MoleQueue (Results 1 – 25 of 709) sorted by relevance

12345678910>>...29

/dports/misc/molequeue/molequeue-0.9.0/molequeue/app/testing/
H A Dslurmtest.cpp26 MoleQueue::QueueSlurm m_queue;
85 MoleQueue::IdType jobId; in testParseJobId()
104 << MoleQueue::InvalidId in testParseQueueLine_data()
105 << MoleQueue::Unknown; in testParseQueueLine_data()
111 << MoleQueue::RunningRemote; in testParseQueueLine_data()
117 << MoleQueue::RunningRemote; in testParseQueueLine_data()
123 << MoleQueue::RunningRemote; in testParseQueueLine_data()
129 << MoleQueue::QueuedRemote; in testParseQueueLine_data()
135 << MoleQueue::RunningRemote; in testParseQueueLine_data()
153 << MoleQueue::QueuedRemote; in testParseQueueLine_data()
[all …]
H A Dsgetest.cpp26 MoleQueue::QueueSge m_queue;
84 MoleQueue::IdType jobId; in testParseJobId()
92 MoleQueue::IdType jobId; in testParseQueueLine()
93 MoleQueue::JobState state; in testParseQueueLine()
107 QCOMPARE(state, MoleQueue::RunningRemote); in testParseQueueLine()
122 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
127 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
132 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
137 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
142 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
[all …]
H A Dpbstest.cpp26 MoleQueue::QueuePbs m_queue;
84 MoleQueue::IdType jobId; in testParseJobId()
92 MoleQueue::IdType jobId; in testParseQueueLine()
93 MoleQueue::JobState state; in testParseQueueLine()
108 QCOMPARE(state, MoleQueue::RunningRemote); in testParseQueueLine()
113 QCOMPARE(state, MoleQueue::RunningRemote); in testParseQueueLine()
123 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
128 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
133 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
138 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
[all …]
H A Dqueuetest.cpp24 class DummyQueue : public MoleQueue::Queue
29 : MoleQueue::Queue(queueName, NULL) {}; in DummyQueue()
31 bool submitJob(MoleQueue::Job) { return false; } in submitJob()
32 void killJob(MoleQueue::Job) { } in killJob()
89 MoleQueue::Program *p1 = new MoleQueue::Program(&m_queue); in testAddProgram()
91 MoleQueue::Program *p2 = new MoleQueue::Program(NULL); in testAddProgram()
93 MoleQueue::Program *p2a = new MoleQueue::Program(&m_queue); in testAddProgram()
127 MoleQueue::Program notInQueue; in testRemoveProgram()
143 QPointer<MoleQueue::Program> program = new MoleQueue::Program (); in testCleanup()
154 MoleQueue::JobManager jobManager; in testReplaceKeywords()
[all …]
H A Djobmanagertest.cpp23 using MoleQueue::Job;
30 MoleQueue::JobManager m_jobManager;
43 void setNewJobIds(MoleQueue::Job);
52 connect(&m_jobManager, SIGNAL(jobAboutToBeAdded(MoleQueue::Job)), in initTestCase()
53 this, SLOT(setNewJobIds(MoleQueue::Job)), in initTestCase()
69 void JobManagerTest::setNewJobIds(MoleQueue::Job job) in setNewJobIds()
71 MoleQueue::IdType id = static_cast<MoleQueue::IdType>(m_jobManager.count()); in setNewJobIds()
77 QSignalSpy spy(&m_jobManager, SIGNAL(jobAboutToBeAdded(MoleQueue::Job))); in testJobAboutToBeAdded()
92 const MoleQueue::Job job1 = m_jobManager.jobAt(0); in testLookupMoleQueueId()
93 const MoleQueue::Job job2 = m_jobManager.jobAt(1); in testLookupMoleQueueId()
[all …]
H A Dqueuemanagertest.cpp25 class QueueDummy : public MoleQueue::Queue
29 QueueDummy(MoleQueue::QueueManager *parentManager) in QueueDummy()
30 : MoleQueue::Queue ("Dummy", parentManager) in QueueDummy()
34 bool submitJob(MoleQueue::Job) { return false; } in submitJob()
35 void killJob(MoleQueue::Job) { } in killJob()
43 MoleQueue::QueueManager m_queueManager;
81 QSignalSpy spy (&m_queueManager, SIGNAL(queueAdded(QString,MoleQueue::Queue*))); in testAddQueue()
104 MoleQueue::QueueListType list = m_queueManager.toQueueList(); in testToQueueList()
130 MoleQueue::QueueManager *manager = new MoleQueue::QueueManager (); in testCleanup()
134 QPointer<MoleQueue::Queue> q = manager->addQueue("", queues.first()); in testCleanup()
[all …]
H A Duittest.cpp47 MoleQueue::Uit::SslSetup::init(); in testSslSetup()
83 MoleQueue::JobManager *jobManager = server.jobManager(); in testHandleQueueUpdate()
84 MoleQueue::Job jobQueuedRemote = jobManager->newJob(); in testHandleQueueUpdate()
88 MoleQueue::Job jobRunningRemote = jobManager->newJob(); in testHandleQueueUpdate()
93 MoleQueue::QueueUit queue(server.queueManager()); in testHandleQueueUpdate()
101 MoleQueue::Uit::JobEventList list in testHandleQueueUpdate()
102 = MoleQueue::Uit::JobEventList::fromXml(m_jobEventXml); in testHandleQueueUpdate()
104 QVERIFY(jobQueuedRemote.jobState() != MoleQueue::QueuedRemote); in testHandleQueueUpdate()
105 QVERIFY(jobRunningRemote.jobState() != MoleQueue::RunningRemote); in testHandleQueueUpdate()
108 QVERIFY(jobQueuedRemote.jobState() == MoleQueue::QueuedRemote); in testHandleQueueUpdate()
[all …]
/dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/testing/
H A Dslurmtest.cpp26 MoleQueue::QueueSlurm m_queue;
85 MoleQueue::IdType jobId; in testParseJobId()
104 << MoleQueue::InvalidId in testParseQueueLine_data()
105 << MoleQueue::Unknown; in testParseQueueLine_data()
111 << MoleQueue::RunningRemote; in testParseQueueLine_data()
117 << MoleQueue::RunningRemote; in testParseQueueLine_data()
123 << MoleQueue::RunningRemote; in testParseQueueLine_data()
129 << MoleQueue::QueuedRemote; in testParseQueueLine_data()
135 << MoleQueue::RunningRemote; in testParseQueueLine_data()
153 << MoleQueue::QueuedRemote; in testParseQueueLine_data()
[all …]
H A Dsgetest.cpp26 MoleQueue::QueueSge m_queue;
84 MoleQueue::IdType jobId; in testParseJobId()
92 MoleQueue::IdType jobId; in testParseQueueLine()
93 MoleQueue::JobState state; in testParseQueueLine()
107 QCOMPARE(state, MoleQueue::RunningRemote); in testParseQueueLine()
122 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
127 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
132 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
137 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
142 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
[all …]
H A Dpbstest.cpp26 MoleQueue::QueuePbs m_queue;
84 MoleQueue::IdType jobId; in testParseJobId()
92 MoleQueue::IdType jobId; in testParseQueueLine()
93 MoleQueue::JobState state; in testParseQueueLine()
108 QCOMPARE(state, MoleQueue::RunningRemote); in testParseQueueLine()
113 QCOMPARE(state, MoleQueue::RunningRemote); in testParseQueueLine()
123 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
128 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
133 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
138 QCOMPARE(state, MoleQueue::QueuedRemote); in testParseQueueLine()
[all …]
H A Dqueuetest.cpp24 class DummyQueue : public MoleQueue::Queue
29 : MoleQueue::Queue(queueName, NULL) {}; in DummyQueue()
31 bool submitJob(MoleQueue::Job) { return false; } in submitJob()
32 void killJob(MoleQueue::Job) { } in killJob()
89 MoleQueue::Program *p1 = new MoleQueue::Program(&m_queue); in testAddProgram()
91 MoleQueue::Program *p2 = new MoleQueue::Program(NULL); in testAddProgram()
93 MoleQueue::Program *p2a = new MoleQueue::Program(&m_queue); in testAddProgram()
127 MoleQueue::Program notInQueue; in testRemoveProgram()
143 QPointer<MoleQueue::Program> program = new MoleQueue::Program (); in testCleanup()
154 MoleQueue::JobManager jobManager; in testReplaceKeywords()
[all …]
H A Djobmanagertest.cpp23 using MoleQueue::Job;
30 MoleQueue::JobManager m_jobManager;
43 void setNewJobIds(MoleQueue::Job);
52 connect(&m_jobManager, SIGNAL(jobAboutToBeAdded(MoleQueue::Job)), in initTestCase()
53 this, SLOT(setNewJobIds(MoleQueue::Job)), in initTestCase()
69 void JobManagerTest::setNewJobIds(MoleQueue::Job job) in setNewJobIds()
71 MoleQueue::IdType id = static_cast<MoleQueue::IdType>(m_jobManager.count()); in setNewJobIds()
77 QSignalSpy spy(&m_jobManager, SIGNAL(jobAboutToBeAdded(MoleQueue::Job))); in testJobAboutToBeAdded()
92 const MoleQueue::Job job1 = m_jobManager.jobAt(0); in testLookupMoleQueueId()
93 const MoleQueue::Job job2 = m_jobManager.jobAt(1); in testLookupMoleQueueId()
[all …]
H A Dqueuemanagertest.cpp25 class QueueDummy : public MoleQueue::Queue
29 QueueDummy(MoleQueue::QueueManager *parentManager) in QueueDummy()
30 : MoleQueue::Queue ("Dummy", parentManager) in QueueDummy()
34 bool submitJob(MoleQueue::Job) { return false; } in submitJob()
35 void killJob(MoleQueue::Job) { } in killJob()
43 MoleQueue::QueueManager m_queueManager;
81 QSignalSpy spy (&m_queueManager, SIGNAL(queueAdded(QString,MoleQueue::Queue*))); in testAddQueue()
104 MoleQueue::QueueListType list = m_queueManager.toQueueList(); in testToQueueList()
130 MoleQueue::QueueManager *manager = new MoleQueue::QueueManager (); in testCleanup()
134 QPointer<MoleQueue::Queue> q = manager->addQueue("", queues.first()); in testCleanup()
[all …]
H A Duittest.cpp47 MoleQueue::Uit::SslSetup::init(); in testSslSetup()
83 MoleQueue::JobManager *jobManager = server.jobManager(); in testHandleQueueUpdate()
84 MoleQueue::Job jobQueuedRemote = jobManager->newJob(); in testHandleQueueUpdate()
88 MoleQueue::Job jobRunningRemote = jobManager->newJob(); in testHandleQueueUpdate()
93 MoleQueue::QueueUit queue(server.queueManager()); in testHandleQueueUpdate()
101 MoleQueue::Uit::JobEventList list in testHandleQueueUpdate()
102 = MoleQueue::Uit::JobEventList::fromXml(m_jobEventXml); in testHandleQueueUpdate()
104 QVERIFY(jobQueuedRemote.jobState() != MoleQueue::QueuedRemote); in testHandleQueueUpdate()
105 QVERIFY(jobRunningRemote.jobState() != MoleQueue::RunningRemote); in testHandleQueueUpdate()
108 QVERIFY(jobQueuedRemote.jobState() == MoleQueue::QueuedRemote); in testHandleQueueUpdate()
[all …]
/dports/misc/molequeue/molequeue-0.9.0/molequeue/app/
H A Dserver.h32 namespace MoleQueue
143 void dispatchJobStateChange(const MoleQueue::Job &job,
144 MoleQueue::JobState oldState,
145 MoleQueue::JobState newState);
153 void jobAboutToBeAdded(MoleQueue::Job job);
169 void handleMessage(const MoleQueue::Message &message);
176 void jobRemoved(MoleQueue::IdType moleQueueId);
184 void handleRequest(const MoleQueue::Message &message);
185 void handleUnknownMethod(const MoleQueue::Message &message);
186 void handleInvalidParams(const MoleQueue::Message &message,
[all …]
H A Djobmanager.h30 namespace MoleQueue
155 void moleQueueIdChanged(const MoleQueue::Job &job);
171 void setJobState(MoleQueue::IdType jobManagerId,
172 MoleQueue::JobState newState);
178 MoleQueue::IdType queueId);
192 void jobAboutToBeAdded(MoleQueue::Job job);
198 void jobAdded(const MoleQueue::Job &job);
206 void jobStateChanged(const MoleQueue::Job &job,
207 MoleQueue::JobState oldState,
215 void jobUpdated(const MoleQueue::Job &job);
[all …]
/dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/
H A Dserver.h32 namespace MoleQueue
143 void dispatchJobStateChange(const MoleQueue::Job &job,
144 MoleQueue::JobState oldState,
145 MoleQueue::JobState newState);
153 void jobAboutToBeAdded(MoleQueue::Job job);
169 void handleMessage(const MoleQueue::Message &message);
176 void jobRemoved(MoleQueue::IdType moleQueueId);
184 void handleRequest(const MoleQueue::Message &message);
185 void handleUnknownMethod(const MoleQueue::Message &message);
186 void handleInvalidParams(const MoleQueue::Message &message,
[all …]
H A Djobmanager.h30 namespace MoleQueue
155 void moleQueueIdChanged(const MoleQueue::Job &job);
171 void setJobState(MoleQueue::IdType jobManagerId,
172 MoleQueue::JobState newState);
178 MoleQueue::IdType queueId);
192 void jobAboutToBeAdded(MoleQueue::Job job);
198 void jobAdded(const MoleQueue::Job &job);
206 void jobStateChanged(const MoleQueue::Job &job,
207 MoleQueue::JobState oldState,
215 void jobUpdated(const MoleQueue::Job &job);
[all …]
/dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/queues/
H A Dremote.h24 namespace MoleQueue
84 bool submitJob(MoleQueue::Job job);
85 void killJob(MoleQueue::Job job);
93 virtual void beginJobSubmission(MoleQueue::Job job);
95 virtual void createRemoteDirectory(MoleQueue::Job job) = 0;
98 virtual void copyInputFilesToHost(MoleQueue::Job job) = 0;
100 virtual void submitJobToRemoteQueue(MoleQueue::Job job) = 0;
109 virtual void finalizeJobCleanup(MoleQueue::Job job);
111 virtual void cleanRemoteDirectory(MoleQueue::Job job) = 0;
115 void jobAboutToBeRemoved(const MoleQueue::Job &job);
[all …]
/dports/misc/molequeue/molequeue-0.9.0/molequeue/app/queues/
H A Dremote.h24 namespace MoleQueue
84 bool submitJob(MoleQueue::Job job);
85 void killJob(MoleQueue::Job job);
93 virtual void beginJobSubmission(MoleQueue::Job job);
95 virtual void createRemoteDirectory(MoleQueue::Job job) = 0;
98 virtual void copyInputFilesToHost(MoleQueue::Job job) = 0;
100 virtual void submitJobToRemoteQueue(MoleQueue::Job job) = 0;
109 virtual void finalizeJobCleanup(MoleQueue::Job job);
111 virtual void cleanRemoteDirectory(MoleQueue::Job job) = 0;
115 void jobAboutToBeRemoved(const MoleQueue::Job &job);
[all …]
/dports/misc/py-molequeue/molequeue-0.9.0/molequeue/app/jobactionfactories/
H A Dkilljobactionfactory.cpp29 namespace MoleQueue namespace
47 case MoleQueue::Accepted: in isValidForJob()
48 case MoleQueue::QueuedLocal: in isValidForJob()
49 case MoleQueue::Submitted: in isValidForJob()
50 case MoleQueue::QueuedRemote: in isValidForJob()
51 case MoleQueue::RunningLocal: in isValidForJob()
53 case MoleQueue::Error: in isValidForJob()
55 case MoleQueue::Unknown: in isValidForJob()
56 case MoleQueue::None: in isValidForJob()
57 case MoleQueue::Finished: in isValidForJob()
[all …]
/dports/misc/molequeue/molequeue-0.9.0/molequeue/app/jobactionfactories/
H A Dkilljobactionfactory.cpp29 namespace MoleQueue namespace
47 case MoleQueue::Accepted: in isValidForJob()
48 case MoleQueue::QueuedLocal: in isValidForJob()
49 case MoleQueue::Submitted: in isValidForJob()
50 case MoleQueue::QueuedRemote: in isValidForJob()
51 case MoleQueue::RunningLocal: in isValidForJob()
53 case MoleQueue::Error: in isValidForJob()
55 case MoleQueue::Unknown: in isValidForJob()
56 case MoleQueue::None: in isValidForJob()
57 case MoleQueue::Finished: in isValidForJob()
[all …]
/dports/misc/py-molequeue/molequeue-0.9.0/molequeue/servercore/
H A Djsonrpc.h29 namespace MoleQueue {
84 void addConnectionListener(MoleQueue::ConnectionListener *connlist);
92 void removeConnectionListener(MoleQueue::ConnectionListener *connlist);
98 void messageReceived(const MoleQueue::Message &message);
106 void addConnection(MoleQueue::Connection *conn);
113 void removeConnection(MoleQueue::ConnectionListener *connlist,
114 MoleQueue::Connection *conn);
121 void removeConnection(MoleQueue::Connection *conn);
145 void newPacket(const MoleQueue::PacketType &packet,
146 const MoleQueue::EndpointIdType &endpoint);
/dports/misc/molequeue/molequeue-0.9.0/molequeue/servercore/
H A Djsonrpc.h29 namespace MoleQueue {
84 void addConnectionListener(MoleQueue::ConnectionListener *connlist);
92 void removeConnectionListener(MoleQueue::ConnectionListener *connlist);
98 void messageReceived(const MoleQueue::Message &message);
106 void addConnection(MoleQueue::Connection *conn);
113 void removeConnection(MoleQueue::ConnectionListener *connlist,
114 MoleQueue::Connection *conn);
121 void removeConnection(MoleQueue::Connection *conn);
145 void newPacket(const MoleQueue::PacketType &packet,
146 const MoleQueue::EndpointIdType &endpoint);
/dports/science/avogadro2/avogadroapp-1.94.0/avogadro/
H A Drpclistener.cpp42 m_rpc = new MoleQueue::JsonRpc(this); in RpcListener()
45 new MoleQueue::LocalSocketConnectionListener(this, "avogadro"); in RpcListener()
49 &MoleQueue::ConnectionListener::connectionError, in RpcListener()
54 connect(m_rpc, &MoleQueue::JsonRpc::messageReceived, this, in RpcListener()
84 if (error == MoleQueue::ConnectionListener::AddressInUseError) { in connectionError()
87 m_pingClient = new MoleQueue::JsonRpcClient(this); in connectionError()
94 connect(m_pingClient, &MoleQueue::JsonRpcClient::resultReceived, in connectionError()
151 void RpcListener::messageReceived(const MoleQueue::Message& message) in messageReceived()
167 MoleQueue::Message response = message.generateResponse(); in messageReceived()
203 MoleQueue::Message response = message.generateResponse(); in messageReceived()
[all …]

12345678910>>...29