couchdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rnew...@apache.org
Subject [19/50] fabric commit: updated refs/heads/windsor-merge-121 to 79e6e2f
Date Fri, 01 Aug 2014 09:12:07 GMT
Remove (not that successful) downgrade trick


Project: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/commit/5d007482
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/tree/5d007482
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/diff/5d007482

Branch: refs/heads/windsor-merge-121
Commit: 5d007482b48c331d7f8b82d29ce4f9b36dd465f0
Parents: 60e93b0
Author: Robert Newson <robert.newson@cloudant.com>
Authored: Tue Sep 17 13:31:13 2013 +0100
Committer: Robert Newson <rnewson@apache.org>
Committed: Thu Jul 31 11:12:43 2014 +0100

----------------------------------------------------------------------
 src/fabric_rpc.erl          | 9 ++++-----
 src/fabric_view_changes.erl | 2 +-
 2 files changed, 5 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/couchdb-fabric/blob/5d007482/src/fabric_rpc.erl
----------------------------------------------------------------------
diff --git a/src/fabric_rpc.erl b/src/fabric_rpc.erl
index 7b4473f..2cc31ff 100644
--- a/src/fabric_rpc.erl
+++ b/src/fabric_rpc.erl
@@ -277,14 +277,13 @@ changes_enumerator(DocInfo, {Db, _Seq, Args, Options}) ->
         {Go, {Db, Seq, Args, Options}}
     end.
 
-% TODO change to {Seq, uuid(Db)}
 changes_row(Db, #doc_info{id=Id, high_seq=Seq}=DI, Results, Del, true, Opts) ->
     Doc = doc_member(Db, DI, Opts),
-    #change{key={Seq, uuid(Db), []}, id=Id, value=Results, doc=Doc, deleted=Del};
+    #change{key={Seq, uuid(Db)}, id=Id, value=Results, doc=Doc, deleted=Del};
 changes_row(Db, #doc_info{id=Id, high_seq=Seq}, Results, true, _, _) ->
-    #change{key={Seq, uuid(Db), []}, id=Id, value=Results, deleted=true};
+    #change{key={Seq, uuid(Db)}, id=Id, value=Results, deleted=true};
 changes_row(Db, #doc_info{id=Id, high_seq=Seq}, Results, _, _, _) ->
-    #change{key={Seq, uuid(Db), []}, id=Id, value=Results}.
+    #change{key={Seq, uuid(Db)}, id=Id, value=Results}.
 
 doc_member(Shard, DocInfo, Opts) ->
     case couch_db:open_doc(Shard, DocInfo, [deleted | Opts]) of
@@ -368,7 +367,7 @@ set_io_priority(DbName, Options) ->
 
 calculate_start_seq(_Db, _Node, Seq) when is_integer(Seq) ->
     Seq;
-calculate_start_seq(Db, Node, {Seq, Uuid, _}) -> % remove me
+calculate_start_seq(Db, Node, {Seq, Uuid, _}) -> % downgrade clause
     calculate_start_seq(Db, Node, {Seq, Uuid});
 calculate_start_seq(Db, Node, {Seq, Uuid}) ->
     case is_prefix(Uuid, couch_db:get_uuid(Db)) of

http://git-wip-us.apache.org/repos/asf/couchdb-fabric/blob/5d007482/src/fabric_view_changes.erl
----------------------------------------------------------------------
diff --git a/src/fabric_view_changes.erl b/src/fabric_view_changes.erl
index a54748a..a6c468e 100644
--- a/src/fabric_view_changes.erl
+++ b/src/fabric_view_changes.erl
@@ -297,7 +297,7 @@ pack_seqs(Workers) ->
     Opaque = couch_util:encodeBase64Url(term_to_binary(SeqList, [compressed])),
     [SeqSum, Opaque].
 
-seq({Seq, _Uuid, _Node}) -> Seq; % remove me
+seq({Seq, _Uuid, _Node}) -> Seq; % downgrade clause
 seq({Seq, _Uuid}) -> Seq;
 seq(Seq)          -> Seq.
 


Mime
View raw message