From a13c5b81e2ce5e6ed41c852658b2c6f25d75b3b6 Mon Sep 17 00:00:00 2001 From: Edward Wall Date: Tue, 18 Nov 2025 14:27:41 +0100 Subject: [PATCH] woops, strings got deleted --- src/asynStreamGeneratorDriver.cpp | 10 ++++++---- src/asynStreamGeneratorDriver.h | 4 ++-- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/src/asynStreamGeneratorDriver.cpp b/src/asynStreamGeneratorDriver.cpp index f862f85..4d816b0 100644 --- a/src/asynStreamGeneratorDriver.cpp +++ b/src/asynStreamGeneratorDriver.cpp @@ -217,13 +217,13 @@ asynStreamGeneratorDriver::asynStreamGeneratorDriver( epicsStdoutPrintf( "Detector Kafka Config: broker=%s, topic=%s\n " " queue size:%d, max events per packet: %d\n", - kafkaBroker, this->detectorTopic, kafkaQueueSize, + kafkaBroker, this->detectorTopic.c_str(), kafkaQueueSize, this->kafkaMaxPacketSize); epicsStdoutPrintf( "Monitors Kafka Config: broker=%s, topic=%s\n " " queue size:%d, max events per packet: %d\n", - kafkaBroker, this->monitorTopic, kafkaQueueSize, + kafkaBroker, this->monitorTopic.c_str(), kafkaQueueSize, this->kafkaMaxPacketSize); this->monitorProducer = create_kafka_producer(kafkaBroker); @@ -874,11 +874,13 @@ void asynStreamGeneratorDriver::produce(epicsRingBytesId eventQueue, } void asynStreamGeneratorDriver::produceMonitor() { - this->produce(monitorQueue, monitorProducer, monitorTopic, "monitor"); + this->produce(monitorQueue, monitorProducer, monitorTopic.c_str(), + "monitor"); } void asynStreamGeneratorDriver::produceDetector() { - this->produce(detectorQueue, detectorProducer, detectorTopic, "detector"); + this->produce(detectorQueue, detectorProducer, detectorTopic.c_str(), + "detector"); } /******************************************************************************* diff --git a/src/asynStreamGeneratorDriver.h b/src/asynStreamGeneratorDriver.h index 1ff71eb..f5c1db1 100644 --- a/src/asynStreamGeneratorDriver.h +++ b/src/asynStreamGeneratorDriver.h @@ -194,11 +194,11 @@ class asynStreamGeneratorDriver : public asynPortDriver { epicsRingBytesId monitorQueue; rd_kafka_t *monitorProducer; - const char *monitorTopic; + const std::string monitorTopic; epicsRingBytesId detectorQueue; rd_kafka_t *detectorProducer; - const char *detectorTopic; + const std::string detectorTopic; static constexpr char driverName[]{"StreamGenerator"};