implemented a new service to be used in DCALIGN cooking,

etc/bankdefs/hipo4/neuralnetwork.json

@@ -1,4 +1,23 @@
 [ 
+	{
+	    "name": "MLDC::dc",
+            "group": 4200,
+            "item" : 5,
+            "info": "bank with DC information to trina neural networks",
+            "entries": [
+		{"name":"id",    "type":"S",  "info":"the ID"},
+		{"name":"value", "type":"S",  "info":"value"} 
+            ]
+	},
+	{
+	    "name": "MLDC::tracks",
+            "group": 4200,
+            "item" : 6,
+            "info": "track information",
+            "entries": [
+		    {"name":"bytes",    "type":"B",  "info":"byte array of composite format"}
+        ]
+	},
     {
         "name": "nn::tracks",
         "group": 4200,

etc/services/dcalign.yaml

@@ -51,6 +51,8 @@ services:
     name: RICH
   - class: org.jlab.service.rtpc.RTPCEngine
     name: RTPC
+  - class: org.jlab.service.mltn.MLDCEngine
+    name: MLDC
 configuration:
   global:
     variation: rgb_spring2019

reconstruction/mltn/src/main/java/org/jlab/service/mltn/MLDCEngine.java

@@ -0,0 +1,165 @@
+/*
+ * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
+ * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
+ */
+package org.jlab.service.mltn;
+
+import java.nio.ByteBuffer;
+import java.nio.ByteOrder;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import org.jlab.clas.reco.ReconstructionEngine;
+import org.jlab.io.base.DataBank;
+import org.jlab.io.base.DataEvent;
+import org.jlab.io.hipo.HipoDataBank;
+import org.jlab.jnp.hipo4.data.Bank;
+import org.jlab.jnp.hipo4.data.CompositeBank;
+
+/**
+ *
+ * @author gavalian
+ */
+public class MLDCEngine extends ReconstructionEngine {
+
+
+    public MLDCEngine(){
+        super("MLDC","gavalian","1.0");
+    }
+
+    @Override
+    public boolean init() {
+        return true;
+    }
+
+    @Override
+    public boolean processDataEvent(DataEvent de) {
+
+        List<ByteBuffer> trackBuffers = new ArrayList<>();
+
+        if(de.hasBank("TimeBasedTrkg::TBTracks")&&de.hasBank("TimeBasedTrkg::TBClusters")){
+            //System.out.println("writing trakcing bank");
+            DataBank   tbt = de.getBank("TimeBasedTrkg::TBTracks");
+            DataBank   tbc = de.getBank("TimeBasedTrkg::TBClusters");
+            ByteBuffer bb = getTracks(tbt,tbc,10);
+            trackBuffers.add(bb);
+            /*DataBank output = de.createBank("MLDC::tracks", bb.array().length);
+            for(int j = 0; j < bb.array().length; j++)
+                output.setByte("bytes", j,bb.array()[j]);
+            de.appendBank(output);*/
+        }
+
+        if(de.hasBank("TimeBasedTrkg::AITracks")&&de.hasBank("TimeBasedTrkg::AIClusters")){
+            DataBank   tbt = de.getBank("TimeBasedTrkg::AITracks");
+            DataBank   tbc = de.getBank("TimeBasedTrkg::AIClusters");
+            ByteBuffer bb = getTracks(tbt,tbc,20);
+            trackBuffers.add(bb);
+        }
+
+        if(trackBuffers.size()>0){
+            int[] lengths = new int[trackBuffers.size()];
+            int[] offsets = new int[trackBuffers.size()];
+            int size = 0;
+            for(int k = 0; k < offsets.length; k++){                
+                lengths[k] = trackBuffers.get(k).array().length;
+                offsets[k] = size;
+                size += trackBuffers.get(k).array().length;
+            }
+            byte[] buffer = new byte[size];
+            for(int k = 0; k < trackBuffers.size(); k++){
+                System.arraycopy(trackBuffers.get(k).array(), 0, buffer, offsets[k], lengths[k]);
+            }
+            DataBank output = de.createBank("MLDC::tracks", buffer.length);
+            for(int j = 0; j < buffer.length; j++)
+                output.setByte("bytes", j,buffer[j]);
+            de.appendBank(output);
+        }
+
+        if(de.hasBank("DC::tdc")==true){
+            DataBank   bank = de.getBank("DC::tdc");
+            DataBank output = de.createBank("MLDC::dc", bank.rows());
+
+            HipoDataBank hbank = (HipoDataBank) bank;
+            byte[]  sector = hbank.getByte("sector");
+            byte[]   layer = hbank.getByte("layer");
+            short[]   wire = hbank.getShort("component");
+            int[]      tdc = hbank.getInt("TDC");
+
+            for(int j = 0; j < bank.rows(); j++){
+                int id = (sector[j]-1)*(112*36) + (layer[j]-1)*112 + (wire[j]-1);
+                output.setShort("id", j, (short) id);
+                output.setShort("value", j, (short) tdc[j]);
+            }          
+            de.appendBank(output);
+        }
+        return true;
+    }
+
+    public static Map<Integer,Integer> getMap(DataBank bank){
+        Map<Integer,Integer> map = new HashMap<>();
+        int[] ids = bank.getInt("id");
+        for(int j = 0; j < ids.length; j++)
+            map.put(ids[j], j);
+        return map;
+    }
+
+
+    public static ByteBuffer getTracks(DataBank trkg, DataBank clusters, int status){
+        Map<Integer,Integer> map = getMap(clusters);
+        int size = trkg.rows();
+        int bsize = 110;
+        byte[] bytes = new byte[size*bsize];
+        ByteBuffer b = ByteBuffer.wrap(bytes);
+        b.order(ByteOrder.LITTLE_ENDIAN);
+        HipoDataBank ht = (HipoDataBank) trkg;
+        HipoDataBank hc = (HipoDataBank) clusters;
+        int[] cid = new int[6];
+        for(int j = 0; j < size; j++){
+            int offset = j*bsize;
+            int charge = (int) ht.getByte("q",j);
+            int     ps = status + (charge<0?2:1);
+            //System.out.printf(" row = %4d , status = %5d, charge = %3d, pstat = %5d\n",
+            //        j,status,charge,ps);
+            b.putShort(offset+0, (short) ps);
+            b.putFloat(offset+2, 0.0f);
+            b.putShort(offset+6, (short) ht.getByte("sector",j));
+            b.putShort(offset+8, (short) ht.getByte("q",j));
+            b.putFloat(offset+10, ht.getFloat("chi2", j));
+            b.putFloat(offset+14, ht.getFloat("p0_x", j));
+            b.putFloat(offset+18, ht.getFloat("p0_y", j));
+            b.putFloat(offset+22, ht.getFloat("p0_z", j));
+
+            b.putFloat(offset+26, ht.getFloat("Vtx0_x", j));
+            b.putFloat(offset+30, ht.getFloat("Vtx0_y", j));
+            b.putFloat(offset+34, ht.getFloat("Vtx0_z", j));
+
+            cid[0] = ht.getShort("Cluster1_ID", j);
+            cid[1] = ht.getShort("Cluster2_ID", j);
+            cid[2] = ht.getShort("Cluster3_ID", j);
+            cid[3] = ht.getShort("Cluster4_ID", j);
+            cid[4] = ht.getShort("Cluster5_ID", j);
+            cid[5] = ht.getShort("Cluster6_ID", j);
+
+            b.putInt(offset+38, cid[0]);
+            b.putInt(offset+42, cid[1]);
+            b.putInt(offset+46, cid[2]);
+            b.putInt(offset+50, cid[3]);
+            b.putInt(offset+54, cid[4]);
+            b.putInt(offset+58, cid[5]);
+
+
+            for(int i = 0; i < 6; i++){
+                if(map.containsKey(cid[i])==true){
+                    float avg = hc.getFloat("avgWire", map.get(cid[i]));
+                    b.putFloat(offset+i*4+62, avg);
+                    b.putFloat(offset+i*4+62+4*6, avg);
+                } else { 
+                    b.putFloat(offset+i*4+62, 0.0f);
+                    b.putFloat(offset+i*4+62+4*6, 0.0f);
+                }
+            }
+        }
+        return b;
+    }
+}