Files
Joey Parrish 3e71302ba4 feat!: Rewrite build system and third-party dependencies (#1310)
This work was done over ~80 individual commits in the `cmake` branch,
which are now being merged back into `main`. As a roll-up commit, it is
too big to be reviewable, but each change was reviewed individually in
context of the `cmake` branch. After this, the `cmake` branch will be
renamed `cmake-porting-history` and preserved.

---------

Co-authored-by: Geoff Jukes <geoffjukes@users.noreply.github.com>
Co-authored-by: Bartek Zdanowski <bartek.zdanowski@gmail.com>
Co-authored-by: Carlos Bentzen <cadubentzen@gmail.com>
Co-authored-by: Dennis E. Mungai <2356871+Brainiarc7@users.noreply.github.com>
Co-authored-by: Cosmin Stejerean <cstejerean@gmail.com>
Co-authored-by: Carlos Bentzen <carlos.bentzen@bitmovin.com>
Co-authored-by: Cosmin Stejerean <cstejerean@meta.com>
Co-authored-by: Cosmin Stejerean <cosmin@offbytwo.com>
2023-12-01 09:32:19 -08:00

43 lines
1005 B
C++

// Copyright 2017 Google LLC. All rights reserved.
//
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file or at
// https://developers.google.com/open-source/licenses/bsd
#include <packager/media/replicator/replicator.h>
#include <absl/log/check.h>
#include <absl/log/log.h>
namespace shaka {
namespace media {
Status Replicator::InitializeInternal() {
return Status::OK;
}
Status Replicator::Process(std::unique_ptr<StreamData> stream_data) {
Status status;
for (auto& out : output_handlers()) {
std::unique_ptr<StreamData> copy(new StreamData(*stream_data));
copy->stream_index = out.first;
status.Update(Dispatch(std::move(copy)));
}
return status;
}
bool Replicator::ValidateOutputStreamIndex(size_t /* ignored */) const {
return true;
}
Status Replicator::OnFlushRequest(size_t input_stream_index) {
DCHECK_EQ(input_stream_index, 0u);
return FlushAllDownstreams();
}
} // namespace media
} // namespace shaka