#include <ListJobs_GUI.hxx>

Inheritance diagram for YACS::HMI::BatchJobsListDialog:

Collaboration diagram for YACS::HMI::BatchJobsListDialog:

[legend]

Public Member Functions
	BatchJobsListDialog (QString title, GenericGui *genericGui)

virtual	~BatchJobsListDialog ()

Protected Attributes
QTimer *	_timer1

QTimer *	_timer2

QPushButton *	_ok

QTableWidget *	_table

QString	_jobFile

QString	_dumpStateFile

QString	_filteredJobFile

QString	_filteredDumpStateFile

QString	_hostname

long	_id

Engines::SalomeLauncher_var	_salome_launcher

GenericGui *	_genericGui

YACS::ENGINE::Proc *	_proc

Private Slots
void	userOK ()

void	userCancel ()

void	userCell (QTableWidgetItem *cell)

void	build_table ()

void	get_dump_file ()

Private Member Functions
QWidget *	build_buttons ()

void	getSalomeLauncher ()

void	filterJobFile ()

void	filterDumpStateFile ()

Detailed Description

Definition at line 54 of file ListJobs_GUI.hxx.

Constructor & Destructor Documentation

◆ BatchJobsListDialog()

BatchJobsListDialog::BatchJobsListDialog	(	QString	title,
		GenericGui *	genericGui
	)

Definition at line 43 of file ListJobs_GUI.cxx.

                                                                            : QWidget(),_genericGui(genericGui),_proc(NULL) {
 
  setWindowTitle(title);
 
  // Connection to Salome Launcher
  getSalomeLauncher();
 
  // Add a layout
  QBoxLayout* box = new QBoxLayout(QBoxLayout::TopToBottom, this);
  setLayout(box);
 
  _table = new QTableWidget(this);
  _table->setColumnCount(4);
 
  build_table();
 
  // Add table
  box->addWidget(_table);
 
  // Add buttons
  QWidget* buttons = build_buttons();
  box->addWidget(buttons);
 
  // No line selected
  _ok->setEnabled(false);
  _id = -1;
 
  // Set timer to refresh table
  _timer1 = new QTimer(this);
  connect(_timer1, SIGNAL(timeout()), this, SLOT(build_table()));
  _timer1->start(30000);
 
}

References _id, _ok, _table, _timer1, gui.GraphViewer::box, build_buttons(), build_table(), and getSalomeLauncher().

◆ ~BatchJobsListDialog()

BatchJobsListDialog::~BatchJobsListDialog ( )

virtual

Definition at line 77 of file ListJobs_GUI.cxx.

77 {

78}

Member Function Documentation

◆ build_buttons()

QWidget * BatchJobsListDialog::build_buttons ( )

private

Definition at line 148 of file ListJobs_GUI.cxx.

                                            {
  _ok     = new QPushButton("OK"    , this);
  QPushButton* cancel = new QPushButton("Cancel", this);
 
  connect(_ok    , SIGNAL(clicked()), this, SLOT(userOK    ()));
  connect(cancel, SIGNAL(clicked()), this, SLOT(userCancel()));
 
  QBoxLayout* layout = new QBoxLayout(QBoxLayout::LeftToRight, this);
 
  layout->addWidget(_ok);
  layout->addWidget(cancel);
 
  QWidget* buttons = new QWidget(this);
  buttons->setLayout(layout);
 
  return(buttons);
}

References _ok, userCancel(), and userOK().

Referenced by BatchJobsListDialog().

◆ build_table

void BatchJobsListDialog::build_table ( )

privateslot

Definition at line 91 of file ListJobs_GUI.cxx.

                                      {
 
  int irow = 0;
 
  _table->clear();
 
  Engines::JobsList* joblist = _salome_launcher->getJobsList();
 
  int nblines = joblist->length();
  _table->setRowCount(nblines);
 
  QStringList titres;
  titres << "Job Name" << "State" << "Resource" << "Launcher Id";
  _table->setHorizontalHeaderLabels(titres);
 
  for(int i=0;i<nblines;i++){
    Engines::JobDescription descr = (*joblist)[i];
    string jobType = CORBA::string_dup(descr.job_parameters.job_type);
    // We display only jobs of type yacs_file
    if(jobType.find("yacs_file")!=string::npos){
      long jobId = descr.job_id;
      ostringstream sstId;
      sstId << jobId;
      string jobName = CORBA::string_dup(descr.job_parameters.job_name);
      string jobState = _salome_launcher->getJobState(jobId);
      string jobMachine = CORBA::string_dup(descr.job_parameters.resource_required.name);
      QTableWidgetItem* item0 = new QTableWidgetItem(jobName.c_str()    , type_job);
      QTableWidgetItem* item1 = new QTableWidgetItem(jobState.c_str()   , type_state);
      QTableWidgetItem* item2 = new QTableWidgetItem(jobMachine.c_str() , type_res  );
      QTableWidgetItem* item3 = new QTableWidgetItem(sstId.str().c_str(), type_id   );
      _table->setItem(irow, 0, item0);
      _table->setItem(irow, 1, item1);
      _table->setItem(irow, 2, item2);
      _table->setItem(irow, 3, item3);
      if(jobState != "RUNNING"){
        item0->setFlags(Qt::NoItemFlags);
        item1->setFlags(Qt::NoItemFlags);
        item2->setFlags(Qt::NoItemFlags);
        item3->setFlags(Qt::NoItemFlags);
      }
      else if(jobId == _id){
        item0->setSelected(true);
        item1->setSelected(true);
        item2->setSelected(true);
        item3->setSelected(true);
      }
      irow++;
    }
  }
    
  connect(_table, SIGNAL( itemClicked(QTableWidgetItem*) ), this, SLOT( userCell(QTableWidgetItem*) ));
 
}

References _id, _salome_launcher, _table, yacsorb.CORBAEngineTest::i, type_id, type_job, type_res, type_state, and userCell().

Referenced by BatchJobsListDialog().

◆ filterDumpStateFile()

void BatchJobsListDialog::filterDumpStateFile ( )

private

Definition at line 301 of file ListJobs_GUI.cxx.

{
  string buffer;
  _filteredDumpStateFile = QString("/tmp/%1/filtered_%2.xml").arg(getenv("USER")).arg(QFileInfo(_dumpStateFile).baseName());
  ifstream infile(_dumpStateFile.toStdString().c_str());
  if(!infile){
    string errmsg = "File " + _dumpStateFile.toStdString() + " doesn't exist!!";
    throw YACS::Exception(errmsg);
  }
  ofstream outfile(_filteredDumpStateFile.toStdString().c_str());
  if(!outfile){
    string errmsg = "Impossible to create the file " + _filteredDumpStateFile.toStdString() + "!!";
    throw YACS::Exception(errmsg);
  }
  // replace objref by string in dump state file
  while( !infile.eof() ){
    getline(infile,buffer);
    size_t pos = buffer.find("objref");
    while(pos != string::npos){
      buffer.replace(pos,6,"string");
      pos = buffer.find("objref");
    }
    outfile << buffer << endl;
  }
}

References _dumpStateFile, and _filteredDumpStateFile.

Referenced by get_dump_file().

◆ filterJobFile()

void BatchJobsListDialog::filterJobFile ( )

private

Definition at line 256 of file ListJobs_GUI.cxx.

{
  _filteredJobFile = QString("/tmp/%1/%2.xml").arg(getenv("USER")).arg(QFileInfo(_jobFile).baseName());
  // reading input file
  ifstream infile(_jobFile.toStdString().c_str());
  if(!infile){
    string errmsg = "File " + _jobFile.toStdString() + " doesn't exist!!";
    throw YACS::Exception(errmsg);
  }
  string buffer;
  vector<string> objref;
  while( !infile.eof() ){
    getline(infile,buffer);
    // look for objref and memorize them in vector
    if( (buffer.find("objref") != string::npos) && (buffer.find("IDL") != string::npos) ){
      size_t pos1 = buffer.find("\"");
      size_t pos2 = buffer.find("\"",pos1+1);
      objref.push_back(buffer.substr(pos1+1,pos2-pos1-1));
    }
  }
  infile.close();
  // reread the input file
  infile.open(_jobFile.toStdString().c_str());
  // open the output file
  ofstream outfile(_filteredJobFile.toStdString().c_str());
  if(!outfile){
    string errmsg = "Impossible to create the file " + _filteredJobFile.toStdString() + "!!";
    throw YACS::Exception(errmsg);
  }
  while( !infile.eof() ){
    getline(infile,buffer);
    // replace objref by string
    if( ((buffer.find("objref") == string::npos) || (buffer.find("IDL") == string::npos)) && (buffer.find("/objref") == string::npos) ){
      string tmp = buffer;
      for(int i=0;i<objref.size();i++){
        size_t pos = buffer.find(objref[i]);
        if(pos != string::npos)
          tmp = buffer.substr(0,pos) + "string" + buffer.substr(pos+objref[i].size());
      }
      outfile << tmp << endl;
    }
  }
}

References _filteredJobFile, _jobFile, and yacsorb.CORBAEngineTest::i.

Referenced by userOK().

◆ get_dump_file

void BatchJobsListDialog::get_dump_file ( )

privateslot

Definition at line 234 of file ListJobs_GUI.cxx.

{
  int execState = YACS::NOTYETINITIALIZED;
  // get batch job state
  string jobState = _salome_launcher->getJobState(_id);
  // get dump state remote file
  bool ret = _salome_launcher->getJobDumpState(_id, QFileInfo(_dumpStateFile).absolutePath().toLatin1().constData());
  if(ret){
    // replace objref by string in dump state file
    filterDumpStateFile();
    // parse dump state file and load proc
    YACS::ENGINE::loadState(_proc,_filteredDumpStateFile.toStdString());
    // display remote graph states
    GuiExecutor *executor = QtGuiContext::getQtCurrent()->getGuiExecutor();
    execState = executor->updateSchema(jobState);
  }
  // stop timer if job is not running
  if((execState!=YACS::RUNNING)&&(execState!=YACS::NOTYETINITIALIZED))
    _timer2->stop();
}

References _dumpStateFile, _filteredDumpStateFile, _id, _proc, _salome_launcher, _timer2, filterDumpStateFile(), YACS::HMI::QtGuiContext::getGuiExecutor(), YACS::HMI::QtGuiContext::getQtCurrent(), YACS::ENGINE::loadState(), YACS::NOTYETINITIALIZED, YACS::RUNNING, and YACS::HMI::GuiExecutor::updateSchema().

Referenced by userOK().

◆ getSalomeLauncher()

void BatchJobsListDialog::getSalomeLauncher ( )

private

Definition at line 80 of file ListJobs_GUI.cxx.

                                           {
  YACS::ENGINE::RuntimeSALOME* runTime = YACS::ENGINE::getSALOMERuntime();
  CORBA::ORB_ptr orb = runTime->getOrb();
  SALOME_NamingService_Wrapper NS;
  CORBA::Object_var obj = NS.Resolve("/SalomeLauncher");
  _salome_launcher = Engines::SalomeLauncher::_narrow(obj);
  if (CORBA::is_nil(_salome_launcher))
    throw YACS::Exception("Salome Launcher not reachable!!");
}

References _salome_launcher, YACS::ENGINE::RuntimeSALOME::getOrb(), YACS::ENGINE::getSALOMERuntime(), orb, and SALOME_NamingService_Wrapper::Resolve().

Referenced by BatchJobsListDialog().

◆ userCancel

void BatchJobsListDialog::userCancel ( )

privateslot

Definition at line 227 of file ListJobs_GUI.cxx.

                                     {
  _timer1->stop();
  hide();
}

References _timer1.

Referenced by build_buttons().

◆ userCell

void BatchJobsListDialog::userCell ( QTableWidgetItem * cell )

privateslot

Definition at line 169 of file ListJobs_GUI.cxx.

                                                         {
  if ( cell->flags() ) {
    int line = cell->row();
    string sid = _table->item(line,3)->text().toStdString();
    _id = atoi(sid.c_str());
    _ok->setEnabled(true);
 
    QTableWidget* table = cell->tableWidget();
    for (int c=0; c<4; c++) {
      QTableWidgetItem* it = table->item(line, c);
      it->setSelected(true);
    };
  };
}

References _id, _ok, _table, and gui.CONNECTOR::c.

Referenced by build_table().

◆ userOK

void BatchJobsListDialog::userOK ( )

privateslot

Definition at line 187 of file ListJobs_GUI.cxx.

                                 {
 
  // get job file name
  Engines::JobParameters* jobParam = _salome_launcher->getJobParameters(_id);
  _jobFile = CORBA::string_dup(jobParam->job_file);
  _dumpStateFile = QString("/tmp/%1/dumpState_%2.xml").arg(getenv("USER")).arg(QFileInfo(_jobFile).baseName());
 
  // stop first timer and hide window
  _timer1->stop();
  hide();
 
  // replace objref by string in YACS schema job file to avoid trying to reach remote objects
  filterJobFile();
 
  // display yacs graph
  YACSGuiLoader *loader = _genericGui->getLoader();
  _proc = loader->load(_filteredJobFile.toLatin1());
  if (!_proc) {
    QMessageBox msgBox(QMessageBox::Critical, "Import Batch Schema, native YACS XML format",
                       "The xml graph has not the native YACS XML format or is not readable." );
    msgBox.exec();
  } 
  else {
    YACS::ENGINE::Logger* logger= _proc->getLogger("parser");
    if(!logger->isEmpty()) {
      DEBTRACE(logger->getStr());
    };
    _genericGui->createContext(_proc, _filteredJobFile, _filteredJobFile, false);
  };
 
  // start second timer to get remote graph state xml file
  _timer2 = new QTimer(this);
  connect(_timer2, SIGNAL(timeout()), this, SLOT(get_dump_file()));
  _timer2->start(30000);
  get_dump_file();
}

References _dumpStateFile, _filteredJobFile, _genericGui, _id, _jobFile, _proc, _salome_launcher, _timer1, _timer2, YACS::HMI::GenericGui::createContext(), DEBTRACE, filterJobFile(), get_dump_file(), YACS::HMI::GenericGui::getLoader(), YACS::ENGINE::Proc::getLogger(), YACS::ENGINE::Logger::getStr(), YACS::ENGINE::Logger::isEmpty(), and loader.

Referenced by build_buttons().

Member Data Documentation

◆ _dumpStateFile

QString YACS::HMI::BatchJobsListDialog::_dumpStateFile

protected

Definition at line 79 of file ListJobs_GUI.hxx.

Referenced by filterDumpStateFile(), get_dump_file(), and userOK().

◆ _filteredDumpStateFile

QString YACS::HMI::BatchJobsListDialog::_filteredDumpStateFile

protected

Definition at line 81 of file ListJobs_GUI.hxx.

Referenced by filterDumpStateFile(), and get_dump_file().

◆ _filteredJobFile

QString YACS::HMI::BatchJobsListDialog::_filteredJobFile

protected

Definition at line 80 of file ListJobs_GUI.hxx.

Referenced by filterJobFile(), and userOK().

◆ _genericGui

GenericGui* YACS::HMI::BatchJobsListDialog::_genericGui

protected

Definition at line 85 of file ListJobs_GUI.hxx.

Referenced by userOK().

◆ _hostname

QString YACS::HMI::BatchJobsListDialog::_hostname

protected

Definition at line 82 of file ListJobs_GUI.hxx.

◆ _id

long YACS::HMI::BatchJobsListDialog::_id

protected

Definition at line 83 of file ListJobs_GUI.hxx.

Referenced by BatchJobsListDialog(), build_table(), get_dump_file(), userCell(), and userOK().

◆ _jobFile

QString YACS::HMI::BatchJobsListDialog::_jobFile

protected

Definition at line 78 of file ListJobs_GUI.hxx.

Referenced by filterJobFile(), and userOK().

◆ _ok

QPushButton* YACS::HMI::BatchJobsListDialog::_ok

protected

Definition at line 76 of file ListJobs_GUI.hxx.

Referenced by BatchJobsListDialog(), build_buttons(), and userCell().

◆ _proc

YACS::ENGINE::Proc* YACS::HMI::BatchJobsListDialog::_proc

protected

Definition at line 86 of file ListJobs_GUI.hxx.

Referenced by get_dump_file(), and userOK().

◆ _salome_launcher

Engines::SalomeLauncher_var YACS::HMI::BatchJobsListDialog::_salome_launcher

protected

Definition at line 84 of file ListJobs_GUI.hxx.

Referenced by build_table(), get_dump_file(), getSalomeLauncher(), and userOK().

◆ _table

QTableWidget* YACS::HMI::BatchJobsListDialog::_table

protected

Definition at line 77 of file ListJobs_GUI.hxx.

Referenced by BatchJobsListDialog(), build_table(), and userCell().

◆ _timer1

QTimer* YACS::HMI::BatchJobsListDialog::_timer1

protected

Definition at line 75 of file ListJobs_GUI.hxx.

Referenced by BatchJobsListDialog(), userCancel(), and userOK().

◆ _timer2

QTimer * YACS::HMI::BatchJobsListDialog::_timer2

protected

Definition at line 75 of file ListJobs_GUI.hxx.

Referenced by get_dump_file(), and userOK().

The documentation for this class was generated from the following files:

src/genericgui/ListJobs_GUI.hxx
src/genericgui/ListJobs_GUI.cxx

Public Member Functions

Protected Attributes

Private Slots

Private Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ BatchJobsListDialog()

◆ ~BatchJobsListDialog()

Member Function Documentation

◆ build_buttons()

◆ build_table

◆ filterDumpStateFile()

◆ filterJobFile()

◆ get_dump_file

◆ getSalomeLauncher()

◆ userCancel

◆ userCell

◆ userOK

Member Data Documentation

◆ _dumpStateFile

◆ _filteredDumpStateFile

◆ _filteredJobFile

◆ _genericGui

◆ _hostname

◆ _id

◆ _jobFile

◆ _ok

◆ _proc

◆ _salome_launcher

◆ _table

◆ _timer1

◆ _timer2