diff --git a/src/sink.cpp b/src/sink.cpp new file mode 100644 --- /dev/null +++ b/src/sink.cpp @@ -0,0 +1,70 @@ +/* + Copyright © 2018 Hasan Yavuz Özderya + + This file is part of serialplot. + + serialplot is free software: you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation, either version 3 of the License, or + (at your option) any later version. + + serialplot is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with serialplot. If not, see . +*/ + +#include +#include "sink.h" + +void Sink::connectFollower(Sink* sink) +{ + Q_ASSERT(!followers.contains(sink)); + + followers.append(sink); + sink->setNumChannels(_numChannels, _hasX); +} + +void Sink::disconnectFollower(Sink* sink) +{ + Q_ASSERT(followers.contains(sink)); + + followers.removeOne(sink); +} + +void Sink::feedIn(const SamplePack& data) +{ + for (auto sink : followers) + { + sink->feedIn(data); + } +} + +void Sink::setNumChannels(unsigned nc, bool x) +{ + _numChannels = nc; + _hasX = x; + for (auto sink : followers) + { + sink->setNumChannels(nc, x); + } +} + +void Sink::setSource(Source* s) +{ + Q_ASSERT((source == nullptr) != (s == nullptr)); + source = s; +} + +const Source* Sink::connectedSource() const +{ + return source; +} + +Source* Sink::connectedSource() +{ + return const_cast(static_cast(*this).connectedSource()); +}