From 9aae8ab432ef7f42756bd4c44574b6214a1dce64 Mon Sep 17 00:00:00 2001
From: Jonathan Hanks <jonathan.hanks@ligo.org>
Date: Fri, 1 May 2020 10:33:47 -0700
Subject: [PATCH] Minor updates to address review questions.
Update a comment to correct a name. Put a magic number into a constant.
---
src/pub_sub_stream/plugins/sub_plugin_daq_m.cc | 2 +-
src/pub_sub_stream/plugins/sub_plugin_rmipc.cc | 3 ++-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/pub_sub_stream/plugins/sub_plugin_daq_m.cc b/src/pub_sub_stream/plugins/sub_plugin_daq_m.cc
index 08832f9a5..6c985f4ff 100644
--- a/src/pub_sub_stream/plugins/sub_plugin_daq_m.cc
+++ b/src/pub_sub_stream/plugins/sub_plugin_daq_m.cc
@@ -1,6 +1,6 @@
/*!
* @file
- * @brief a subscription interface to the mbuf based rmIpcStr data
+ * @brief a subscription interface to the mbuf based daq_m data
*/
#include <iostream>
diff --git a/src/pub_sub_stream/plugins/sub_plugin_rmipc.cc b/src/pub_sub_stream/plugins/sub_plugin_rmipc.cc
index c8f45cd4b..986c8a0ce 100644
--- a/src/pub_sub_stream/plugins/sub_plugin_rmipc.cc
+++ b/src/pub_sub_stream/plugins/sub_plugin_rmipc.cc
@@ -70,6 +70,7 @@ namespace cps_plugins
memory_arena_( 5 ), stopping_{ false }, th_{}
{
std::size_t i = 0;
+ size_t FE_MBUF_SIZE = 64*1024*1024;
if ( !symmetricom_fd.get( ) )
{
@@ -79,7 +80,7 @@ namespace cps_plugins
{
std::string shmem_fname = name + "_daq";
void* dcu_addr = (void*)shmem_open_segment(
- shmem_fname.c_str( ), 64 * 1024 * 1024 );
+ shmem_fname.c_str( ), FE_MBUF_SIZE );
if ( !dcu_addr )
{
throw std::runtime_error(
--
GitLab