110 lines
3.1 KiB
C++
110 lines
3.1 KiB
C++
// Copyright 2014 Google Inc. 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/base/media_stream.h"
|
|
|
|
#include "packager/base/logging.h"
|
|
#include "packager/base/strings/stringprintf.h"
|
|
#include "packager/media/base/demuxer.h"
|
|
#include "packager/media/base/media_sample.h"
|
|
#include "packager/media/base/muxer.h"
|
|
#include "packager/media/base/stream_info.h"
|
|
|
|
namespace shaka {
|
|
namespace media {
|
|
|
|
MediaStream::MediaStream(scoped_refptr<StreamInfo> info, Demuxer* demuxer)
|
|
: info_(info), demuxer_(demuxer), muxer_(NULL), state_(kIdle) {}
|
|
|
|
MediaStream::~MediaStream() {}
|
|
|
|
Status MediaStream::PullSample(scoped_refptr<MediaSample>* sample) {
|
|
DCHECK(state_ == kPulling || state_ == kIdle);
|
|
|
|
// Trigger a new parse in demuxer if no more samples.
|
|
while (samples_.empty()) {
|
|
Status status = demuxer_->Parse();
|
|
if (!status.ok())
|
|
return status;
|
|
}
|
|
|
|
*sample = samples_.front();
|
|
samples_.pop_front();
|
|
return Status::OK;
|
|
}
|
|
|
|
Status MediaStream::PushSample(const scoped_refptr<MediaSample>& sample) {
|
|
switch (state_) {
|
|
case kIdle:
|
|
case kPulling:
|
|
samples_.push_back(sample);
|
|
return Status::OK;
|
|
case kDisconnected:
|
|
return Status::OK;
|
|
case kPushing:
|
|
return muxer_->AddSample(this, sample);
|
|
default:
|
|
NOTREACHED() << "Unexpected State " << state_;
|
|
return Status::UNKNOWN;
|
|
}
|
|
}
|
|
|
|
void MediaStream::Connect(Muxer* muxer) {
|
|
DCHECK(muxer);
|
|
DCHECK(!muxer_);
|
|
state_ = kConnected;
|
|
muxer_ = muxer;
|
|
}
|
|
|
|
Status MediaStream::Start(MediaStreamOperation operation) {
|
|
DCHECK(demuxer_);
|
|
DCHECK(operation == kPush || operation == kPull);
|
|
|
|
switch (state_) {
|
|
case kIdle:
|
|
// Disconnect the stream if it is not connected to a muxer.
|
|
state_ = kDisconnected;
|
|
samples_.clear();
|
|
return Status::OK;
|
|
case kConnected:
|
|
state_ = (operation == kPush) ? kPushing : kPulling;
|
|
if (operation == kPush) {
|
|
// Push samples in the queue to muxer if there is any.
|
|
while (!samples_.empty()) {
|
|
Status status = muxer_->AddSample(this, samples_.front());
|
|
if (!status.ok())
|
|
return status;
|
|
samples_.pop_front();
|
|
}
|
|
} else {
|
|
// We need to disconnect all its peer streams which are not connected
|
|
// to a muxer.
|
|
for (size_t i = 0; i < demuxer_->streams().size(); ++i) {
|
|
Status status = demuxer_->streams()[i]->Start(operation);
|
|
if (!status.ok())
|
|
return status;
|
|
}
|
|
}
|
|
return Status::OK;
|
|
case kPulling:
|
|
DCHECK(operation == kPull);
|
|
return Status::OK;
|
|
default:
|
|
NOTREACHED() << "Unexpected State " << state_;
|
|
return Status::UNKNOWN;
|
|
}
|
|
}
|
|
|
|
const scoped_refptr<StreamInfo> MediaStream::info() const { return info_; }
|
|
|
|
std::string MediaStream::ToString() const {
|
|
return base::StringPrintf("state: %d\n samples in the queue: %zu\n %s",
|
|
state_, samples_.size(), info_->ToString().c_str());
|
|
}
|
|
|
|
} // namespace media
|
|
} // namespace shaka
|