query Namespace Reference

Classes
class	DDOptionParser

Functions
def	sendMessage (host, port, dbsInst, userInput, page, limit, xml=0, case='on', iface='dd', details=0, cff=0, debug=0)

Variables
	args
string	dbsInst = "cms_dbs_prod_global"
string	host = "cmsweb.cern.ch/dbs_discovery/"
	input = open(opts.input,'r').readline()
	optManager = DDOptionParser()
	opts
int	port = 443
def	result = sendMessage(host,port,dbsInst,input,opts.page,opts.limit,opts.xml,opts.case,opts.iface,opts.details,opts.cff,opts.verbose)

Function Documentation

sendMessage()

def query.sendMessage	(		host,
			port,
			dbsInst,
			userInput,
			page,
			limit,
			xml = 0,
			case = 'on',
			iface = 'dd',
			details = 0,
			cff = 0,
			debug = 0
	)

   Send message to server, message should be an well formed XML document.

Definition at line 52 of file query.py.

References createfilelist.int, join(), print(), fileinputsource_cfi.read, python.rootplot.root2matplotlib.replace(), and str.

def sendMessage(host,port,dbsInst,userInput,page,limit,xml=0,case='on',iface='dd',details=0,cff=0,debug=0):
    """
       Send message to server, message should be an well formed XML document.
    """
    if xml: xml=1
    else:   xml=0
    if cff: cff=1
    else:   cff=0
    input=urllib.quote(userInput)
    if debug:
       httplib.HTTPConnection.debuglevel = 1
       print("Contact",host,port)
    _port=443
    if host.find("http://")!=-1:
       _port=80
    if host.find("https://")!=-1:
       _port=443
    host=host.replace("http://","").replace("https://","")
    if host.find(":")==-1:
       port=_port
    prefix_path=""
    if host.find("/")!=-1:
       hs=host.split("/")
       host=hs[0]
       prefix_path='/'.join(hs[1:])
    if host.find(":")!=-1:
       host,port=host.split(":")
    port=int(port)
#    print "\n\n+++",host,port
    if port==443:
       http_conn = httplib.HTTPS(host,port)
    else:
       http_conn = httplib.HTTP(host,port)
    if details: details=1
    else:       details=0
    path='/aSearch?dbsInst=%s&html=0&caseSensitive=%s&_idx=%s&pagerStep=%s&userInput=%s&xml=%s&details=%s&cff=%s&method=%s'%(dbsInst,case,page,limit,input,xml,details,cff,iface)
    if prefix_path:
       path="/"+prefix_path+path[1:]
    http_conn.putrequest('POST',path)
    http_conn.putheader('Host',host)
    http_conn.putheader('Content-Type','text/html; charset=utf-8')
    http_conn.putheader('Content-Length',str(len(input)))
    http_conn.endheaders()
    http_conn.send(input)

    (status_code,msg,reply)=http_conn.getreply()
    data=http_conn.getfile().read()
    if debug or msg!="OK":
       print()
       print(http_conn.headers)
       print("*** Send message ***")
       print(input)
       print("************************************************************************")
       print("status code:",status_code)
       print("message:",msg)
       print("************************************************************************")
       print(reply)
    return data

#
# main
#

Variable Documentation

args

query.args

Definition at line 119 of file query.py.

dbsInst

query.dbsInst = "cms_dbs_prod_global"

Definition at line 117 of file query.py.

host

string query.host = "cmsweb.cern.ch/dbs_discovery/"

Definition at line 115 of file query.py.

Referenced by edm::service::SiteLocalConfigService.computeStatisticsDestination(), DTCtcp.Connect(), emtf::phase2::data::Zone.contains(), DQMService.DQMService(), EcalTPGParamReaderFromDB.EcalTPGParamReaderFromDB(), dqm::DQMFileSaverPB.fillJson(), dqmfilesaver.fillJson(), XrdAdaptor::Source.getDomain(), XrdAdaptor::Source.getHostname(), popcon::RpcDataV.getNewObjects(), popcon::RPCObPVSSmapData.getNewObjects(), popcon::RpcDataI.getNewObjects(), popcon::RpcDataS.getNewObjects(), popcon::RpcDataUXC.getNewObjects(), popcon::RpcDataT.getNewObjects(), popcon::RpcObGasData.getNewObjects(), popcon::RpcDataFebmap.getNewObjects(), popcon::RpcDataGasMix.getNewObjects(), emtf::phase2::data::TimeZoneLut.getTimezones(), emtf::phase2::data::ZoneLut.getZones(), CSCGeometryESModule.initCSCGeometry_(), DQMNet.listenToCollector(), EcalSeverityLevelESProducer.produce(), RPCInverseCPPFLinkMapESProducer.produce(), EcalNextToDeadChannelESProducer.produce(), RPCInverseTwinMuxLinkMapESProducer.produce(), RPCInverseLBLinkMapESProducer.produce(), RPCInverseOMTFLinkMapESProducer.produce(), EcalLaserCorrectionService.produce(), EcalLaserCorrectionServiceMC.produce(), HcalDbProducer.produce(), HcalTPGCoderULUT.produce(), CastorDbProducer.produce(), CSCGeometryESModule.produce(), DTGeometryESModule.produce(), edmtest::ESTestProducerBUsingHost.produce(), DTGeometryESProducer.produce(), FFTJetLookupTableESProducer< CT >.produce(), FFTJetCorrectionESProducer< CT >.produce(), TestAlpakaHostDeviceCompare.require(), HcalDbProducer.serviceSetData(), DTGeometryESModule.setupDBGeometry(), DTGeometryESModule.setupDD4hepGeometry(), DTGeometryESModule.setupDDDGeometry(), DTGeometryESProducer.setupGeometry(), HcalDbProducer::ServiceTokenImpl< ProductType, RecordType, LABEL, EffectiveType >.setupHcalDbService(), HcalDbProducer::TokensForServiceHolder< RecordType, TokenHolders >.setupHcalDbService(), and DQMNet.updateToCollector().

input

query.input = open(opts.input,'r').readline()

Definition at line 132 of file query.py.

optManager

query.optManager = DDOptionParser()

Definition at line 118 of file query.py.

opts

query.opts

Definition at line 119 of file query.py.

port

int query.port = 443

Definition at line 116 of file query.py.

Referenced by edm::service::SiteLocalConfigService.computeStatisticsDestination(), DQMService.DQMService(), EcalTPGParamReaderFromDB.EcalTPGParamReaderFromDB(), DQMNet.listenToCollector(), HCAL_HLX::TCPReceiver.SetPort(), DQMNet.startLocalServer(), HCAL_HLX::TCPReceiver.TCPReceiver(), and DQMNet.updateToCollector().

result

def query.result = sendMessage(host,port,dbsInst,input,opts.page,opts.limit,opts.xml,opts.case,opts.iface,opts.details,opts.cff,opts.verbose)

Definition at line 138 of file query.py.