G4ZMQServer Class Reference

#include <G4ZMQServer.hh>

Inheritance diagram for G4ZMQServer:

Public Types
using	Transformer = std::function< G4bool(G4String &)>

Public Member Functions
void	AddCerrTransformer (const Transformer &t)
void	AddCerrTransformer (Transformer &&t)
void	AddCoutTransformer (const Transformer &t)
void	AddCoutTransformer (Transformer &&t)
	G4ZMQServer ()
G4String	GetEndpoint () const
G4int	GetLastReturnCode () const
virtual void	PauseSessionStart (const G4String &message)
virtual G4int	ReceiveG4cerr (const G4String &cerrString)
G4int	ReceiveG4cerr_ (const G4String &msg)
virtual G4int	ReceiveG4cout (const G4String &coutString)
G4int	ReceiveG4cout_ (const G4String &msg)
virtual void	ResetTransformers ()
virtual G4UIsession *	SessionStart ()
void	SetDebug (G4bool flag)
void	SetEndpoint (const G4String &endpoint)
	~G4ZMQServer ()

Static Public Member Functions
static G4int	InSession ()

Protected Member Functions
void	ApplyShellCommand (const G4String &, G4bool &, G4bool &)
G4bool	ChangeDirectory (const char *newDir)
void	ChangeDirectoryCommand (const G4String &)
G4String	Complete (const G4String &)
G4UIcommand *	FindCommand (const char *commandName) const
G4UIcommandTree *	FindDirectory (const char *dirName) const
G4String	FindMatchingPath (G4UIcommandTree *, const G4String &)
G4String	GetCurrentWorkingDirectory () const
void	ListDirectory (const G4String &) const
G4String	ModifyToFullPathCommand (const char *aCommandLine) const
void	ShowCurrent (const G4String &) const
void	TerminalHelp (const G4String &)

Protected Attributes
G4int	ifBatch = 0
G4int	lastRC = 0
std::vector< Transformer >	transformersCerr
std::vector< Transformer >	transformersCout

Static Protected Attributes
static G4ICOMS_DLL G4int	inSession = 0
static G4MTGLOB_DLL G4coutDestination *	masterG4coutDestination = nullptr

Private Member Functions
virtual void	ExecuteCommand (const G4String &command)
virtual void	ExitHelp () const
G4String	GetCommand (const G4String &input)
virtual G4bool	GetHelpChoice (G4int &)
G4String	ModifyPath (const G4String &tempPath) const

Private Attributes
G4String	currentDirectory
G4String	endpoint_
G4bool	qdebug_
G4UItcsh *	shell_

Detailed Description

Definition at line 36 of file G4ZMQServer.hh.

Member Typedef Documentation

Transformer

using G4coutDestination::Transformer = std::function<G4bool(G4String&)>

inherited

Definition at line 61 of file G4coutDestination.hh.

Constructor & Destructor Documentation

G4ZMQServer()

G4ZMQServer::G4ZMQServer

(

)

Definition at line 74 of file G4ZMQServer.cc.

{
  endpoint_ = "tcp://127.0.0.1:5555";
  qdebug_ = false;
  shell_= new G4UItcsh();
  shell_-> SetLsColor(BLUE, RED);
 
  ::ui_manager = G4UImanager::GetUIpointer();
  ::ui_manager-> SetSession(this);
  ::ui_manager-> SetCoutDestination(this);
 
  ::qexit = false;
}

References BLUE, endpoint_, G4UImanager::GetUIpointer(), qdebug_, anonymous_namespace{G4ZMQServer.cc}::qexit, RED, shell_, and anonymous_namespace{G4ZMQServer.cc}::ui_manager.

~G4ZMQServer()

G4ZMQServer::~G4ZMQServer

(

)

Definition at line 89 of file G4ZMQServer.cc.

{
  delete shell_;
}

References shell_.

Member Function Documentation

AddCerrTransformer() [1/2]

void G4coutDestination::AddCerrTransformer ( const Transformer &  t )

inlineinherited

Definition at line 67 of file G4coutDestination.hh.

  {
    transformersCerr.push_back(t);
  }

References G4coutDestination::transformersCerr.

Referenced by G4MTcoutDestination::HandleFileCerr().

AddCerrTransformer() [2/2]

void G4coutDestination::AddCerrTransformer ( Transformer &&  t )

inlineinherited

Definition at line 71 of file G4coutDestination.hh.

{ transformersCerr.push_back(t); }

References G4coutDestination::transformersCerr.

AddCoutTransformer() [1/2]

void G4coutDestination::AddCoutTransformer ( const Transformer &  t )

inlineinherited

Definition at line 62 of file G4coutDestination.hh.

  {
    transformersCout.push_back(t);
  }

References G4coutDestination::transformersCout.

Referenced by G4MTcoutDestination::AddMasterOutput(), G4MTcoutDestination::HandleFileCout(), and G4MTcoutDestination::SetDefaultOutput().

AddCoutTransformer() [2/2]

void G4coutDestination::AddCoutTransformer ( Transformer &&  t )

inlineinherited

Definition at line 66 of file G4coutDestination.hh.

{ transformersCout.push_back(t); }

References G4coutDestination::transformersCout.

ApplyShellCommand()

void G4VBasicShell::ApplyShellCommand ( const G4String &  a_string, G4bool &  exitSession, G4bool &  exitPause  )

protectedinherited

!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!

Definition at line 232 of file G4VBasicShell.cc.

{
  G4UImanager* UI = G4UImanager::GetUIpointer();
  if(UI==NULL) return;
 
  G4String command = G4StrUtil::lstrip_copy(a_string);
 
  if( command[0] == '#' ) {
 
    G4cout << command << G4endl;
 
  } else if( command == "ls" || command.substr(0,3) == "ls " ) {
 
    ListDirectory( command );
 
  } else if( command == "pwd" ) {
 
    G4cout << "Current Working Directory : "
       << GetCurrentWorkingDirectory() << G4endl;
 
  } else if( command == "cd" || command.substr(0,3) == "cd ") {
 
    ChangeDirectoryCommand ( command );
 
  } else if( command == "help" || command.substr(0,5) == "help ") {
 
    TerminalHelp( command );
 
  } else if( command[0] == '?' ) {
 
    ShowCurrent( command );
 
  } else if( command == "hist" || command == "history") {
 
    G4int nh = UI->GetNumberOfHistory();
    for(G4int i=0;i<nh;i++) {
      G4cout << i << ": " << UI->GetPreviousCommand(i) << G4endl;
    }
 
  } else if( command[0] == '!' ) {
 
    G4String ss = command.substr(1,command.length()-1);
    G4int vl;
    const char* tt = ss;
    std::istringstream is(tt);
    is >> vl;
    G4int nh = UI->GetNumberOfHistory();
    if(vl>=0 && vl<nh) {
      G4String prev = UI->GetPreviousCommand(vl);
      G4cout << prev << G4endl;
      ExecuteCommand (ModifyToFullPathCommand(prev));
    } else {
      G4cerr << "history " << vl << " is not found." << G4endl;
    }
 
  } else if( command == "exit" ) {
 
    if( exitPause == false) { //In a secondary loop.
      G4cout << "You are now processing RUN." << G4endl;
      G4cout << "Please abort it using \"/run/abort\" command first" << G4endl;
      G4cout << " and use \"continue\" command until the application" << G4endl;
      G4cout << " becomes to Idle." << G4endl;
    } else {
      exitSession = true;
    }
 
  } else if( command == "cont" || command == "continue"){
 
    exitPause = true;
 
  } else {
 
    ExecuteCommand(ModifyToFullPathCommand(a_string));
 
  }
}

References G4VBasicShell::ChangeDirectoryCommand(), G4VBasicShell::ExecuteCommand(), exitPause, exitSession, G4cerr, G4cout, G4endl, G4VBasicShell::GetCurrentWorkingDirectory(), G4UImanager::GetNumberOfHistory(), G4UImanager::GetPreviousCommand(), G4UImanager::GetUIpointer(), G4VBasicShell::ListDirectory(), G4StrUtil::lstrip_copy(), G4VBasicShell::ModifyToFullPathCommand(), G4VBasicShell::ShowCurrent(), and G4VBasicShell::TerminalHelp().

Referenced by G4UIQt::ButtonCallback(), G4UIXm::ButtonCallback(), G4UIQt::CommandEnteredCallback(), G4UIXm::CommandEnteredCallback(), G4UIWin32::DoOpenMacro(), G4UIWin32::DoSaveViewer(), G4UIWin32::ProcessDefaultCommands(), and G4UIWin32::ProcessEnterKey().

ChangeDirectory()

G4bool G4VBasicShell::ChangeDirectory ( const char *  newDir )

protectedinherited

Definition at line 74 of file G4VBasicShell.cc.

{
  G4String newPrefix = G4StrUtil::strip_copy(newDir);
 
  G4String newDirectory = ModifyPath( newPrefix );
  if( newDirectory.back() != '/' )
  { newDirectory += "/"; }
  if( FindDirectory( newDirectory.c_str() ) == NULL )
  { return false; }
  currentDirectory = newDirectory;
  return true;
}

References G4VBasicShell::currentDirectory, G4VBasicShell::FindDirectory(), G4VBasicShell::ModifyPath(), and G4StrUtil::strip_copy().

Referenced by G4VBasicShell::ChangeDirectoryCommand().

ChangeDirectoryCommand()

void G4VBasicShell::ChangeDirectoryCommand ( const G4String &  newCommand )

protectedinherited

Definition at line 325 of file G4VBasicShell.cc.

{
  G4String prefix;
  if( newCommand.length() <= 3 ) {
    prefix = "/";
  } else {
    G4String aNewPrefix = newCommand.substr(3, newCommand.length()-3);
    prefix = G4StrUtil::strip_copy(aNewPrefix);
  }
  if(!ChangeDirectory(prefix)) {
    G4cout << "directory <" << prefix << "> not found." << G4endl;
  }
}

References G4VBasicShell::ChangeDirectory(), G4cout, G4endl, and G4StrUtil::strip_copy().

Referenced by G4VBasicShell::ApplyShellCommand(), G4UIterminal::GetCommand(), and GetCommand().

Complete()

G4String G4VBasicShell::Complete ( const G4String &  commandName )

protectedinherited

Definition at line 180 of file G4VBasicShell.cc.

{
  G4String rawCommandLine = commandName;
  G4String commandLine = G4StrUtil::strip_copy(rawCommandLine);
  
  size_t i = commandLine.find(" ");
  if( i != std::string::npos ) return rawCommandLine; // Already entering parameters,
                                            // assume command path is correct.
  G4String commandString = commandLine;
  G4String targetCom = ModifyPath(commandString);
  G4UIcommandTree* tree = G4UImanager::GetUIpointer()->GetTree();
  G4String value = FindMatchingPath(tree,targetCom);
  if(value=="") return rawCommandLine;
  return value;
}

References G4VBasicShell::FindMatchingPath(), G4UImanager::GetTree(), G4UImanager::GetUIpointer(), G4VBasicShell::ModifyPath(), and G4StrUtil::strip_copy().

Referenced by G4UIQt::eventFilter(), G4UIXm::keyHandler(), and G4UIWin32::ProcessTabKey().

ExecuteCommand()

void G4ZMQServer::ExecuteCommand ( const G4String &  aCommand )

privatevirtual

!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!

Reimplemented from G4VBasicShell.

Definition at line 263 of file G4ZMQServer.cc.

{
  auto rc = ::ui_manager-> ApplyCommand(command);
  auto pcode = rc % 100;
  auto status = rc - pcode;
 
  G4UIcommand* cmd = nullptr;
  if( status != fCommandSucceeded ) cmd = FindCommand(command);
 
  switch ( status ) {
  case fCommandSucceeded:
    break;
  case fCommandNotFound:
    G4cerr << "command <" << ::ui_manager-> SolveAlias(command)
           << "> not found" << G4endl;
    break;
  case fIllegalApplicationState:
    G4cerr << "illegal application state -- command refused" << G4endl;
    break;
  case fParameterOutOfRange:
    G4cerr << "Parameter is out of range" << G4endl;
   break;
  case fParameterOutOfCandidates:
    G4cerr << "Parameter is out of candidate list (index "
           << pcode << ")" << G4endl;
    G4cerr << "Candidates : "
           << cmd-> GetParameter(pcode)-> GetParameterCandidates()
           << G4endl;
    break;
  case fParameterUnreadable:
    G4cerr << "Parameter is wrong type and/or is not omittable (index "
           << pcode << ")" << G4endl;
    break;
  case fAliasNotFound:
    break;
  default:
    G4cerr << "command refused (" << status << ")" << G4endl;
    break;
 }
}

References fAliasNotFound, fCommandNotFound, fCommandSucceeded, fIllegalApplicationState, G4VBasicShell::FindCommand(), fParameterOutOfCandidates, fParameterOutOfRange, fParameterUnreadable, G4cerr, G4endl, and anonymous_namespace{G4ZMQServer.cc}::ui_manager.

Referenced by SessionStart().

ExitHelp()

void G4ZMQServer::ExitHelp ( ) const

privatevirtual

Implements G4VBasicShell.

Definition at line 311 of file G4ZMQServer.cc.

{
}

FindCommand()

G4UIcommand * G4VBasicShell::FindCommand ( const char *  commandName ) const

protectedinherited

Definition at line 109 of file G4VBasicShell.cc.

{
  G4String commandLine = G4StrUtil::strip_copy(commandName);
 
  G4String commandString;
  size_t i = commandLine.find(" ");
  if( i != std::string::npos )
  { commandString = commandLine.substr(0,i); }
  else
  { commandString = commandLine; }
 
  G4String targetCom = ModifyPath(commandString);
  return G4UImanager::GetUIpointer()->GetTree()->FindPath(targetCom);
}

References G4UIcommandTree::FindPath(), G4UImanager::GetTree(), G4UImanager::GetUIpointer(), G4VBasicShell::ModifyPath(), and G4StrUtil::strip_copy().

Referenced by G4UIterminal::ExecuteCommand(), and ExecuteCommand().

FindDirectory()

G4UIcommandTree * G4VBasicShell::FindDirectory ( const char *  dirName ) const

protectedinherited

Definition at line 87 of file G4VBasicShell.cc.

{
  G4String theDir = G4StrUtil::strip_copy(dirName);
 
  G4String targetDir = ModifyPath( theDir );
  if( targetDir.back() != '/' )
  { targetDir += "/"; }
  G4UIcommandTree* comTree = G4UImanager::GetUIpointer()->GetTree();
  if( targetDir == "/" )
  { return comTree; }
  size_t idx = 1;
  while( idx < targetDir.length()-1 )
  {
    size_t i = targetDir.find("/",idx);
    comTree = comTree->GetTree(targetDir.substr(0,i+1).c_str());
    if( comTree == NULL )
    { return NULL; }
    idx = i+1;
  }
  return comTree;
}

References G4UImanager::GetTree(), G4UIcommandTree::GetTree(), G4UImanager::GetUIpointer(), G4VBasicShell::ModifyPath(), and G4StrUtil::strip_copy().

Referenced by G4VBasicShell::ChangeDirectory(), G4VBasicShell::ListDirectory(), and SessionStart().

FindMatchingPath()

G4String G4VBasicShell::FindMatchingPath ( G4UIcommandTree *  aTree, const G4String &  aCommandPath  )

protectedinherited

Definition at line 196 of file G4VBasicShell.cc.

{
  return aTree-> CompleteCommandPath(aCommandPath);
}

Referenced by G4VBasicShell::Complete().

GetCommand()

G4String G4ZMQServer::GetCommand ( const G4String &  input )

private

Definition at line 203 of file G4ZMQServer.cc.

{
  const std::string nullstr = "";
  G4String cmdstr = input;
 
  G4String cstr = G4StrUtil::lstrip_copy(cmdstr);
  if ( cstr.length() == 0 ) {
    cmdstr = nullstr;
 
  // define built-in shell commands...
  } else if ( cstr[0] == '#' ) {
    G4cout << cstr << G4endl;
    cmdstr = nullstr;
 
  } else if ( cstr == "ls" || cstr.substr(0,3) == "ls " ) {
    ListDirectory(cstr);
    cmdstr = nullstr;
 
  } else if ( cstr == "lc" || cstr.substr(0,3) == "lc " ) {
    shell_-> ListCommand(cstr.erase(0,2));
    cmdstr = nullstr;
 
  } else if (cstr == "pwd" ) {
    G4cout << "Current Command Directory : "
           << GetCurrentWorkingDirectory() << G4endl;
    cmdstr = nullstr;
 
  } else if ( cstr == "cwd" ) {
    shell_-> ShowCurrentDirectory();
    cmdstr = nullstr;
 
  } else if (cstr == "cd" || cstr.substr(0,3) == "cd " ) {
    ChangeDirectoryCommand(cstr);
    shell_-> SetCurrentDirectory(GetCurrentWorkingDirectory());
    cmdstr = nullstr;
 
  } else if ( cstr == "help" || cstr.substr(0,5) == "help " ) {
    TerminalHelp(cstr);
    cmdstr = nullstr;
 
  } else if ( cstr(0) == '?' ) {
    ShowCurrent(cstr);
    cmdstr = nullstr;
 
  } else if ( cstr == "history" ) {
    auto nh= ::ui_manager-> GetNumberOfHistory();
    for (auto i = 0; i < nh; i++) {
      G4cout << i << ": " << ::ui_manager->GetPreviousCommand(i) << G4endl;
    }
    cmdstr = nullstr;
 
  } else if ( cstr == "exit" ) {
    ::qexit = true;
    cmdstr = nullstr;
  }
 
  return ModifyToFullPathCommand(cmdstr);
}

References G4VBasicShell::ChangeDirectoryCommand(), test::cmdstr, G4cout, G4endl, G4VBasicShell::GetCurrentWorkingDirectory(), G4UImanager::GetPreviousCommand(), G4VBasicShell::ListDirectory(), G4StrUtil::lstrip_copy(), G4VBasicShell::ModifyToFullPathCommand(), anonymous_namespace{G4ZMQServer.cc}::qexit, shell_, G4VBasicShell::ShowCurrent(), G4VBasicShell::TerminalHelp(), and anonymous_namespace{G4ZMQServer.cc}::ui_manager.

Referenced by SessionStart().

GetCurrentWorkingDirectory()

G4String G4VBasicShell::GetCurrentWorkingDirectory ( ) const

protectedinherited

Definition at line 69 of file G4VBasicShell.cc.

{
  return currentDirectory;
}

References G4VBasicShell::currentDirectory.

Referenced by G4VBasicShell::ApplyShellCommand(), G4UIterminal::GetCommand(), GetCommand(), G4VBasicShell::ListDirectory(), SessionStart(), and G4VBasicShell::TerminalHelp().

GetEndpoint()

G4String G4ZMQServer::GetEndpoint ( ) const

inline

Definition at line 71 of file G4ZMQServer.hh.

{
  return endpoint_;
}

References endpoint_.

GetHelpChoice()

G4bool G4ZMQServer::GetHelpChoice ( G4int &  )

privatevirtual

Implements G4VBasicShell.

Definition at line 305 of file G4ZMQServer.cc.

{
  return true;
}

GetLastReturnCode()

G4int G4UIsession::GetLastReturnCode ( ) const

inlineinherited

Definition at line 63 of file G4UIsession.hh.

{ return lastRC; }

References G4UIsession::lastRC.

InSession()

G4int G4UIsession::InSession ( )

staticinherited

Definition at line 68 of file G4UIsession.cc.

{
  return inSession;
}

References G4UIsession::inSession.

Referenced by G4UIcontrolMessenger::SetNewValue().

ListDirectory()

void G4VBasicShell::ListDirectory ( const G4String &  newCommand ) const

protectedinherited

Definition at line 339 of file G4VBasicShell.cc.

{
  G4String targetDir;
  if( newCommand.length() <= 3 ) {
    targetDir = GetCurrentWorkingDirectory();
  } else {
    G4String newPrefix = newCommand.substr(3, newCommand.length()-3);
    targetDir = G4StrUtil::strip_copy(newPrefix);
  }
  G4UIcommandTree* commandTree = FindDirectory( targetDir );
  if( commandTree == NULL ) {
    G4cout << "Directory <" << targetDir << "> is not found." << G4endl;
  } else {
    commandTree->ListCurrent();
  }
}

References G4VBasicShell::FindDirectory(), G4cout, G4endl, G4VBasicShell::GetCurrentWorkingDirectory(), G4UIcommandTree::ListCurrent(), and G4StrUtil::strip_copy().

Referenced by G4VBasicShell::ApplyShellCommand(), G4UIterminal::GetCommand(), and GetCommand().

ModifyPath()

G4String G4VBasicShell::ModifyPath ( const G4String &  tempPath ) const

privateinherited

Definition at line 124 of file G4VBasicShell.cc.

{
  if( tempPath.length() == 0 ) return tempPath;
 
  G4String newPath = "";
 
  // temporal full path
  if( tempPath[0] == '/') newPath = tempPath;
  else newPath = currentDirectory + tempPath;
 
  // body of path...
  while(1){
    size_t idx = newPath.find("/./");
    if( idx == G4String::npos) break;
    newPath.erase(idx,2);
  }
 
  while(1) {
    size_t idx = newPath.find("/../");
    if( idx == G4String::npos) break;
    if( idx == 0) {
      newPath.erase(1,3);
      continue;
    }
    size_t idx2 = newPath.find_last_of('/', idx-1);
    if(idx2 != G4String::npos) newPath.erase(idx2, idx-idx2+3);
  }
 
  // end of path...
  if ( newPath.size() >= 3 ) {
    if(newPath.substr(newPath.size()-3,3) == "/..") {
      if( newPath.size() == 3) {
        newPath = "/";
      } else {
        size_t idx = newPath.find_last_of('/', newPath.size()-4);
        if(idx != G4String::npos) newPath.erase(idx+1);
      }
    }
  }
 
  if ( newPath.size() >= 2 ) {
    if(newPath.substr(newPath.size()-2,2) == "/.") newPath.erase(newPath.size()-1,1);
  }
 
  // truncate "/////" to "/"
  while(1) {
    size_t idx = newPath.find("//");
    if( idx == G4String::npos) break;
    newPath.erase(idx,1);
  }
 
  return newPath;
}

References G4VBasicShell::currentDirectory.

Referenced by G4VBasicShell::ChangeDirectory(), G4VBasicShell::Complete(), G4VBasicShell::FindCommand(), G4VBasicShell::FindDirectory(), and G4VBasicShell::ModifyToFullPathCommand().

ModifyToFullPathCommand()

G4String G4VBasicShell::ModifyToFullPathCommand ( const char *  aCommandLine ) const

protectedinherited

Definition at line 47 of file G4VBasicShell.cc.

{
  G4String rawCommandLine = aCommandLine;
  if(rawCommandLine.empty()||rawCommandLine[0]=='\0') return rawCommandLine;
  G4String commandLine = G4StrUtil::strip_copy(rawCommandLine);
  G4String commandString;
  G4String parameterString;
  size_t i = commandLine.find(" ");
  if( i != std::string::npos )
  {
    commandString = commandLine.substr(0,i);
    parameterString = " ";
    parameterString += commandLine.substr(i+1,commandLine.length()-(i+1));
  }
  else
  { commandString = commandLine; }
 
  G4String fullPathCommandLine
    = ModifyPath( commandString )+parameterString;
  return fullPathCommandLine;
}

References G4VBasicShell::ModifyPath(), and G4StrUtil::strip_copy().

Referenced by G4UIQt::ActivateCommand(), G4VBasicShell::ApplyShellCommand(), G4UIterminal::GetCommand(), GetCommand(), G4VBasicShell::ShowCurrent(), and G4VBasicShell::TerminalHelp().

PauseSessionStart()

void G4ZMQServer::PauseSessionStart ( const G4String &  message )

virtual

Implements G4VBasicShell.

Definition at line 174 of file G4ZMQServer.cc.

{
}

ReceiveG4cerr()

G4int G4ZMQServer::ReceiveG4cerr ( const G4String &  cerrString )

virtual

Reimplemented from G4UIsession.

Definition at line 191 of file G4ZMQServer.cc.

{
  if ( qdebug_ ) {
    std::cerr << cerrString << std::flush;
  }
 
  ::cout_stream << cerrString << std::flush;
 
  return 0;
}

References anonymous_namespace{G4ZMQServer.cc}::cout_stream, and qdebug_.

ReceiveG4cerr_()

G4int G4coutDestination::ReceiveG4cerr_ ( const G4String &  msg )

inherited

Definition at line 84 of file G4coutDestination.cc.

{
  if(transformersCout.size() > 0)
  {
    G4String m = msg;
    std::for_each(transformersCerr.begin(), transformersCerr.end(),
                  [&m](const Transformer& t) { t(m); }
                  // Call transforming function on message
    );
    return ReceiveG4cerr(m);
  }
  else
  {
    return ReceiveG4cerr(msg);
  }
}

References m, G4coutDestination::ReceiveG4cerr(), G4coutDestination::transformersCerr, and G4coutDestination::transformersCout.

Referenced by G4MasterForwardcoutDestination::ReceiveG4cerr().

ReceiveG4cout()

G4int G4ZMQServer::ReceiveG4cout ( const G4String &  coutString )

virtual

Reimplemented from G4UIsession.

Definition at line 179 of file G4ZMQServer.cc.

{
  if ( qdebug_ ) {
    std::cout << coutString << std::flush;
  }
 
  ::cout_stream << coutString << std::flush;
 
  return 0;
}

References anonymous_namespace{G4ZMQServer.cc}::cout_stream, and qdebug_.

ReceiveG4cout_()

G4int G4coutDestination::ReceiveG4cout_ ( const G4String &  msg )

inherited

Definition at line 62 of file G4coutDestination.cc.

{
  // Avoid copy of string if not necessary
  if(transformersCout.size() > 0)
  {
    G4String m    = msg;
    G4bool result = true;
    for(const auto& el : transformersCout)
    {
      result &= el(m);
      if(!result)
        break;
    }
    return (result ? ReceiveG4cout(m) : 0);
  }
  else
  {
    return ReceiveG4cout(msg);
  }
}

References m, G4coutDestination::ReceiveG4cout(), and G4coutDestination::transformersCout.

Referenced by G4MasterForwardcoutDestination::ReceiveG4cout().

ResetTransformers()

void G4coutDestination::ResetTransformers ( )

virtualinherited

Definition at line 41 of file G4coutDestination.cc.

{
  transformersCout.clear();
  transformersCerr.clear();
}

References G4coutDestination::transformersCerr, and G4coutDestination::transformersCout.

SessionStart()

G4UIsession * G4ZMQServer::SessionStart ( )

virtual

Implements G4VBasicShell.

Definition at line 95 of file G4ZMQServer.cc.

{
  zmq::context_t context(1);
  zmq::socket_t socket( context, ZMQ_REP );
  socket.bind(endpoint_);
 
  enum { kBufferSize = 4096 };
  char buffer[kBufferSize];
 
  while ( ! ::qexit ) {
    if ( qdebug_ ) {
      std::cout << "@@ Waiting..." << std::endl;
    }
 
    // waiting command
    zmq::message_t request;
    G4bool qok = socket.recv(&request);
    if ( qok ==  false ) ::ThrowException("G4ZMQSever: socket recv error");
    auto end_pos = request.size();
    if ( end_pos >= kBufferSize  ) end_pos = kBufferSize - 1;
    std::memcpy(buffer, request.data(), end_pos);
    buffer[end_pos] = '\0';
    std::string cmd_str = buffer;
 
    if ( qdebug_ ) {
      std::cout << "@@ Recv=" << cmd_str << "<<" << std::endl;
    }
 
    // store output & send back response
    ::cout_stream.str("");
 
    if ( cmd_str == "@@ping" ) {
      G4cout << "pong" << G4endl;
 
    } else if ( cmd_str == "@@debug") {
      qdebug_ = true;
      G4cout << "G4ZMQ debug activated" << G4endl;
 
    } else if ( cmd_str == "@@nodebug") {
      qdebug_ = false;
      G4cout << "G4ZMQ debug deactivated" << G4endl;
 
    } else if ( cmd_str == "@@get_command_tree" ) {
      auto cwd_name = GetCurrentWorkingDirectory();
      auto cwd_tree = FindDirectory(cwd_name.c_str());
      ::command_list = "";
      ::GetCommandTree(cwd_tree);
      G4cout << ::command_list << std::flush;
 
    } else if ( cmd_str == "@@get_fullcommand_tree" ) {
      auto root = ::ui_manager-> GetTree();
      ::command_list = "";
      ::GetCommandTree(root);
      G4cout << ::command_list << std::flush;
 
    } else if ( cmd_str == "help" ) {
      G4cout << "help <command>" << G4endl;
 
    } else {
      G4String new_command = GetCommand(cmd_str);
      if ( qdebug_ ) {
        std::cout << ::black_str << "@@ Cmd="
                  << new_command << "<<" << std::endl;
      }
      ExecuteCommand(new_command);
    }
 
    std::string reply = ::cout_stream.str();
    size_t cout_size = reply.size();
    zmq::message_t message(cout_size);
    std::strncpy((char*)message.data(), reply.c_str(), cout_size);
    qok = socket.send(message);
    if ( qok ==  false ) ::ThrowException("G4ZMQServer: socket send error");
  }
 
  return nullptr;
}

References anonymous_namespace{G4ZMQServer.cc}::black_str, buffer, anonymous_namespace{G4ZMQServer.cc}::command_list, g4zmq::context, anonymous_namespace{G4ZMQServer.cc}::cout_stream, endpoint_, ExecuteCommand(), G4VBasicShell::FindDirectory(), G4cout, G4endl, GetCommand(), anonymous_namespace{G4ZMQServer.cc}::GetCommandTree(), G4VBasicShell::GetCurrentWorkingDirectory(), qdebug_, anonymous_namespace{G4ZMQServer.cc}::qexit, g4zmq::socket, anonymous_namespace{G4ZMQServer.cc}::ThrowException(), and anonymous_namespace{G4ZMQServer.cc}::ui_manager.

SetDebug()

void G4ZMQServer::SetDebug ( G4bool  flag )

inline

Definition at line 76 of file G4ZMQServer.hh.

{
  qdebug_ = flag;
}

References qdebug_.

SetEndpoint()

void G4ZMQServer::SetEndpoint ( const G4String &  endpoint )

inline

Definition at line 66 of file G4ZMQServer.hh.

{
  endpoint_ = endpoint;
}

References endpoint_.

ShowCurrent()

void G4VBasicShell::ShowCurrent ( const G4String &  newCommand ) const

protectedinherited

Definition at line 313 of file G4VBasicShell.cc.

{
  G4UImanager* UI = G4UImanager::GetUIpointer();
  if(UI==NULL) return;
  G4String comString = newCommand.substr(1,newCommand.length()-1);
  G4String theCommand = ModifyToFullPathCommand(comString);
  G4String curV = UI->GetCurrentValues(theCommand);
  if( ! curV.empty() ) {
    G4cout << "Current value(s) of the parameter(s) : " << curV << G4endl;
  }
}

References G4cout, G4endl, G4UImanager::GetCurrentValues(), G4UImanager::GetUIpointer(), and G4VBasicShell::ModifyToFullPathCommand().

Referenced by G4VBasicShell::ApplyShellCommand(), G4UIterminal::GetCommand(), and GetCommand().

TerminalHelp()

void G4VBasicShell::TerminalHelp ( const G4String &  newCommand )

protectedinherited

Definition at line 355 of file G4VBasicShell.cc.

{
  G4UImanager* UI = G4UImanager::GetUIpointer();
  if(UI==NULL) return;
  G4UIcommandTree * treeTop = UI->GetTree();
  size_t i = newCommand.find(" ");
  if( i != std::string::npos )
  {
    G4String newValue = newCommand.substr(i+1, newCommand.length()-(i+1));
    G4StrUtil::strip(newValue);
    G4String targetCom = ModifyToFullPathCommand(newValue);
    G4UIcommand* theCommand = treeTop->FindPath(targetCom);
    if( theCommand != NULL )
    {
      theCommand->List();
      return;
    }
    else
    {
      G4cout << "Command <" << newValue << " is not found." << G4endl;
      return;
    }
  }
 
  G4UIcommandTree * floor[10];
  floor[0] = treeTop;
  size_t iFloor = 0;
  size_t prefixIndex = 1;
  G4String prefix = GetCurrentWorkingDirectory();
  while( prefixIndex < prefix.length()-1 )
  {
    size_t ii = prefix.find("/",prefixIndex);
    floor[iFloor+1] =
      floor[iFloor]->GetTree(G4String(prefix.substr(0,ii+1)));
    prefixIndex = ii+1;
    iFloor++;
  }
  floor[iFloor]->ListCurrentWithNum();
  // 1998 Oct 2 non-number input
  while(1){
   //G4cout << G4endl << "Type the number ( 0:end, -n:n level back ) : "<<std::flush;
    G4cout << G4endl << "Type the number ( 0:end, -n:n level back ) : "<<G4endl;
    G4int j;
    if(!GetHelpChoice(j)){
      G4cout << G4endl << "Not a number, once more" << G4endl;
      continue;
    } else if( j < 0 ){
      if( iFloor < (size_t)-j ) iFloor = 0;
      else iFloor += j;
      //iFloor += j;
      //if( iFloor < 0 ) iFloor = 0;
      floor[iFloor]->ListCurrentWithNum();
      continue;
    } else if(j == 0) {
      break;
    } else if( j > 0 ) {
      G4int n_tree = floor[iFloor]->GetTreeEntry();
      if( j > n_tree )
      {
        if( j <= n_tree + floor[iFloor]->GetCommandEntry() )
        {
          floor[iFloor]->GetCommand(j-n_tree)->List();
        }
      }
      else
      {
        floor[iFloor+1] = floor[iFloor]->GetTree(j);
        iFloor++;
        floor[iFloor]->ListCurrentWithNum();
      }
    }
  }
  G4cout << "Exit from HELP." << G4endl << G4endl;
  //G4cout << G4endl;
  ExitHelp();
}

References G4VBasicShell::ExitHelp(), G4UIcommandTree::FindPath(), G4cout, G4endl, G4UIcommandTree::GetCommand(), G4VBasicShell::GetCurrentWorkingDirectory(), G4VBasicShell::GetHelpChoice(), G4UImanager::GetTree(), G4UIcommandTree::GetTree(), G4UIcommandTree::GetTreeEntry(), G4UImanager::GetUIpointer(), G4UIcommand::List(), G4UIcommandTree::ListCurrentWithNum(), G4VBasicShell::ModifyToFullPathCommand(), and G4StrUtil::strip().

Referenced by G4VBasicShell::ApplyShellCommand(), G4UIterminal::GetCommand(), GetCommand(), and G4UIQt::ShowHelpCallback().

Field Documentation

currentDirectory

G4String G4VBasicShell::currentDirectory

privateinherited

Definition at line 101 of file G4VBasicShell.hh.

Referenced by G4VBasicShell::ChangeDirectory(), G4VBasicShell::GetCurrentWorkingDirectory(), and G4VBasicShell::ModifyPath().

endpoint_

G4String G4ZMQServer::endpoint_

private

Definition at line 54 of file G4ZMQServer.hh.

Referenced by G4ZMQServer(), GetEndpoint(), SessionStart(), and SetEndpoint().

ifBatch

G4int G4UIsession::ifBatch = 0

protectedinherited

Definition at line 68 of file G4UIsession.hh.

Referenced by G4UIsession::~G4UIsession().

inSession

G4int G4UIsession::inSession = 0

staticprotectedinherited

Definition at line 67 of file G4UIsession.hh.

Referenced by G4UIsession::G4UIsession(), G4UIsession::InSession(), and G4UIsession::~G4UIsession().

lastRC

G4int G4UIsession::lastRC = 0

protectedinherited

Definition at line 69 of file G4UIsession.hh.

Referenced by G4UIbatch::G4UIbatch(), G4UIsession::GetLastReturnCode(), and G4UIbatch::SessionStart().

masterG4coutDestination

G4coutDestination * G4coutDestination::masterG4coutDestination = nullptr

staticprotectedinherited

Definition at line 88 of file G4coutDestination.hh.

Referenced by G4UIQt::G4UIQt(), G4MasterForwardcoutDestination::ReceiveG4cerr(), G4MasterForwardcoutDestination::ReceiveG4cout(), and G4UIQt::~G4UIQt().

qdebug_

G4bool G4ZMQServer::qdebug_

private

Definition at line 53 of file G4ZMQServer.hh.

Referenced by G4ZMQServer(), ReceiveG4cerr(), ReceiveG4cout(), SessionStart(), and SetDebug().

shell_

G4UItcsh* G4ZMQServer::shell_

private

Definition at line 55 of file G4ZMQServer.hh.

Referenced by G4ZMQServer(), GetCommand(), and ~G4ZMQServer().

transformersCerr

std::vector<Transformer> G4coutDestination::transformersCerr

protectedinherited

Definition at line 94 of file G4coutDestination.hh.

Referenced by G4coutDestination::AddCerrTransformer(), G4coutDestination::ReceiveG4cerr_(), and G4coutDestination::ResetTransformers().

transformersCout

std::vector<Transformer> G4coutDestination::transformersCout

protectedinherited

Definition at line 93 of file G4coutDestination.hh.

Referenced by G4coutDestination::AddCoutTransformer(), G4coutDestination::ReceiveG4cerr_(), G4coutDestination::ReceiveG4cout_(), and G4coutDestination::ResetTransformers().

---

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

• environments/zmq/zmq/G4ZMQServer.hh
• environments/zmq/zmq/G4ZMQServer.cc