tempo-plotter Changeset - 9ce163ba1b88 · protofusion repositories

Changeset - 9ce163ba1b88

Parent rev.

Child rev.

[Not reviewed]

stream

0 3 0

Hasan Yavuz ÖZDERYA - 8 years ago 2018-04-03 15:37:27
hy@ozderya.net

added method for disconnecting all sinks

3 files changed with 31 insertions and 1 deletions:

src/source.cpp

src/source.h

tests/test.cpp

0 comments (0 inline, 0 general)

src/source.cpp

➞

Show inline comments

@@ @@ -27,39 +27,48 @@ Source::~Source() @@
+    {
         sink->setSource(NULL);
+    }
+}
 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::disconnectSinks()
+{
     while (!sinks.isEmpty())
+    {
         auto sink = sinks.takeFirst();
         sink->setSource(NULL);
+    }
+}
 void Source::feedOut(const SamplePack& data) const
+{
     for (auto sink : sinks)
+    {
         sink->feedIn(data);
+    }
+}
 void Source::updateNumChannels() const
+{
     for (auto sink : sinks)
+    {
         sink->setNumChannels(numChannels(), hasX());
+    }
+}

src/source.h

➞

Show inline comments

@@ @@ -24,37 +24,40 @@ @@
 #include "sink.h"
 #include "samplepack.h"
 class Source
+{
 public:
     /// Virtual destructor. Must be called by implementors to notify sinks.
     virtual ~Source();
     /// Returns true if source has X data
     virtual bool hasX() const = 0;
     /// Returns number of channels
     virtual unsigned numChannels() const = 0;
     /// Connects a sink to this source. Trying to connect an already
     /// connected sink is an error.
     void connect(Sink* sink);
     /// Disconnects an already connected sink. Trying to disconnect an
     /// unconnected sink is an error.
     void disconnect(Sink* sink);
     /// Disconnects all connected sinks.
     void disconnectSinks();
 protected:
     /// Feeds "in" given data to connected sinks
     void feedOut(const SamplePack& data) const;
+    virtual void feedOut(const SamplePack& data) const;
     /// Updates "number of channels" of connected sinks. Must be
     /// called when num. channels or hasX changes.
     void updateNumChannels() const;
 private:
     QList<Sink*> sinks;
 };
 #endif // SOURCE_H

tests/test.cpp

➞

Show inline comments

@@ @@ -106,48 +106,66 @@ 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("source disconnect all sinks", "[memory, stream]")
+{
     TestSink sinks[3];
     TestSource source(3, false);
     // connect sinks
     for (int i = 0; i < 3; i++)
+    {
         source.connect(&sinks[i]);
+    }
     source.disconnectSinks();
     for (int i = 0; i < 3; i++)
+    {
         REQUIRE(sinks[i].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);
     buf.resize(20);
     REQUIRE(buf.size() == 20);
     REQUIRE(buf.sample(15) == 15);
     l = buf.limits();
     REQUIRE(l.start == 0);
     REQUIRE(l.end == 19);
+}
 TEST_CASE("LinIndexBuffer", "[memory, buffer]")
+{
     LinIndexBuffer buf(10, 0., 3.0);

0 comments (0 inline, 0 general)