Closedown

This commit is contained in:
gac-x12sa
2023-01-05 14:48:47 +01:00
parent d30c312dae
commit 70b259b9e2
3 changed files with 8 additions and 5 deletions
+5 -2
View File
@@ -33,16 +33,18 @@ class StdDaq(DeviceBase):
else:
self.req_id = self.simulated_id
self.simulated_id=self.simulated_id+1
print "Started request: ", self.req_id
self.setCache(self.req_id, None)
self.setState(State.Busy)
fork (self.monitor)
def stop(self):
def abort(self):
self.state.assertIs(State.Busy)
if not self.simulated:
print "Aborting request: ", self.req_id
data = {"request_id":self.req_id}
headers = {'Content-type': 'application/json'}
r = requests.post(url = self.url + "/write_kill", json=data, headers=headers)
r = requests.post(url = self.url + "/write_kill", json=data, headers=headers)
self.setCache(None, None)
self.setState(State.Ready)
@@ -56,6 +58,7 @@ class StdDaq(DeviceBase):
if not self.simulated:
pass #TODO: Check Status
if done:
print "Finished request: ", self.req_id
self.setCache(None, None)
self.setState(State.Ready)
time.sleep(0.2)