pshell_config/sf-op
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Startup

Browse Source
This commit is contained in:
sfop
2017-04-12 14:55:10 +02:00
parent b19b74403e
commit 067f293ce1
6 changed files with 327 additions and 215 deletions
Download Patch File Download Diff File Expand all files Collapse all files
script/Devices/WireScanner.py
+53 -42
View File
@@ -2,35 +2,42 @@ import ch.psi.pshell.epics.Motor
class WireScanInfo(DeviceBase):
def __init__(self, name, prefix):
self.prefix = prefix
def __init__(self, name, prefix):
DeviceBase.__init__(self, name)
self.prefix = prefix
self.nb_cycles = Channel(self.prefix + ":NB_CYCL_SP", 'l')
self.curr_cycl = Channel(self.prefix + ":CURR_CYCL", 'l', callback = self.on_cycle_change)
self.curr_cycl.set_monitored(True)
set_device_alias(self.curr_cycl, "current_cycle")
self.current_cycle = self.curr_cycl.get()
self.status_channels=[]
for s in ("SCANNING", "SCAN_DONE", "INITIALIZING", "INIT_DONE", "ABORTED", "ERROR"):
c = Channel(self.prefix + ":" + s, 'i', callback = self.on_status_change);
c.set_monitored(True)
self.status_channels.append(c)
self.cycles = self.nb_cycles.get()
self.on_status_change(None)
self.initialize()
def on_status_change(self, val):
try:
if self.status_channels[0].get() == 1:
self.setCache("scanning", None)
self.setCache("Scanning " + str(self.current_cycle) + "/" + str(self.cycles), None)
self.setState(State.Busy)
elif self.status_channels[1].get() == 1:
self.setCache( "scan done", None)
self.setCache("Scan done", None)
self.setState(State.Ready)
elif self.status_channels[2].get() == 1:
self.setCache("traveling", None)
self.setState(State.Initializing)
self.setCache("Traveling", None)
self.setState(State.Paused)
elif self.status_channels[3].get() == 1:
self.setCache("at start", None)
self.setCache("At start", None)
self.setState(State.Ready)
elif self.status_channels[4].get() == 1:
self.setCache("abort", None)
self.setCache("Abort", None)
self.setState(State.Ready)
elif self.status_channels[5].get() == 1:
self.setCache("error", None)
self.setCache("Error", None)
self.setState(State.Fault)
else:
pass #All zero, a transition
@@ -38,11 +45,18 @@ class WireScanInfo(DeviceBase):
self.setCache("offline", None)
self.setState(State.Offline)
def doClose(self):
def on_cycle_change(self, val):
#print "Wire scan cycle change: ", val
self.current_cycle = val
self.on_status_change(val)
def doClose(self):
self.nb_cycles.close()
self.curr_cycl.close()
for c in self.status_channels:
c.close()
def newScanInfoDevice(name, prefix):
def newScanInfoDevice(name, prefix):
return WireScanInfo(name, prefix)
@@ -50,19 +64,16 @@ class WireScanner(WireScanInfo):
Selection = [Garage, W1X, W1Y, W2X, W2Y, Foil] = "GARAGE", "W1X", "W1Y", "W2X", "W2Y", "FOIL"
def __init__(self, prefix, sel = None, start=None , end=None, cycles=None, velocity=None, continuous = None):
WireScanInfo.__init__(self, "Wire Scan " + prefix, prefix)
WireScanInfo.__init__(self, "Wire Scan " + prefix, prefix)
self.motor = ch.psi.pshell.epics.Motor("WireScanner motor", self.prefix + ":MOTOR_1")
self.motor.uploadConfig()
self.motor.initialize()
self.motor_bs_readback = Channel(self.prefix + ":ENC_1_BS")
self.motor_bs_readback = Channel(self.prefix + ":ENC_1_BS") #, callback = self.on_readback_change)
#self.motor_bs_readback.set_monitored(True)
self.wire_velocity = Channel(self.prefix + ":SCAN_VELO_SP") #wire coordinates
self.motor_velocity = Channel(self.prefix + ":SCAN_M_VELO") #motor coordinates
self.travel_velocity = Channel(self.prefix + ":TRAVEL_VELO_SP") #motor coordinates
self.nb_cycles = Channel(self.prefix + ":NB_CYCL_SP", 'l')
self.curr_cycl = Channel(self.prefix + ":CURR_CYCL", 'l', callback = self.on_cycle_change)
self.curr_cycl.set_monitored(True)
set_device_alias(self.curr_cycl, "current_cycle")
self.wire_sel = Channel(self.prefix + ":WIRE_SP", 'l')
self.current_cycle = self.curr_cycl.get()
self.wire_sel = Channel(self.prefix + ":WIRE_SP", 'l')
self.selection = None
self.u0 = None
self.offset = None
@@ -77,22 +88,22 @@ class WireScanner(WireScanInfo):
self.start.write(float(start))
if end is not None:
self.end.write(float(end))
if cycles is not None:
self.nb_cycles.write(int(cycles))
if velocity is not None:
self.wire_velocity.write(float(velocity))
if cycles is not None:
self.nb_cycles.write(int(cycles))
if continuous is not None:
caputq(self.prefix + ":SCAN_MODE_SP", 0 if continuous else 1)
self.readback = self.motor_bs_readback.get()
self.cycles = self.nb_cycles.get()
self.velocity = self.wire_velocity.get()
self.scan_range = [self.start.get(), self.end.get()]
self.initialize()
def on_cycle_change(self, val):
#print "Wire scan cycle change: ", val
self.current_cycle = val
#def on_readback_change(self, val):
# self.readback = val
def set_selection(self, sel):
if not sel in WireScanner.Selection:
raise Exception("Invalid Wire Scan selection: " + str(sel))
@@ -104,6 +115,19 @@ class WireScanner(WireScanInfo):
self.end = Channel(self.prefix + ":" + self.selection + "_END_SP")
self.wire_sel.put(WireScanner.Selection.index(sel))
def abort(self):
caputq(self.prefix + ":ABORT.PROC", 1)
def init(self):
caputq(self.prefix + ":INIT.PROC", 1)
def park(self):
caputq(self.prefix + ":GARAGE_SEL.PROC", 1)
def scan(self):
self.cycles = self.nb_cycles.get()
caputq(self.prefix + ":SCAN_WIRE", 1)
def doClose(self):
WireScanState.doClose(self)
self.motor.close()
@@ -111,15 +135,13 @@ class WireScanner(WireScanInfo):
self.wire_velocity.close()
self.motor_velocity.close()
self.travel_velocity.close()
self.nb_cycles.close()
self.curr_cycl.close()
self.wire_sel.close()
if self.u0 is not None: self.u0.close()
if self.offset is not None: self.offset.close()
if self.range is not None: self.range.close()
if self.start is not None: self.start.close()
if self.end is not None: self.end.close()
"""
def get_cicle_time(self):
range = abs(self.start.get() -self.end.get())
speed = self.motor_velocity.get()
@@ -127,21 +149,10 @@ class WireScanner(WireScanInfo):
def get_total_time(self):
return self.get_cicle_time() * self.cycles
def abort(self):
caputq("SINDI01-DWSC090:ABORT.PROC", 1)
def init(self):
caputq("SINDI01-DWSC090:INIT.PROC", 1)
def park(self):
caputq("SINDI01-DWSC090:GARAGE_SEL.PROC", 1)
def scan(self):
self.cycles = self.nb_cycles.get()
caputq("SINDI01-DWSC090:SCAN_WIRE", 1)
"""