[Sync] Add timestamp to TrafficRecorder records

sync/engine/traffic_recorder.cc

 // 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.
 
 #include "sync/engine/traffic_recorder.h"
 
 #include "base/json/json_writer.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/values.h"
 #include "sync/protocol/proto_value_conversions.h"
 #include "sync/protocol/sync.pb.h"
 #include "sync/sessions/sync_session.h"
+#include "sync/util/time.h"
 
 namespace syncer {
 
+// Return current time.
+base::Time TrafficRecorder::GetTime() {
+  return base::Time::Now();
+}
+
 TrafficRecorder::TrafficRecord::TrafficRecord(const std::string& message,
                                               TrafficMessageType message_type,
-                                              bool truncated) :
+                                              bool truncated,
+                                              base::Time time) :
     message(message),
     message_type(message_type),
-    truncated(truncated) {
+    truncated(truncated),
+    timestamp(time) {
 }
 
 TrafficRecorder::TrafficRecord::TrafficRecord()
     : message_type(UNKNOWN_MESSAGE_TYPE),
       truncated(false) {
 }
 
 TrafficRecorder::TrafficRecord::~TrafficRecord() {
 }
 
@@ skipping 36 matching lines @@
   } else if (message_type == TrafficRecorder::CLIENT_TO_SERVER_RESPONSE) {
     sync_pb::ClientToServerResponse message_proto;
     if (message_proto.ParseFromString(message))
       value.reset(
           ClientToServerResponseToValue(message_proto,
                                         false /* include_specifics */));
   } else {
     NOTREACHED();
   }
 
+  value->SetString("timestamp", GetTimeDebugString(timestamp));
+
   return value.release();
 }
 
 
 ListValue* TrafficRecorder::ToValue() const {
   scoped_ptr<ListValue> value(new ListValue());
   std::deque<TrafficRecord>::const_iterator it;
   for (it = records_.begin(); it != records_.end(); ++it) {
     const TrafficRecord& record = *it;
     value->Append(record.ToValue());
@@ skipping 19 matching lines @@
     TrafficMessageType type) {
   bool truncated = false;
   std::string message;
   if (static_cast<unsigned int>(msg.ByteSize()) >= max_message_size_) {
     // TODO(lipalani): Trim the specifics to fit in size.
     truncated = true;
   } else {
     msg.SerializeToString(&message);
   }
 
-  TrafficRecord record(message, type, truncated);
+  TrafficRecord record(message, type, truncated, GetTime());
   AddTrafficToQueue(&record);
 }
 
 void TrafficRecorder::RecordClientToServerMessage(
     const sync_pb::ClientToServerMessage& msg) {
   StoreProtoInQueue(msg, CLIENT_TO_SERVER_MESSAGE);
 }
 
 void TrafficRecorder::RecordClientToServerResponse(
     const sync_pb::ClientToServerResponse& response) {
   StoreProtoInQueue(response, CLIENT_TO_SERVER_RESPONSE);
 }
 
 }  // namespace syncer