Skip to content
Snippets Groups Projects
Verified Commit f83eadc5 authored by Tamas Gal's avatar Tamas Gal :speech_balloon:
Browse files

Add memory observer for triggermap

parent 0347a310
No related branches found
No related tags found
No related merge requests found
Pipeline #33444 canceled
...@@ -40,6 +40,7 @@ from km3pipe.hardware import Detector ...@@ -40,6 +40,7 @@ from km3pipe.hardware import Detector
from km3pipe.io import CHPump from km3pipe.io import CHPump
from km3pipe.io.daq import (DAQProcessor, DAQPreamble, DAQSummaryslice, from km3pipe.io.daq import (DAQProcessor, DAQPreamble, DAQSummaryslice,
DAQEvent) DAQEvent)
from km3modules.common import MemoryObserver
import km3pipe.style import km3pipe.style
km3pipe.style.use('km3pipe') km3pipe.style.use('km3pipe')
...@@ -210,6 +211,7 @@ def main(): ...@@ -210,6 +211,7 @@ def main():
ligier_port = int(args['-p']) ligier_port = int(args['-p'])
pipe = kp.Pipeline() pipe = kp.Pipeline()
pipe.attach(MemoryObserver, every=1000)
pipe.attach( pipe.attach(
kp.io.ch.CHPump, kp.io.ch.CHPump,
host=ligier_ip, host=ligier_ip,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment