From 55e87191d43de89b9abe8faf20bfe1e2d0693140 Mon Sep 17 00:00:00 2001
From: Tamas Gal <tgal@km3net.de>
Date: Mon, 20 Jan 2020 16:26:15 +0100
Subject: [PATCH] Add timeslice streamds
---
km3io/daq.py | 17 +++++++++++++++++
1 file changed, 17 insertions(+)
diff --git a/km3io/daq.py b/km3io/daq.py
index 807e59e..9e58cec 100644
--- a/km3io/daq.py
+++ b/km3io/daq.py
@@ -150,6 +150,8 @@ class DAQTimeslices:
TIMESLICE_FRAME_BASKET_CACHE_SIZE))
self._timeslices[stream.decode("ascii")] = (headers, superframes,
hits_buffer)
+ setattr(self, stream.decode("ascii"),
+ DAQTimesliceStream(headers, superframes, hits_buffer))
def stream(self, stream, idx):
ts = self._timeslices[stream]
@@ -163,6 +165,21 @@ class DAQTimeslices:
return str(self)
+class DAQTimesliceStream:
+ def __init__(self, headers, superframes, hits_buffer):
+ # self.headers = headers.lazyarray(
+ # uproot.asjagged(uproot.astable(
+ # uproot.asdtype(
+ # np.dtype([('a', 'i4'), ('b', 'i4'), ('c', 'i4'),
+ # ('d', 'i4'), ('e', 'i4')]))),
+ # skipbytes=6),
+ # basketcache=uproot.cache.ThreadSafeArrayCache(
+ # TIMESLICE_FRAME_BASKET_CACHE_SIZE))
+ self.headers = headers
+ self.superframes = superframes
+ self._hits_buffer = hits_buffer
+
+
class DAQTimeslice:
"""A wrapper for a DAQ timeslice"""
def __init__(self, header, superframe, hits_buffer, idx, stream):
--
GitLab