Daqbox dev

deployment/script_names.txt

@@ -11,4 +11,5 @@ set_bias
 set_pps
 set_rtc_time
 start_health_udpcapture
+start_science_udpcapture
 toggle_power

deployment/service_names.txt

@@ -1,4 +1,6 @@
 gpio-init.service
 gpiomem-group.service
-system-health.service
 health-udpcapture.service
+quicklook-udpcapture.service
+science-udpcapture.service
+system-health.service

deployment/setup_directories

@@ -1,2 +1,13 @@
+#!/bin/bash
+
 sudo mkdir -p /data/health
-sudo chmod -R 0777 /data
+sudo mkdir -p /data/journal
+sudo mkdir -p /data/quicklook
+sudo mkdir -p /data/science
+
+# Make them editable by anyone
+sudo chmod 0777 /data
+sudo chmod 0777 /data/health
+sudo chmod 0777 /data/journal
+sudo chmod 0777 /data/quicklook
+sudo chmod 0777 /data/science

impisc/packets.py

@@ -1,6 +1,68 @@
 import ctypes
 
 
+class QuicklookPacket(ctypes.LittleEndianStructure):
+    """
+    """
+
+    # Do not include padding bytes
+    _pack_ = 1
+
+    _fields_ = [
+        ("unix_timestamp", ctypes.c_uint32),
+        ("det1_ebin1", ctypes.c_uint8),
+        ("det1_ebin1_counts", ctypes.c_uint16),
+        ("det1_ebin1_cps", ctypes.c_uint16),
+        ("det1_ebin2", ctypes.c_uint8),
+        ("det1_ebin2_counts", ctypes.c_uint16),
+        ("det1_ebin2_cps", ctypes.c_uint16),
+        ("det1_ebin3", ctypes.c_uint8),
+        ("det1_ebin3_counts", ctypes.c_uint16),
+        ("det1_ebin3_cps", ctypes.c_uint16),
+        ("det1_ebin4", ctypes.c_uint8),
+        ("det1_ebin4_counts", ctypes.c_uint16),
+        ("det1_ebin4_cps", ctypes.c_uint16),
+
+        ("det2_ebin1", ctypes.c_uint8),
+        ("det2_ebin1_counts", ctypes.c_uint16),
+        ("det2_ebin1_cps", ctypes.c_uint16),
+        ("det2_ebin2", ctypes.c_uint8),
+        ("det2_ebin2_counts", ctypes.c_uint16),
+        ("det2_ebin2_cps", ctypes.c_uint16),
+        ("det2_ebin3", ctypes.c_uint8),
+        ("det2_ebin3_counts", ctypes.c_uint16),
+        ("det2_ebin3_cps", ctypes.c_uint16),
+        ("det2_ebin4", ctypes.c_uint8),
+        ("det2_ebin4_counts", ctypes.c_uint16),
+        ("det2_ebin4_cps", ctypes.c_uint16),
+
+        ("det3_ebin1", ctypes.c_uint8),
+        ("det3_ebin1_counts", ctypes.c_uint16),
+        ("det3_ebin1_cps", ctypes.c_uint16),
+        ("det3_ebin2", ctypes.c_uint8),
+        ("det3_ebin2_counts", ctypes.c_uint16),
+        ("det3_ebin2_cps", ctypes.c_uint16),
+        ("det3_ebin3", ctypes.c_uint8),
+        ("det3_ebin3_counts", ctypes.c_uint16),
+        ("det3_ebin3_cps", ctypes.c_uint16),
+        ("det3_ebin4", ctypes.c_uint8),
+        ("det3_ebin4_counts", ctypes.c_uint16),
+        ("det3_ebin4_cps", ctypes.c_uint16),
+
+        ("det4_ebin1", ctypes.c_uint8),
+        ("det4_ebin1_counts", ctypes.c_uint16),
+        ("det4_ebin1_cps", ctypes.c_uint16),
+        ("det4_ebin2", ctypes.c_uint8),
+        ("det4_ebin2_counts", ctypes.c_uint16),
+        ("det4_ebin2_cps", ctypes.c_uint16),
+        ("det4_ebin3", ctypes.c_uint8),
+        ("det4_ebin3_counts", ctypes.c_uint16),
+        ("det4_ebin3_cps", ctypes.c_uint16),
+        ("det4_ebin4", ctypes.c_uint8),
+        ("det4_ebin4_counts", ctypes.c_uint16),
+        ("det4_ebin4_cps", ctypes.c_uint16),
+    ]
+
 class HealthPacket(ctypes.LittleEndianStructure):
     """
     The IMPISH health packet

processes/quicklook_monitor

@@ -0,0 +1,62 @@
+#!/python-venv/bin/python
+
+import os
+import json
+import socket
+import logging
+
+
+from impisc.packets import QuicklookPacket
+
+
+my_port = int(os.getenv("QUICKLOOK_MONITOR_PORT"))
+send_port = int(os.getenv("LOCAL_QUICKLOOK_FWD_PORT"))
+
+
+def main():
+    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    sock.bind(("", my_port))
+
+    while True:
+        try:
+            packet = QuicklookPacket()
+
+            data, _ = sock.recvfrom(8192)
+            msg = json.loads(data.decode())
+            channel = msg.get("channel")
+            if channel is None:
+                logging.warning("Quicklook message missing channel field")
+                continue
+
+            det_fields = {
+                f"det{channel}_ebin1": "det_ebin1",
+                f"det{channel}_ebin1_counts": "det_ebin1_counts",
+                f"det{channel}_ebin1_cps": "det_ebin1_cps",
+                f"det{channel}_ebin2": "det_ebin2",
+                f"det{channel}_ebin2_counts": "det_ebin2_counts",
+                f"det{channel}_ebin2_cps": "det_ebin2_cps",
+                f"det{channel}_ebin3": "det_ebin3",
+                f"det{channel}_ebin3_counts": "det_ebin3_counts",
+                f"det{channel}_ebin3_cps": "det_ebin3_cps",
+                f"det{channel}_ebin4": "det_ebin4",
+                f"det{channel}_ebin4_counts": "det_ebin4_counts",
+                f"det{channel}_ebin4_cps": "det_ebin4_cps",
+                f"unix_timestamp": "unix_timestamp",
+            }
+
+            for target, field in det_fields.items():
+                if field in msg:
+                    setattr(packet, target, msg[field])
+
+            sock.sendto(bytes(packet), ("localhost", send_port))
+
+        except Exception:
+            logging.exception("Quicklook monitor crashed")
+
+
+if __name__ == "__main__":
+    main()
+
+
+# deadtime includes
+# 1. sipm recharge time

scripts/start_quicklook_udpcapture

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+source variables.env
+udpcapture --port $LOCAL_QUICKLOOK_FWD_PORT --base-filename '/data/quicklook/impish_quicklook' \
+	--file-lifetime 300 --forward-addrs $GROUNDSTATION_IP\
+	--post-process-cmd 'xz $out_file'

scripts/start_science_udpcapture

@@ -0,0 +1,6 @@
+#!/bin/bash
+
+source variables.env
+udpcapture --port $LOCAL_SCIENCE_FWD_PORT --base-filename '/data/science/impish_science' \
+	--file-lifetime 300 -f 127.0.0.1:12346\
+	--post-process-cmd 'xz $out_file'

scripts/tests/.gitignore

@@ -0,0 +1,25 @@
+quicklook_recv.py
+waveform_config.json
+udp_receivedata.py
+spectrum_config.json
+notes.txt
+impish_logs/
+impisc_patch/
+daq_control_cont.py
+config/waveform_config.json
+cmd_listener.py
+test_daq_control.py
+config/active.json
+daq_control_test.py
+daq_control_thread.py
+udp_sender_test.py
+protocol.py
+send_cmd_shutdown.py
+udp_receivedata_test.py
+udp_sender_test.py
+processes/quicklook_monitor_t.py
+daq_control_test1.py
+quicklook_accum.py
+quicklook_accum1.py
+udp_receive_test.py
+udp_sender_thread.py

scripts/tests/config/default.json

@@ -0,0 +1,22 @@
+{
+    "global": {
+        "enabled": 1,
+        "thresholds": [100, 50, 50, 50],
+        "polarities": 0,
+        "enable_pileup_rejection": false,
+        "integration_window": 74,
+        "zoom_division": 4,
+        "pileup_integration_time": 20
+    },
+
+    "modes": {
+        "spectrum": {
+            "acquisition_mode": "spectrum"
+        },
+        "waveform": {
+            "acquisition_mode": "waveform"
+        }
+    },
+
+    "startup_mode": "safe"
+}