Home | History | Annotate | Download | only in engine
      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 #ifndef SYNC_ENGINE_NON_BLOCKING_SYNC_COMMON_H_
      6 #define SYNC_ENGINE_NON_BLOCKING_SYNC_COMMON_H_
      7 
      8 #include <string>
      9 #include <vector>
     10 
     11 #include "base/time/time.h"
     12 #include "sync/base/sync_export.h"
     13 #include "sync/protocol/sync.pb.h"
     14 
     15 namespace syncer {
     16 
     17 static const int64 kUncommittedVersion = -1;
     18 
     19 // Data-type global state that must be accessed and updated on the sync thread,
     20 // but persisted on or through the model thread.
     21 struct SYNC_EXPORT_PRIVATE DataTypeState {
     22   DataTypeState();
     23   ~DataTypeState();
     24 
     25   // The latest progress markers received from the server.
     26   sync_pb::DataTypeProgressMarker progress_marker;
     27 
     28   // A data type context.  Sent to the server in every commit or update
     29   // request.  May be updated by either by responses from the server or
     30   // requests made on the model thread.  The interpretation of this value may
     31   // be data-type specific.  Many data types ignore it.
     32   sync_pb::DataTypeContext type_context;
     33 
     34   // The ID of the folder node that sits at the top of this type's folder
     35   // hierarchy.  We keep this around for legacy reasons.  The protocol expects
     36   // that all nodes of a certain type are children of the same type root
     37   // entity.  This entity is delivered by the server, and may not be available
     38   // until the first download cycle has completed.
     39   std::string type_root_id;
     40 
     41   // A strictly increasing counter used to generate unique values for the
     42   // client-assigned IDs.  The incrementing and ID assignment happens on the
     43   // sync thread, but we store the value here so we can pass it back to the
     44   // model thread for persistence.  This is probably unnecessary for the
     45   // client-tagged data types supported by non-blocking sync, but we will
     46   // continue to emulate the directory sync's behavior for now.
     47   int64 next_client_id;
     48 
     49   // This flag is set to true when the first download cycle is complete.  The
     50   // NonBlockingTypeProcessor should not attempt to commit any items until this
     51   // flag is set.
     52   bool initial_sync_done;
     53 };
     54 
     55 struct SYNC_EXPORT_PRIVATE CommitRequestData {
     56   CommitRequestData();
     57   ~CommitRequestData();
     58 
     59   std::string id;
     60   std::string client_tag_hash;
     61 
     62   // Strictly incrementing number for in-progress commits.  More information
     63   // about its meaning can be found in comments in the files that make use of
     64   // this struct.
     65   int64 sequence_number;
     66 
     67   int64 base_version;
     68   base::Time ctime;
     69   base::Time mtime;
     70   std::string non_unique_name;
     71   bool deleted;
     72   sync_pb::EntitySpecifics specifics;
     73 };
     74 
     75 struct SYNC_EXPORT_PRIVATE CommitResponseData {
     76   CommitResponseData();
     77   ~CommitResponseData();
     78 
     79   std::string id;
     80   std::string client_tag_hash;
     81   int64 sequence_number;
     82   int64 response_version;
     83 };
     84 
     85 struct SYNC_EXPORT_PRIVATE UpdateResponseData {
     86   UpdateResponseData();
     87   ~UpdateResponseData();
     88 
     89   std::string id;
     90   std::string client_tag_hash;
     91   int64 response_version;
     92   base::Time ctime;
     93   base::Time mtime;
     94   std::string non_unique_name;
     95   bool deleted;
     96   sync_pb::EntitySpecifics specifics;
     97 };
     98 
     99 typedef std::vector<CommitRequestData> CommitRequestDataList;
    100 typedef std::vector<CommitResponseData> CommitResponseDataList;
    101 typedef std::vector<UpdateResponseData> UpdateResponseDataList;
    102 
    103 }  // namespace syncer
    104 
    105 #endif  // SYNC_ENGINE_NON_BLOCKING_SYNC_COMMON_H_
    106