add trigger-bit filter

Author: baltzell

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

@@ -1,11 +1,8 @@
 package org.jlab.io.clara;
 
-import java.io.File;
 import java.nio.file.Path;
-import java.util.List;
 import org.jlab.clara.std.services.EventWriterException;
 import org.jlab.detector.calib.utils.ConstantsManager;
-import org.jlab.detector.helicity.HelicitySequenceDelayed;
 import org.jlab.detector.serial.SerialHoncho;
 import org.jlab.detector.serial.Occupancer;
 import org.jlab.jnp.hipo4.data.Bank;

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

@@ -26,21 +26,25 @@ public class Occupancer extends ArrayList<Occupancer.OccupanceTable> {
     static final SchemaFactory FULL_SCHEMA = new SchemaFactory();
     static { FULL_SCHEMA.initFromDirectory(ClasUtilsFile.getResourceDir("CLAS12DIR","etc/bankdefs/hipo4")); }
 
-    int prescale = 1000;
+    long triggerMask = 0x8000000000l;
+    int prescale = 0;
     int nevents = 0;
+    Schema cfgSchema;
 
     public Occupancer() {
         super();
         init();
     }
 
-    public Occupancer(int prescale) {
+    public Occupancer(long triggerMask, int prescale) {
         super();
+        this.triggerMask = triggerMask;
         this.prescale = prescale;
         init();
     }
 
     private void init() {
+        cfgSchema = FULL_SCHEMA.getSchema("RUN::config");
         try {
             // Initialize list, by reading occupancy bank filenames from a directory
             // and stripping ".json" suffix and "OCC::" prefix to get hit bank name:
@@ -56,16 +60,19 @@ private void init() {
     }
 
     public boolean process(Event event) {
-        int size = size();
-        for (int i=0; i<size; i++) get(i).fill(event);
-        if (++nevents % prescale == 0) {
-            for (int i=0; i<size; i++) {
-                if (get(i).getTable().getRowCount() > 0) {
-                    event.write(get(i).create(nevents));
+        Bank cfgBank = event.read(new Bank(cfgSchema, 1));
+        if (cfgBank.getRows() > 0 && 0 != (triggerMask & cfgBank.getLong("trigger",0))) {
+            int size = size();
+            for (int i=0; i<size; i++) get(i).fill(event);
+            if (++nevents % prescale == 0) {
+                for (int i=0; i<size; i++) {
+                    if (get(i).getTable().getRowCount() > 0) {
+                        event.write(get(i).create(nevents));
+                    }
+                    get(i).reset();
                 }
-                get(i).reset();
+                nevents = 0;
             }
-            nevents = 0;
         }
         return true;
     }