From 6e83c72725071749a79f6b0b8e15f5b866a511c2 Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Fri, 6 Mar 2026 11:57:06 +0100
Subject: [PATCH 01/11] Introduced SocketDetectorToDaqConnection

---
 config/daqsystemtest/moduleconfs.data.xml |   4 -
 config/daqsystemtest/ru-segment.data.xml  | 100 ++++++++++++++++++----
 2 files changed, 83 insertions(+), 21 deletions(-)

diff --git a/config/daqsystemtest/moduleconfs.data.xml b/config/daqsystemtest/moduleconfs.data.xml
index e2649a2..3760319 100644
--- a/config/daqsystemtest/moduleconfs.data.xml
+++ b/config/daqsystemtest/moduleconfs.data.xml
@@ -742,14 +742,10 @@
 <obj class="SocketReaderConf" id="def-socket-reader-conf">
  <attr name="template_for" type="class" val="SocketReaderModule"/>
  <attr name="emulation_mode" type="bool" val="0"/>
- <attr name="socket_type" type="enum" val="UDP"/>
- <attr name="local_ip" type="string" val="127.0.0.1"/>
 </obj>
 
 <obj class="SocketWriterConf" id="def-socket-writer-conf">
  <attr name="template_for" type="class" val="SocketWriterModule"/>
- <attr name="socket_type" type="enum" val="UDP"/>
- <attr name="remote_ip" type="string" val="127.0.0.1"/>
 </obj>
 
 <obj class="StreamEmulationParameters" id="crt-stream-emu">
diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index 2d29d26..29716ac 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -63,7 +63,7 @@
 
 <oks-data>
 
-<info name="" type="" num-of-items="49" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105615" last-modified-by="eflumerf" last-modified-on="ironvirt9.mshome.net" last-modification-time="20251105T144619"/>
+<info name="" type="" num-of-items="58" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105615" last-modified-by="dergonul" last-modified-on="np04-srv-015.cern.ch" last-modification-time="20260305T122304"/>
 
 <include>
  <file path="schema/confmodel/dunedaq.schema.xml"/>
@@ -103,6 +103,7 @@
  <comment creation-time="20250325T145413" created-by="dergonul" created-on="np04-srv-015.cern.ch" author="dergonul" text="Disabled TP"/>
  <comment creation-time="20250526T125136" created-by="dergonul" created-on="np04-srv-031.cern.ch" author="dergonul" text="Added crt-bern and crt-grenoble"/>
  <comment creation-time="20250805T092423" created-by="dergonul" created-on="np04-srv-028.cern.ch" author="dergonul" text="Emu CRT configs"/>
+ <comment creation-time="20260225T104925" created-by="dergonul" created-on="np04-srv-015.cern.ch" author="dergonul" text="Introduced SocketDetectorToDaqConnection"/>
 </comments>
 
 
@@ -120,12 +121,10 @@
  <rel name="queue_rules">
   <ref class="QueueConnectionRule" id="crt-bern-raw-data-rule"/>
  </rel>
- <rel name="data_writers">
-  <ref class="SocketWriterConf" id="def-socket-writer-conf"/>
- </rel>
  <rel name="data_reader" class="CRTReaderConf" id="def-emu-crt-receiver-conf"/>
+ <rel name="data_writer" class="SocketWriterConf" id="def-socket-writer-conf"/>
  <rel name="detector_connections">
-  <ref class="NetworkDetectorToDaqConnection" id="socket_crt"/>
+  <ref class="SocketDetectorToDaqConnection" id="socket_crt"/>
  </rel>
 </obj>
 
@@ -163,11 +162,26 @@
  <rel name="geo_id" class="GeoId" id="g_13_1_1_0"/>
 </obj>
 
+<obj class="DetectorStream" id="stream_1008">
+ <attr name="source_id" type="u32" val="1008"/>
+ <rel name="geo_id" class="GeoId" id="g_13_1_1_1"/>
+</obj>
+
+<obj class="DetectorStream" id="stream_1009">
+ <attr name="source_id" type="u32" val="1009"/>
+ <rel name="geo_id" class="GeoId" id="g_13_2_1_0"/>
+</obj>
+
 <obj class="DetectorStream" id="stream_101">
  <attr name="source_id" type="u32" val="101"/>
  <rel name="geo_id" class="GeoId" id="g_3_1_1_1"/>
 </obj>
 
+<obj class="DetectorStream" id="stream_1010">
+ <attr name="source_id" type="u32" val="1010"/>
+ <rel name="geo_id" class="GeoId" id="g_13_2_1_1"/>
+</obj>
+
 <obj class="DetectorStream" id="stream_102">
  <attr name="source_id" type="u32" val="102"/>
  <rel name="geo_id" class="GeoId" id="g_3_1_1_2"/>
@@ -210,6 +224,26 @@
  <attr name="slot_id" type="u32" val="1"/>
 </obj>
 
+<obj class="GeoId" id="g_13_1_1_1">
+ <attr name="detector_id" type="u32" val="13"/>
+ <attr name="crate_id" type="u32" val="1"/>
+ <attr name="slot_id" type="u32" val="1"/>
+ <attr name="stream_id" type="u32" val="1"/>
+</obj>
+
+<obj class="GeoId" id="g_13_2_1_0">
+ <attr name="detector_id" type="u32" val="13"/>
+ <attr name="crate_id" type="u32" val="2"/>
+ <attr name="slot_id" type="u32" val="1"/>
+</obj>
+
+<obj class="GeoId" id="g_13_2_1_1">
+ <attr name="detector_id" type="u32" val="13"/>
+ <attr name="crate_id" type="u32" val="2"/>
+ <attr name="slot_id" type="u32" val="1"/>
+ <attr name="stream_id" type="u32" val="1"/>
+</obj>
+
 <obj class="GeoId" id="g_3_1_1_0">
  <attr name="detector_id" type="u32" val="3"/>
  <attr name="crate_id" type="u32" val="1"/>
@@ -302,13 +336,6 @@
  <rel name="net_receiver" class="DPDKReceiver" id="ru-2-rcv"/>
 </obj>
 
-<obj class="NetworkDetectorToDaqConnection" id="socket_crt">
- <rel name="net_senders">
-  <ref class="SocketDataSender" id="socket_sender_crt"/>
- </rel>
- <rel name="net_receiver" class="SocketReceiver" id="socket-ru-1-rcv"/>
-</obj>
-
 <obj class="NetworkDevice" id="ru_1_readout">
  <attr name="mac_address" type="string" val="00:00:00:00:00:00"/>
  <attr name="ip_address" type="string">
@@ -332,7 +359,25 @@
 <obj class="NetworkInterface" id="crt_101_asio0">
  <attr name="mac_address" type="string" val="00:00:00:00:00:00"/>
  <attr name="ip_address" type="string">
-  <data val="123.456.101.000"/>
+  <data val="127.0.0.1"/>
+ </attr>
+ <attr name="interface_name" type="string" val="asio0"/>
+ <attr name="network_name" type="enum" val="Control"/>
+</obj>
+
+<obj class="NetworkInterface" id="crt_101_asio1">
+ <attr name="mac_address" type="string" val="00:00:00:00:00:00"/>
+ <attr name="ip_address" type="string">
+  <data val="127.0.0.1"/>
+ </attr>
+ <attr name="interface_name" type="string" val="asio1"/>
+ <attr name="network_name" type="enum" val="Control"/>
+</obj>
+
+<obj class="NetworkInterface" id="socket_ru_1_readout">
+ <attr name="mac_address" type="string" val="00:00:00:00:00:00"/>
+ <attr name="ip_address" type="string">
+  <data val="127.0.0.1"/>
  </attr>
  <attr name="interface_name" type="string" val="asio0"/>
  <attr name="network_name" type="enum" val="Control"/>
@@ -489,7 +534,7 @@
  <rel name="data_reader" class="SocketReaderConf" id="def-socket-reader-conf"/>
  <rel name="fragment_aggregator" class="FragmentAggregatorConf" id="frag-agg-01"/>
  <rel name="detector_connections">
-  <ref class="NetworkDetectorToDaqConnection" id="socket_crt"/>
+  <ref class="SocketDetectorToDaqConnection" id="socket_crt"/>
  </rel>
 </obj>
 
@@ -513,16 +558,37 @@
 </obj>
 
 <obj class="SocketDataSender" id="socket_sender_crt">
- <attr name="port" type="u32" val="1234"/>
- <attr name="control_host" type="string" val="localhost"/>
+ <attr name="socket_type" type="enum" val="UDP"/>
+ <attr name="local_port" type="u32" val="12345"/>
+ <attr name="remote_port" type="u32" val="20001"/>
  <rel name="streams">
   <ref class="DetectorStream" id="stream_1007"/>
+  <ref class="DetectorStream" id="stream_1008"/>
  </rel>
  <rel name="uses" class="NetworkInterface" id="crt_101_asio0"/>
 </obj>
 
+<obj class="SocketDataSender" id="socket_sender_crt_2">
+ <attr name="socket_type" type="enum" val="TCP"/>
+ <attr name="local_port" type="u32" val="12346"/>
+ <attr name="remote_port" type="u32" val="20002"/>
+ <rel name="streams">
+  <ref class="DetectorStream" id="stream_1009"/>
+  <ref class="DetectorStream" id="stream_1010"/>
+ </rel>
+ <rel name="uses" class="NetworkInterface" id="crt_101_asio1"/>
+</obj>
+
+<obj class="SocketDetectorToDaqConnection" id="socket_crt">
+ <rel name="net_senders">
+  <ref class="SocketDataSender" id="socket_sender_crt"/>
+  <ref class="SocketDataSender" id="socket_sender_crt_2"/>
+ </rel>
+ <rel name="net_receiver" class="SocketReceiver" id="socket-ru-1-rcv"/>
+</obj>
+
 <obj class="SocketReceiver" id="socket-ru-1-rcv">
- <rel name="uses" class="NetworkDevice" id="ru_1_readout"/>
+ <rel name="uses" class="NetworkInterface" id="socket_ru_1_readout"/>
 </obj>
 
 <obj class="SourceIDConf" id="tp-srcid-1000">

From 4ababce8ad0582015c64a1368690e852ed17d5be Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Wed, 11 Mar 2026 16:22:50 +0100
Subject: [PATCH 02/11] CRT and SocketWriter communicates via queues

---
 config/daqsystemtest/connections.data.xml | 27 +++++++++++++++++++++++
 config/daqsystemtest/moduleconfs.data.xml |  4 ++--
 config/daqsystemtest/ru-segment.data.xml  |  6 +++--
 3 files changed, 33 insertions(+), 4 deletions(-)

diff --git a/config/daqsystemtest/connections.data.xml b/config/daqsystemtest/connections.data.xml
index ffd4cd8..3025d64 100644
--- a/config/daqsystemtest/connections.data.xml
+++ b/config/daqsystemtest/connections.data.xml
@@ -313,6 +313,14 @@
  <rel name="descriptor" class="QueueDescriptor" id="trigger-records"/>
 </obj>
 
+<obj class="QueueConnectionRule" id="crt-bern-raw-input-queue">
+ <rel name="descriptor" class="QueueDescriptor" id="crt-bern-raw-input-queue-desc"/>
+</obj>
+
+<obj class="QueueConnectionRule" id="crt-grenoble-raw-input-queue">
+ <rel name="descriptor" class="QueueDescriptor" id="crt-grenoble-raw-input-queue-desc"/>
+</obj>
+
 <obj class="QueueDescriptor" id="data-req-queue-desc">
  <attr name="uid_base" type="string" val="internal_data_requests_for_"/>
  <attr name="queue_type" type="enum" val="kFollySPSCQueue"/>
@@ -376,6 +384,20 @@
  <attr name="data_type" type="string" val="TriggerRecord"/>
 </obj>
 
+<obj class="QueueDescriptor" id="crt-bern-raw-input-queue-desc">
+ <attr name="uid_base" type="string" val="raw_input_queue_"/>
+ <attr name="queue_type" type="enum" val="kFollySPSCQueue"/>
+ <attr name="capacity" type="u32" val="10000"/>
+ <attr name="data_type" type="string" val="CRTBernFrame"/>
+</obj>
+
+<obj class="QueueDescriptor" id="crt-grenoble-raw-input-queue-desc">
+ <attr name="uid_base" type="string" val="raw_input_queue_"/>
+ <attr name="queue_type" type="enum" val="kFollySPSCQueue"/>
+ <attr name="capacity" type="u32" val="10000"/>
+ <attr name="data_type" type="string" val="CRTGrenobleFrame"/>
+</obj>
+
 <obj class="RCBroadcaster" id="broadcaster-root">
  <attr name="type" type="enum" val="kafka"/>
  <attr name="address" type="string" val="monkafka.cern.ch:30092"/>
@@ -387,6 +409,11 @@
  <attr name="data_type" type="string" val="CRTBernFrame"/>
 </obj>
 
+<obj class="DataMoveCallbackDescriptor" id="null_callback_desc">
+ <attr name="uid_base" type="string" val="raw_input_"/>
+ <attr name="data_type" type="string" val="CRTBernFrame"/>
+</obj>
+
 <obj class="DataMoveCallbackDescriptor" id="crt-grenoble-raw-input">
  <attr name="uid_base" type="string" val="raw_input_"/>
  <attr name="data_type" type="string" val="CRTGrenobleFrame"/>
diff --git a/config/daqsystemtest/moduleconfs.data.xml b/config/daqsystemtest/moduleconfs.data.xml
index 10c4bae..dcc1992 100644
--- a/config/daqsystemtest/moduleconfs.data.xml
+++ b/config/daqsystemtest/moduleconfs.data.xml
@@ -139,7 +139,7 @@
  <rel name="command" class="FSMCommand" id="start"/>
  <rel name="steps">
   <ref class="DaqModulesGroupByType" id="socket-writer-data-source-step"/>
-  <ref class="DaqModulesGroupByType" id="data-source-step"/>
+  <ref class="DaqModulesGroupByType" id="crt-bern-reader-data-source-step"/>
  </rel>
 </obj>
 
@@ -147,7 +147,7 @@
  <attr name="execution_policy" type="enum" val="modules-in-parallel"/>
  <rel name="command" class="FSMCommand" id="stop_trigger_sources"/>
  <rel name="steps">
-  <ref class="DaqModulesGroupByType" id="data-source-step"/>
+  <ref class="DaqModulesGroupByType" id="crt-bern-reader-data-source-step"/>
   <ref class="DaqModulesGroupByType" id="socket-writer-data-source-step"/>
  </rel>
 </obj>
diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index 41cb5b9..ae87d3a 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -118,13 +118,15 @@
   <ref class="ActionPlan" id="crt-readout-start"/>
   <ref class="ActionPlan" id="crt-readout-stop"/>
  </rel>
+ <rel name="queue_rules">
+  <ref class="QueueConnectionRule" id="crt-bern-raw-input-queue"/>
  </rel>
- <rel name="data_reader" class="CRTReaderConf" id="def-emu-crt-receiver-conf"/>
+ <rel name="data_reader" class="CRTBernReaderConf" id="def-crt-bern-receiver-conf"/>
  <rel name="data_writer" class="SocketWriterConf" id="def-socket-writer-conf"/>
  <rel name="detector_connections">
   <ref class="SocketDetectorToDaqConnection" id="socket_crt"/>
  </rel>
- <rel name="callback_desc" class="DataMoveCallbackDescriptor" id="crt-bern-raw-input"/>
+ <rel name="callback_desc" class="DataMoveCallbackDescriptor" id="null_callback_desc"/>
 </obj>
 
 <obj class="DPDKPortConfiguration" id="dpdk_e810_conf">

From 37ef260fe33053809022eb021c253a797581959a Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Fri, 13 Mar 2026 17:00:38 +0100
Subject: [PATCH 03/11] Communicates via callbacks: CRT readers with socket
 writers, socket readers with DHLs

---
 config/daqsystemtest/connections.data.xml | 29 +----------------------
 config/daqsystemtest/ru-segment.data.xml  |  5 +---
 2 files changed, 2 insertions(+), 32 deletions(-)

diff --git a/config/daqsystemtest/connections.data.xml b/config/daqsystemtest/connections.data.xml
index 3025d64..f95d3c8 100644
--- a/config/daqsystemtest/connections.data.xml
+++ b/config/daqsystemtest/connections.data.xml
@@ -63,7 +63,7 @@
 
 <oks-data>
 
-<info name="" type="" num-of-items="70" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105549" last-modified-by="eflumerf" last-modified-on="ironvirt9.mshome.net" last-modification-time="20260202T153912"/>
+<info name="" type="" num-of-items="65" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105549" last-modified-by="eflumerf" last-modified-on="ironvirt9.mshome.net" last-modification-time="20260202T153912"/>
 
 <include>
  <file path="schema/confmodel/dunedaq.schema.xml"/>
@@ -313,14 +313,6 @@
  <rel name="descriptor" class="QueueDescriptor" id="trigger-records"/>
 </obj>
 
-<obj class="QueueConnectionRule" id="crt-bern-raw-input-queue">
- <rel name="descriptor" class="QueueDescriptor" id="crt-bern-raw-input-queue-desc"/>
-</obj>
-
-<obj class="QueueConnectionRule" id="crt-grenoble-raw-input-queue">
- <rel name="descriptor" class="QueueDescriptor" id="crt-grenoble-raw-input-queue-desc"/>
-</obj>
-
 <obj class="QueueDescriptor" id="data-req-queue-desc">
  <attr name="uid_base" type="string" val="internal_data_requests_for_"/>
  <attr name="queue_type" type="enum" val="kFollySPSCQueue"/>
@@ -384,20 +376,6 @@
  <attr name="data_type" type="string" val="TriggerRecord"/>
 </obj>
 
-<obj class="QueueDescriptor" id="crt-bern-raw-input-queue-desc">
- <attr name="uid_base" type="string" val="raw_input_queue_"/>
- <attr name="queue_type" type="enum" val="kFollySPSCQueue"/>
- <attr name="capacity" type="u32" val="10000"/>
- <attr name="data_type" type="string" val="CRTBernFrame"/>
-</obj>
-
-<obj class="QueueDescriptor" id="crt-grenoble-raw-input-queue-desc">
- <attr name="uid_base" type="string" val="raw_input_queue_"/>
- <attr name="queue_type" type="enum" val="kFollySPSCQueue"/>
- <attr name="capacity" type="u32" val="10000"/>
- <attr name="data_type" type="string" val="CRTGrenobleFrame"/>
-</obj>
-
 <obj class="RCBroadcaster" id="broadcaster-root">
  <attr name="type" type="enum" val="kafka"/>
  <attr name="address" type="string" val="monkafka.cern.ch:30092"/>
@@ -409,11 +387,6 @@
  <attr name="data_type" type="string" val="CRTBernFrame"/>
 </obj>
 
-<obj class="DataMoveCallbackDescriptor" id="null_callback_desc">
- <attr name="uid_base" type="string" val="raw_input_"/>
- <attr name="data_type" type="string" val="CRTBernFrame"/>
-</obj>
-
 <obj class="DataMoveCallbackDescriptor" id="crt-grenoble-raw-input">
  <attr name="uid_base" type="string" val="raw_input_"/>
  <attr name="data_type" type="string" val="CRTGrenobleFrame"/>
diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index ae87d3a..2faf084 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -118,15 +118,12 @@
   <ref class="ActionPlan" id="crt-readout-start"/>
   <ref class="ActionPlan" id="crt-readout-stop"/>
  </rel>
- <rel name="queue_rules">
-  <ref class="QueueConnectionRule" id="crt-bern-raw-input-queue"/>
- </rel>
  <rel name="data_reader" class="CRTBernReaderConf" id="def-crt-bern-receiver-conf"/>
  <rel name="data_writer" class="SocketWriterConf" id="def-socket-writer-conf"/>
  <rel name="detector_connections">
   <ref class="SocketDetectorToDaqConnection" id="socket_crt"/>
  </rel>
- <rel name="callback_desc" class="DataMoveCallbackDescriptor" id="null_callback_desc"/>
+ <rel name="callback_desc" class="DataMoveCallbackDescriptor" id="crt-bern-raw-input"/>
 </obj>
 
 <obj class="DPDKPortConfiguration" id="dpdk_e810_conf">

From 310b0a3c0c87d36ef1e188e971439e736d9940ae Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Fri, 13 Mar 2026 17:02:20 +0100
Subject: [PATCH 04/11] Revert changes

---
 config/daqsystemtest/connections.data.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/config/daqsystemtest/connections.data.xml b/config/daqsystemtest/connections.data.xml
index f95d3c8..ffd4cd8 100644
--- a/config/daqsystemtest/connections.data.xml
+++ b/config/daqsystemtest/connections.data.xml
@@ -63,7 +63,7 @@
 
 <oks-data>
 
-<info name="" type="" num-of-items="65" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105549" last-modified-by="eflumerf" last-modified-on="ironvirt9.mshome.net" last-modification-time="20260202T153912"/>
+<info name="" type="" num-of-items="70" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105549" last-modified-by="eflumerf" last-modified-on="ironvirt9.mshome.net" last-modification-time="20260202T153912"/>
 
 <include>
  <file path="schema/confmodel/dunedaq.schema.xml"/>

From 8d9a0062a4e478dc7c839756339001342baeecba Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Tue, 17 Mar 2026 13:50:52 +0100
Subject: [PATCH 05/11] Example conf uses fake reader

---
 config/daqsystemtest/moduleconfs.data.xml | 4 ++--
 config/daqsystemtest/ru-segment.data.xml  | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/config/daqsystemtest/moduleconfs.data.xml b/config/daqsystemtest/moduleconfs.data.xml
index dcc1992..10c4bae 100644
--- a/config/daqsystemtest/moduleconfs.data.xml
+++ b/config/daqsystemtest/moduleconfs.data.xml
@@ -139,7 +139,7 @@
  <rel name="command" class="FSMCommand" id="start"/>
  <rel name="steps">
   <ref class="DaqModulesGroupByType" id="socket-writer-data-source-step"/>
-  <ref class="DaqModulesGroupByType" id="crt-bern-reader-data-source-step"/>
+  <ref class="DaqModulesGroupByType" id="data-source-step"/>
  </rel>
 </obj>
 
@@ -147,7 +147,7 @@
  <attr name="execution_policy" type="enum" val="modules-in-parallel"/>
  <rel name="command" class="FSMCommand" id="stop_trigger_sources"/>
  <rel name="steps">
-  <ref class="DaqModulesGroupByType" id="crt-bern-reader-data-source-step"/>
+  <ref class="DaqModulesGroupByType" id="data-source-step"/>
   <ref class="DaqModulesGroupByType" id="socket-writer-data-source-step"/>
  </rel>
 </obj>
diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index 2faf084..0b0c283 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -118,7 +118,7 @@
   <ref class="ActionPlan" id="crt-readout-start"/>
   <ref class="ActionPlan" id="crt-readout-stop"/>
  </rel>
- <rel name="data_reader" class="CRTBernReaderConf" id="def-crt-bern-receiver-conf"/>
+ <rel name="data_reader" class="CRTReaderConf" id="def-emu-crt-receiver-conf"/>
  <rel name="data_writer" class="SocketWriterConf" id="def-socket-writer-conf"/>
  <rel name="detector_connections">
   <ref class="SocketDetectorToDaqConnection" id="socket_crt"/>

From cd650328d43fa5d123aec6aabbbd386d068602b4 Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Tue, 17 Mar 2026 16:58:31 +0100
Subject: [PATCH 06/11] Added more streams to differentiate Grenoble/Bern with
 detector ID

---
 config/daqsystemtest/ru-segment.data.xml | 32 +++++++++++++++++++-----
 1 file changed, 26 insertions(+), 6 deletions(-)

diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index 0b0c283..d3361e2 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -63,7 +63,7 @@
 
 <oks-data>
 
-<info name="" type="" num-of-items="58" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105615" last-modified-by="dergonul" last-modified-on="np04-srv-015.cern.ch" last-modification-time="20260305T122304"/>
+<info name="" type="" num-of-items="62" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105615" last-modified-by="dergonul" last-modified-on="np04-srv-015.cern.ch" last-modification-time="20260305T122304"/>
 
 <include>
  <file path="schema/confmodel/dunedaq.schema.xml"/>
@@ -157,17 +157,17 @@
 
 <obj class="DetectorStream" id="stream_1007">
  <attr name="source_id" type="u32" val="1007"/>
- <rel name="geo_id" class="GeoId" id="g_13_1_1_0"/>
+ <rel name="geo_id" class="GeoId" id="g_12_1_1_0"/>
 </obj>
 
 <obj class="DetectorStream" id="stream_1008">
  <attr name="source_id" type="u32" val="1008"/>
- <rel name="geo_id" class="GeoId" id="g_13_1_1_1"/>
+ <rel name="geo_id" class="GeoId" id="g_12_1_1_1"/>
 </obj>
 
 <obj class="DetectorStream" id="stream_1009">
  <attr name="source_id" type="u32" val="1009"/>
- <rel name="geo_id" class="GeoId" id="g_13_2_1_0"/>
+ <rel name="geo_id" class="GeoId" id="g_12_2_1_0"/>
 </obj>
 
 <obj class="DetectorStream" id="stream_101">
@@ -177,7 +177,7 @@
 
 <obj class="DetectorStream" id="stream_1010">
  <attr name="source_id" type="u32" val="1010"/>
- <rel name="geo_id" class="GeoId" id="g_13_2_1_1"/>
+ <rel name="geo_id" class="GeoId" id="g_12_2_1_1"/>
 </obj>
 
 <obj class="DetectorStream" id="stream_102">
@@ -216,6 +216,26 @@
  <attr name="slot_id" type="u32" val="1"/>
 </obj>
 
+<obj class="GeoId" id="g_12_1_1_1">
+ <attr name="detector_id" type="u32" val="12"/>
+ <attr name="crate_id" type="u32" val="1"/>
+ <attr name="slot_id" type="u32" val="1"/>
+ <attr name="stream_id" type="u32" val="1"/>
+</obj>
+
+<obj class="GeoId" id="g_12_2_1_0">
+ <attr name="detector_id" type="u32" val="12"/>
+ <attr name="crate_id" type="u32" val="2"/>
+ <attr name="slot_id" type="u32" val="1"/>
+</obj>
+
+<obj class="GeoId" id="g_12_2_1_1">
+ <attr name="detector_id" type="u32" val="12"/>
+ <attr name="crate_id" type="u32" val="2"/>
+ <attr name="slot_id" type="u32" val="1"/>
+ <attr name="stream_id" type="u32" val="1"/>
+</obj>
+
 <obj class="GeoId" id="g_13_1_1_0">
  <attr name="detector_id" type="u32" val="13"/>
  <attr name="crate_id" type="u32" val="1"/>
@@ -567,7 +587,7 @@
 </obj>
 
 <obj class="SocketDataSender" id="socket_sender_crt_2">
- <attr name="socket_type" type="enum" val="TCP"/>
+ <attr name="socket_type" type="enum" val="UDP"/>
  <attr name="local_port" type="u32" val="12346"/>
  <attr name="remote_port" type="u32" val="20002"/>
  <rel name="streams">

From 1cbddd56b951737d33ec5ddbc3d3776e3d093fe2 Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Tue, 17 Mar 2026 17:18:46 +0100
Subject: [PATCH 07/11] TCP instead of UDP

---
 config/daqsystemtest/ru-segment.data.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index d3361e2..ba7de41 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -587,7 +587,7 @@
 </obj>
 
 <obj class="SocketDataSender" id="socket_sender_crt_2">
- <attr name="socket_type" type="enum" val="UDP"/>
+ <attr name="socket_type" type="enum" val="TCP"/>
  <attr name="local_port" type="u32" val="12346"/>
  <attr name="remote_port" type="u32" val="20002"/>
  <rel name="streams">

From 60d69ea21a385f92bc810d6b4e3790066ba4989a Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Wed, 18 Mar 2026 17:36:06 +0100
Subject: [PATCH 08/11] New schema added

---
 config/daqsystemtest/ru-segment.data.xml | 1 +
 1 file changed, 1 insertion(+)

diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index ba7de41..ef819d7 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -70,6 +70,7 @@
  <file path="schema/appmodel/application.schema.xml"/>
  <file path="schema/appmodel/fdmodules.schema.xml"/>
  <file path="schema/appmodel/wiec.schema.xml"/>
+ <file path="schema/appmodel/socket.schema.xml"/>
  <file path="config/daqsystemtest/connections.data.xml"/>
  <file path="config/daqsystemtest/moduleconfs.data.xml"/>
  <file path="config/daqsystemtest/hosts.data.xml"/>

From 12d5b803914c789578db8a7910fc03b3744c8276 Mon Sep 17 00:00:00 2001
From: Kurt Biery <biery@daq.fnal.gov>
Date: Thu, 19 Mar 2026 10:00:42 -0500
Subject: [PATCH 09/11] In readout_type_scan_test.py, increased the readout
 window sizes for the two CRT-based configurations to take into account the
 recent changes in the CRT fake-data parameters.

---
 integtest/readout_type_scan_test.py | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/integtest/readout_type_scan_test.py b/integtest/readout_type_scan_test.py
index 640540e..a843ce1 100644
--- a/integtest/readout_type_scan_test.py
+++ b/integtest/readout_type_scan_test.py
@@ -355,11 +355,24 @@
 bern_crt_conf = copy.deepcopy(conf_dict)
 bern_crt_conf.dro_map_config.det_id = 12
 bern_crt_conf.frame_file = "asset://?checksum=dd156b4895f1b06a06b6ff38e37bd798" # WIBEth All Zeros
+bern_crt_conf.config_substitutions.append(
+    data_classes.attribute_substitution(
+        obj_class="RandomTCMakerConf",
+        obj_id="random-tc-generator",
+        updates={"candidate_window_before_ts": 8000, "candidate_window_after_ts": 10},
+    )
+)
 
 grenoble_crt_conf = copy.deepcopy(conf_dict)
 grenoble_crt_conf.dro_map_config.det_id = 13
 grenoble_crt_conf.frame_file = "asset://?checksum=dd156b4895f1b06a06b6ff38e37bd798" # WIBEth All Zeros
-
+grenoble_crt_conf.config_substitutions.append(
+    data_classes.attribute_substitution(
+        obj_class="RandomTCMakerConf",
+        obj_id="random-tc-generator",
+        updates={"candidate_window_before_ts": 8000, "candidate_window_after_ts": 10},
+    )
+)
 
 confgen_arguments = {
     "WIBEth_System": wibeth_conf,

From bf85270a8089df49ab437e47ace5905d9e1f4798 Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Fri, 20 Mar 2026 10:25:14 +0100
Subject: [PATCH 10/11] CRTReader is not a DataReader

---
 config/daqsystemtest/moduleconfs.data.xml | 24 ++++++++---------------
 config/daqsystemtest/ru-segment.data.xml  |  6 +++---
 2 files changed, 11 insertions(+), 19 deletions(-)

diff --git a/config/daqsystemtest/moduleconfs.data.xml b/config/daqsystemtest/moduleconfs.data.xml
index 10c4bae..7ccb7d9 100644
--- a/config/daqsystemtest/moduleconfs.data.xml
+++ b/config/daqsystemtest/moduleconfs.data.xml
@@ -225,20 +225,12 @@
  </rel>
 </obj>
 
-<obj class="CRTBernReaderConf" id="def-crt-bern-receiver-conf">
- <attr name="template_for" type="class" val="CRTBernReaderModule"/>
- <attr name="emulation_mode" type="bool" val="0"/>
-</obj>
-
-<obj class="CRTGrenobleReaderConf" id="def-crt-grenoble-receiver-conf">
- <attr name="template_for" type="class" val="CRTGrenobleReaderModule"/>
- <attr name="emulation_mode" type="bool" val="0"/>
+<obj class="CRTBernFrameBuilderConf" id="def-crt-bern-frame-builder-conf">
+ <attr name="template_for" type="class" val="CRTBernFrameBuilderModule"/>
 </obj>
 
-<obj class="CRTReaderConf" id="def-emu-crt-receiver-conf">
- <attr name="template_for" type="class" val="FDFakeReaderModule"/>
- <attr name="emulation_mode" type="bool" val="1"/>
- <rel name="emulation_conf" class="StreamEmulationParameters" id="crt-stream-emu"/>
+<obj class="CRTGrenobleFrameBuilderConf" id="def-crt-grenoble-frame-builder-conf">
+ <attr name="template_for" type="class" val="CRTGrenobleFrameBuilderModule"/>
 </obj>
 
 <obj class="DFOConf" id="dfoconf-01">
@@ -267,17 +259,17 @@
  </attr>
 </obj>
 
-<obj class="DaqModulesGroupByType" id="crt-bern-reader-data-source-step">
+<obj class="DaqModulesGroupByType" id="crt-bern-frame-builder-data-source-step">
  <attr name="optional" type="bool" val="0"/>
  <attr name="modules" type="class">
-  <data val="CRTBernReaderModule"/>
+  <data val="CRTBernFrameBuilderModule"/>
  </attr>
 </obj>
 
-<obj class="DaqModulesGroupByType" id="crt-grenoble-reader-data-source-step">
+<obj class="DaqModulesGroupByType" id="crt-grenoble-frame-builder-data-source-step">
  <attr name="optional" type="bool" val="0"/>
  <attr name="modules" type="class">
-  <data val="CRTGrenobleReaderModule"/>
+  <data val="CRTGrenobleFrameBuilderModule"/>
  </attr>
 </obj>
 
diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index ef819d7..6260f64 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -108,7 +108,7 @@
 </comments>
 
 
-<obj class="CRTReaderApplication" id="crt-data-source-01">
+<obj class="CRTFrameBuilderApplication" id="crt-data-source-01">
  <attr name="application_name" type="string" val="daq_application"/>
  <rel name="runs_on" class="VirtualHost" id="vlocalhost"/>
  <rel name="exposes_service">
@@ -119,7 +119,7 @@
   <ref class="ActionPlan" id="crt-readout-start"/>
   <ref class="ActionPlan" id="crt-readout-stop"/>
  </rel>
- <rel name="data_reader" class="CRTReaderConf" id="def-emu-crt-receiver-conf"/>
+ <rel name="detector_frame_builder" class="CRTFrameBuilderConf" id="def-crt-bern-frame-builder-conf"/>
  <rel name="data_writer" class="SocketWriterConf" id="def-socket-writer-conf"/>
  <rel name="detector_connections">
   <ref class="SocketDetectorToDaqConnection" id="socket_crt"/>
@@ -570,7 +570,7 @@
 
 <obj class="Segment" id="socket-ru-segment">
  <rel name="applications">
-  <ref class="CRTReaderApplication" id="crt-data-source-01"/>
+  <ref class="CRTFrameBuilderApplication" id="crt-data-source-01"/>
   <ref class="ReadoutApplication" id="socket-ru-01"/>
  </rel>
  <rel name="controller" class="RCApplication" id="socket-ru-controller"/>

From dd81634610f2a1acffa0e9686873d55c20ef2a3d Mon Sep 17 00:00:00 2001
From: Deniz Tuana Ergonul Uzun <deniz.tuana.ergonul@cern.ch>
Date: Mon, 23 Mar 2026 13:09:40 +0100
Subject: [PATCH 11/11] Switch to IOM

---
 config/daqsystemtest/connections.data.xml | 27 ++++++++++++++++++++++-
 config/daqsystemtest/moduleconfs.data.xml |  4 ++--
 config/daqsystemtest/ru-segment.data.xml  |  6 +++--
 docs/bundle_script_overview.md            |  6 ++---
 4 files changed, 35 insertions(+), 8 deletions(-)

diff --git a/config/daqsystemtest/connections.data.xml b/config/daqsystemtest/connections.data.xml
index ffd4cd8..f56816a 100644
--- a/config/daqsystemtest/connections.data.xml
+++ b/config/daqsystemtest/connections.data.xml
@@ -63,7 +63,7 @@
 
 <oks-data>
 
-<info name="" type="" num-of-items="70" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105549" last-modified-by="eflumerf" last-modified-on="ironvirt9.mshome.net" last-modification-time="20260202T153912"/>
+<info name="" type="" num-of-items="74" oks-format="data" oks-version="862f2957270" created-by="gjc" created-on="thinkpad" creation-time="20231207T105549" last-modified-by="dergonul" last-modified-on="np04-srv-015.cern.ch" last-modification-time="20260320T111440"/>
 
 <include>
  <file path="schema/confmodel/dunedaq.schema.xml"/>
@@ -74,6 +74,7 @@
 
 <comments>
  <comment creation-time="20250526T123756" created-by="dergonul" created-on="np04-srv-031.cern.ch" author="dergonul" text="Added CRT queue rules"/>
+ <comment creation-time="20260320T111440" created-by="dergonul" created-on="np04-srv-015.cern.ch" author="dergonul" text="Added queue rules for CRT frames"/>
 </comments>
 
 
@@ -258,6 +259,16 @@
  <rel name="descriptor" class="NetworkConnectionDescriptor" id="timesync-publisher"/>
 </obj>
 
+<obj class="QueueConnectionRule" id="crt-bern-sender-input-queue-rule">
+ <attr name="destination_class" type="class" val="DaqModule"/>
+ <rel name="descriptor" class="QueueDescriptor" id="crt-bern-sender-input"/>
+</obj>
+
+<obj class="QueueConnectionRule" id="crt-grenoble-sender-input-queue-rule">
+ <attr name="destination_class" type="class" val="DaqModule"/>
+ <rel name="descriptor" class="QueueDescriptor" id="crt-grenoble-sender-input"/>
+</obj>
+
 <obj class="QueueConnectionRule" id="fa-queue-rule">
  <attr name="destination_class" type="class" val="FragmentAggregatorModule"/>
  <rel name="descriptor" class="QueueDescriptor" id="fa-input"/>
@@ -313,6 +324,20 @@
  <rel name="descriptor" class="QueueDescriptor" id="trigger-records"/>
 </obj>
 
+<obj class="QueueDescriptor" id="crt-bern-sender-input">
+ <attr name="uid_base" type="string" val="sender_input_"/>
+ <attr name="queue_type" type="enum" val="kFollyMPMCQueue"/>
+ <attr name="capacity" type="u32" val="10000"/>
+ <attr name="data_type" type="string" val="CRTBernFrame"/>
+</obj>
+
+<obj class="QueueDescriptor" id="crt-grenoble-sender-input">
+ <attr name="uid_base" type="string" val="sender_input_"/>
+ <attr name="queue_type" type="enum" val="kFollyMPMCQueue"/>
+ <attr name="capacity" type="u32" val="10000"/>
+ <attr name="data_type" type="string" val="CRTGrenobleFrame"/>
+</obj>
+
 <obj class="QueueDescriptor" id="data-req-queue-desc">
  <attr name="uid_base" type="string" val="internal_data_requests_for_"/>
  <attr name="queue_type" type="enum" val="kFollySPSCQueue"/>
diff --git a/config/daqsystemtest/moduleconfs.data.xml b/config/daqsystemtest/moduleconfs.data.xml
index 7ccb7d9..0cb78c4 100644
--- a/config/daqsystemtest/moduleconfs.data.xml
+++ b/config/daqsystemtest/moduleconfs.data.xml
@@ -139,7 +139,7 @@
  <rel name="command" class="FSMCommand" id="start"/>
  <rel name="steps">
   <ref class="DaqModulesGroupByType" id="socket-writer-data-source-step"/>
-  <ref class="DaqModulesGroupByType" id="data-source-step"/>
+  <ref class="DaqModulesGroupByType" id="crt-bern-frame-builder-data-source-step"/>
  </rel>
 </obj>
 
@@ -147,7 +147,7 @@
  <attr name="execution_policy" type="enum" val="modules-in-parallel"/>
  <rel name="command" class="FSMCommand" id="stop_trigger_sources"/>
  <rel name="steps">
-  <ref class="DaqModulesGroupByType" id="data-source-step"/>
+  <ref class="DaqModulesGroupByType" id="crt-bern-frame-builder-data-source-step"/>
   <ref class="DaqModulesGroupByType" id="socket-writer-data-source-step"/>
  </rel>
 </obj>
diff --git a/config/daqsystemtest/ru-segment.data.xml b/config/daqsystemtest/ru-segment.data.xml
index 6260f64..f8482b3 100644
--- a/config/daqsystemtest/ru-segment.data.xml
+++ b/config/daqsystemtest/ru-segment.data.xml
@@ -119,12 +119,14 @@
   <ref class="ActionPlan" id="crt-readout-start"/>
   <ref class="ActionPlan" id="crt-readout-stop"/>
  </rel>
- <rel name="detector_frame_builder" class="CRTFrameBuilderConf" id="def-crt-bern-frame-builder-conf"/>
+ <rel name="queue_rules">
+  <ref class="QueueConnectionRule" id="crt-bern-sender-input-queue-rule"/>
+ </rel> 
+ <rel name="detector_frame_builder" class="CRTBernFrameBuilderConf" id="def-crt-bern-frame-builder-conf"/>
  <rel name="data_writer" class="SocketWriterConf" id="def-socket-writer-conf"/>
  <rel name="detector_connections">
   <ref class="SocketDetectorToDaqConnection" id="socket_crt"/>
  </rel>
- <rel name="callback_desc" class="DataMoveCallbackDescriptor" id="crt-bern-raw-input"/>
 </obj>
 
 <obj class="DPDKPortConfiguration" id="dpdk_e810_conf">
diff --git a/docs/bundle_script_overview.md b/docs/bundle_script_overview.md
index aa80548..3bca4d6 100644
--- a/docs/bundle_script_overview.md
+++ b/docs/bundle_script_overview.md
@@ -112,7 +112,7 @@ The following tests will be run:
 
 The following tests will be run:
   asiolibs/socket_reader_test.py
-  crtmodules/crt_reader_test.py
+  crtmodules/crt_frame_builder_test.py
 
 (dbt) [biery@daq]$ dunedaq_integtest_bundle.sh -r local -k tp --list-only
 
@@ -143,7 +143,7 @@ The following tests will be run:
 Looking for integtests in _all_ repos...
 
 asiolibs/socket_reader_test.py
-crtmodules/crt_reader_test.py
+crtmodules/crt_frame_builder_test.py
 daqsystemtest/3ru_1df_multirun_test.py
 daqsystemtest/3ru_3df_multirun_test.py
 daqsystemtest/example_system_test.py
@@ -205,7 +205,7 @@ dfmodules/trmonrequestor_test.py
 Looking for integtests in the _asiolibs crtmodules_ repo(s)...
 
 asiolibs/socket_reader_test.py
-crtmodules/crt_reader_test.py
+crtmodules/crt_frame_builder_test.py
 
 (dbt) [biery@daq]$ list_available_integtests.sh asdf jklp