• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1  /*
2   *  Copyright (c) 2012 The WebRTC project authors. All Rights Reserved.
3   *
4   *  Use of this source code is governed by a BSD-style license
5   *  that can be found in the LICENSE file in the root of the source
6   *  tree. An additional intellectual property rights grant can be found
7   *  in the file PATENTS.  All contributing project authors may
8   *  be found in the AUTHORS file in the root of the source tree.
9   */
10  
11  #include <assert.h>
12  
13  #include <algorithm>  // Access to min.
14  
15  #include "webrtc/modules/audio_coding/neteq/sync_buffer.h"
16  
17  namespace webrtc {
18  
FutureLength() const19  size_t SyncBuffer::FutureLength() const {
20    return Size() - next_index_;
21  }
22  
PushBack(const AudioMultiVector & append_this)23  void SyncBuffer::PushBack(const AudioMultiVector& append_this) {
24    size_t samples_added = append_this.Size();
25    AudioMultiVector::PushBack(append_this);
26    AudioMultiVector::PopFront(samples_added);
27    if (samples_added <= next_index_) {
28      next_index_ -= samples_added;
29    } else {
30      // This means that we are pushing out future data that was never used.
31  //    assert(false);
32      // TODO(hlundin): This assert must be disabled to support 60 ms frames.
33      // This should not happen even for 60 ms frames, but it does. Investigate
34      // why.
35      next_index_ = 0;
36    }
37    dtmf_index_ -= std::min(dtmf_index_, samples_added);
38  }
39  
PushFrontZeros(size_t length)40  void SyncBuffer::PushFrontZeros(size_t length) {
41    InsertZerosAtIndex(length, 0);
42  }
43  
InsertZerosAtIndex(size_t length,size_t position)44  void SyncBuffer::InsertZerosAtIndex(size_t length, size_t position) {
45    position = std::min(position, Size());
46    length = std::min(length, Size() - position);
47    AudioMultiVector::PopBack(length);
48    for (size_t channel = 0; channel < Channels(); ++channel) {
49      channels_[channel]->InsertZerosAt(length, position);
50    }
51    if (next_index_ >= position) {
52      // We are moving the |next_index_| sample.
53      set_next_index(next_index_ + length);  // Overflow handled by subfunction.
54    }
55    if (dtmf_index_ > 0 && dtmf_index_ >= position) {
56      // We are moving the |dtmf_index_| sample.
57      set_dtmf_index(dtmf_index_ + length);  // Overflow handled by subfunction.
58    }
59  }
60  
ReplaceAtIndex(const AudioMultiVector & insert_this,size_t length,size_t position)61  void SyncBuffer::ReplaceAtIndex(const AudioMultiVector& insert_this,
62                                  size_t length,
63                                  size_t position) {
64    position = std::min(position, Size());  // Cap |position| in the valid range.
65    length = std::min(length, Size() - position);
66    AudioMultiVector::OverwriteAt(insert_this, length, position);
67  }
68  
ReplaceAtIndex(const AudioMultiVector & insert_this,size_t position)69  void SyncBuffer::ReplaceAtIndex(const AudioMultiVector& insert_this,
70                                  size_t position) {
71    ReplaceAtIndex(insert_this, insert_this.Size(), position);
72  }
73  
GetNextAudioInterleaved(size_t requested_len,int16_t * output)74  size_t SyncBuffer::GetNextAudioInterleaved(size_t requested_len,
75                                             int16_t* output) {
76    if (!output) {
77      assert(false);
78      return 0;
79    }
80    size_t samples_to_read = std::min(FutureLength(), requested_len);
81    ReadInterleavedFromIndex(next_index_, samples_to_read, output);
82    next_index_ += samples_to_read;
83    return samples_to_read;
84  }
85  
IncreaseEndTimestamp(uint32_t increment)86  void SyncBuffer::IncreaseEndTimestamp(uint32_t increment) {
87    end_timestamp_ += increment;
88  }
89  
Flush()90  void SyncBuffer::Flush() {
91    Zeros(Size());
92    next_index_ = Size();
93    end_timestamp_ = 0;
94    dtmf_index_ = 0;
95  }
96  
set_next_index(size_t value)97  void SyncBuffer::set_next_index(size_t value) {
98    // Cannot set |next_index_| larger than the size of the buffer.
99    next_index_ = std::min(value, Size());
100  }
101  
set_dtmf_index(size_t value)102  void SyncBuffer::set_dtmf_index(size_t value) {
103    // Cannot set |dtmf_index_| larger than the size of the buffer.
104    dtmf_index_ = std::min(value, Size());
105  }
106  
107  }  // namespace webrtc
108