CMS 3D CMS Logo

All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
CmsShowMain.cc
Go to the documentation of this file.
1 // -*- C++ -*-
2 //
3 // Package: Core
4 // Class : CmsShowMain
5 //
6 // Implementation:
7 // <Notes on implementation>
8 //
9 // Original Author:
10 // Created: Mon Dec 3 08:38:38 PST 2007
11 //
12 
13 // system include files
14 #include <sstream>
15 #include <boost/bind.hpp>
16 #include <boost/program_options.hpp>
17 #include <string.h>
18 
19 #include "TSystem.h"
20 #include "TGLWidget.h"
21 #include "TTimer.h"
22 #include "TROOT.h"
23 #include "TGFileDialog.h"
24 #include "TGMsgBox.h"
25 #include "TMonitor.h"
26 #include "TServerSocket.h"
27 #include "TEveLine.h"
28 #include "TEveManager.h"
29 #include "TFile.h"
30 #include "TGClient.h"
31 #include <KeySymbols.h>
32 
34 
36 
50 
55 
57 
60 
64 
66 
68 
69 #if defined(R__LINUX)
70 #include "TGX11.h" // !!!! AMT has to be at the end to pass build
71 #include "X11/Xlib.h"
72 #endif
73 //
74 // constants, enums and typedefs
75 //
76 
77 static const char* const kInputFilesOpt = "input-files";
78 static const char* const kInputFilesCommandOpt = "input-files,i";
79 static const char* const kConfigFileOpt = "config-file";
80 static const char* const kConfigFileCommandOpt = "config-file,c";
81 static const char* const kGeomFileOpt = "geom-file";
82 static const char* const kGeomFileCommandOpt = "geom-file,g";
83 static const char* const kSimGeomFileOpt = "sim-geom-file";
84 static const char* const kSimGeomFileCommandOpt= "sim-geom-file";
85 static const char* const kNoConfigFileOpt = "noconfig";
86 static const char* const kNoConfigFileCommandOpt = "noconfig,n";
87 static const char* const kPlayOpt = "play";
88 static const char* const kPlayCommandOpt = "play,p";
89 static const char* const kLoopOpt = "loop";
90 static const char* const kLoopCommandOpt = "loop";
91 static const char* const kLogLevelCommandOpt = "log";
92 static const char* const kLogLevelOpt = "log";
93 static const char* const kEveOpt = "eve";
94 static const char* const kEveCommandOpt = "eve";
95 static const char* const kAdvancedRenderOpt = "shine";
96 static const char* const kAdvancedRenderCommandOpt = "shine,s";
97 static const char* const kHelpOpt = "help";
98 static const char* const kHelpCommandOpt = "help,h";
99 static const char* const kSoftCommandOpt = "soft";
100 static const char* const kExpertCommandOpt = "expert";
101 static const char* const kPortCommandOpt = "port";
102 static const char* const kPlainRootCommandOpt = "prompt";
103 static const char* const kRootInteractiveCommandOpt = "root-interactive,r";
104 static const char* const kChainCommandOpt = "chain";
105 static const char* const kLiveCommandOpt = "live";
106 static const char* const kFieldCommandOpt = "field";
107 static const char* const kFreePaletteCommandOpt = "free-palette";
108 static const char* const kAutoSaveAllViews = "auto-save-all-views";
109 static const char* const kAutoSaveType = "auto-save-type";
110 static const char* const kAutoSaveHeight = "auto-save-height";
111 static const char* const kSyncAllViews = "sync-all-views";
112 static const char* const kEnableFPE = "enable-fpe";
113 static const char* const kZeroWinOffsets = "zero-window-offsets";
114 static const char* const kNoVersionCheck = "no-version-check";
115 
116 
117 //
118 // constructors and destructor
119 //
121  : CmsShowMainBase(),
122  m_navigator(new CmsShowNavigator(*this)),
123  m_metadataManager(new FWLiteJobMetadataManager()),
124  m_context(new fireworks::Context(changeManager(),
125  selectionManager(),
126  eiManager(),
127  colorManager(),
128  m_metadataManager.get())),
129  m_loadedAnyInputFile(false),
130  m_openFile(0),
131  m_live(false),
132  m_liveTimer(new SignalTimer()),
133  m_liveTimeout(600000),
134  m_lastXEventSerial(0),
135  m_noVersionCheck(false)
136 {
137  try {
138  TGLWidget* w = TGLWidget::Create(gClient->GetDefaultRoot(), kTRUE, kTRUE, 0, 10, 10);
139  delete w;
140  }
141  catch (std::exception& iException) {
142  fwLog(fwlog::kError) << "Failed creating an OpenGL window: " << iException.what() << "\n"
143  "Things to check:\n"
144  "- Is DISPLAY environment variable set?\n"
145  "- Are OpenGL libraries installed?\n"
146  "- If running remotely, make sure you use 'ssh -X' or 'ssh -Y'.\n"
147  "See also: https://twiki.cern.ch/twiki/bin/viewauth/CMS/WorkBookFireworks\n";
148  gSystem->Exit(1);
149  }
150 
151  eiManager()->setContext(m_context.get());
152 
153 
154  std::string descString(argv[0]);
155  descString += " [options] <data file>\nGeneral";
156 
157  namespace po = boost::program_options;
158  po::options_description desc(descString);
159  desc.add_options()
160  (kInputFilesCommandOpt, po::value< std::vector<std::string> >(), "Input root files")
161  (kConfigFileCommandOpt, po::value<std::string>(), "Include configuration file")
162  (kNoConfigFileCommandOpt, "Empty configuration")
163  (kNoVersionCheck, "No file version check")
164  (kGeomFileCommandOpt, po::value<std::string>(), "Reco geometry file. Default is cmsGeom10.root")
165  (kSimGeomFileCommandOpt,po::value<std::string>(), "Geometry file for browsing in table view. Default is CmsSimGeom-14.root. Can be simulation or reco geometry in TGeo format")
166  (kFieldCommandOpt, po::value<double>(), "Set magnetic field value explicitly. Default is auto-field estimation")
167  (kRootInteractiveCommandOpt, "Enable root interactive prompt")
168  (kSoftCommandOpt, "Try to force software rendering to avoid problems with bad hardware drivers")
169  (kExpertCommandOpt, "Enable PF user plugins.")
170  (kHelpCommandOpt, "Display help message");
171 
172  po::options_description livedesc("Live Event Display");
173  livedesc.add_options()
174  (kPlayCommandOpt, po::value<float>(), "Start in play mode with given interval between events in seconds")
175  (kPortCommandOpt, po::value<unsigned int>(), "Listen to port for new data files to open")
176  (kLoopCommandOpt, "Loop events in play mode")
177  (kChainCommandOpt, po::value<unsigned int>(), "Chain up to a given number of recently open files. Default is 1 - no chain")
178  (kLiveCommandOpt, "Enforce playback mode if a user is not using display")
179  (kAutoSaveAllViews, po::value<std::string>(), "Auto-save all views with given prefix (run_event_lumi_view.<auto-save-type> is appended)")
180  (kAutoSaveType, po::value<std::string>(), "Image type of auto-saved views, png or jpg (png is default)")
181  (kAutoSaveHeight, po::value<int>(), "Screenshots height when auto-save-all-views is enabled")
182  (kSyncAllViews, "Synchronize all views on new event");
183 
184  po::options_description debugdesc("Debug");
185  debugdesc.add_options()
186  (kLogLevelCommandOpt, po::value<unsigned int>(), "Set log level starting from 0 to 4 : kDebug, kInfo, kWarning, kError")
187  (kEveCommandOpt, "Show TEveBrowser to help debug problems")
188  (kEnableFPE, "Enable detection of floating-point exceptions");
189 
190 
191  po::options_description rnrdesc("Appearance");
192  rnrdesc.add_options()
193  (kFreePaletteCommandOpt, "Allow free color selection (requires special configuration!)")
194  (kZeroWinOffsets, "Disable auto-detection of window position offsets")
195  (kAdvancedRenderCommandOpt, "Enable line anti-aliasing");
196  po::positional_options_description p;
197  p.add(kInputFilesOpt, -1);
198 
199 
200  po::options_description hiddendesc("hidden");
201  hiddendesc.add_options();
202 
203  po::options_description all("");
204  all.add(desc).add(rnrdesc).add(livedesc).add(debugdesc);
205 
206 
207  int newArgc = argc;
208  char **newArgv = argv;
209  po::variables_map vm;
210  try{
211  po::store(po::command_line_parser(newArgc, newArgv).
212  options(all).positional(p).run(), vm);
213 
214  po::notify(vm);
215  }
216  catch ( const std::exception& e)
217  {
218  // Return with exit status 0 to avoid generating crash reports
219 
220  fwLog(fwlog::kError) << e.what() << std::endl;
221  std::cout << all <<std::endl;
222  exit(0);
223  }
224 
225  if(vm.count(kHelpOpt)) {
226  std::cout << all <<std::endl;
227  exit(0);
228  }
229 
230  if(vm.count(kLogLevelOpt)) {
231  fwlog::LogLevel level = (fwlog::LogLevel)(vm[kLogLevelOpt].as<unsigned int>());
233  }
234 
235  if(vm.count(kPlainRootCommandOpt)) {
236  fwLog(fwlog::kInfo) << "Plain ROOT prompt requested" << std::endl;
237  return;
238  }
239 
240  const char* cmspath = gSystem->Getenv("CMSSW_BASE");
241  if(0 == cmspath) {
242  throw std::runtime_error("CMSSW_BASE environment variable not set");
243  }
244 
245  // input file
246  if (vm.count(kInputFilesOpt)) {
247  m_inputFiles = vm[kInputFilesOpt].as< std::vector<std::string> >();
248  }
249 
250  if (!m_inputFiles.size())
251  fwLog(fwlog::kInfo) << "No data file given." << std::endl;
252  else if (m_inputFiles.size() == 1)
253  fwLog(fwlog::kInfo) << "Input " << m_inputFiles.front() << std::endl;
254  else
255  fwLog(fwlog::kInfo) << m_inputFiles.size() << " input files; first: " << m_inputFiles.front() << ", last: " << m_inputFiles.back() << std::endl;
256 
257  // configuration file
258  if (vm.count(kConfigFileOpt)) {
259  setConfigFilename(vm[kConfigFileOpt].as<std::string>());
260  if (access(configFilename(), R_OK) == -1)
261  {
262  fwLog(fwlog::kError) << "Specified configuration file does not exist. Quitting.\n";
263  exit(1);
264  }
265 
266  fwLog(fwlog::kInfo) << "Config " << configFilename() << std::endl;
267  } else {
268  if (vm.count(kNoConfigFileOpt)) {
269  fwLog(fwlog::kInfo) << "No configuration is loaded.\n";
271  }
272  }
273 
274  // geometry
275  if (vm.count(kGeomFileOpt)) {
276  setGeometryFilename(vm[kGeomFileOpt].as<std::string>());
277  fwLog(fwlog::kInfo) << "Geometry file " << geometryFilename() << "\n";
278  } else {
279  // fwLog(fwlog::kInfo) << "No geom file name. Choosing default.\n";
280  setGeometryFilename("cmsGeom10.root");
281  }
282 
283  if (vm.count(kSimGeomFileOpt)) {
284  setSimGeometryFilename(vm[kSimGeomFileOpt].as<std::string>());
285  } else {
286  setSimGeometryFilename("cmsSimGeom-14.root");
287  }
288  // Free-palette palette
289  if (vm.count(kFreePaletteCommandOpt)) {
291  fwLog(fwlog::kInfo) << "Palette restriction removed on user request!\n";
292  }
293  bool eveMode = vm.count(kEveOpt);
294 
295  //Delay creating guiManager and enabling autoloading until here so that if we have a 'help' request we don't
296  // open any graphics or build dictionaries
298 
299  TEveManager::Create(kFALSE, eveMode ? "FIV" : "FI");
300 
301  if(vm.count(kExpertCommandOpt))
302  {
303  m_context->setHidePFBuilders(false);
304  }
305  else {
306  m_context->setHidePFBuilders(true);
307  }
308 
309  if(vm.count(kExpertCommandOpt))
310  {
311  m_context->setHidePFBuilders(false);
312  }
313  else {
314  m_context->setHidePFBuilders(true);
315  }
316 
317  setup(m_navigator.get(), m_context.get(), m_metadataManager.get());
318 
319  if (vm.count(kZeroWinOffsets))
320  {
322  fwLog(fwlog::kInfo) << "Window offsets reset on user request!\n";
323  }
324 
325  if ( vm.count(kAdvancedRenderOpt) )
326  {
327  TEveLine::SetDefaultSmooth(kTRUE);
328  }
329 
330  //figure out where to find macros
331  //tell ROOT where to find our macros
333  // first check if port is not occupied
334  if (vm.count(kPortCommandOpt)) {
335  f=boost::bind(&CmsShowMain::setupSocket, this, vm[kPortCommandOpt].as<unsigned int>());
336  startupTasks()->addTask(f);
337  }
338 
339  f=boost::bind(&CmsShowMainBase::loadGeometry,this);
340  startupTasks()->addTask(f);
341  f=boost::bind(&CmsShowMainBase::setupViewManagers,this);
342  startupTasks()->addTask(f);
343 
344  if(vm.count(kLiveCommandOpt))
345  {
346  f = boost::bind(&CmsShowMain::setLiveMode, this);
347  startupTasks()->addTask(f);
348  }
349 
350  if(vm.count(kFieldCommandOpt))
351  {
352  m_context->getField()->setSource(FWMagField::kUser);
353  m_context->getField()->setUserField(vm[kFieldCommandOpt].as<double>());
354  }
355 
356  f=boost::bind(&CmsShowMain::setupDataHandling,this);
357  startupTasks()->addTask(f);
358 
359 
360  if (vm.count(kLoopOpt))
361  setPlayLoop();
362 
363  if (eveMode) {
364  f = boost::bind(&CmsShowMainBase::setupDebugSupport,this);
365  startupTasks()->addTask(f);
366  }
367  if(vm.count(kChainCommandOpt)) {
368  f = boost::bind(&CmsShowNavigator::setMaxNumberOfFilesToChain, m_navigator.get(), vm[kChainCommandOpt].as<unsigned int>());
369  startupTasks()->addTask(f);
370  }
371  if (vm.count(kPlayOpt)) {
372  f = boost::bind(&CmsShowMainBase::setupAutoLoad, this, vm[kPlayOpt].as<float>());
373  startupTasks()->addTask(f);
374  }
375 
376  if(vm.count(kAutoSaveAllViews)) {
377  std::string type = "png";
378  if(vm.count(kAutoSaveType)) {
379  type = vm[kAutoSaveType].as<std::string>();
380  if (type != "png" && type != "jpg")
381  {
382  fwLog(fwlog::kError) << "Specified auto-save type not supported. Quitting.\n";
383  exit(1);
384  }
385  }
387  fmt += "%u_%u_%llu_%s.";
388  fmt += type;
390  }
391  if (vm.count(kAutoSaveHeight)) {
393  }
394  if (vm.count(kSyncAllViews)) {
396  }
397  if(vm.count(kNoVersionCheck)) {
398  m_noVersionCheck=true;
399  }
400  if(vm.count(kEnableFPE)) {
401  gSystem->SetFPEMask();
402  }
403 
404  if (vm.count(kPortCommandOpt)) {
405  f=boost::bind(&CmsShowMain::connectSocket, this);
406  startupTasks()->addTask(f);
407  }
408 
410 }
411 
412 //
413 // Destruction
414 //
415 
417 {
418  //avoids a seg fault from eve which happens if eve is terminated after the GUI is gone
420 }
421 
422 class DieTimer : public TTimer
423 {
424 protected:
426 public:
427  DieTimer(CmsShowMain* app) : TTimer(), fApp(app)
428  {
429  Start(0, kTRUE);
430  }
431 
432  virtual Bool_t Notify() override
433  {
434  TurnOff();
435  fApp->doExit();
436  delete this;
437  return kFALSE;
438  }
439 };
440 
442 {
443  new DieTimer(this);
444 }
445 
447 {
448  // pre terminate eve
449  m_context->deleteEveElements();
451 
452  // sleep at least 150 ms
453  // windows in ROOT GUI are destroyed in 150 ms timeout after
454  gSystem->Sleep(151);
455  gSystem->ProcessEvents();
456  gSystem->ExitLoop();
457 }
458 
459 //
460 // assignment operators
461 //
462 // const CmsShowMain& CmsShowMain::operator=(const CmsShowMain& rhs)
463 // {
464 // //An exception safe implementation is
465 // CmsShowMain temp(rhs);
466 // swap(rhs);
467 //
468 // return *this;
469 // }
470 
471 //
472 // member functions
473 //
474 
475 const fwlite::Event*
477 {
478  if (m_navigator.get())
479  return static_cast<const fwlite::Event*>(m_navigator->getCurrentEvent());
480  return 0;
481 }
482 
483 void
485 {
486  m_openFile = file;
487  if (file)
488  guiManager()->titleChanged(m_navigator->frameTitle());
489 
490 
491  if (context()->getField()->getSource() == FWMagField::kNone) {
493  }
495 }
496 
497 void
499 {
501  guiManager()->titleChanged(m_navigator->frameTitle());
503 }
504 
506  //printf("Need to reset\n");
507 }
508 
510 {
511  const char* kRootType[] = {"ROOT files","*.root", 0, 0};
512  TGFileInfo fi;
513  fi.fFileTypes = kRootType;
514  /* this is how things used to be done:
515  fi.fIniDir = ".";
516  this is bad because the destructor calls delete[] on fIniDir.
517  */
518  fi.fIniDir = new char[128];
519  strncpy(fi.fIniDir, ".", 127);
520  guiManager()->updateStatus("waiting for data file ...");
521  new TGFileDialog(gClient->GetDefaultRoot(), guiManager()->getMainFrame(), kFDOpen, &fi);
522  guiManager()->updateStatus("loading file ...");
523  if (fi.fFilename) {
524  m_navigator->openFile(fi.fFilename);
525 
527  m_navigator->firstEvent();
528  checkPosition();
529  draw();
530  }
531  guiManager()->clearStatus();
532 }
533 
535 {
536  const char* kRootType[] = {"ROOT files","*.root", 0, 0};
537  TGFileInfo fi;
538  fi.fFileTypes = kRootType;
539  /* this is how things used to be done:
540  fi.fIniDir = ".";
541  this is bad because the destructor calls delete[] on fIniDir.
542  */
543  fi.fIniDir = new char[128];
544  strncpy(fi.fIniDir, ".", 127);
545  guiManager()->updateStatus("waiting for data file ...");
546  new TGFileDialog(gClient->GetDefaultRoot(), guiManager()->getMainFrame(), kFDOpen, &fi);
547  guiManager()->updateStatus("loading file ...");
548  if (fi.fFilename) {
549  m_navigator->appendFile(fi.fFilename, false, false);
551  checkPosition();
552  draw();
553  guiManager()->titleChanged(m_navigator->frameTitle());
554  }
555  guiManager()->clearStatus();
556 }
557 
558 void
560 {
561  if (m_searchFiles.get() == 0) {
562  m_searchFiles = std::auto_ptr<CmsShowSearchFiles>(new CmsShowSearchFiles("",
563  "Open Remote Data Files",
564  guiManager()->getMainFrame(),
565  500, 400));
566  m_searchFiles->CenterOnParent(kTRUE,TGTransientFrame::kBottomRight);
567  }
568  std::string chosenFile = m_searchFiles->chooseFileFromURL();
569  if(!chosenFile.empty()) {
570  guiManager()->updateStatus("loading file ...");
571  if(m_navigator->openFile(chosenFile.c_str())) {
573  m_navigator->firstEvent();
574  checkPosition();
575  draw();
576  guiManager()->clearStatus();
577  } else {
578  guiManager()->updateStatus("failed to load data file");
579  }
580  }
581 }
582 
583 //
584 // const member functions
585 //
586 
587 //_______________________________________________________________________________
588 void
590 {
592 
593  // case when start with no input file
595  {
596  if (m_monitor.get())
598  return;
599  }
600 
601  bool reachedEnd = (forward() && m_navigator->isLastEvent()) || (!forward() && m_navigator->isFirstEvent());
602 
603  if (loop() && reachedEnd)
604  {
605  forward() ? m_navigator->firstEvent() : m_navigator->lastEvent();
606  draw();
607  }
608  else if (!reachedEnd)
609  {
610  forward() ? m_navigator->nextEvent() : m_navigator->previousEvent();
611  draw();
612  }
613 
614  // stop loop in case no loop or monitor mode
615  if (reachedEnd && (loop() || m_monitor.get()) == kFALSE)
616  {
617  if (forward() && m_navigator->isLastEvent())
618  {
620  checkPosition();
621  }
622 
623  if ((!forward()) && m_navigator->isFirstEvent())
624  {
626  checkPosition();
627  }
628  }
629  else
631 }
632 
633 //______________________________________________________________________________
634 
635 void
637 {
638  if ((m_monitor.get() || loop() ) && isPlaying())
639  return;
640 
642 
643  if (m_navigator->isFirstEvent())
645 
646  if (m_navigator->isLastEvent())
647  {
648  guiManager()->disableNext();
649  // force enable play events action in --port mode
650  if (m_monitor.get() && !guiManager()->playEventsAction()->isEnabled())
652  }
653 }
654 
655 //==============================================================================
656 void
658 {
659  guiManager()->updateStatus("Setting up data handling...");
660 
661  // navigator filtering ->
662  m_navigator->fileChanged_.connect(boost::bind(&CmsShowMain::fileChangedSlot, this, _1));
663  m_navigator->editFiltersExternally_.connect(boost::bind(&FWGUIManager::updateEventFilterEnable, guiManager(), _1));
664  m_navigator->filterStateChanged_.connect(boost::bind(&CmsShowMain::navigatorChangedFilterState, this, _1));
665  m_navigator->postFiltering_.connect(boost::bind(&CmsShowMain::postFiltering, this, _1));
666 
667  // navigator fitlering <-
670 
671  // Data handling. File related and therefore not in the base class.
672  if (guiManager()->getAction(cmsshow::sOpenData) != 0)
673  guiManager()->getAction(cmsshow::sOpenData)->activated.connect(sigc::mem_fun(*this, &CmsShowMain::openData));
674  if (guiManager()->getAction(cmsshow::sAppendData) != 0)
675  guiManager()->getAction(cmsshow::sAppendData)->activated.connect(sigc::mem_fun(*this, &CmsShowMain::appendData));
676  if (guiManager()->getAction(cmsshow::sSearchFiles) != 0)
678 
679  setupActions();
680  // init data from CmsShowNavigator configuration, can do this with signals since there were not connected yet
681  guiManager()->setFilterButtonIcon(m_navigator->getFilterState());
682 
683  for (unsigned int ii = 0; ii < m_inputFiles.size(); ++ii)
684  {
685  const std::string& fname = m_inputFiles[ii];
686  if (fname.empty())
687  continue;
688  guiManager()->updateStatus("loading data file ...");
689  if (!m_navigator->appendFile(fname, false, false))
690  {
691  guiManager()->updateStatus("failed to load data file");
692  }
693  else
694  {
695  m_loadedAnyInputFile = true;
696  }
697  }
698 
700  {
701  m_navigator->firstEvent();
702  checkPosition();
703  draw();
705  }
706  else {
707  if (configFilename()[0] == '\0') {
708  guiManager()->initEmpty();
709  }
710  else {
712  }
713 
714  if (m_monitor.get() == 0 && (configurationManager()->getIgnore() == false)) {
715  if (m_inputFiles.empty())
716  openDataViaURL();
717  else
718  openData();
719  }
720  }
721 }
722 
723 void
725 {
726  if (m_loadedAnyInputFile == false) {
727  m_loadedAnyInputFile = true;
728  if ((configFilename()[0] == '\0') && (configurationManager()->getIgnore() == false))
730  }
731 }
732 
733 
734 void
735 CmsShowMain::setupSocket(unsigned int iSocket)
736 {
737  m_monitor = std::auto_ptr<TMonitor>(new TMonitor);
738  TServerSocket* server = new TServerSocket(iSocket,kTRUE);
739  if (server->GetErrorCode())
740  {
741  fwLog(fwlog::kError) << "CmsShowMain::setupSocket, can't create socket on port "<< iSocket << "." << std::endl;
742  exit(0);
743  }
744  m_monitor->Add(server);
745 }
746 
747 void
749 {
750  m_monitor->Connect("Ready(TSocket*)","CmsShowMain",this,"notified(TSocket*)");
751 
752 }
753 
754 void
755 CmsShowMain::notified(TSocket* iSocket)
756 {
757  TServerSocket* server = dynamic_cast<TServerSocket*> (iSocket);
758  if (server)
759  {
760  TSocket* connection = server->Accept();
761  if (connection)
762  {
763  m_monitor->Add(connection);
764  std::stringstream s;
765  s << "received connection from "<<iSocket->GetInetAddress().GetHostName();
766  guiManager()->updateStatus(s.str().c_str());
767  }
768  }
769  else
770  {
771  char buffer[4096];
772  memset(buffer,0,sizeof(buffer));
773  if (iSocket->RecvRaw(buffer, sizeof(buffer)) <= 0)
774  {
775  m_monitor->Remove(iSocket);
776  //std::stringstream s;
777  //s << "closing connection to "<<iSocket->GetInetAddress().GetHostName();
778  //m_guiManager->updateStatus(s.str().c_str());
779  delete iSocket;
780  return;
781  }
782  std::string fileName(buffer);
783  std::string::size_type lastNonSpace = fileName.find_last_not_of(" \n\t");
784  if (lastNonSpace != std::string::npos)
785  {
786  fileName.erase(lastNonSpace+1);
787  }
788 
789  std::stringstream s;
790  s <<"New file notified '"<<fileName<<"'";
791  guiManager()->updateStatus(s.str().c_str());
792 
793  bool appended = m_navigator->appendFile(fileName, true, m_live);
794 
795  if (appended)
796  {
797  if (m_live && isPlaying() && forward())
798  m_navigator->activateNewFileOnNextEvent();
799  else if (!isPlaying())
800  checkPosition();
801 
802  // bootstrap case: --port and no input file
804  {
805  m_loadedAnyInputFile = true;
806  m_navigator->firstEvent();
807  if (!isPlaying())
808  draw();
809  }
810 
811  std::stringstream sr;
812  sr <<"New file registered '"<<fileName<<"'";
813  guiManager()->updateStatus(sr.str().c_str());
814  }
815  else
816  {
817  std::stringstream sr;
818  sr <<"New file NOT registered '"<<fileName<<"'";
819  guiManager()->updateStatus(sr.str().c_str());
820  }
821  }
822 }
823 
824 void
826 {
827  if (m_live) {
828  Int_t keycode = gVirtualX->KeysymToKeycode((int)kKey_Space);
829  Window_t id = FWGUIManager::getGUIManager()->getMainFrame()->GetId();
830  gVirtualX->GrabKey(id, keycode, 0, isPlaying());
831  }
832 }
833 
834 void
836 {
838  if (m_live)
839  m_navigator->resetNewFileOnNextEvent();
842  checkPosition();
843 }
844 
845 void
847 {
849  if (m_navigator->filesNeedUpdate() == false)
850  {
851  guiManager()->setFilterButtonText(m_navigator->filterStatusMessage());
852  checkPosition();
853  }
854 }
855 
856 void
858 {
859  if (m_navigator->getFilterState() == CmsShowNavigator::kWithdrawn )
861  else
862  m_navigator->toggleFilterEnable();
863 }
864 
865 void
867 {
868  // called only if filter has changed
869  guiManager()->updateStatus("Filtering events");
870 }
871 
872 void
874 {
875  // called only filter is changed
876  guiManager()->clearStatus();
877  if (doDraw) draw();
878  checkPosition();
879  guiManager()->setFilterButtonText(m_navigator->filterStatusMessage());
880 }
881 
882 //______________________________________________________________________________
883 
884 void
886 {
887  m_live = true;
888  m_liveTimer.reset(new SignalTimer());
889  m_liveTimer->timeout_.connect(boost::bind(&CmsShowMain::checkLiveMode,this));
890 
891  Window_t rootw, childw;
892  Int_t root_x, root_y, win_x, win_y;
893  UInt_t mask;
894  gVirtualX->QueryPointer(gClient->GetDefaultRoot()->GetId(),
895  rootw, childw,
896  root_x, root_y,
897  win_x, win_y,
898  mask);
899 
900 
901  m_liveTimer->SetTime(m_liveTimeout);
902  m_liveTimer->Reset();
903  m_liveTimer->TurnOn();
904 }
905 
906 void
908 {
909  m_liveTimer->TurnOff();
910 
911 #if defined(R__LINUX)
912  TGX11 *x11 = dynamic_cast<TGX11*>(gVirtualX);
913  if (x11) {
914  XAnyEvent *ev = (XAnyEvent*) x11->GetNativeEvent();
915  // printf("serial %d \n",(int)ev->serial );
916 
917  if ( !isPlaying() && m_lastXEventSerial == ev->serial )
919  m_lastXEventSerial = ev->serial;
920  }
921 #endif
922  m_liveTimer->SetTime((Long_t)(m_liveTimeout));
923  m_liveTimer->Reset();
924  m_liveTimer->TurnOn();
925 }
DieTimer(CmsShowMain *app)
Definition: CmsShowMain.cc:427
void fileChangedSlot(const TFile *file)
Definition: CmsShowMain.cc:484
static const char *const kPlayCommandOpt
Definition: CmsShowMain.cc:88
static const char *const kNoVersionCheck
Definition: CmsShowMain.cc:114
void navigatorChangedFilterState(int)
Definition: CmsShowMain.cc:846
type
Definition: HCALResponse.h:21
void openData()
Definition: CmsShowMain.cc:509
const fwlite::Event * getCurrentEvent() const
Definition: CmsShowMain.cc:476
CmsShowMain * fApp
Definition: CmsShowMain.cc:425
static const char *const kGeomFileCommandOpt
Definition: CmsShowMain.cc:82
void setLoadedAnyInputFileAfterStartup()
Definition: CmsShowMain.cc:724
void showEventFilterGUI(const TGWindow *p)
FWSelectionManager * selectionManager()
sigc::signal< void > filterButtonClicked_
Definition: FWGUIManager.h:207
static const char *const kChainCommandOpt
Definition: CmsShowMain.cc:104
static const char *const kAutoSaveAllViews
Definition: CmsShowMain.cc:108
bool m_loadedAnyInputFile
Definition: CmsShowMain.h:121
void resetInitialization()
Definition: CmsShowMain.cc:505
virtual void checkPosition()
Definition: CmsShowMain.cc:636
virtual void eventChangedImp()
Definition: CmsShowMain.cc:498
const double w
Definition: UKUtility.cc:23
FWGUIManager * guiManager()
static const char *const kZeroWinOffsets
Definition: CmsShowMain.cc:113
void appendData()
Definition: CmsShowMain.cc:534
void preFiltering()
Definition: CmsShowMain.cc:866
void setupSocket(unsigned int)
Definition: CmsShowMain.cc:735
void setFilterButtonIcon(int)
static const char *const kSyncAllViews
Definition: CmsShowMain.cc:111
void checkLiveMode()
Definition: CmsShowMain.cc:907
static const char *const kFieldCommandOpt
Definition: CmsShowMain.cc:106
void setAutoSaveAllViewsHeight(int x)
void enable()
Definition: CSGAction.cc:284
FWEventItemsManager * eiManager()
virtual void checkKeyBindingsOnPLayEventsStateChanged()
Definition: CmsShowMain.cc:825
sigc::signal< void > activated
Definition: CSGAction.h:88
static const char *const kLogLevelOpt
Definition: CmsShowMain.cc:92
static const char *const kSimGeomFileOpt
Definition: CmsShowMain.cc:83
std::auto_ptr< FWLiteJobMetadataManager > m_metadataManager
Definition: CmsShowMain.h:117
static const char *const kNoConfigFileOpt
Definition: CmsShowMain.cc:85
bool ev
const char * configFilename() const
const std::string sOpenData
Definition: ActionsList.cc:12
void setup(FWNavigatorBase *navigator, fireworks::Context *context, FWJobMetadataManager *metadataManager)
void updateStatus(const char *status)
void setContext(fireworks::Context *)
virtual ~CmsShowMain()
Definition: CmsShowMain.cc:416
int ii
Definition: cuy.py:588
uint16_t size_type
static const char *const kConfigFileCommandOpt
Definition: CmsShowMain.cc:80
void setupDataHandling()
Definition: CmsShowMain.cc:657
void enableActions(bool enable=true)
virtual void autoLoadNewEvent()
Definition: CmsShowMain.cc:589
static const char * fmt
Definition: Version.cc:9
std::auto_ptr< SignalTimer > m_liveTimer
Definition: CmsShowMain.h:128
static const char *const kExpertCommandOpt
Definition: CmsShowMain.cc:100
static const char *const kAdvancedRenderOpt
Definition: CmsShowMain.cc:95
CmsShowMain(int argc, char *argv[])
Definition: CmsShowMain.cc:120
static const char *const kGeomFileOpt
Definition: CmsShowMain.cc:81
std::auto_ptr< fireworks::Context > m_context
Definition: CmsShowMain.h:118
LogLevel
Definition: fwLog.h:35
void setupAutoLoad(float x)
static const char *const kPortCommandOpt
Definition: CmsShowMain.cc:101
void setGeometryFilename(const std::string &filename)
static const char *const kPlayOpt
Definition: CmsShowMain.cc:87
virtual void stopPlaying()
void filterButtonClicked()
Definition: CmsShowMain.cc:857
void resetWMOffsets()
const std::string sAppendData
Definition: ActionsList.cc:13
FWMagField * getField() const
Definition: Context.h:77
bool loop() const
virtual Bool_t Notify() override
Definition: CmsShowMain.cc:432
CmsShowTaskExecutor * startupTasks()
virtual Bool_t isEnabled() const
Definition: CSGAction.cc:308
std::auto_ptr< TMonitor > m_monitor
Definition: CmsShowMain.h:134
UInt_t m_lastXEventSerial
Definition: CmsShowMain.h:130
sigc::signal< void, const TGWindow * > showEventFilterGUI_
Definition: FWGUIManager.h:208
static const char *const kEveOpt
Definition: CmsShowMain.cc:93
virtual void quit()
Definition: CmsShowMain.cc:441
virtual void eventChangedImp()
static void enable()
enable automatic library loading
static const char *const kConfigFileOpt
Definition: CmsShowMain.cc:79
static const char *const kFreePaletteCommandOpt
Definition: CmsShowMain.cc:107
static const char *const kLoopOpt
Definition: CmsShowMain.cc:89
static const char *const kEveCommandOpt
Definition: CmsShowMain.cc:94
double f[11][100]
static const char *const kSoftCommandOpt
Definition: CmsShowMain.cc:99
static const char *const kLogLevelCommandOpt
Definition: CmsShowMain.cc:91
CmsShowMainFrame * getMainFrame() const
Definition: FWGUIManager.h:201
void disablePrevious()
ESource getSource() const
Definition: FWMagField.h:33
static const char *const kNoConfigFileCommandOpt
Definition: CmsShowMain.cc:86
static const char *const kEnableFPE
Definition: CmsShowMain.cc:112
std::vector< std::string > m_inputFiles
Definition: CmsShowMain.h:120
void setLiveMode()
Definition: CmsShowMain.cc:885
void setSimGeometryFilename(const std::string &filename)
void clearStatus()
void postFiltering(bool)
Definition: CmsShowMain.cc:873
CSGAction * getAction(const std::string name)
static const char *const kLiveCommandOpt
Definition: CmsShowMain.cc:105
void updateEventFilterEnable(bool)
static const char *const kHelpCommandOpt
Definition: CmsShowMain.cc:98
static FWGUIManager * getGUIManager()
static const char *const kInputFilesCommandOpt
Definition: CmsShowMain.cc:78
#define fwLog(_level_)
Definition: fwLog.h:50
static const char *const kInputFilesOpt
Definition: CmsShowMain.cc:77
static const char *const kPlainRootCommandOpt
Definition: CmsShowMain.cc:102
tuple argc
Definition: dir2webdir.py:38
const TFile * m_openFile
Definition: CmsShowMain.h:122
void setAutoSaveAllViewsFormat(const std::string &fmt)
std::auto_ptr< CmsShowNavigator > m_navigator
Definition: CmsShowMain.h:116
void setFilterButtonText(const char *txt)
std::auto_ptr< CmsShowSearchFiles > m_searchFiles
Definition: CmsShowMain.h:124
static const char *const kAutoSaveType
Definition: CmsShowMain.cc:109
static const char *const kRootInteractiveCommandOpt
Definition: CmsShowMain.cc:103
CSGContinuousAction * playEventsAction()
string fname
main script
bool m_noVersionCheck
Definition: CmsShowMain.h:132
static const char *const kAdvancedRenderCommandOpt
Definition: CmsShowMain.cc:96
void doExit()
Definition: CmsShowMain.cc:446
bool isPlaying() const
boost::function0< void > TaskFunctor
FWConfigurationManager * configurationManager()
void showEventFilterGUI()
void addTask(const TaskFunctor &iTask)
int m_liveTimeout
Definition: CmsShowMain.h:129
void evePreTerminate()
void setMaxNumberOfFilesToChain(unsigned int i)
tuple cout
Definition: gather_cfg.py:121
virtual void stopPlaying()
Definition: CmsShowMain.cc:835
void notified(TSocket *)
Definition: CmsShowMain.cc:755
tuple level
Definition: testEve_cfg.py:34
bool forward() const
volatile std::atomic< bool > shutdown_flag false
const std::string & geometryFilename(void)
static void EnableFreePalette()
void setPresentLogLevel(LogLevel)
Definition: fwLog.cc:55
const fireworks::Context * context() const
Definition: CmsShowMain.h:80
static const char *const kSimGeomFileCommandOpt
Definition: CmsShowMain.cc:84
static void syncAllViews()
void connectSocket()
Definition: CmsShowMain.cc:748
void titleChanged(const char *title)
void resetFieldEstimate() const
Definition: FWMagField.cc:162
static const char *const kHelpOpt
Definition: CmsShowMain.cc:97
void disableNext()
static const char *const kLoopCommandOpt
Definition: CmsShowMain.cc:90
void openDataViaURL()
Definition: CmsShowMain.cc:559
static const char *const kAutoSaveHeight
Definition: CmsShowMain.cc:110
void reachedEnd()
void setConfigFilename(const std::string &f)
T get(const Candidate &c)
Definition: component.h:55
const std::string sSearchFiles
Definition: ActionsList.cc:14