add serial class

Author: baltzell

common-tools/clas-detector/src/main/java/org/jlab/detector/serial/SerialHoncho.java

@@ -0,0 +1,99 @@
+package org.jlab.detector.serial;
+
+import java.util.TreeMap;
+import java.util.TreeSet;
+import org.jlab.detector.calib.utils.ConstantsManager;
+import org.jlab.detector.decode.CLASDecoder;
+import org.jlab.detector.helicity.HelicitySequence;
+import org.jlab.detector.helicity.HelicityState;
+import org.jlab.detector.scalers.DaqScalersSequence;
+import org.jlab.jnp.hipo4.data.Bank;
+import org.jlab.jnp.hipo4.data.Event;
+import org.jlab.jnp.hipo4.data.SchemaFactory;
+import org.jlab.jnp.hipo4.io.HipoWriterSorted;
+
+/**
+ *
+ * @author baltzell
+ */
+public class SerialHoncho {
+    
+    static final String[] TAG1BANKS = {"RUN::scaler","HEL::scaler","RAW::scaler","RAW::epics","HEL::flip","COAT::config"};
+   
+    SchemaFactory schema;
+    Bank[] tag1banks;
+    Bank runConfig;
+    Bank helicityAdc;
+    ConstantsManager conman;
+    TreeMap<Integer,Integer> eventUnix;
+    TreeSet<HelicityState> helicities;
+    DaqScalersSequence scalers;
+  
+    public SerialHoncho(SchemaFactory schema) {
+        this.schema = schema;
+        conman = new ConstantsManager();
+        conman.init("/runcontrol/hwp","/runcontrol/helicity");
+        runConfig = new Bank(schema.getSchema("RUN::config"));
+        helicityAdc = new Bank(schema.getSchema("HEL::adc"));
+        helicities = new TreeSet<>();
+        scalers = new DaqScalersSequence(schema);
+        eventUnix = new TreeMap<>();
+        tag1banks = new Bank[TAG1BANKS.length];
+        for (int i=0; i<tag1banks.length; ++i)
+            tag1banks[i] = new Bank(schema.getSchema(TAG1BANKS[i]));
+    }
+
+    public synchronized Event read(Event event) {
+        scalers.add(event);
+        event.read(runConfig);
+        event.read(helicityAdc);
+        if (runConfig.getRows() > 0) {
+            int unix = runConfig.getInt("unixtime",0);
+            int evno = runConfig.getInt("event",0);
+            if (unix > 0 && evno > 0) eventUnix.put(evno, unix);
+        }
+        helicities.add(HelicityState.createFromFadcBank(helicityAdc, runConfig, conman));
+        return CLASDecoder.createTaggedEvent(event, runConfig, tag1banks);
+    }
+
+    public void finish(HipoWriterSorted writer) {
+        writer.addEvent(getUnixEvent(runConfig),1);
+        HelicitySequence.writeFlips(schema, writer, helicities);
+    }
+
+    public void clear() {
+        while (helicities.size() > 100) helicities.pollFirst();
+        scalers.clear(100);
+    }
+    
+    Event getUnixEvent(Bank config) {
+        Bank unix = new Bank(schema.getSchema("RUN::unix"));
+        unix.setRows(eventUnix.size());
+        int row = 0;
+        for (int evno : eventUnix.keySet()) {
+            unix.putInt("event", row, evno);
+            unix.putInt("unixtime",row, eventUnix.get(evno));
+            row++;
+        }
+        Event e = new Event();
+        e.write(config);
+        e.write(unix);
+        return e;
+    }
+
+    public DaqScalersSequence getScalers() {
+        return scalers;
+    }
+    
+    public TreeSet<HelicityState> getHelicities() {
+        return helicities;
+    }
+
+    public ConstantsManager getConstantsManager() {
+        return conman;
+    }
+
+    public SchemaFactory getSchemaFactory() {
+        return schema;
+    }
+}