Commit 5e4c621e authored by Kento HASEGAWA's avatar Kento HASEGAWA

Merge branch 'comm-resolver' into 'comm'

Merge comm-resolver

See merge request adc2018/adc2018-system!8
parents 2cda9dfe a64ea72d
...@@ -67,7 +67,8 @@ def resolve(): ...@@ -67,7 +67,8 @@ def resolve():
'resolver': client_baseurl, 'resolver': client_baseurl,
'client': client_baseurl, 'client': client_baseurl,
'cputime': data['cputime'], 'cputime': data['cputime'],
'qname': data['qname'] 'qname': data['qname'],
'req_id': data['req_id']
} }
# 結果をホストに返す # 結果をホストに返す
r = requests.post("http://{}/post".format(args['host']), data=res) r = requests.post("http://{}/post".format(args['host']), data=res)
...@@ -90,8 +91,9 @@ def start(): ...@@ -90,8 +91,9 @@ def start():
data = { data = {
'client': request.form['client'], 'client': request.form['client'],
'qname': request.form['qname'], 'qname': request.form['qname'],
'answer': request.form['answer'], 'answer': request.form['solution'],
'cputime': request.form['cputime'] 'cputime': request.form['cputime'],
'req_id': request.form['req_id']
} }
resolve_queue.put(data) resolve_queue.put(data)
...@@ -112,7 +114,7 @@ def stop(): ...@@ -112,7 +114,7 @@ def stop():
ans = {"status": "Nothing queued"} ans = {"status": "Nothing queued"}
else: else:
# pynq_thread.stop() # pynq_thread.stop()
while not resolve_queue.emtpy(): while not resolve_queue.empty():
resolve_queue.get() resolve_queue.get()
ans = {"status": "Stopped"} ans = {"status": "Stopped"}
...@@ -121,8 +123,6 @@ def stop(): ...@@ -121,8 +123,6 @@ def stop():
@app.route("/status") @app.route("/status")
def status(): def status():
# global pynq_thread
res_mes = "" res_mes = ""
if resolve_queue.empty(): if resolve_queue.empty():
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment