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
	dbsInst
	host
	input
	optManager
	opts
	port
	result

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.

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
#

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

Variable Documentation

args

query.args

Definition at line 119 of file query.py.

dbsInst

query.dbsInst

Definition at line 117 of file query.py.

host

query.host

Definition at line 115 of file query.py.

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

input

query.input

Definition at line 132 of file query.py.

optManager

query.optManager

Definition at line 118 of file query.py.

opts

query.opts

Definition at line 119 of file query.py.

port

query.port

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

query.result

Definition at line 138 of file query.py.