g4zmq Namespace Reference

Functions
def	connect (endpoint="tcp://127.0.0.1:5555")
def	ping ()
def	debug (dflag)
def	apply (command)
def	execute (command)
def	pwd ()
def	cwd ()
def	cd (dir="")
def	lc (target="")
def	ls (target="")
def	help (target="")
def	history ()
def	beamOn (nevent)
def	getvalue (target="")
def	exit ()

Variables
	charset
	context
	socket

Function Documentation

def g4zmq.apply

(

command

)

Definition at line 38 of file g4zmq.py.

References print.

Referenced by PandAna.reco_validation.prod5_pid_validation.ApplySlcCutsPngDF(), beamOn(), execute(), garching_flux_to_genie_root.main(), genie::flux::GDk2NuFlux.SetApplyWindowTiltWeight(), and genie::flux::GNuMIFlux.SetApplyWindowTiltWeight().

def apply(command) :
  cmd_str= command.encode(charset)
  socket.send(cmd_str)
  output = socket.recv()
  print(output.decode(charset))

def g4zmq.beamOn

(

nevent

)

Definition at line 89 of file g4zmq.py.

References apply(), and runNovaSAM.str.

def beamOn(nevent) :
  cmd = "/run/beamOn " + str(nevent)
  apply(cmd)

def g4zmq.cd

(

dir = ""

)

Definition at line 57 of file g4zmq.py.

References print.

def cd(dir="") :
  cmd = "cd " + dir
  socket.send(cmd.encode(charset))
  output = socket.recv()
  print(output.decode(charset))

def g4zmq.connect

(

endpoint = "tcp://127.0.0.1:5555"

)

Definition at line 15 of file g4zmq.py.

References ping().

Referenced by dbutils::gui::BasicEditorDisplay._addHelpMenu(), dbutils::gui::CustomTabWidget.addTab(), dbutils::gui::BasicEditorDisplay.BasicEditorDisplay(), dbutils::gui::BitmapEditor.BitmapEditor(), dbutils::gui::ConfigSelectionDialog.ConfigSelectionDialog(), dbutils::gui::DAQConfigEditorDisplay.DAQConfigEditorDisplay(), dbutils::gui::DCSConfigEditorDisplay.DCSConfigEditorDisplay(), dbutils::gui::ConfigDataTableEditor.loadData(), dbutils::gui::ConfigDataTreeEditor.loadData(), dbutils::gui::TabbedSetOfTableEditors.TabbedSetOfTableEditors(), dbutils::gui::TabbedSetOfTreeEditors.TabbedSetOfTreeEditors(), dbutils::gui::ConfigDataTreeEditor.updatePopupMenu(), and dbutils::gui::ConfigDataTableEditor.updatePopupMenu().

def connect(endpoint="tcp://127.0.0.1:5555") :
  socket.setsockopt(zmq.LINGER, 0)
  socket.connect(endpoint)
  ping()

def g4zmq.cwd

(

)

Definition at line 52 of file g4zmq.py.

References print.

Referenced by syst_table_fit_new().

def cwd() :
  socket.send(b"cwd")
  output = socket.recv()
  print(output.decode(charset))

def g4zmq.debug

(

dflag

)

Definition at line 30 of file g4zmq.py.

References print.

def debug(dflag) :
  if dflag :
    socket.send(b"@@debug")
  else :
    socket.send(b"@@nodebug")
  output = socket.recv()
  print(output.decode(charset))

def g4zmq.execute

(

command

)

Definition at line 44 of file g4zmq.py.

References apply().

Referenced by cet::SimultaneousFunctionSpawner.SimultaneousFunctionSpawner().

def execute(command) :
  apply(command)

def g4zmq.exit

(

)

Definition at line 99 of file g4zmq.py.

References print.

def exit() :
  socket.send(b"exit")
  output = socket.recv()
  print(output.decode(charset))

# ===============================================================

def g4zmq.getvalue

(

target = ""

)

Definition at line 93 of file g4zmq.py.

References print.

def getvalue(target="") :
  cmd = "?" + target
  socket.send(cmd.encode(charset))
  output = socket.recv()
  print(output.decode(charset))

def g4zmq.help

(

target = ""

)

Definition at line 75 of file g4zmq.py.

References print.

def help(target="") :
  if ( target == "" ) :
    raise SyntaxWarning("*** no command specified.")
  else :
    cmd = "help " + target
    socket.send(cmd.encode(charset))
    output = socket.recv()
    print(output.decode(charset))

def g4zmq.history

(

)

Definition at line 84 of file g4zmq.py.

References print.

Referenced by convert().

def history() :
  socket.send(b"history")
  output = socket.recv()
  print(output.decode(charset))

def g4zmq.lc

(

target = ""

)

Definition at line 63 of file g4zmq.py.

References print.

Referenced by cmap::dataprov::CMap.encodeLChan(), evd::GeometryDrawer.GetDCMBoxes(), rsim::ReadoutSim.produce(), and SetDrawOptions().

def lc(target="") :
  cmd = "lc " + target
  socket.send(cmd.encode(charset))
  output = socket.recv()
  print(output.decode(charset))

def g4zmq.ls

(

target = ""

)

Definition at line 69 of file g4zmq.py.

References print.

Referenced by lem::UnTranspose.beginRun(), lem::FindLEMMatches.beginRun(), lem::LEM.beginRun(), CreatePlots(), ana::CovMxSurface.DrawSurfacePoint(), lem::FindMatchesTranspose.endRun(), stan::io::stan_csv_reader.read_samples(), and ana::SpectrumHandler.SpectrumHandler().

def ls(target="") :
  cmd = "ls " + target
  socket.send(cmd.encode(charset))
  output = socket.recv()
  print(output.decode(charset))

def g4zmq.ping

(

)

Definition at line 20 of file g4zmq.py.

Referenced by connect().

def ping() :
  socket.send(b"@@ping")
  poller = zmq.Poller()
  poller.register(socket, zmq.POLLIN)
  if poller.poll(1*1000) :
    output = socket.recv()
    print ("@@ G4ZMQ server connected.")
  else :
    raise ConnectionError("*** connection timeout")

def g4zmq.pwd

(

)

Definition at line 47 of file g4zmq.py.

References print.

Referenced by nutools::dbi::Table.GetPassword(), nova::dbi::Table.GetPassword(), daq2raw::TestBeamRawInputDriver.readBeamline(), nutools::dbi::Table.Tag(), nova::dbi::Table.Tag(), nutools::dbi::Table.Write(), and nova::dbi::Table.Write().

def pwd() :
  socket.send(b"pwd")
  output = socket.recv()
  print(output.decode(charset))

Variable Documentation

g4zmq.charset

Definition at line 10 of file g4zmq.py.

g4zmq.context

Definition at line 11 of file g4zmq.py.

g4zmq.socket

Definition at line 12 of file g4zmq.py.