New Neutron Velocity Selector simulatin for Quokka.

site_ansto/instrument/TEST_SICS/fakeNVS/SIM_NVS.py

@@ -0,0 +1,53 @@
+#!/usr/bin/python
+# An acceptable state reply looks like this,
+# reply = 'N#SOS#ACCEPT#STATE = BRAKING       #RSPEED= 25476#ASPEED=     0#SSPEED=  0.3#AVETO = nok#PLOSS = 290.2#SPLOS = 25422#TTANG = 0.000#RTEMP = 23.9#WFLOW =  0.1#WINLT = 20.3#WOUTT = 21.0#VACUM = 0.1922#WVALV = clos#VVALV = open#VIBRT = 0.08#BCUUN =  0.0#SDATE = 24.04.2013#STIME = 13:53:10#'
+
+from twisted.internet import reactor, protocol
+
+
+class NVS_Prot(protocol.Protocol):
+  def __init__(self):
+    self.fields = [
+      'state' , 'rspeed', 'aspeed', 'sspeed', 'aveto' , 'ploss' , 'sploss',
+      'ttang' , 'rtemp' , 'wflow' , 'winlt' , 'woutt' , 'vacum' , 'wvalv' ,
+      'vvalv' , 'vibrt' , 'bcuun' , 'sdate' , 'stime'
+    ]
+    self.state = {
+      'state' : {'fname': '#STATE ', 'fval':'BRAKING'},
+      'rspeed': {'fname': '#RSPEED', 'fval': 25476},
+      'aspeed': {'fname': '#ASPEED', 'fval':     0},
+      'sspeed': {'fname': '#SSPEED', 'fval':  0.3},
+      'aveto' : {'fname': '#AVETO ', 'fval': 'nok'},
+      'ploss' : {'fname': '#PLOSS ', 'fval': 290.2},
+      'sploss': {'fname': '#SPLOS ', 'fval': 25422},
+      'ttang' : {'fname': '#TTANG ', 'fval': 0.000},
+      'rtemp' : {'fname': '#RTEMP ', 'fval': 23.9},
+			'wflow' : {'fname': '#WFLOW ', 'fval': 0.1},
+			'winlt' : {'fname': '#WINLT ', 'fval': 20.3},
+			'woutt' : {'fname': '#WOUTT ', 'fval': 21.0},
+			'vacum' : {'fname': '#VACUM ', 'fval': 0.1922},
+			'wvalv' : {'fname': '#WVALV ', 'fval': ' clos'},
+			'vvalv' : {'fname': '#VVALV ', 'fval': ' open'},
+			'vibrt' : {'fname': '#VIBRT ', 'fval': 0.08},
+			'bcuun' : {'fname': '#BCUUN ', 'fval': 0.0},
+			'sdate' : {'fname': '#SDATE ', 'fval': '24.04.2013'},
+			'stime' : {'fname': '#STIME ', 'fval': '13:53:10'}
+    }
+
+  def dataReceived(self, data):
+    print "RECEIVED ", data
+    reply = 'N#SOS#ACCEPT'
+    for k in self.fields:
+      reply += self.state[k]['fname'] + '= ' + str(self.state[k]['fval'])
+    reply += '#'
+    print "REPLY ", reply
+    self.transport.write(reply)
+
+def main():
+  factory = protocol.ServerFactory()
+  factory.protocol = NVS_Prot
+  reactor.listenTCP(60001,factory)
+  reactor.run()
+
+if __name__ == '__main__':
+  main()