Decoding engine

common-tools/clara-io/src/main/java/org/jlab/io/clara/EvioToEvioReader.java

@@ -39,7 +39,7 @@ public int readEventCount() throws EventReaderException {
 
     @Override
     public ByteOrder readByteOrder() throws EventReaderException {
-        return reader.getFileByteOrder();
+        return ByteOrder.LITTLE_ENDIAN; //reader.getFileByteOrder();
     }
 
     @Override
@@ -53,6 +53,6 @@ public Object readEvent(int eventNumber) throws EventReaderException {
 
     @Override
     protected EngineDataType getDataType() {
-        return Clas12Types.EVIO;
+        return Clas12Types.HIPO;
     }
 }

common-tools/clas-detector/src/main/java/org/jlab/detector/decode/CLASDecoder.java

@@ -15,8 +15,6 @@
 
 import org.jlab.io.base.DataEvent;
 import org.jlab.io.evio.EvioDataEvent;
-import org.jlab.io.hipo.HipoDataEvent;
-import org.jlab.io.hipo.HipoDataSync;
 
 import org.jlab.jnp.hipo4.data.Bank;
 import org.jlab.jnp.hipo4.data.Event;
@@ -38,8 +36,6 @@ public class CLASDecoder {
     protected SchemaFactory           schemaFactory = new SchemaFactory();
     private CodaEventDecoder          codaDecoder = null;
     private List<DetectorDataDgtz>       dataList = new ArrayList<>();
-    private HipoDataSync                   writer = null;
-    private HipoDataEvent               hipoEvent = null;
     private boolean              isRunNumberFixed = false;
     private int                  decoderDebugMode = 0;
     private ModeAHDC                ahdcExtractor = new ModeAHDC();
@@ -48,17 +44,13 @@ public class CLASDecoder {
     public CLASDecoder(boolean development){
         codaDecoder = new CodaEventDecoder();
         detectorDecoder = new DetectorEventDecoder(development);
-        writer = new HipoDataSync();
-        hipoEvent = (HipoDataEvent) writer.createEvent();
         String dir = ClasUtilsFile.getResourceDir("CLAS12DIR", "etc/bankdefs/hipo4");
         schemaFactory.initFromDirectory(dir);
     }
 
     public CLASDecoder(){
         codaDecoder = new CodaEventDecoder();
         detectorDecoder = new DetectorEventDecoder();
-        writer = new HipoDataSync();
-        hipoEvent = (HipoDataEvent) writer.createEvent();
         String dir = ClasUtilsFile.getResourceDir("CLAS12DIR", "etc/bankdefs/hipo4");
         schemaFactory.initFromDirectory(dir);
     }
@@ -67,6 +59,10 @@ public SchemaFactory getSchemaFactory(){
         return schemaFactory;
     }
 
+    public void shareManagers(CLASDecoder d) {
+        detectorDecoder.shareManagers(d.detectorDecoder);
+    }
+
     public void setVariation(String variation) {
         detectorDecoder.setVariation(variation);
     }
@@ -792,4 +788,8 @@ public Event getDecodedEvent(EvioDataEvent rawEvent, int run, int counter, Doubl
 
         return decodedEvent;
     }
+
+    public Event getDecodedEvent(EvioDataEvent rawEvent) {
+        return getDecodedEvent(rawEvent, -1, -1, null, null);
+    }
 }

common-tools/clas-detector/src/main/java/org/jlab/detector/decode/DetectorEventDecoder.java

@@ -80,6 +80,12 @@ public float getRcdbSolenoidScale() {
                 getValue()).floatValue();
     }
 
+    public void shareManagers(DetectorEventDecoder d) {
+        translationManager = d.translationManager;
+        fitterManager = d.fitterManager;
+        scalerManager = d.scalerManager;
+    }
+
     public DetectorEventDecoder(){
         this.initDecoder();
     }

common-tools/clas-reco/src/main/java/org/jlab/clas/reco/DecodingEngine.java

@@ -0,0 +1,105 @@
+package org.jlab.clas.reco;
+
+import java.util.Set;
+import java.util.HashSet;
+import java.nio.ByteBuffer;
+import java.nio.ByteOrder;
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.BlockingQueue;
+import org.jlab.clara.base.ClaraUtil;
+import org.jlab.clara.engine.Engine;
+import org.jlab.clara.engine.EngineData;
+import org.jlab.clara.engine.EngineDataType;
+import org.jlab.clara.engine.EngineStatus;
+import org.jlab.detector.decode.CLASDecoder;
+import org.jlab.io.evio.EvioDataEvent;
+import org.jlab.io.hipo.HipoDataEvent;
+import org.jlab.jnp.hipo4.data.SchemaFactory;
+import org.json.JSONObject;
+
+/**
+ *
+ * @author baltzell
+ */
+public class DecodingEngine implements Engine {
+
+    SchemaFactory schema;
+
+    BlockingQueue<CLASDecoder> pool;
+
+    public DecodingEngine() {
+        schema = new SchemaFactory();
+        schema.initFromDirectory(System.getenv("CLAS12DIR") + "/etc/bankdefs/hipo4");
+    }
+
+    @Override
+    public EngineData executeGroup(Set<EngineData> set) { return null; }
+    @Override
+    public Set<String> getStates() { return new HashSet<>(); }
+    @Override
+    public String getDescription() { return "decoder engine"; }
+    @Override
+    public String getVersion() { return "1.0"; }
+    @Override
+    public String getAuthor() { return "baltzell"; }
+    @Override
+    public void reset() {}
+    @Override
+    public void destroy() {}
+
+    @Override
+    public Set<EngineDataType> getInputDataTypes() {
+        return ClaraUtil.buildDataTypes(Clas12Types.EVIO);
+    }
+
+    @Override
+    public Set<EngineDataType> getOutputDataTypes() {
+        return ClaraUtil.buildDataTypes(Clas12Types.HIPO);
+    }
+
+    @Override
+    public EngineData configure(EngineData ed) {
+        JSONObject j = new JSONObject(ed.getData());
+        pool = new ArrayBlockingQueue<>(64);
+        CLASDecoder d0 = new CLASDecoder();
+        if (j.has("variation")) d0.setVariation(j.getString("variation"));
+        if (j.has("timestamp")) d0.setVariation(j.getString("timestamp"));
+        for (int i=0; i<64; i++) {
+            CLASDecoder d = i==0 ? d0 : new CLASDecoder();
+            if (i > 0) d.shareManagers(d0);
+            pool.add(d);
+        }
+        return ed;
+    }
+
+    @Override
+    public EngineData execute(EngineData input) {
+        EngineData output = input;
+        EvioDataEvent evio;
+        HipoDataEvent hipo;
+        try {
+            ByteBuffer bb = (ByteBuffer) input.getData();
+            //evio = new EvioDataEvent(bb.array(), bb.order());
+            evio = new EvioDataEvent(bb.array(), ByteOrder.LITTLE_ENDIAN);
+        } catch (Exception e) {
+            String msg = String.format("Error reading input event%n%n%s", ClaraUtil.reportException(e));
+            output.setStatus(EngineStatus.ERROR);
+            output.setDescription(msg);
+            return output;
+        }
+
+        try {
+            CLASDecoder d = pool.take();
+            hipo = new HipoDataEvent(d.getDecodedEvent(evio),schema);
+            pool.put(d);
+            output.setData("binary/data-hipo", hipo.getHipoEvent());
+        } catch (Exception e) {
+            String msg = String.format("Error processing input event%n%n%s", ClaraUtil.reportException(e));
+            output.setStatus(EngineStatus.ERROR);
+            output.setDescription(msg);
+            return output;
+        }
+        return output;
+    }
+
+}

etc/services/rgd-clarode.yml

@@ -19,12 +19,14 @@ configuration:
       outputBankPrefix: "HB"
 io-services:
   reader:
-    class: org.jlab.io.clara.Clas12Reader
-    name: Clas12Reader
+    class: org.jlab.io.clara.EvioToEvioReader
+    name: EvioReader
   writer:
     class: org.jlab.io.clara.DecoderWriter
     name: DecoderWriter
 services:
+  - class: org.jlab.clas.reco.DecodingEngine
+    name: DECO
   - class: org.jlab.service.ai.DCDenoiseEngine
     name: DCDN
   - class: org.jlab.clas.swimtools.MagFieldsEngine