Stop playing/recording when not needed.

components/copresence/rpc/rpc_handler.h

 // 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.
 
 #ifndef COMPONENTS_COPRESENCE_RPC_RPC_HANDLER_H_
 #define COMPONENTS_COPRESENCE_RPC_RPC_HANDLER_H_
 
 #include <set>
 #include <string>
 #include <vector>
@@ skipping 32 matching lines @@
   // to be called before invoking any other methods.
   void Initialize(const SuccessCallback& init_done_callback);
 
   // Send a report request
   void SendReportRequest(scoped_ptr<ReportRequest> request);
   void SendReportRequest(scoped_ptr<ReportRequest> request,
                          const std::string& app_id,
                          const StatusCallback& callback);
 
   // Report a set of tokens to the server for a given medium.
-  void ReportTokens(const std::vector<FullToken>& tokens);
+  void ReportTokens(const std::vector<AudioToken>& tokens);
 
   // Create the directive handler and connect it to
   // the whispernet client specified by the delegate.
   void ConnectToWhispernet();
 
  private:
   // An HttpPost::ResponseCallback prepended with an HttpPost object
   // that needs to be deleted.
   typedef base::Callback<void(HttpPost*, int, const std::string&)>
       PostCleanupCallback;
@@ skipping 14 matching lines @@
 
   void RegisterResponseHandler(const SuccessCallback& init_done_callback,
                                HttpPost* completed_post,
                                int http_status_code,
                                const std::string& response_data);
   void ReportResponseHandler(const StatusCallback& status_callback,
                              HttpPost* completed_post,
                              int http_status_code,
                              const std::string& response_data);
 
+  // If the request has any unpublish or unsubscribe operations, it removes
+  // them from our directive handlers.
+  void ProcessRemovedOperations(const ReportRequest& request);
+
+  // Add all currently playing tokens to the update signals in this report
+  // request. This ensures that the server doesn't keep issueing new tokens to
+  // us when we're already playing valid tokens.
+  void AddPlayingTokens(ReportRequest* request);
+
   void DispatchMessages(
       const google::protobuf::RepeatedPtrField<SubscribedMessage>&
       subscribed_messages);
 
   RequestHeader* CreateRequestHeader(const std::string& client_name) const;
 
   template <class T>
   void SendServerRequest(const std::string& rpc_name,
                          const std::string& app_id,
                          scoped_ptr<T> request,
@@ skipping 20 matching lines @@
   std::string device_id_;
   scoped_ptr<DirectiveHandler> directive_handler_;
   std::set<HttpPost*> pending_posts_;
 
   DISALLOW_COPY_AND_ASSIGN(RpcHandler);
 };
 
 }  // namespace copresence
 
 #endif  // COMPONENTS_COPRESENCE_RPC_RPC_HANDLER_H_