Fix Request/Answer queries
This commit is contained in:
4
main.py
4
main.py
@@ -49,14 +49,14 @@ def replication_task():
|
|||||||
filename = '51a8a2c81f774af7bba61b475b4b51b5'
|
filename = '51a8a2c81f774af7bba61b475b4b51b5'
|
||||||
filepath = '/tmp/' + filename
|
filepath = '/tmp/' + filename
|
||||||
response_files = [{'name': filename, 'url': filepath, 'size': os.path.getsize(filepath)}]
|
response_files = [{'name': filename, 'url': filepath, 'size': os.path.getsize(filepath)}]
|
||||||
logging.info('Send replication package')
|
logging.debug('Send replication package')
|
||||||
proxy = ServerProxy('http://127.0.0.1:7000/xmlrpc')
|
proxy = ServerProxy('http://127.0.0.1:7000/xmlrpc')
|
||||||
proxy.send(response_params, response_files, 'http://10.10.8.27:9000/')
|
proxy.send(response_params, response_files, 'http://10.10.8.27:9000/')
|
||||||
|
|
||||||
|
|
||||||
# Expose a function
|
# Expose a function
|
||||||
def list_contents(dir_name):
|
def list_contents(dir_name):
|
||||||
logging.info('list_contents(%s)', dir_name)
|
logging.debug('list_contents(%s)', dir_name)
|
||||||
return os.listdir(dir_name)
|
return os.listdir(dir_name)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user