| Index: webrtc/modules/audio_coding/main/acm2/acm_dump.cc
|
| diff --git a/webrtc/modules/audio_coding/main/acm2/acm_dump.cc b/webrtc/modules/audio_coding/main/acm2/acm_dump.cc
|
| deleted file mode 100644
|
| index 4454c25947d5d1d1d226aea04d75833d362ddf39..0000000000000000000000000000000000000000
|
| --- a/webrtc/modules/audio_coding/main/acm2/acm_dump.cc
|
| +++ /dev/null
|
| @@ -1,220 +0,0 @@
|
| -/*
|
| - * Copyright (c) 2015 The WebRTC project authors. All Rights Reserved.
|
| - *
|
| - * Use of this source code is governed by a BSD-style license
|
| - * that can be found in the LICENSE file in the root of the source
|
| - * tree. An additional intellectual property rights grant can be found
|
| - * in the file PATENTS. All contributing project authors may
|
| - * be found in the AUTHORS file in the root of the source tree.
|
| - */
|
| -
|
| -#include "webrtc/modules/audio_coding/main/acm2/acm_dump.h"
|
| -
|
| -#include <sstream>
|
| -
|
| -#include "webrtc/base/checks.h"
|
| -#include "webrtc/base/thread_annotations.h"
|
| -#include "webrtc/system_wrappers/interface/clock.h"
|
| -#include "webrtc/system_wrappers/interface/critical_section_wrapper.h"
|
| -#include "webrtc/system_wrappers/interface/file_wrapper.h"
|
| -
|
| -// Files generated at build-time by the protobuf compiler.
|
| -#ifdef WEBRTC_ANDROID_PLATFORM_BUILD
|
| -#include "external/webrtc/webrtc/modules/audio_coding/dump.pb.h"
|
| -#else
|
| -#include "webrtc/audio_coding/dump.pb.h"
|
| -#endif
|
| -
|
| -namespace webrtc {
|
| -
|
| -// Noop implementation if flag is not set
|
| -#ifndef RTC_AUDIOCODING_DEBUG_DUMP
|
| -class AcmDumpImpl final : public AcmDump {
|
| - public:
|
| - void StartLogging(const std::string& file_name, int duration_ms) override{};
|
| - void LogRtpPacket(bool incoming,
|
| - const uint8_t* packet,
|
| - size_t length) override{};
|
| - void LogDebugEvent(DebugEvent event_type,
|
| - const std::string& event_message) override{};
|
| - void LogDebugEvent(DebugEvent event_type) override{};
|
| -};
|
| -#else
|
| -
|
| -class AcmDumpImpl final : public AcmDump {
|
| - public:
|
| - AcmDumpImpl();
|
| -
|
| - void StartLogging(const std::string& file_name, int duration_ms) override;
|
| - void LogRtpPacket(bool incoming,
|
| - const uint8_t* packet,
|
| - size_t length) override;
|
| - void LogDebugEvent(DebugEvent event_type,
|
| - const std::string& event_message) override;
|
| - void LogDebugEvent(DebugEvent event_type) override;
|
| -
|
| - private:
|
| - // Checks if the logging time has expired, and if so stops the logging.
|
| - void StopIfNecessary() EXCLUSIVE_LOCKS_REQUIRED(crit_);
|
| - // Stops logging and clears the stored data and buffers.
|
| - void Clear() EXCLUSIVE_LOCKS_REQUIRED(crit_);
|
| - // Returns true if the logging is currently active.
|
| - bool CurrentlyLogging() const EXCLUSIVE_LOCKS_REQUIRED(crit_) {
|
| - return active_ &&
|
| - (clock_->TimeInMicroseconds() <= start_time_us_ + duration_us_);
|
| - }
|
| - // This function is identical to LogDebugEvent, but requires holding the lock.
|
| - void LogDebugEventLocked(DebugEvent event_type,
|
| - const std::string& event_message)
|
| - EXCLUSIVE_LOCKS_REQUIRED(crit_);
|
| -
|
| - rtc::scoped_ptr<webrtc::CriticalSectionWrapper> crit_;
|
| - rtc::scoped_ptr<webrtc::FileWrapper> file_ GUARDED_BY(crit_);
|
| - rtc::scoped_ptr<ACMDumpEventStream> stream_ GUARDED_BY(crit_);
|
| - bool active_ GUARDED_BY(crit_);
|
| - int64_t start_time_us_ GUARDED_BY(crit_);
|
| - int64_t duration_us_ GUARDED_BY(crit_);
|
| - const webrtc::Clock* clock_ GUARDED_BY(crit_);
|
| -};
|
| -
|
| -namespace {
|
| -
|
| -// Convert from AcmDump's debug event enum (runtime format) to the corresponding
|
| -// protobuf enum (serialized format).
|
| -ACMDumpDebugEvent_EventType convertDebugEvent(AcmDump::DebugEvent event_type) {
|
| - switch (event_type) {
|
| - case AcmDump::DebugEvent::kLogStart:
|
| - return ACMDumpDebugEvent::LOG_START;
|
| - case AcmDump::DebugEvent::kLogEnd:
|
| - return ACMDumpDebugEvent::LOG_END;
|
| - case AcmDump::DebugEvent::kAudioPlayout:
|
| - return ACMDumpDebugEvent::AUDIO_PLAYOUT;
|
| - }
|
| - return ACMDumpDebugEvent::UNKNOWN_EVENT;
|
| -}
|
| -
|
| -} // Anonymous namespace.
|
| -
|
| -// AcmDumpImpl member functions.
|
| -AcmDumpImpl::AcmDumpImpl()
|
| - : crit_(webrtc::CriticalSectionWrapper::CreateCriticalSection()),
|
| - file_(webrtc::FileWrapper::Create()),
|
| - stream_(new webrtc::ACMDumpEventStream()),
|
| - active_(false),
|
| - start_time_us_(0),
|
| - duration_us_(0),
|
| - clock_(webrtc::Clock::GetRealTimeClock()) {
|
| -}
|
| -
|
| -void AcmDumpImpl::StartLogging(const std::string& file_name, int duration_ms) {
|
| - CriticalSectionScoped lock(crit_.get());
|
| - Clear();
|
| - if (file_->OpenFile(file_name.c_str(), false) != 0) {
|
| - return;
|
| - }
|
| - // Add a single object to the stream that is reused at every log event.
|
| - stream_->add_stream();
|
| - active_ = true;
|
| - start_time_us_ = clock_->TimeInMicroseconds();
|
| - duration_us_ = static_cast<int64_t>(duration_ms) * 1000;
|
| - // Log the start event.
|
| - std::stringstream log_msg;
|
| - log_msg << "Initial timestamp: " << start_time_us_;
|
| - LogDebugEventLocked(DebugEvent::kLogStart, log_msg.str());
|
| -}
|
| -
|
| -void AcmDumpImpl::LogRtpPacket(bool incoming,
|
| - const uint8_t* packet,
|
| - size_t length) {
|
| - CriticalSectionScoped lock(crit_.get());
|
| - if (!CurrentlyLogging()) {
|
| - StopIfNecessary();
|
| - return;
|
| - }
|
| - // Reuse the same object at every log event.
|
| - auto rtp_event = stream_->mutable_stream(0);
|
| - rtp_event->clear_debug_event();
|
| - const int64_t timestamp = clock_->TimeInMicroseconds() - start_time_us_;
|
| - rtp_event->set_timestamp_us(timestamp);
|
| - rtp_event->set_type(webrtc::ACMDumpEvent::RTP_EVENT);
|
| - rtp_event->mutable_packet()->set_direction(
|
| - incoming ? ACMDumpRTPPacket::INCOMING : ACMDumpRTPPacket::OUTGOING);
|
| - rtp_event->mutable_packet()->set_rtp_data(packet, length);
|
| - std::string dump_buffer;
|
| - stream_->SerializeToString(&dump_buffer);
|
| - file_->Write(dump_buffer.data(), dump_buffer.size());
|
| - file_->Flush();
|
| -}
|
| -
|
| -void AcmDumpImpl::LogDebugEvent(DebugEvent event_type,
|
| - const std::string& event_message) {
|
| - CriticalSectionScoped lock(crit_.get());
|
| - LogDebugEventLocked(event_type, event_message);
|
| -}
|
| -
|
| -void AcmDumpImpl::LogDebugEvent(DebugEvent event_type) {
|
| - CriticalSectionScoped lock(crit_.get());
|
| - LogDebugEventLocked(event_type, "");
|
| -}
|
| -
|
| -void AcmDumpImpl::StopIfNecessary() {
|
| - if (active_) {
|
| - DCHECK_GT(clock_->TimeInMicroseconds(), start_time_us_ + duration_us_);
|
| - LogDebugEventLocked(DebugEvent::kLogEnd, "");
|
| - Clear();
|
| - }
|
| -}
|
| -
|
| -void AcmDumpImpl::Clear() {
|
| - if (active_ || file_->Open()) {
|
| - file_->CloseFile();
|
| - }
|
| - active_ = false;
|
| - stream_->Clear();
|
| -}
|
| -
|
| -void AcmDumpImpl::LogDebugEventLocked(DebugEvent event_type,
|
| - const std::string& event_message) {
|
| - if (!CurrentlyLogging()) {
|
| - StopIfNecessary();
|
| - return;
|
| - }
|
| -
|
| - // Reuse the same object at every log event.
|
| - auto event = stream_->mutable_stream(0);
|
| - int64_t timestamp = clock_->TimeInMicroseconds() - start_time_us_;
|
| - event->set_timestamp_us(timestamp);
|
| - event->set_type(webrtc::ACMDumpEvent::DEBUG_EVENT);
|
| - event->clear_packet();
|
| - auto debug_event = event->mutable_debug_event();
|
| - debug_event->set_type(convertDebugEvent(event_type));
|
| - debug_event->set_message(event_message);
|
| - std::string dump_buffer;
|
| - stream_->SerializeToString(&dump_buffer);
|
| - file_->Write(dump_buffer.data(), dump_buffer.size());
|
| -}
|
| -
|
| -#endif // RTC_AUDIOCODING_DEBUG_DUMP
|
| -
|
| -// AcmDump member functions.
|
| -rtc::scoped_ptr<AcmDump> AcmDump::Create() {
|
| - return rtc::scoped_ptr<AcmDump>(new AcmDumpImpl());
|
| -}
|
| -
|
| -bool AcmDump::ParseAcmDump(const std::string& file_name,
|
| - ACMDumpEventStream* result) {
|
| - char tmp_buffer[1024];
|
| - int bytes_read = 0;
|
| - rtc::scoped_ptr<FileWrapper> dump_file(FileWrapper::Create());
|
| - if (dump_file->OpenFile(file_name.c_str(), true) != 0) {
|
| - return false;
|
| - }
|
| - std::string dump_buffer;
|
| - while ((bytes_read = dump_file->Read(tmp_buffer, sizeof(tmp_buffer))) > 0) {
|
| - dump_buffer.append(tmp_buffer, bytes_read);
|
| - }
|
| - dump_file->CloseFile();
|
| - return result->ParseFromString(dump_buffer);
|
| -}
|
| -
|
| -} // namespace webrtc
|
|
|