110 lines
3.1 KiB
Python
110 lines
3.1 KiB
Python
is_panel = get_exec_pars().source != CommandSource.ui #Must be checked before callin "run"
|
|
run("Devices/Elements")
|
|
run("Devices/WireScanner")
|
|
|
|
#BPM_SENSORS = {"x":"X1", "y":"Y1", "q":"Q1"}
|
|
BPM_SENSORS = {"x":"X1"}
|
|
|
|
if is_panel:
|
|
prefix = args[0]
|
|
sel = args[1]
|
|
start = args[2]
|
|
end = args[3]
|
|
cycles = args[4]
|
|
velocity = args[5]
|
|
bpm3 = args[6]
|
|
else:
|
|
prefix = "S30CB09-DWSC440" #"SARCL02-DWSC270" # "SINDI01-DWSC090" #"SARCL02-DWSC270"
|
|
sel = WireScanner.W1X
|
|
start = -200
|
|
end = 200
|
|
cycles = 5
|
|
velocity = 200
|
|
bpm3 = None
|
|
|
|
print prefix, sel, start, end, cycles, cycles, bpm3
|
|
#Creating WireScanner object
|
|
if prefix not in get_wire_scans():
|
|
raise Exception("Invalid wire scan: " + prefix)
|
|
scanner = WireScanner(prefix, sel, start, end, cycles, velocity, True)
|
|
scanner.init()
|
|
scanner.waitValue("At start", 60000)
|
|
|
|
#Stream channels
|
|
bs_position = scanner.motor_bs_readback.get_name()
|
|
bpms = get_wire_scans_bpms(prefix)
|
|
if bpms is None:
|
|
raise Exception("Cannot determine wire scan bpms: " + prefix)
|
|
channels = [("w_pos", scanner.motor_bs_readback.get_name()),
|
|
("cur_cycle", scanner.curr_cycl.get_name()),
|
|
("scanning", scanner.status_channels[0].get_name())]
|
|
if bpm3 is not None:
|
|
bpms.append(bpm3)
|
|
|
|
bpms = ["SINDI01-DBPM060", "SINDI02-DBPM010"]
|
|
for i in range (len(bpms)):
|
|
for sensor in BPM_SENSORS.keys():
|
|
channels.append (("bpm" + str(i+1) + "_" + sensor, bpms[i] + ":" + BPM_SENSORS[sensor]))
|
|
channels.append (("timer", "SINDI01-RLLE-STA:SLAVE1-CPUTIMER"))
|
|
|
|
#Stream creation
|
|
st = Stream("pulse_id", dispatcher)
|
|
#st.setFilter(scanner.status_channels[0].get_name() + ">0") #Not used because we must the reansition to know when the finished
|
|
scanner.curr_cycl.write(0)
|
|
st.setFilter(scanner.curr_cycl.get_name() + ">0")
|
|
for c in channels:
|
|
print c[1]
|
|
st.addScalar(c[0], c[1], 10, 0)
|
|
st.initialize()
|
|
st.start()
|
|
st.waitCacheChange(10000)
|
|
scanner.scan()
|
|
scanner.waitState(State.Busy, 60000)
|
|
|
|
#End of scan checking
|
|
scan_complete=False
|
|
cur_cycle = scanner.curr_cycl.get()
|
|
def check_end_scan(record, scan):
|
|
global scan_complete
|
|
global cur_cycle
|
|
#print record[1] ,scanner.readback
|
|
if record[3]<1:
|
|
print "Data aquisition completed"
|
|
scan_complete=True
|
|
scan.abort()
|
|
elif record[2] != cur_cycle:
|
|
print "New step"
|
|
print cur_cycle, record[2]
|
|
cur_cycle = record[2]
|
|
scan.abort()
|
|
scan.start()
|
|
|
|
#Metadata
|
|
def write_metadata(path):
|
|
try:
|
|
set_attribute(path, "Wire Scan", prefix)
|
|
set_attribute(path, "Selection", sel)
|
|
set_attribute(path, "Range", scaner.scan_range)
|
|
set_attribute(path, "Cycles", scanner.cycles )
|
|
set_attribute(path, "Velocity", scanner.velocity )
|
|
except:
|
|
pass
|
|
#Scan
|
|
try:
|
|
mscan (st, st.getReadables(), -1, -1, after_read = check_end_scan)
|
|
except:
|
|
if not scanner.isReady():
|
|
print "Aborting Wire Scan"
|
|
scanner.abort()
|
|
if not scan_complete:
|
|
raise
|
|
finally:
|
|
write_metadata(get_exec_pars().scanPath)
|
|
print "Closing scanner"
|
|
scanner.close()
|
|
st.close()
|
|
|
|
|
|
|
|
|