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

@@ @@ -45,12 +45,21 @@ void Source::disconnect(Sink* 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);
+    }

src/source.h

➞

Show inline comments

@@ @@ -42,15 +42,18 @@ public: @@
     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:

tests/test.cpp

➞

Show inline comments

@@ @@ -124,12 +124,30 @@ TEST_CASE("source must set/unset sink 's @@
     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++)

0 comments (0 inline, 0 general)