From a0d83abee95e0ba7fcb882c970a76576cd3afb81 Mon Sep 17 00:00:00 2001 From: Trygve Laugstøl Date: Tue, 21 Jul 2015 11:26:42 +0200 Subject: Fixing two bugs in mqtt-publish: o The last character after EOF was parsed twice. o Create a separate counter for unacked messages instead of checking want_write. --- sensor/include/trygvis/sensor/io.h | 6 ++++++ sensor/main/io.cpp | 1 - 2 files changed, 6 insertions(+), 1 deletion(-) (limited to 'sensor') diff --git a/sensor/include/trygvis/sensor/io.h b/sensor/include/trygvis/sensor/io.h index dd1460b..71b0b84 100644 --- a/sensor/include/trygvis/sensor/io.h +++ b/sensor/include/trygvis/sensor/io.h @@ -208,6 +208,12 @@ class SampleStreamParser { public: virtual int process(mutable_buffers_1 &buffer) = 0; + /** + * Tells the parser that the data that has been written so far either "is it" (there is no more input) or that + * it should just process what it has so far. It is ok to call process() after again after this method. + * + * TODO: should probably be renamed to "process()", "flush()" or "done()". + */ virtual int finish() = 0; virtual sample_format_type type() { diff --git a/sensor/main/io.cpp b/sensor/main/io.cpp index 6c384ff..74bc796 100644 --- a/sensor/main/io.cpp +++ b/sensor/main/io.cpp @@ -71,7 +71,6 @@ void ThreadSafeSampleOutputStream::write(SampleRecord const &sample) { underlying->write(sample); } - AddTimestampSampleOutputStream::AddTimestampSampleOutputStream(unique_ptr underlying, KeyDictionary &dict, const string ×tamp_name) : underlying_(move(underlying)), timestamp_key(dict.indexOf(timestamp_name)) { -- cgit v1.2.3