Skip to content
Snippets Groups Projects
Commit 23a1201c authored by Lamar Moore's avatar Lamar Moore
Browse files

clang and revert Facilities.xml to remove DENEX

parent 34c8da7d
No related branches found
No related tags found
No related merge requests found
......@@ -631,19 +631,19 @@ void KafkaEventStreamDecoder::initLocalCaches(
// Buffers for each period
size_t nperiods = runStartData.nPeriods;
if (nperiods == 0) {
g_log.warning(
"KafkaEventStreamDecoder - Stream reports 0 periods. This is "
"an error by the data producer. Number of periods being set to 1.");
nperiods = 1;
g_log.warning(
"KafkaEventStreamDecoder - Stream reports 0 periods. This is "
"an error by the data producer. Number of periods being set to 1.");
nperiods = 1;
}
{
std::lock_guard<std::mutex> workspaceLock(m_mutex);
m_localEvents.resize(nperiods);
m_localEvents[0] = eventBuffer;
for (size_t i = 1; i < nperiods; ++i) {
// A clone should be cheap here as there are no events yet
m_localEvents[i] = eventBuffer->clone();
}
std::lock_guard<std::mutex> workspaceLock(m_mutex);
m_localEvents.resize(nperiods);
m_localEvents[0] = eventBuffer;
for (size_t i = 1; i < nperiods; ++i) {
// A clone should be cheap here as there are no events yet
m_localEvents[i] = eventBuffer->clone();
}
}
// New caches so LoadLiveData's output workspace needs to be replaced
......
......@@ -50,14 +50,6 @@
<connection name="event" address="NDXENGINX:10000" listener="ISISLiveEventDataListener" />
</livedata>
</instrument>
<instrument name="DENEX" shortname="DENEX" >
<zeropadding size="8" />
<technique>Neutron Diffraction</technique>
<livedata default="event">
<connection name="event" address="sakura:9092" listener="KafkaEventListener" />
</livedata>
</instrument>
<instrument name="GEM">
<technique>Neutron Diffraction</technique>
......
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