From c3e162c114ff1fef46c9a7eb1893db207bda263c Mon Sep 17 00:00:00 2001
From: mer0m <baptiste.marechal@femto-st.fr>
Date: Sat, 3 Jun 2017 09:21:38 +0200
Subject: [PATCH] add AG53230A frequency counter

---
 instruments/AG53230A.py | 72 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 72 insertions(+)
 create mode 100644 instruments/AG53230A.py

diff --git a/instruments/AG53230A.py b/instruments/AG53230A.py
new file mode 100644
index 0000000..403baa2
--- /dev/null
+++ b/instruments/AG53230A.py
@@ -0,0 +1,72 @@
+from abstract_instrument import abstract_instrument
+import socket
+
+#==============================================================================
+
+ALL_VAL_TYPE = ['FREQ']
+ALL_CHANNELS = ['1']
+
+ADDRESS = "192.168.0.74"
+CONF_VAL_TYPE = ['CONF:FREQ']
+
+#==============================================================================
+
+class AG53230A(abstract_instrument):
+    def __init__(self, channels, vtypes, address):
+        self.address = address
+        self.port = 5025
+        self.channels = channels
+        self.vtypes = vtypes
+
+    def model(self):
+        #self.send("*IDN?")
+        #return self.read()
+        return "AG53230A"
+
+    def connect(self):
+        print('Connecting to device @%s:%s...' %(self.address, self.port))
+        self.sock = socket.socket(socket.AF_INET,
+                             socket.SOCK_STREAM,
+                             socket.IPPROTO_TCP)
+        self.sock.settimeout(10.0)    # Don't hang around forever
+        self.sock.connect((self.address, self.port))
+        self.send("SYST:BEEP")
+        print('  --> Ok')
+        print(self.model())
+        self.configure()
+
+    def configure(self):
+        for ch in self.channels:
+            self.send(CONF_VAL_TYPE[ALL_VAL_TYPE.index(self.vtypes[self.channels.index(ch)])])
+
+    def getValue(self):
+        mes = ''
+        for ch in self.channels:
+            self.send("READ?")
+            mesTemp = self.read()
+            mes = mes + '\t' + mesTemp
+        return mes
+
+    def read(self):
+        ans = ''
+        nb_data_list = []
+        nb_data = ''
+        try:
+            while ans != '\n':
+                ans = self.sock.recv(1)
+                nb_data_list.append(ans) # Return the number of data
+            list_size = len(nb_data_list)
+            for j in range (0, list_size):
+                nb_data = nb_data+nb_data_list[j]
+            return nb_data
+        except socket.timeout:
+            print "Socket timeout error when reading."
+            raise
+
+    def disconnect(self):
+        self.send('*RST')
+        self.send("SYST:BEEP")
+        self.sock.close()
+
+    def send(self, command):
+        self.sock.send("%s\n"%command)
-- 
2.16.4