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)