Restore FluidDataWr C++ atfer overzealous revert

nix
Owen Green 6 years ago
parent 7a1bdc5a02
commit 5bd0832981

@ -23,18 +23,19 @@ namespace client {
class DataSetWriterClient : public FluidBaseClient, OfflineIn, OfflineOut class DataSetWriterClient : public FluidBaseClient, OfflineIn, OfflineOut
{ {
public: public:
FLUID_DECLARE_PARAMS(StringParam("label", "Label"), FLUID_DECLARE_PARAMS(
BufferParam("buf", "Data Buffer"), DataSetClientRef::makeParam("dataSet", "DataSet Name"),
DataSetClientRef::makeParam("dataSet", "DataSet Name")); StringParam("labelPrefix","Label Prefix"),
LongParam("labelOffset", "Label Counter Offset", 0),
BufferParam("buf", "Data Buffer")
);
DataSetWriterClient(ParamSetViewType& p) : mParams(p) {} DataSetWriterClient(ParamSetViewType& p) : mParams(p) {}
template <typename T> template <typename T>
Result process(FluidContext&) Result process(FluidContext&)
{ {
auto& idx = get<0>(); auto dataset = get<0>().get();
auto buf = get<1>();
auto dataset = get<2>().get();
if (auto datasetPtr = dataset.lock()) if (auto datasetPtr = dataset.lock())
{ {
std::stringstream ss; std::stringstream ss;
@ -43,13 +44,15 @@ public:
index labelOffset = get<2>(); index labelOffset = get<2>();
if(labelOffset >= 0) ss << labelOffset + (mCounter++); if(labelOffset >= 0) ss << labelOffset + (mCounter++);
auto buf = get<3>(); auto buf = get<3>();
return datasetPtr->addPoint(ss.str(), buf); return datasetPtr->addPoint(ss.str(), buf);
} }
else else
return {Result::Status::kError, "No dataset"}; return {Result::Status::kError, "No dataset"};
} }
private:
index mCounter{0};
}; };
using NRTThreadedDataSetWriter = using NRTThreadedDataSetWriter =

Loading…
Cancel
Save