Add polling and audio check to copresence.

components/copresence/handlers/audio/audio_directive_handler_impl.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/copresence/handlers/audio/audio_directive_handler_impl.h"
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/logging.h"
@@ skipping 37 matching lines @@
 AudioDirectiveHandlerImpl::AudioDirectiveHandlerImpl(
     scoped_ptr<AudioManager> audio_manager,
     scoped_ptr<base::Timer> timer,
     const scoped_refptr<TickClockRefCounted>& clock)
     : audio_manager_(audio_manager.Pass()),
       audio_event_timer_(timer.Pass()),
       clock_(clock) {}
 
 AudioDirectiveHandlerImpl::~AudioDirectiveHandlerImpl() {}
 
-void AudioDirectiveHandlerImpl::Initialize(
-    const AudioManager::DecodeSamplesCallback& decode_cb,
-    const AudioManager::EncodeTokenCallback& encode_cb) {
+void AudioDirectiveHandlerImpl::Initialize(WhispernetClient* whispernet_client,
+                                           const TokensCallback& tokens_cb) {
   if (!audio_manager_)
     audio_manager_.reset(new AudioManagerImpl());
-  audio_manager_->Initialize(decode_cb, encode_cb);
+  audio_manager_->Initialize(whispernet_client, tokens_cb);
 
   DCHECK(transmits_lists_.empty());
   transmits_lists_.push_back(new AudioDirectiveList(clock_));
   transmits_lists_.push_back(new AudioDirectiveList(clock_));
 
   DCHECK(receives_lists_.empty());
   receives_lists_.push_back(new AudioDirectiveList(clock_));
   receives_lists_.push_back(new AudioDirectiveList(clock_));
 }
 
@@ skipping 56 matching lines @@
   receives_lists_[INAUDIBLE]->RemoveDirective(op_id);
 
   ProcessNextInstruction();
 }
 
 const std::string AudioDirectiveHandlerImpl::PlayingToken(
     AudioType type) const {
   return audio_manager_->GetToken(type);
 }
 
+bool AudioDirectiveHandlerImpl::IsPlayingTokenHeard(AudioType type) const {
+  return audio_manager_->IsPlayingTokenHeard(type);
+}
 
 // Private functions.
 
 void AudioDirectiveHandlerImpl::ProcessNextInstruction() {
   DCHECK(audio_event_timer_);
   audio_event_timer_->Stop();
 
   // Change |audio_manager_| state for audible transmits.
   if (transmits_lists_[AUDIBLE]->GetActiveDirective())
     audio_manager_->StartPlaying(AUDIBLE);
@@ skipping 34 matching lines @@
 
   *expiry = GetEarliestEventTime(transmits_lists_[AUDIBLE], base::TimeTicks());
   *expiry = GetEarliestEventTime(transmits_lists_[INAUDIBLE], *expiry);
   *expiry = GetEarliestEventTime(receives_lists_[AUDIBLE], *expiry);
   *expiry = GetEarliestEventTime(receives_lists_[INAUDIBLE], *expiry);
 
   return !expiry->is_null();
 }
 
 }  // namespace copresence