Inject timestamps to resource messages.

content/common/resource_dispatcher.h

 // Copyright (c) 2012 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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #ifndef CONTENT_COMMON_RESOURCE_DISPATCHER_H_
 #define CONTENT_COMMON_RESOURCE_DISPATCHER_H_
 
 #include <deque>
@@ skipping 53 matching lines @@
   // Indicates the priority of the specified request changed.
   void DidChangePriority(int routing_id, int request_id,
                          net::RequestPriority new_priority);
 
   // This does not take ownership of the delegate. It is expected that the
   // delegate have a longer lifetime than the ResourceDispatcher.
   void set_delegate(ResourceDispatcherDelegate* delegate) {
     delegate_ = delegate;
   }
 
+  // Remembers IO thread timestamp for next resource message.
+  void set_io_timestamp(base::TimeTicks io_timestamp) {
+    io_timestamp_ = io_timestamp;
+  }
+
  private:
   friend class ResourceDispatcherTest;
 
   typedef std::deque<IPC::Message*> MessageQueue;
   struct PendingRequestInfo {
     PendingRequestInfo();
 
     PendingRequestInfo(webkit_glue::ResourceLoaderBridge::Peer* peer,
                        ResourceType::Type resource_type,
                        const GURL& request_url);
@@ skipping 66 matching lines @@
 
   void ToResourceResponseInfo(
       const PendingRequestInfo& request_info,
       const ResourceResponseHead& browser_info,
       webkit_glue::ResourceResponseInfo* renderer_info) const;
 
   base::TimeTicks ToRendererCompletionTime(
       const PendingRequestInfo& request_info,
       const base::TimeTicks& browser_completion_time) const;
 
+  // Returns timestamp provided by IO thread. If no timestamp is supplied,
+  // then current time is returned. Saved timestamp is reset, so following
+  // invocations will return current time until set_io_timestamp is called.
+  base::TimeTicks ConsumeIOTimestamp();
+
   // Returns true if the message passed in is a resource related message.
   static bool IsResourceDispatcherMessage(const IPC::Message& message);
 
   // ViewHostMsg_Resource_DataReceived is not POD, it has a shared memory
   // handle in it that we should cleanup it up nicely. This method accepts any
   // message and determine whether the message is
   // ViewHostMsg_Resource_DataReceived and clean up the shared memory handle.
   static void ReleaseResourcesInDataMessage(const IPC::Message& message);
 
   // Iterate through a message queue and clean up the messages by calling
   // ReleaseResourcesInDataMessage and removing them from the queue. Intended
   // for use on deferred message queues that are no longer needed.
   static void ReleaseResourcesInMessageQueue(MessageQueue* queue);
 
   IPC::Sender* message_sender_;
 
   // All pending requests issued to the host
   PendingRequestList pending_requests_;
 
   base::WeakPtrFactory<ResourceDispatcher> weak_factory_;
 
   ResourceDispatcherDelegate* delegate_;
 
+  // IO thread timestamp for ongoing IPC message.
+  base::TimeTicks io_timestamp_;
+
   DISALLOW_COPY_AND_ASSIGN(ResourceDispatcher);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_COMMON_RESOURCE_DISPATCHER_H_