/dports/misc/molequeue/molequeue-0.9.0/molequeue/app/testing/ |
H A D | slurmtest.cpp | 26 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 D | sgetest.cpp | 26 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 D | pbstest.cpp | 26 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 D | queuetest.cpp | 24 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 D | jobmanagertest.cpp | 23 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 D | queuemanagertest.cpp | 25 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 D | uittest.cpp | 47 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 D | slurmtest.cpp | 26 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 D | sgetest.cpp | 26 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 D | pbstest.cpp | 26 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 D | queuetest.cpp | 24 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 D | jobmanagertest.cpp | 23 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 D | queuemanagertest.cpp | 25 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 D | uittest.cpp | 47 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 D | server.h | 32 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 D | jobmanager.h | 30 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 D | server.h | 32 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 D | jobmanager.h | 30 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 D | remote.h | 24 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 D | remote.h | 24 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 D | killjobactionfactory.cpp | 29 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 D | killjobactionfactory.cpp | 29 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 D | jsonrpc.h | 29 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 D | jsonrpc.h | 29 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 D | rpclistener.cpp | 42 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 …]
|