tempo-plotter Changeset - 46213689acd3 · protofusion repositories

Changeset - 46213689acd3

Parent rev.

Child rev.

[Not reviewed]

stream

0 4 0

Hasan Yavuz ÖZDERYA - 8 years ago 2017-12-19 10:13:34
hy@ozderya.net

sink stores pointer to connected source

4 files changed with 42 insertions and 0 deletions:

src/sink.cpp

src/sink.h

src/source.cpp

tests/test.cpp

0 comments (0 inline, 0 general)

src/sink.cpp

➞

Show inline comments

@@ @@ -41,12 +41,23 @@ void Sink::feedIn(const SamplePack& data @@
+    {
         sink->feedIn(data);
+    }
+}
 void Sink::setNumChannels(unsigned nc, bool x)
+{
     for (auto sink : followers)
+    {
         sink->setNumChannels(nc, x);
+    }
+}
 void Sink::setSource(const Source* s)
+{
     Q_ASSERT((source == NULL) != (s == NULL));
     source = s;
+}
 const Source* Sink::connectedSource() const
+{
     return source;
+}

src/sink.h

➞

Show inline comments

@@ @@ -25,32 +25,41 @@ @@
 class Source;
 class Sink
+{
 public:
     /// Connects a sink to get any data that this sink
     /// gets. Connecting an already connected sink is an error.
     void connectFollower(Sink* sink);
     /// Disconnects a follower. Disconnecting an unconnected sink is
     /// an error.
     void disconnectFollower(Sink* sink);
     /// Returns the connected source. `NULL` if it's not connected.
     const Source* connectedSource() const;
 protected:
     /// Entry point for incoming data. Re-implementations should
     /// call this function to feed followers.
     virtual void feedIn(const SamplePack& data);
     /// Is set by connected source. Re-implementations should call
     /// this function to update followers.
     virtual void setNumChannels(unsigned nc, bool x);
     /// Returns true if sink has X data
     virtual bool hasX() const = 0;
     /// Returns number of channels
     virtual unsigned numChannels() const = 0;
     /// Set by the connected source when its connected. When
     /// disconnecting it's set to `NULL`.
     ///
     /// @important Trying to connect a source while its already
     /// connected is an error.
     void setSource(const Source* s);
     friend Source;
 private:
     QList<Sink*> followers;
     const Source* source = NULL;   ///< source that this sink is connected to
 };
 #endif // SINK_H

src/source.cpp

➞

Show inline comments

@@ @@ -15,33 +15,37 @@ @@
   You should have received a copy of the GNU General Public License
   along with serialplot.  If not, see <http://www.gnu.org/licenses/>.
 */
 #include <QtGlobal>
 #include "source.h"
 void Source::connect(Sink* sink)
+{
     Q_ASSERT(!sinks.contains(sink));
     Q_ASSERT(sink->connectedSource() == NULL);
     sinks.append(sink);
     sink->setSource(this);
     sink->setNumChannels(numChannels(), hasX());
+}
 void Source::disconnect(Sink* sink)
+{
     Q_ASSERT(sinks.contains(sink));
     Q_ASSERT(sink->connectedSource() == this);
     sink->setSource(NULL);
     sinks.removeOne(sink);
+}
 void Source::feedOut(const SamplePack& data) const
+{
     for (auto sink : sinks)
+    {
         sink->feedIn(data);
+    }
+}
 void Source::updateNumChannels() const

tests/test.cpp

➞

Show inline comments

@@ @@ -114,24 +114,30 @@ TEST_CASE("sink", "[memory, stream]") @@
     REQUIRE(follower.numChannels() == 3);
     REQUIRE(follower.hasX() == false);
     sink.feedIn(pack);
     REQUIRE(sink.totalFed == 300);
     REQUIRE(follower.totalFed == 100);
     sink.setNumChannels(2, true);
     REQUIRE(follower.numChannels() == 2);
     REQUIRE(follower.hasX() == true);
+}
 TEST_CASE("sink must be created unconnected", "[memory, stream]")
+{
     TestSink sink;
     REQUIRE(sink.connectedSource() == NULL);
+}
 class TestSource : public Source
+{
 public:
     int _numChannels;
     bool _hasX;
     TestSource(unsigned nc, bool x)
+        {
             _numChannels = nc;
             _hasX = x;
         };
@@ @@ -176,24 +182,36 @@ TEST_CASE("source", "[memory, stream]") @@
     REQUIRE(sink.numChannels() == 5);
     REQUIRE(sink.hasX() == true);
     SamplePack pack(100, 5, true);
     source._feed(pack);
     REQUIRE(sink.totalFed == 100);
     source.disconnect(&sink);
     source._feed(pack);
     REQUIRE(sink.totalFed == 100);
+}
 TEST_CASE("source must set/unset sink 'source'", "[memory, stream]")
+{
     TestSink sink;
     TestSource source(3, false);
     source.connect(&sink);
     REQUIRE(sink.connectedSource() == &source);
     source.disconnect(&sink);
     REQUIRE(sink.connectedSource() == NULL);
+}
 TEST_CASE("IndexBuffer", "[memory, buffer]")
+{
     IndexBuffer buf(10);
     REQUIRE(buf.size() == 10);
     for (unsigned i = 0; i < 10; i++)
+    {
         REQUIRE(buf.sample(i) == i);
+    }
     auto l = buf.limits();
     REQUIRE(l.start == 0);
     REQUIRE(l.end == 9);

0 comments (0 inline, 0 general)