Home | History | Annotate | Download | only in audio 
      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 "components/copresence/handlers/audio/audio_directive_list.h"
      6 
      7 #include "base/bind.h"
      8 #include "base/logging.h"
      9 #include "base/memory/scoped_ptr.h"
     10 #include "base/time/time.h"
     11 
     12 namespace copresence {
     13 
     14 // Public methods.
     15 
     16 AudioDirective::AudioDirective() {
     17 }
     18 
     19 AudioDirective::AudioDirective(const std::string& op_id, base::Time end_time)
     20     : op_id(op_id), end_time(end_time) {
     21 }
     22 
     23 AudioDirectiveList::AudioDirectiveList() {
     24 }
     25 
     26 AudioDirectiveList::~AudioDirectiveList() {
     27 }
     28 
     29 void AudioDirectiveList::AddDirective(const std::string& op_id,
     30                                       base::TimeDelta ttl) {
     31   base::Time end_time = base::Time::Now() + ttl;
     32 
     33   // In case this op is already in the list, update it instead of adding
     34   // it again.
     35   std::vector<AudioDirective>::iterator it = FindDirectiveByOpId(op_id);
     36   if (it != active_directives_.end()) {
     37     it->end_time = end_time;
     38     std::make_heap(active_directives_.begin(),
     39                    active_directives_.end(),
     40                    LatestFirstComparator());
     41     return;
     42   }
     43 
     44   active_directives_.push_back(AudioDirective(op_id, end_time));
     45   std::push_heap(active_directives_.begin(),
     46                  active_directives_.end(),
     47                  LatestFirstComparator());
     48 }
     49 
     50 void AudioDirectiveList::RemoveDirective(const std::string& op_id) {
     51   std::vector<AudioDirective>::iterator it = FindDirectiveByOpId(op_id);
     52   if (it != active_directives_.end())
     53     active_directives_.erase(it);
     54 
     55   std::make_heap(active_directives_.begin(),
     56                  active_directives_.end(),
     57                  LatestFirstComparator());
     58 }
     59 
     60 scoped_ptr<AudioDirective> AudioDirectiveList::GetActiveDirective() {
     61   // The top is always the instruction that is ending the latest. If that time
     62   // has passed, means all our previous instructions have expired too, hence
     63   // clear the list.
     64   if (!active_directives_.empty() &&
     65       active_directives_.front().end_time < base::Time::Now()) {
     66     active_directives_.clear();
     67   }
     68 
     69   if (active_directives_.empty())
     70     return make_scoped_ptr<AudioDirective>(NULL);
     71 
     72   return make_scoped_ptr(new AudioDirective(active_directives_.front()));
     73 }
     74 
     75 std::vector<AudioDirective>::iterator AudioDirectiveList::FindDirectiveByOpId(
     76     const std::string& op_id) {
     77   for (std::vector<AudioDirective>::iterator it = active_directives_.begin();
     78        it != active_directives_.end();
     79        ++it) {
     80     if (it->op_id == op_id)
     81       return it;
     82   }
     83   return active_directives_.end();
     84 }
     85 
     86 }  // namespace copresence
     87