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

@@ @@ -47,6 +47,17 @@ void Sink::setNumChannels(unsigned nc, b @@
+{
     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

@@ @@ -31,26 +31,35 @@ 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

@@ @@ -21,21 +21,25 @@ @@
 #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)

tests/test.cpp

➞

Show inline comments

@@ @@ -120,12 +120,18 @@ TEST_CASE("sink", "[memory, stream]") @@
     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;
@@ @@ -182,12 +188,24 @@ TEST_CASE("source", "[memory, stream]") @@
     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++)

0 comments (0 inline, 0 general)