History

TimeSeriesPlatformLibrary: Added code to handle application of meta-data filters.

J. Ritchie Carroll committed 7 years ago

Commit 9939c551 parent b9d9ecb10 files · +206 −17Browse files

Showing the changes to Source/Libraries/TimeSeriesPlatformLibrary/Samples/SubscriberHandler.cpp (1 of 10 files). Show all

Unified · Split

Source/Libraries/TimeSeriesPlatformLibrary/Samples/SubscriberHandler.cpp+5−6
@@ -32,9 +32,9 @@ using namespace std; · 31 unmodified lines
32using namespace GSF;32using namespace GSF;
33using namespace GSF::TimeSeries;33using namespace GSF::TimeSeries;
34 34
35SubscriberHandler::SubscriberHandler(const string& name)35SubscriberHandler::SubscriberHandler(string name) :
36 m_name(std::move(name))
36{37{
37 m_name = name;
38}38}
39 39
40SubscriptionInfo SubscriberHandler::CreateSubscriptionInfo()40SubscriptionInfo SubscriberHandler::CreateSubscriptionInfo()
@@ -153,9 +153,9 @@ void SubscriberHandler::ReceivedNewMeasurements(const vector<MeasurementPtr>& me · 112 unmodified lines
153 153
154 static long processCount = 0;154 static long processCount = 0;
155 static char timestamp[MaxTimestampSize];155 static char timestamp[MaxTimestampSize];
156 static const long interval = 5 * 60;156 static const long interval = 10 * 60;
157 const long measurementCount = measurements.size();157 const long measurementCount = measurements.size();
158 const bool showMessage = true; // (processCount + measurementCount >= (processCount / interval + 1) * interval);158 const bool showMessage = (processCount + measurementCount >= (processCount / interval + 1) * interval);
159 159
160 processCount += measurementCount;160 processCount += measurementCount;
161 161
@@ -194,8 +194,7 @@ void SubscriberHandler::HistoricalReadComplete() · 32 unmodified lines
194 194
195void SubscriberHandler::ConnectionEstablished()195void SubscriberHandler::ConnectionEstablished()
196{196{
197 StatusMessage("Connection established.");197 StatusMessage("Connection established.");
198
199}198}
200 199
201void SubscriberHandler::ConnectionTerminated()200void SubscriberHandler::ConnectionTerminated()

Keyboard shortcuts

General

Show keyboard shortcuts
?
Focus the current search
/

Issues and pull requests

Open filters
f

Issues, pull requests and Inbox

Select next item
j↓
Select previous item
k↑
Open selected item
Enter
Dismiss filters or clear selection
Esc

Repository code

Go to file
t