]> SALOME platform Git repositories - modules/jobmanager.git/commitdiff
Salome HOME
Correct srun entry V6_3_1_BR V6_3_1 V6_3_1rc2 V6_3_1rc3
authorribes <ribes>
Wed, 6 Jul 2011 08:56:27 +0000 (08:56 +0000)
committerribes <ribes>
Wed, 6 Jul 2011 08:56:27 +0000 (08:56 +0000)
Correct messages for changed states

src/engine/BL_Job.cxx
src/engine/BL_JobsManager.cxx
src/engine/BL_SALOMEServices.cxx
src/genericgui/BL_JobsManager_QT.cxx
src/genericgui/JM_EditSalomeResource.cxx

index 5bfb3bd0aca0e619fdda711ab4e5ade0ec7e2cc1..19b80847a3f799d618049495089f02290e914682 100644 (file)
@@ -234,7 +234,7 @@ BL::Job::setStringState(const std::string & state)
      )
   {
     DEBTRACE("Error state in setStringState");
-    result = state;
+    result = "RefreshError";
   }
 
   if (result == "")
@@ -244,7 +244,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::CREATED)
       {
         setState(BL::Job::CREATED);
-        result = "new_state";
+        result = state;
       }
     }
     else if (state == "NOT_CREATED")
@@ -252,7 +252,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::NOT_CREATED)
       {
         setState(BL::Job::NOT_CREATED);
-        result = "new_state";
+        result = state;
       }
     }
     else if (state == "QUEUED")
@@ -260,7 +260,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::QUEUED)
       {
         setState(BL::Job::QUEUED);
-        result = "new_state";
+        result = state;
       }
     }
     else if (state == "IN_PROCESS")
@@ -268,7 +268,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::IN_PROCESS)
       {
         setState(BL::Job::IN_PROCESS);
-        result = "new_state";
+        result = state;
       }
     }
     else if (state == "RUNNING")
@@ -276,7 +276,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::RUNNING)
       {
         setState(BL::Job::RUNNING);
-        result = "new_state";
+        result = state;
       }
     }
     else if (state == "PAUSED")
@@ -284,7 +284,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::PAUSED)
       {
         setState(BL::Job::PAUSED);
-        result = "new_state";
+        result = state;
       }
     }
     else if (state == "FINISHED")
@@ -292,7 +292,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::FINISHED)
       {
         setState(BL::Job::FINISHED);
-        result = "new_state";
+        result = state;
       }
     }
     else if (state == "ERROR")
@@ -300,7 +300,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::ERROR)
       {
         setState(BL::Job::ERROR);
-        result = "new_state";
+        result = state;
       }
     }
     else if (state == "FAILED")
@@ -308,7 +308,7 @@ BL::Job::setStringState(const std::string & state)
       if (_state != BL::Job::FAILED)
       {
         setState(BL::Job::FAILED);
-        result = "new_state";
+        result = state;
       }
     }
   }
index 5acdb8cc3604de4a1359a69f6b64bfc37207b0bf..9eee2ae4f7be975f1e540854b17e0c2188c92993 100644 (file)
@@ -235,16 +235,16 @@ BL::JobsManager::refresh_jobs_thread(void * object_ptr)
         {
           std::string result_launcher = object->_salome_services->refresh_job(job);
           std::string result_job = job->setStringState(result_launcher);
-          if (result_job == "new_state")
+          if (result_job == "RefreshError")
           {
+            // Error using launcher...
             if (object->_observer)
-              object->_observer->sendEvent("refresh_job", "Ok", job->getName(), "new state");
+              object->_observer->sendEvent("refresh_job", "Error", job->getName(), result_launcher);
           }
           else if (result_job != "")
           {
-            // Error using launcher...
             if (object->_observer)
-              object->_observer->sendEvent("refresh_job", "Error", job->getName(), result_launcher);
+              object->_observer->sendEvent("refresh_job", "Ok", job->getName(), result_job);
           }
         }
       }
index 4b8672dd8ebc76cd6f82c0accacecda5a0b5c369..1b05577df0258989e76e2850f863ffcd41d2efd8 100644 (file)
@@ -582,8 +582,8 @@ BL::SALOMEServices::get_new_job(int job_number)
 
     // Get current state
     std::string result_job = job_return->setStringState(refresh_job(job_return));
-    if (result_job == "new_state") {}
-    else if (result_job != "")
+    if (result_job != "RefreshError") {}
+    else
     {
       // Error in getting state
       DEBMSG("Error in getting state of the new job!");
index ea5612b04a73404fad576468527a30c9de3bb72f..b157c46f0410dfe8bbbedb842f5542abe88c9636 100644 (file)
@@ -232,7 +232,7 @@ BL::JobsManager_QT::edit_clone_job(const std::string & name)
   // Check if the job has the same name
   if (name == wizard.job_name)
   {
-    DEBTRACE("Job " << name << " has been changed");
+    DEBTRACE("Job " << name << " has been edited");
     _main_gui->delete_job_internal();
   }
 
@@ -378,8 +378,10 @@ BL::JobsManager_QT::event(QEvent * e)
   {
     if (event->event_name == "Ok")
     {
-      QString str((event->job_name).c_str());
-      write_normal_text("Job " + str + " state changed\n");
+      QString name((event->job_name).c_str());
+      QString state((event->data).c_str());
+      state = state.toLower();
+      write_normal_text("Job " + name + " new state is " + state + "\n");
       emit job_state_changed(QString((event->job_name).c_str()));
     }
     else
index dba4dfa7de0969604f0cc8cc954037ddd93adb03..8fac9cb4a4330f2c64ba77710664cc2ec70ea7e6 100644 (file)
@@ -49,6 +49,7 @@ JM::EditSalomeResource::EditSalomeResource(QWidget *parent, BL::SALOMEServices *
   _protocol_line = new QComboBox(this);
   _protocol_line->addItem("ssh");
   _protocol_line->addItem("rsh");
+  _protocol_line->addItem("srun");
   _protocol_line->setCurrentIndex(-1);
 
   QLabel * componentList_label = new QLabel("Component List:");
@@ -108,10 +109,11 @@ JM::EditSalomeResource::EditSalomeResource(QWidget *parent, BL::SALOMEServices *
   _nb_proc_per_node_line->setMaximum(1000000);
   _nb_proc_per_node_line->setValue(1);
 
-  QLabel * iprotocol_label = new QLabel("Internal proctocol:");
+  QLabel * iprotocol_label = new QLabel("Internal protocol:");
   _iprotocol_line = new QComboBox(this);
   _iprotocol_line->addItem("ssh");
   _iprotocol_line->addItem("rsh");
+  _iprotocol_line->addItem("srun");
   _iprotocol_line->setCurrentIndex(-1);
 
   QLabel * batch_label = new QLabel("Batch:");
@@ -194,6 +196,8 @@ JM::EditSalomeResource::get_infos()
     _protocol_line->setCurrentIndex(0);
   else if(protocol == "rsh")
     _protocol_line->setCurrentIndex(1);
+  else if(protocol == "srun")
+    _protocol_line->setCurrentIndex(2);
   else
     _protocol_line->setCurrentIndex(-1);
 
@@ -202,6 +206,8 @@ JM::EditSalomeResource::get_infos()
     _iprotocol_line->setCurrentIndex(0);
   else if (iprotocol == "rsh")
     _iprotocol_line->setCurrentIndex(1);
+  else if (iprotocol == "srun")
+    _iprotocol_line->setCurrentIndex(2);
   else
     _iprotocol_line->setCurrentIndex(-1);