src/ppapi/shared_impl/media_stream_buffer_manager.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "ppapi/shared_impl/media_stream_buffer_manager.h"
   6
   7 #include "base/logging.h"
   8 #include "ppapi/c/pp_errors.h"
   9 #include "ppapi/shared_impl/media_stream_buffer.h"
  10
  11 namespace ppapi {
  12
  13 MediaStreamBufferManager::Delegate::~Delegate() {}
  14
  15 void MediaStreamBufferManager::Delegate::OnNewBufferEnqueued() {}
  16
  17 MediaStreamBufferManager::MediaStreamBufferManager(Delegate* delegate)
  18     : delegate_(delegate), buffer_size_(0), number_of_buffers_(0) {
  19   DCHECK(delegate_);
  20 }
  21
  22 MediaStreamBufferManager::~MediaStreamBufferManager() {}
  23
  24 bool MediaStreamBufferManager::SetBuffers(int32_t number_of_buffers,
  25                                           int32_t buffer_size,
  26                                           scoped_ptr<base::SharedMemory> shm,
  27                                           bool enqueue_all_buffers) {
  28   DCHECK(shm);
  29   DCHECK_GT(number_of_buffers, 0);
  30   DCHECK_GT(buffer_size,
  31             static_cast<int32_t>(sizeof(MediaStreamBuffer::Header)));
  32   DCHECK_EQ(buffer_size & 0x3, 0);
  33
  34   number_of_buffers_ = number_of_buffers;
  35   buffer_size_ = buffer_size;
  36
  37   size_t size = number_of_buffers_ * buffer_size;
  38   shm_ = shm.Pass();
  39   if (!shm_->Map(size))
  40     return false;
  41
  42   buffer_queue_.clear();
  43   buffers_.clear();
  44   uint8_t* p = reinterpret_cast<uint8_t*>(shm_->memory());
  45   for (int32_t i = 0; i < number_of_buffers; ++i) {
  46     if (enqueue_all_buffers)
  47       buffer_queue_.push_back(i);
  48     buffers_.push_back(reinterpret_cast<MediaStreamBuffer*>(p));
  49     p += buffer_size_;
  50   }
  51   return true;
  52 }
  53
  54 int32_t MediaStreamBufferManager::DequeueBuffer() {
  55   if (buffer_queue_.empty())
  56     return PP_ERROR_FAILED;
  57   int32_t buffer = buffer_queue_.front();
  58   buffer_queue_.pop_front();
  59   return buffer;
  60 }
  61
  62 std::vector<int32_t> MediaStreamBufferManager::DequeueBuffers() {
  63   std::vector<int32_t> buffers(buffer_queue_.begin(), buffer_queue_.end());
  64   buffer_queue_.clear();
  65   return buffers;
  66 }
  67
  68 void MediaStreamBufferManager::EnqueueBuffer(int32_t index) {
  69   CHECK_GE(index, 0) << "Invalid buffer index";
  70   CHECK_LT(index, number_of_buffers_) << "Invalid buffer index";
  71   buffer_queue_.push_back(index);
  72   delegate_->OnNewBufferEnqueued();
  73 }
  74
  75 MediaStreamBuffer* MediaStreamBufferManager::GetBufferPointer(int32_t index) {
  76   if (index < 0 || index >= number_of_buffers_)
  77     return NULL;
  78   return buffers_[index];
  79 }
  80
  81 }  // namespace ppapi