You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafodion.apache.org by db...@apache.org on 2016/07/18 22:40:54 UTC

[2/8] incubator-trafodion git commit: Fix to correct loss of updates following a regionServer failure v2

http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/c74e3d62/core/sqf/src/seatrans/hbase-trx/src/main/protobuf/TrxRegion.proto
----------------------------------------------------------------------
diff --git a/core/sqf/src/seatrans/hbase-trx/src/main/protobuf/TrxRegion.proto b/core/sqf/src/seatrans/hbase-trx/src/main/protobuf/TrxRegion.proto
index d37bb6d..c3975c7 100755
--- a/core/sqf/src/seatrans/hbase-trx/src/main/protobuf/TrxRegion.proto
+++ b/core/sqf/src/seatrans/hbase-trx/src/main/protobuf/TrxRegion.proto
@@ -92,7 +92,7 @@ message CommitMultipleResponse {
 message CommitRequestRequest{
   required bytes regionName = 1;
   required int64 transactionId = 2;
-  required int64 startEpoc = 3;
+  required int64 startEpoch = 3;
   required int32 participantNum = 4;
   required bool dropTableRecorded = 5;
 }
@@ -106,7 +106,7 @@ message CommitRequestResponse {
 message CommitRequestMultipleRequest{
   repeated bytes regionName = 1;
   required int64 transactionId = 2;
-  required int64 startEpoc = 3;
+  required int64 startEpoch = 3;
   required int32 participantNum = 4;
 }
 
@@ -119,7 +119,7 @@ message CommitRequestMultipleResponse {
 message CommitIfPossibleRequest{
   required bytes regionName = 1;
   required int64 transactionId = 2;
-  required int64 startEpoc = 3;
+  required int64 startEpoch = 3;
   required int64 commitId = 4;
   required int32 participantNum = 5;
 }
@@ -262,6 +262,17 @@ message PutMultipleTransactionalResponse {
   optional bool hasException = 3;
 }
 
+message PushEpochRequest{
+  required bytes regionName = 1;
+  required int64 transactionId = 2;
+  required int64 epoch = 3;
+}
+
+message PushEpochResponse{
+  optional string exception = 1;
+  optional bool hasException = 2;
+}
+
 message RecoveryRequestRequest {
   required int64 transactionId = 1;
   required bytes regionName = 2;
@@ -359,7 +370,7 @@ message TransactionPersist {
   repeated int64 seqNoListSeq = 2;
   repeated int64 seqNoListTxn = 3;
   required int64 nextSeqId = 4;
-  required int64 onlineEpoc = 5;
+  required int64 onlineEpoch = 5;
 }
 
 message TransactionStateMsg {
@@ -413,6 +424,8 @@ service TrxRegionService {
     returns(PutTransactionalResponse);
   rpc putMultiple(PutMultipleTransactionalRequest)
     returns(PutMultipleTransactionalResponse);
+  rpc pushOnlineEpoch(PushEpochRequest)
+    returns(PushEpochResponse);
   rpc recoveryRequest(RecoveryRequestRequest)
     returns(RecoveryRequestResponse);
   rpc deleteTlogEntries(TlogDeleteRequest)