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

@@ @@ -39,24 +39,33 @@ void Source::connect(Sink* sink) @@
     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)
+    {

src/source.h

➞

Show inline comments

@@ @@ -36,25 +36,28 @@ public: @@
     /// 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

@@ @@ -118,24 +118,42 @@ TEST_CASE("source", "[memory, stream]") @@
 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);

0 comments (0 inline, 0 general)