cco/cybertools
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

make transporter run with dummy XML-RPC API

Browse source 
git-svn-id: svn://svn.cy55.de/Zope3/src/cybertools/trunk@2722 fd906abe-77d9-0310-91a1-e0d9ade77398
This commit is contained in:
helmutm 2008-06-25 15:48:12 +00:00
parent 9db11e8486
commit e76f640529
4 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
agent/system/rpcapi.py
View file

@ -24,7 +24,7 @@ $Id: rpcapi.py
def setup(config): def setup(config):
global xmlrpc global xmlrpc
if config.transportserver.xmlrpc == 'testing': if config.transport.remote.server == 'testing':
from cybertools.agent.testing.rpcserver import RPCServer, xmlrpc from cybertools.agent.testing.rpcserver import RPCServer, xmlrpc
else: else:
from twisted.web import xmlrpc from twisted.web import xmlrpc

2
agent/testing/main_transport.py
View file

@ -70,5 +70,5 @@ if __name__ == '__main__':
master = setup() master = setup()
controller = master.controllers[0] controller = master.controllers[0]
controller.createAgent('transport.remote', 'sample03') controller.createAgent('transport.remote', 'sample03')
controller.enterJob('sample', 'sample03', params=dict(serverURL='', machineName='', method='', userName='', password='')) controller.enterJob('sample', 'sample03', params=dict(resource='xxx'))
startReactor() startReactor()

2
agent/transport/remote.py
View file

@ -53,7 +53,7 @@ class Transporter(QueueableAgent):
def __init__(self, master): def __init__(self, master):
super(Transporter, self).__init__(master) super(Transporter, self).__init__(master)
config = master.config config = master.config
#self.serverURL = params[serverURL] self.serverURL = config.transport.remote.url
self.server = rpcapi.xmlrpc.Proxy(self.serverURL) self.server = rpcapi.xmlrpc.Proxy(self.serverURL)
#self.method = params[method] #self.method = params[method]
#self.machineName = params[machineName] #self.machineName = params[machineName]

3
agent/transport/transporter.txt
View file

@ -8,7 +8,8 @@ Agents for Job Execution and Communication Tasks
... controller(names=['core.sample']) ... controller(names=['core.sample'])
... scheduler(name='core') ... scheduler(name='core')
... logger(name='default', standard=30) ... logger(name='default', standard=30)
... transportserver.xmlrpc = 'testing' ... transport.remote.server = 'testing'
... transport.remote.url = 'http://localhost:8123'
... ''' ... '''
>>> from cybertools.agent.main import setup >>> from cybertools.agent.main import setup
>>> master = setup(config) >>> master = setup(config)