Classes | |
class | ConnInfo |
Functions | |
def | is_allowed_ip (ip) |
def | pop_old_conns (q) |
def | nConns (d) |
def | pop_fronts (d) |
def | get_tag () |
def | is_complete_query (msg) |
def | ok200 () |
def | ok200_html () |
def | unimp501 () |
def | status_text () |
def | handle_status (client, args) |
def | handle_releases (client, args) |
def | handle_backlog (client, args) |
def | handle_ids (client, args) |
def | handle_status_html (client, args) |
def | failsafe_arg (cmd, args, name) |
def | handle_get_work (client, args) |
def | handle_return_results (client, args, postdata) |
def | handle_pid (client, args, postdata) |
def | handle_query (sockStr, client) |
def | startup (port) |
def | close_old_connections () |
def | shed_load () |
Variables | |
int | gVerbosity = 0 |
list | gIPWhitelist |
gPIDQueue = defaultdict(deque) | |
gGetWorkQueue = defaultdict(deque) | |
dictionary | gWorkInProgress = {} |
dictionary | gClientMap = {} |
int | gSeqNo = 0 |
int | gErrCount = 0 |
int | gBusyTime = 0 |
int | gIdleTime = 0 |
gIdList = defaultdict(lambda: 0) | |
dictionary | gClientList = {} |
dictionary | gWorkerList = {} |
int | gLastSeqNo = 0 |
gLastStatus = time.time() | |
int | kMinPort = 1024 |
int | kMaxPort = 1031 |
int | kNumPorts = kMaxPort-kMinPort+1 |
list | serverSock = [startup(port) for port in range(kMinPort, kMaxPort+1)] |
ep = select.epoll() | |
dictionary | socketMap = {} |
inbox = defaultdict(lambda: '') | |
outbox = defaultdict(lambda: '') | |
statusTime = time.time() | |
t1 = time.time() | |
t2 = time.time() | |
events = ep.poll(60) | |
fileno | |
mask | |
ss = socketMap[fileno] | |
clientSock | |
addr | |
cs = gClientMap[fileno] | |
x = cs.recv(4096) | |
msgs = handle_query(inbox[cs], cs) | |
msg = outbox[cs] | |
n = cs.send(msg) | |
def lem_server.close_old_connections | ( | ) |
def lem_server.failsafe_arg | ( | cmd, | |
args, | |||
name | |||
) |
Definition at line 299 of file lem_server.py.
Referenced by handle_backlog(), handle_get_work(), handle_pid(), and handle_return_results().
def lem_server.get_tag | ( | ) |
Definition at line 141 of file lem_server.py.
References makeTrainCVSamples.int, and submit_syst.str.
Referenced by handle_get_work(), and handle_pid().
def lem_server.handle_backlog | ( | client, | |
args | |||
) |
Definition at line 257 of file lem_server.py.
References failsafe_arg(), ok200(), and submit_syst.str.
def lem_server.handle_get_work | ( | client, | |
args | |||
) |
Definition at line 306 of file lem_server.py.
References append(), failsafe_arg(), get_tag(), min(), ok200(), and unimp501().
def lem_server.handle_ids | ( | client, | |
args | |||
) |
def lem_server.handle_pid | ( | client, | |
args, | |||
postdata | |||
) |
Definition at line 358 of file lem_server.py.
References append(), failsafe_arg(), get_tag(), ok200(), and unimp501().
def lem_server.handle_query | ( | sockStr, | |
client | |||
) |
def lem_server.handle_releases | ( | client, | |
args | |||
) |
def lem_server.handle_return_results | ( | client, | |
args, | |||
postdata | |||
) |
Definition at line 336 of file lem_server.py.
References failsafe_arg(), ok200(), and unimp501().
def lem_server.handle_status | ( | client, | |
args | |||
) |
def lem_server.handle_status_html | ( | client, | |
args | |||
) |
Definition at line 292 of file lem_server.py.
References ok200_html(), and status_text().
def lem_server.is_allowed_ip | ( | ip | ) |
Definition at line 63 of file lem_server.py.
def lem_server.is_complete_query | ( | msg | ) |
def lem_server.nConns | ( | d | ) |
Definition at line 93 of file lem_server.py.
References sum.
Referenced by shed_load(), and status_text().
def lem_server.ok200 | ( | ) |
Definition at line 172 of file lem_server.py.
Referenced by handle_backlog(), handle_get_work(), handle_ids(), handle_pid(), handle_releases(), handle_return_results(), and handle_status().
def lem_server.ok200_html | ( | ) |
def lem_server.pop_fronts | ( | d | ) |
def lem_server.pop_old_conns | ( | q | ) |
def lem_server.shed_load | ( | ) |
Definition at line 488 of file lem_server.py.
References nConns(), and pop_fronts().
def lem_server.startup | ( | port | ) |
Definition at line 453 of file lem_server.py.
def lem_server.status_text | ( | ) |
Definition at line 199 of file lem_server.py.
References makeTrainCVSamples.int, nConns(), and submit_syst.str.
Referenced by handle_status(), and handle_status_html().
def lem_server.unimp501 | ( | ) |
Definition at line 188 of file lem_server.py.
Referenced by handle_get_work(), handle_pid(), handle_query(), and handle_return_results().
lem_server.addr |
Definition at line 573 of file lem_server.py.
lem_server.clientSock |
Definition at line 573 of file lem_server.py.
lem_server.cs = gClientMap[fileno] |
Definition at line 582 of file lem_server.py.
Referenced by evd::RecoBaseDrawer.DimOutOfTime(), tdslicer::TDSlicer.FillDists(), ana::PredictionInterp.FitRatios(), GausFit(), evdb::ColorScale.Palette(), plot_times(), tdslicer::TDSlicer.produce(), evdb::Colors.reconfigure(), evdb::Colors.Scale(), evdb::ColorScale.Scale(), lem::DistanceMap.SetCellScale(), calib::ThresholdCorrMap.ThresholdCorrMap(), evdb::Colors.UnpackColorScale(), VarContainer.VarContainer(), VarContainer2D.VarContainer2D(), and VarContainer3D.VarContainer3D().
lem_server.ep = select.epoll() |
Definition at line 529 of file lem_server.py.
Referenced by art::detail::Analyzer.Analyzer(), skim::CellHitSkimmer.endRun(), jmshower::RecoJMShower.GetCellTransDedx(), jmshower::RecoJMShower.GetPlaneDedx(), art::MixOp< Prod, OProd >.mixAndPut(), caf::CAFMaker.produce(), art::RandomNumberGenerator.restoreSnapshot_(), BrightnessModelPlots.ScheduleSamples(), MEUPerDiblock.ScheduleSamples(), MEUPerFEB.ScheduleSamples(), MEUPerCell.ScheduleSamples(), ValidCalibPDF.ScheduleSamples(), ValidCalibPDF.SetEpochList(), and genie::NuElectronPXSec.XSec().
lem_server.events = ep.poll(60) |
Definition at line 559 of file lem_server.py.
lem_server.fileno |
Definition at line 564 of file lem_server.py.
int lem_server.gBusyTime = 0 |
Definition at line 129 of file lem_server.py.
dictionary lem_server.gClientList = {} |
Definition at line 135 of file lem_server.py.
dictionary lem_server.gClientMap = {} |
Definition at line 122 of file lem_server.py.
int lem_server.gErrCount = 0 |
Definition at line 127 of file lem_server.py.
lem_server.gGetWorkQueue = defaultdict(deque) |
Definition at line 112 of file lem_server.py.
int lem_server.gIdleTime = 0 |
Definition at line 130 of file lem_server.py.
lem_server.gIdList = defaultdict(lambda: 0) |
Definition at line 132 of file lem_server.py.
list lem_server.gIPWhitelist |
Definition at line 45 of file lem_server.py.
int lem_server.gLastSeqNo = 0 |
Definition at line 197 of file lem_server.py.
lem_server.gLastStatus = time.time() |
Definition at line 198 of file lem_server.py.
lem_server.gPIDQueue = defaultdict(deque) |
Definition at line 106 of file lem_server.py.
int lem_server.gSeqNo = 0 |
Definition at line 125 of file lem_server.py.
int lem_server.gVerbosity = 0 |
Definition at line 42 of file lem_server.py.
dictionary lem_server.gWorkerList = {} |
Definition at line 136 of file lem_server.py.
dictionary lem_server.gWorkInProgress = {} |
Definition at line 119 of file lem_server.py.
lem_server.inbox = defaultdict(lambda: '') |
Definition at line 535 of file lem_server.py.
int lem_server.kMaxPort = 1031 |
Definition at line 522 of file lem_server.py.
int lem_server.kMinPort = 1024 |
Definition at line 521 of file lem_server.py.
Definition at line 523 of file lem_server.py.
lem_server.mask |
Definition at line 564 of file lem_server.py.
Referenced by genie::GHepRecord.Accept(), ana::FileReducer.AccumulateExposures(), calhit::RemoveBadChannels.beginRun(), calhit::CalHit.beginRun(), caf::CAFMaker.beginRun(), calhit::RemoveBadChannels.beginSubRun(), calhit::CalHit.beginSubRun(), caf::CAFMaker.beginSubRun(), daqdataformats::VERSION_NAMESPACE::RawTriggerMask.init(), ana.LogLikelihood(), novaddt::HotMapMaker.MakeMask(), maskify(), novaddt.nbitMask(), nova::dbi::RunHistoryService.preBeginRun(), nova::dbi::RunHistoryService.preBeginSubrun(), daqdataformats::VERSION_NAMESPACE::RawTrigger.print(), nova::dbi::Table.SetDataTypeMask(), nutools::dbi::Table.SetDataTypeMask(), nova::dbi::RunHistory.SetSubrunDiBlockMask(), genie::GMCJDriver.SetUnphysEventMask(), genie::GEVGDriver.SetUnphysEventMask(), genie::GHepRecord.SetUnphysEventMask(), evdb::ParameterSetEditRow.SetupCheckButton(), daqdataformats::VERSION_NAMESPACE::RawNanoSlice.setValue1(), rawdata::RawTrigger.TDCT0(), and genie::GHepRecord.Vertex().
Definition at line 603 of file lem_server.py.
Referenced by ana::CovMxManager.AddSystematic(), novaddt::SendTriggerSignal.analyze(), novaddt::SupernovaTrigger.filter(), daqdataformats::RawDAQData.generateExceptionForWrongVersion(), daqdataformats::RawMicroSlice.getNumNanoSlices(), dbutils::gui::ConfigDataTreeModel.headerData(), daqdataformats::VERSION_NAMESPACE::RawTriggerMask.init(), gov::fnal::cd::rms::RmsProducer.initialize(), main(), cet::ostream_handle.operator<<(), art::Tracer.preBeginRun(), art::Tracer.preBeginSubRun(), art::Tracer.preEndRun(), art::Tracer.preEndSubRun(), art::Tracer.preEvent(), nl::timing::LogFile.ProcessLog(), cet::sqlite.query(), daqdataformats::RawMicroSlice.RawMicroSlice(), gov::fnal::cd::rms::RmsConsumer.RmsConsumer(), gov::fnal::cd::rms::RmsReceiver< CONN, MSG, LSTNR >.RmsReceiver(), gov::fnal::cd::rms::RmsSender< C, M >.RmsSender(), dbutils::gui::BasicEditorDisplay.saveChangesWithNewName(), genie::PhysInteractionSelector.SelectInteraction(), gov::fnal::cd::rms::base::RmsDestination.setProperty(), daqdataformats::RawMicroSlice.setVersion(), art::Source< T >.throwDataCorruption_(), tf.TimingFitErrorHandler(), VerticalSlice(), and warp_meta().
lem_server.msgs = handle_query(inbox[cs], cs) |
Definition at line 596 of file lem_server.py.
lem_server.n = cs.send(msg) |
Definition at line 604 of file lem_server.py.
lem_server.outbox = defaultdict(lambda: '') |
Definition at line 536 of file lem_server.py.
Definition at line 525 of file lem_server.py.
dictionary lem_server.socketMap = {} |
Definition at line 530 of file lem_server.py.
Definition at line 572 of file lem_server.py.
lem_server.statusTime = time.time() |
Definition at line 538 of file lem_server.py.
lem_server.t1 = time.time() |
Definition at line 540 of file lem_server.py.
lem_server.t2 = time.time() |
Definition at line 541 of file lem_server.py.
lem_server.x = cs.recv(4096) |
Definition at line 585 of file lem_server.py.