Updated Tari protocol definitions

merge-mining
SChernykh 2024-04-11 18:04:10 +02:00
parent ad04fd13ae
commit d6d9b5bc22
8 changed files with 3510 additions and 691 deletions

View File

@ -36,6 +36,8 @@ static const char* BaseNode_method_names[] = {
"/tari.rpc.BaseNode/GetNetworkDifficulty",
"/tari.rpc.BaseNode/GetNewBlockTemplate",
"/tari.rpc.BaseNode/GetNewBlock",
"/tari.rpc.BaseNode/GetNewBlockWithCoinbases",
"/tari.rpc.BaseNode/GetNewBlockTemplateWithCoinbases",
"/tari.rpc.BaseNode/GetNewBlockBlob",
"/tari.rpc.BaseNode/SubmitBlock",
"/tari.rpc.BaseNode/SubmitBlockBlob",
@ -79,27 +81,29 @@ BaseNode::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel,
, rpcmethod_GetNetworkDifficulty_(BaseNode_method_names[10], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetNewBlockTemplate_(BaseNode_method_names[11], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetNewBlock_(BaseNode_method_names[12], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetNewBlockBlob_(BaseNode_method_names[13], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SubmitBlock_(BaseNode_method_names[14], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SubmitBlockBlob_(BaseNode_method_names[15], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SubmitTransaction_(BaseNode_method_names[16], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetSyncInfo_(BaseNode_method_names[17], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetSyncProgress_(BaseNode_method_names[18], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetTipInfo_(BaseNode_method_names[19], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SearchKernels_(BaseNode_method_names[20], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_SearchUtxos_(BaseNode_method_names[21], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_FetchMatchingUtxos_(BaseNode_method_names[22], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetPeers_(BaseNode_method_names[23], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetMempoolTransactions_(BaseNode_method_names[24], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_TransactionState_(BaseNode_method_names[25], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_Identify_(BaseNode_method_names[26], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetNetworkStatus_(BaseNode_method_names[27], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_ListConnectedPeers_(BaseNode_method_names[28], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetMempoolStats_(BaseNode_method_names[29], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetActiveValidatorNodes_(BaseNode_method_names[30], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetShardKey_(BaseNode_method_names[31], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetTemplateRegistrations_(BaseNode_method_names[32], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetSideChainUtxos_(BaseNode_method_names[33], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetNewBlockWithCoinbases_(BaseNode_method_names[13], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetNewBlockTemplateWithCoinbases_(BaseNode_method_names[14], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetNewBlockBlob_(BaseNode_method_names[15], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SubmitBlock_(BaseNode_method_names[16], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SubmitBlockBlob_(BaseNode_method_names[17], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SubmitTransaction_(BaseNode_method_names[18], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetSyncInfo_(BaseNode_method_names[19], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetSyncProgress_(BaseNode_method_names[20], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetTipInfo_(BaseNode_method_names[21], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_SearchKernels_(BaseNode_method_names[22], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_SearchUtxos_(BaseNode_method_names[23], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_FetchMatchingUtxos_(BaseNode_method_names[24], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetPeers_(BaseNode_method_names[25], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetMempoolTransactions_(BaseNode_method_names[26], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_TransactionState_(BaseNode_method_names[27], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_Identify_(BaseNode_method_names[28], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetNetworkStatus_(BaseNode_method_names[29], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_ListConnectedPeers_(BaseNode_method_names[30], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetMempoolStats_(BaseNode_method_names[31], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetActiveValidatorNodes_(BaseNode_method_names[32], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetShardKey_(BaseNode_method_names[33], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
, rpcmethod_GetTemplateRegistrations_(BaseNode_method_names[34], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
, rpcmethod_GetSideChainUtxos_(BaseNode_method_names[35], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel)
{}
::grpc::ClientReader< ::tari::rpc::BlockHeaderResponse>* BaseNode::Stub::ListHeadersRaw(::grpc::ClientContext* context, const ::tari::rpc::ListHeadersRequest& request) {
@ -373,6 +377,52 @@ void BaseNode::Stub::async::GetNewBlock(::grpc::ClientContext* context, const ::
return result;
}
::grpc::Status BaseNode::Stub::GetNewBlockWithCoinbases(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockWithCoinbasesRequest& request, ::tari::rpc::GetNewBlockResult* response) {
return ::grpc::internal::BlockingUnaryCall< ::tari::rpc::GetNewBlockWithCoinbasesRequest, ::tari::rpc::GetNewBlockResult, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_GetNewBlockWithCoinbases_, context, request, response);
}
void BaseNode::Stub::async::GetNewBlockWithCoinbases(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockWithCoinbasesRequest* request, ::tari::rpc::GetNewBlockResult* response, std::function<void(::grpc::Status)> f) {
::grpc::internal::CallbackUnaryCall< ::tari::rpc::GetNewBlockWithCoinbasesRequest, ::tari::rpc::GetNewBlockResult, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_GetNewBlockWithCoinbases_, context, request, response, std::move(f));
}
void BaseNode::Stub::async::GetNewBlockWithCoinbases(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockWithCoinbasesRequest* request, ::tari::rpc::GetNewBlockResult* response, ::grpc::ClientUnaryReactor* reactor) {
::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_GetNewBlockWithCoinbases_, context, request, response, reactor);
}
::grpc::ClientAsyncResponseReader< ::tari::rpc::GetNewBlockResult>* BaseNode::Stub::PrepareAsyncGetNewBlockWithCoinbasesRaw(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockWithCoinbasesRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::tari::rpc::GetNewBlockResult, ::tari::rpc::GetNewBlockWithCoinbasesRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_GetNewBlockWithCoinbases_, context, request);
}
::grpc::ClientAsyncResponseReader< ::tari::rpc::GetNewBlockResult>* BaseNode::Stub::AsyncGetNewBlockWithCoinbasesRaw(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockWithCoinbasesRequest& request, ::grpc::CompletionQueue* cq) {
auto* result =
this->PrepareAsyncGetNewBlockWithCoinbasesRaw(context, request, cq);
result->StartCall();
return result;
}
::grpc::Status BaseNode::Stub::GetNewBlockTemplateWithCoinbases(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest& request, ::tari::rpc::GetNewBlockResult* response) {
return ::grpc::internal::BlockingUnaryCall< ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest, ::tari::rpc::GetNewBlockResult, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_GetNewBlockTemplateWithCoinbases_, context, request, response);
}
void BaseNode::Stub::async::GetNewBlockTemplateWithCoinbases(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest* request, ::tari::rpc::GetNewBlockResult* response, std::function<void(::grpc::Status)> f) {
::grpc::internal::CallbackUnaryCall< ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest, ::tari::rpc::GetNewBlockResult, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_GetNewBlockTemplateWithCoinbases_, context, request, response, std::move(f));
}
void BaseNode::Stub::async::GetNewBlockTemplateWithCoinbases(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest* request, ::tari::rpc::GetNewBlockResult* response, ::grpc::ClientUnaryReactor* reactor) {
::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_GetNewBlockTemplateWithCoinbases_, context, request, response, reactor);
}
::grpc::ClientAsyncResponseReader< ::tari::rpc::GetNewBlockResult>* BaseNode::Stub::PrepareAsyncGetNewBlockTemplateWithCoinbasesRaw(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest& request, ::grpc::CompletionQueue* cq) {
return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::tari::rpc::GetNewBlockResult, ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_GetNewBlockTemplateWithCoinbases_, context, request);
}
::grpc::ClientAsyncResponseReader< ::tari::rpc::GetNewBlockResult>* BaseNode::Stub::AsyncGetNewBlockTemplateWithCoinbasesRaw(::grpc::ClientContext* context, const ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest& request, ::grpc::CompletionQueue* cq) {
auto* result =
this->PrepareAsyncGetNewBlockTemplateWithCoinbasesRaw(context, request, cq);
result->StartCall();
return result;
}
::grpc::Status BaseNode::Stub::GetNewBlockBlob(::grpc::ClientContext* context, const ::tari::rpc::NewBlockTemplate& request, ::tari::rpc::GetNewBlockBlobResult* response) {
return ::grpc::internal::BlockingUnaryCall< ::tari::rpc::NewBlockTemplate, ::tari::rpc::GetNewBlockBlobResult, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_GetNewBlockBlob_, context, request, response);
}
@ -934,6 +984,26 @@ BaseNode::Service::Service() {
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[13],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::GetNewBlockWithCoinbasesRequest, ::tari::rpc::GetNewBlockResult, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
::grpc::ServerContext* ctx,
const ::tari::rpc::GetNewBlockWithCoinbasesRequest* req,
::tari::rpc::GetNewBlockResult* resp) {
return service->GetNewBlockWithCoinbases(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[14],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest, ::tari::rpc::GetNewBlockResult, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
::grpc::ServerContext* ctx,
const ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest* req,
::tari::rpc::GetNewBlockResult* resp) {
return service->GetNewBlockTemplateWithCoinbases(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[15],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::NewBlockTemplate, ::tari::rpc::GetNewBlockBlobResult, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
::grpc::ServerContext* ctx,
@ -942,7 +1012,7 @@ BaseNode::Service::Service() {
return service->GetNewBlockBlob(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[14],
BaseNode_method_names[16],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::Block, ::tari::rpc::SubmitBlockResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -952,7 +1022,7 @@ BaseNode::Service::Service() {
return service->SubmitBlock(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[15],
BaseNode_method_names[17],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::BlockBlobRequest, ::tari::rpc::SubmitBlockResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -962,7 +1032,7 @@ BaseNode::Service::Service() {
return service->SubmitBlockBlob(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[16],
BaseNode_method_names[18],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::SubmitTransactionRequest, ::tari::rpc::SubmitTransactionResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -972,7 +1042,7 @@ BaseNode::Service::Service() {
return service->SubmitTransaction(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[17],
BaseNode_method_names[19],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::Empty, ::tari::rpc::SyncInfoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -982,7 +1052,7 @@ BaseNode::Service::Service() {
return service->GetSyncInfo(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[18],
BaseNode_method_names[20],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::Empty, ::tari::rpc::SyncProgressResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -992,7 +1062,7 @@ BaseNode::Service::Service() {
return service->GetSyncProgress(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[19],
BaseNode_method_names[21],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::Empty, ::tari::rpc::TipInfoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -1002,7 +1072,7 @@ BaseNode::Service::Service() {
return service->GetTipInfo(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[20],
BaseNode_method_names[22],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< BaseNode::Service, ::tari::rpc::SearchKernelsRequest, ::tari::rpc::HistoricalBlock>(
[](BaseNode::Service* service,
@ -1012,7 +1082,7 @@ BaseNode::Service::Service() {
return service->SearchKernels(ctx, req, writer);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[21],
BaseNode_method_names[23],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< BaseNode::Service, ::tari::rpc::SearchUtxosRequest, ::tari::rpc::HistoricalBlock>(
[](BaseNode::Service* service,
@ -1022,7 +1092,7 @@ BaseNode::Service::Service() {
return service->SearchUtxos(ctx, req, writer);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[22],
BaseNode_method_names[24],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< BaseNode::Service, ::tari::rpc::FetchMatchingUtxosRequest, ::tari::rpc::FetchMatchingUtxosResponse>(
[](BaseNode::Service* service,
@ -1032,7 +1102,7 @@ BaseNode::Service::Service() {
return service->FetchMatchingUtxos(ctx, req, writer);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[23],
BaseNode_method_names[25],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< BaseNode::Service, ::tari::rpc::GetPeersRequest, ::tari::rpc::GetPeersResponse>(
[](BaseNode::Service* service,
@ -1042,7 +1112,7 @@ BaseNode::Service::Service() {
return service->GetPeers(ctx, req, writer);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[24],
BaseNode_method_names[26],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< BaseNode::Service, ::tari::rpc::GetMempoolTransactionsRequest, ::tari::rpc::GetMempoolTransactionsResponse>(
[](BaseNode::Service* service,
@ -1052,7 +1122,7 @@ BaseNode::Service::Service() {
return service->GetMempoolTransactions(ctx, req, writer);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[25],
BaseNode_method_names[27],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::TransactionStateRequest, ::tari::rpc::TransactionStateResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -1062,7 +1132,7 @@ BaseNode::Service::Service() {
return service->TransactionState(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[26],
BaseNode_method_names[28],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::Empty, ::tari::rpc::NodeIdentity, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -1072,7 +1142,7 @@ BaseNode::Service::Service() {
return service->Identify(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[27],
BaseNode_method_names[29],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::Empty, ::tari::rpc::NetworkStatusResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -1082,7 +1152,7 @@ BaseNode::Service::Service() {
return service->GetNetworkStatus(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[28],
BaseNode_method_names[30],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::Empty, ::tari::rpc::ListConnectedPeersResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -1092,7 +1162,7 @@ BaseNode::Service::Service() {
return service->ListConnectedPeers(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[29],
BaseNode_method_names[31],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::Empty, ::tari::rpc::MempoolStatsResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -1102,7 +1172,7 @@ BaseNode::Service::Service() {
return service->GetMempoolStats(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[30],
BaseNode_method_names[32],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< BaseNode::Service, ::tari::rpc::GetActiveValidatorNodesRequest, ::tari::rpc::GetActiveValidatorNodesResponse>(
[](BaseNode::Service* service,
@ -1112,7 +1182,7 @@ BaseNode::Service::Service() {
return service->GetActiveValidatorNodes(ctx, req, writer);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[31],
BaseNode_method_names[33],
::grpc::internal::RpcMethod::NORMAL_RPC,
new ::grpc::internal::RpcMethodHandler< BaseNode::Service, ::tari::rpc::GetShardKeyRequest, ::tari::rpc::GetShardKeyResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
[](BaseNode::Service* service,
@ -1122,7 +1192,7 @@ BaseNode::Service::Service() {
return service->GetShardKey(ctx, req, resp);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[32],
BaseNode_method_names[34],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< BaseNode::Service, ::tari::rpc::GetTemplateRegistrationsRequest, ::tari::rpc::GetTemplateRegistrationResponse>(
[](BaseNode::Service* service,
@ -1132,7 +1202,7 @@ BaseNode::Service::Service() {
return service->GetTemplateRegistrations(ctx, req, writer);
}, this)));
AddMethod(new ::grpc::internal::RpcServiceMethod(
BaseNode_method_names[33],
BaseNode_method_names[35],
::grpc::internal::RpcMethod::SERVER_STREAMING,
new ::grpc::internal::ServerStreamingHandler< BaseNode::Service, ::tari::rpc::GetSideChainUtxosRequest, ::tari::rpc::GetSideChainUtxosResponse>(
[](BaseNode::Service* service,
@ -1237,6 +1307,20 @@ BaseNode::Service::~Service() {
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
}
::grpc::Status BaseNode::Service::GetNewBlockWithCoinbases(::grpc::ServerContext* context, const ::tari::rpc::GetNewBlockWithCoinbasesRequest* request, ::tari::rpc::GetNewBlockResult* response) {
(void) context;
(void) request;
(void) response;
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
}
::grpc::Status BaseNode::Service::GetNewBlockTemplateWithCoinbases(::grpc::ServerContext* context, const ::tari::rpc::GetNewBlockTemplateWithCoinbasesRequest* request, ::tari::rpc::GetNewBlockResult* response) {
(void) context;
(void) request;
(void) response;
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
}
::grpc::Status BaseNode::Service::GetNewBlockBlob(::grpc::ServerContext* context, const ::tari::rpc::NewBlockTemplate* request, ::tari::rpc::GetNewBlockBlobResult* response) {
(void) context;
(void) request;

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

View File

@ -57,6 +57,10 @@ service BaseNode {
rpc GetNewBlockTemplate(NewBlockTemplateRequest) returns (NewBlockTemplateResponse);
// Construct a new block from a provided template
rpc GetNewBlock(NewBlockTemplate) returns (GetNewBlockResult);
// Construct a new block from a provided template
rpc GetNewBlockWithCoinbases(GetNewBlockWithCoinbasesRequest) returns (GetNewBlockResult);
// Construct a new block from a provided template
rpc GetNewBlockTemplateWithCoinbases(GetNewBlockTemplateWithCoinbasesRequest) returns (GetNewBlockResult);
// Construct a new block and header blob from a provided template
rpc GetNewBlockBlob(NewBlockTemplate) returns (GetNewBlockBlobResult);
// Submit a new block for propagation
@ -182,6 +186,28 @@ message NewBlockTemplateRequest{
uint64 max_weight = 2;
}
/// return type of NewBlockTemplateRequest
message GetNewBlockTemplateWithCoinbasesRequest{
PowAlgo algo = 1;
//This field should be moved to optional once optional keyword is standard
uint64 max_weight = 2;
repeated NewBlockCoinbase coinbases = 3;
}
/// request type of GetNewBlockWithCoinbasesRequest
message GetNewBlockWithCoinbasesRequest{
NewBlockTemplate new_template = 1;
repeated NewBlockCoinbase coinbases = 2;
}
message NewBlockCoinbase{
string address = 1;
uint64 value = 2;
bool stealth_payment= 3;
bool revealed_value_proof= 4;
bytes coinbase_extra =5;
}
// Network difficulty response
message NetworkDifficultyResponse {
uint64 difficulty = 1;
@ -310,9 +336,9 @@ enum Sorting {
message MetaData {
// The current chain height, or the block number of the longest valid chain, or `None` if there is no chain
uint64 height_of_longest_chain = 1;
uint64 best_block_height = 1;
// The block hash of the current tip of the longest valid chain, or `None` for an empty chain
bytes best_block = 2;
bytes best_block_hash = 2;
// This is the min height this node can provide complete blocks for. A 0 here means this node is archival and can provide complete blocks for every height.
uint64 pruned_height = 6;
// The current geometric mean of the pow of the chain tip, or `None` if there is no chain
@ -348,6 +374,7 @@ message GetNewBlockResult{
Block block = 2;
bytes merge_mining_hash =3;
bytes tari_unique_id =4;
MinerData miner_data = 5;
}
// This is the message that is returned for a miner after it asks for a new block.

View File

@ -310,6 +310,8 @@ inline constexpr ConsensusConstants::Impl_::Impl_(
validator_node_registration_min_deposit_amount_{::uint64_t{0u}},
validator_node_registration_min_lock_height_{::uint64_t{0u}},
validator_node_registration_shuffle_interval_epoch_{::uint64_t{0u}},
inflation_bips_{::uint64_t{0u}},
tail_epoch_length_{::uint64_t{0u}},
blockchain_version_{0u} {}
template <typename>
@ -499,6 +501,8 @@ const ::uint32_t TableStruct_types_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(
PROTOBUF_FIELD_OFFSET(::tari::rpc::ConsensusConstants, _impl_.validator_node_registration_min_lock_height_),
PROTOBUF_FIELD_OFFSET(::tari::rpc::ConsensusConstants, _impl_.validator_node_registration_shuffle_interval_epoch_),
PROTOBUF_FIELD_OFFSET(::tari::rpc::ConsensusConstants, _impl_.permitted_range_proof_types_),
PROTOBUF_FIELD_OFFSET(::tari::rpc::ConsensusConstants, _impl_.inflation_bips_),
PROTOBUF_FIELD_OFFSET(::tari::rpc::ConsensusConstants, _impl_.tail_epoch_length_),
~0u,
~0u,
~0u,
@ -530,6 +534,8 @@ const ::uint32_t TableStruct_types_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(
~0u,
~0u,
~0u,
~0u,
~0u,
};
static const ::_pbi::MigrationSchema
@ -546,7 +552,7 @@ static const ::_pbi::MigrationSchema
{96, -1, -1, sizeof(::tari::rpc::PermittedRangeProofs)},
{106, -1, -1, sizeof(::tari::rpc::RangeProof)},
{115, 125, -1, sizeof(::tari::rpc::ConsensusConstants_ProofOfWorkEntry_DoNotUse)},
{127, 166, -1, sizeof(::tari::rpc::ConsensusConstants)},
{127, 168, -1, sizeof(::tari::rpc::ConsensusConstants)},
};
static const ::_pb::Message* const file_default_instances[] = {
@ -585,50 +591,52 @@ const char descriptor_table_protodef_types_2eproto[] PROTOBUF_SECTION_VARIABLE(p
"output_type\030\001 \001(\0162\024.tari.rpc.OutputType\022"
"3\n\021range_proof_types\030\002 \003(\0162\030.tari.rpc.Ra"
"ngeProofType\"!\n\nRangeProof\022\023\n\013proof_byte"
"s\030\001 \001(\014\"\240\n\n\022ConsensusConstants\022\035\n\025coinba"
"s\030\001 \001(\014\"\327\n\n\022ConsensusConstants\022\035\n\025coinba"
"se_min_maturity\030\001 \001(\004\022\032\n\022blockchain_vers"
"ion\030\002 \001(\r\022\031\n\021future_time_limit\030\003 \001(\004\022\037\n\027"
"difficulty_block_window\030\005 \001(\004\022$\n\034max_blo"
"ck_transaction_weight\030\007 \001(\004\022\026\n\016pow_algo_"
"count\030\010 \001(\004\022\036\n\026median_timestamp_count\030\t "
"\001(\004\022\030\n\020emission_initial\030\n \001(\004\022\026\n\016emissio"
"n_decay\030\013 \003(\004\022\025\n\remission_tail\030\014 \001(\004\022 \n\030"
"min_sha3x_pow_difficulty\030\r \001(\004\022\033\n\023block_"
"weight_inputs\030\016 \001(\004\022\034\n\024block_weight_outp"
"uts\030\017 \001(\004\022\034\n\024block_weight_kernels\030\020 \001(\004\022"
"\024\n\014faucet_value\030\021 \001(\004\022\034\n\024max_script_byte"
"_size\030\022 \001(\004\022&\n\036validator_node_validity_p"
"eriod\030\023 \001(\004\022\035\n\025effective_from_height\030\024 \001"
"(\004\0227\n\036valid_blockchain_version_range\030\025 \001"
"(\0132\017.tari.rpc.Range\022\037\n\027max_randomx_seed_"
"height\030\026 \001(\004\022D\n\rproof_of_work\030\027 \003(\0132-.ta"
"ri.rpc.ConsensusConstants.ProofOfWorkEnt"
"ry\0222\n\022transaction_weight\030\030 \001(\0132\026.tari.rp"
"c.WeightParams\022,\n\023input_version_range\030\032 "
"\001(\0132\017.tari.rpc.Range\0226\n\024output_version_r"
"ange\030\033 \001(\0132\030.tari.rpc.OutputsVersion\022-\n\024"
"kernel_version_range\030\034 \001(\0132\017.tari.rpc.Ra"
"nge\0224\n\026permitted_output_types\030\035 \003(\0162\024.ta"
"ri.rpc.OutputType\022\024\n\014epoch_length\030\036 \001(\004\022"
"6\n.validator_node_registration_min_depos"
"it_amount\030\037 \001(\004\0223\n+validator_node_regist"
"ration_min_lock_height\030 \001(\004\022:\n2validato"
"r_node_registration_shuffle_interval_epo"
"ch\030! \001(\004\022C\n\033permitted_range_proof_types\030"
"\" \003(\0132\036.tari.rpc.PermittedRangeProofs\032S\n"
"\020ProofOfWorkEntry\022\013\n\003key\030\001 \001(\r\022.\n\005value\030"
"\002 \001(\0132\037.tari.rpc.PowAlgorithmConstants:\002"
"8\001*s\n\nOutputType\022\014\n\010STANDARD\020\000\022\014\n\010COINBA"
"SE\020\001\022\010\n\004BURN\020\002\022\037\n\033VALIDATOR_NODE_REGISTR"
"ATION\020\003\022\036\n\032CODE_TEMPLATE_REGISTRATION\020\004*"
":\n\016RangeProofType\022\024\n\020BULLETPROOF_PLUS\020\000\022"
"\022\n\016REVEALED_VALUE\020\001b\006proto3"
"n_decay\030\013 \003(\004\022\031\n\remission_tail\030\014 \001(\004B\002\030\001"
"\022 \n\030min_sha3x_pow_difficulty\030\r \001(\004\022\033\n\023bl"
"ock_weight_inputs\030\016 \001(\004\022\034\n\024block_weight_"
"outputs\030\017 \001(\004\022\034\n\024block_weight_kernels\030\020 "
"\001(\004\022\024\n\014faucet_value\030\021 \001(\004\022\034\n\024max_script_"
"byte_size\030\022 \001(\004\022&\n\036validator_node_validi"
"ty_period\030\023 \001(\004\022\035\n\025effective_from_height"
"\030\024 \001(\004\0227\n\036valid_blockchain_version_range"
"\030\025 \001(\0132\017.tari.rpc.Range\022\037\n\027max_randomx_s"
"eed_height\030\026 \001(\004\022D\n\rproof_of_work\030\027 \003(\0132"
"-.tari.rpc.ConsensusConstants.ProofOfWor"
"kEntry\0222\n\022transaction_weight\030\030 \001(\0132\026.tar"
"i.rpc.WeightParams\022,\n\023input_version_rang"
"e\030\032 \001(\0132\017.tari.rpc.Range\0226\n\024output_versi"
"on_range\030\033 \001(\0132\030.tari.rpc.OutputsVersion"
"\022-\n\024kernel_version_range\030\034 \001(\0132\017.tari.rp"
"c.Range\0224\n\026permitted_output_types\030\035 \003(\0162"
"\024.tari.rpc.OutputType\022\024\n\014epoch_length\030\036 "
"\001(\004\0226\n.validator_node_registration_min_d"
"eposit_amount\030\037 \001(\004\0223\n+validator_node_re"
"gistration_min_lock_height\030 \001(\004\022:\n2vali"
"dator_node_registration_shuffle_interval"
"_epoch\030! \001(\004\022C\n\033permitted_range_proof_ty"
"pes\030\" \003(\0132\036.tari.rpc.PermittedRangeProof"
"s\022\026\n\016inflation_bips\030# \001(\004\022\031\n\021tail_epoch_"
"length\030$ \001(\004\032S\n\020ProofOfWorkEntry\022\013\n\003key\030"
"\001 \001(\r\022.\n\005value\030\002 \001(\0132\037.tari.rpc.PowAlgor"
"ithmConstants:\0028\001*s\n\nOutputType\022\014\n\010STAND"
"ARD\020\000\022\014\n\010COINBASE\020\001\022\010\n\004BURN\020\002\022\037\n\033VALIDAT"
"OR_NODE_REGISTRATION\020\003\022\036\n\032CODE_TEMPLATE_"
"REGISTRATION\020\004*:\n\016RangeProofType\022\024\n\020BULL"
"ETPROOF_PLUS\020\000\022\022\n\016REVEALED_VALUE\020\001b\006prot"
"o3"
};
static ::absl::once_flag descriptor_table_types_2eproto_once;
const ::_pbi::DescriptorTable descriptor_table_types_2eproto = {
false,
false,
2307,
2362,
descriptor_table_protodef_types_2eproto,
"types.proto",
&descriptor_table_types_2eproto_once,
@ -3165,15 +3173,15 @@ const char* ConsensusConstants::_InternalParse(
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
const ::_pbi::TcParseTable<5, 33, 8, 0, 7> ConsensusConstants::_table_ = {
{
PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_._has_bits_),
0, // no _extensions_
34, 248, // max_field_number, fast_idx_mask
36, 248, // max_field_number, fast_idx_mask
offsetof(decltype(_table_), field_lookup_table),
16777256, // skipmap
offsetof(decltype(_table_), field_entries),
31, // num_field_entries
33, // num_field_entries
8, // num_aux_entries
offsetof(decltype(_table_), aux_entries),
&_ConsensusConstants_default_instance_._instance,
@ -3209,7 +3217,7 @@ const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
// repeated uint64 emission_decay = 11;
{::_pbi::TcParser::FastV64P1,
{90, 63, 0, PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_.emission_decay_)}},
// uint64 emission_tail = 12;
// uint64 emission_tail = 12 [deprecated = true];
{::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(ConsensusConstants, _impl_.emission_tail_), 63>(),
{96, 63, 0, PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_.emission_tail_)}},
// uint64 min_sha3x_pow_difficulty = 13;
@ -3267,7 +3275,7 @@ const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
{504, 63, 0, PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_.validator_node_registration_min_deposit_amount_)}},
}}, {{
33, 0, 1,
65532, 29,
65520, 29,
65535, 65535
}}, {{
// uint64 coinbase_min_maturity = 1;
@ -3297,7 +3305,7 @@ const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
// repeated uint64 emission_decay = 11;
{PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_.emission_decay_), -1, 0,
(0 | ::_fl::kFcRepeated | ::_fl::kPackedUInt64)},
// uint64 emission_tail = 12;
// uint64 emission_tail = 12 [deprecated = true];
{PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_.emission_tail_), -1, 0,
(0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
// uint64 min_sha3x_pow_difficulty = 13;
@ -3363,6 +3371,12 @@ const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
// repeated .tari.rpc.PermittedRangeProofs permitted_range_proof_types = 34;
{PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_.permitted_range_proof_types_), -1, 7,
(0 | ::_fl::kFcRepeated | ::_fl::kMessage | ::_fl::kTvTable)},
// uint64 inflation_bips = 35;
{PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_.inflation_bips_), -1, 0,
(0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
// uint64 tail_epoch_length = 36;
{PROTOBUF_FIELD_OFFSET(ConsensusConstants, _impl_.tail_epoch_length_), -1, 0,
(0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
}}, {{
{::_pbi::TcParser::GetTable<::tari::rpc::Range>()},
{::_pbi::TcParser::GetMapAuxInfo<
@ -3451,7 +3465,7 @@ const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
}
}
// uint64 emission_tail = 12;
// uint64 emission_tail = 12 [deprecated = true];
if (this->_internal_emission_tail() != 0) {
target = stream->EnsureSpace(target);
target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
@ -3623,6 +3637,20 @@ const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
InternalWriteMessage(34, repfield, repfield.GetCachedSize(), target, stream);
}
// uint64 inflation_bips = 35;
if (this->_internal_inflation_bips() != 0) {
target = stream->EnsureSpace(target);
target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
35, this->_internal_inflation_bips(), target);
}
// uint64 tail_epoch_length = 36;
if (this->_internal_tail_epoch_length() != 0) {
target = stream->EnsureSpace(target);
target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
36, this->_internal_tail_epoch_length(), target);
}
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
target =
::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
@ -3758,7 +3786,7 @@ const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
this->_internal_emission_initial());
}
// uint64 emission_tail = 12;
// uint64 emission_tail = 12 [deprecated = true];
if (this->_internal_emission_tail() != 0) {
total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
this->_internal_emission_tail());
@ -3842,6 +3870,18 @@ const ::_pbi::TcParseTable<5, 31, 8, 0, 7> ConsensusConstants::_table_ = {
this->_internal_validator_node_registration_shuffle_interval_epoch());
}
// uint64 inflation_bips = 35;
if (this->_internal_inflation_bips() != 0) {
total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
this->_internal_inflation_bips());
}
// uint64 tail_epoch_length = 36;
if (this->_internal_tail_epoch_length() != 0) {
total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
this->_internal_tail_epoch_length());
}
// uint32 blockchain_version = 2;
if (this->_internal_blockchain_version() != 0) {
total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne(
@ -3958,6 +3998,12 @@ void ConsensusConstants::MergeImpl(::google::protobuf::Message& to_msg, const ::
if (from._internal_validator_node_registration_shuffle_interval_epoch() != 0) {
_this->_internal_set_validator_node_registration_shuffle_interval_epoch(from._internal_validator_node_registration_shuffle_interval_epoch());
}
if (from._internal_inflation_bips() != 0) {
_this->_internal_set_inflation_bips(from._internal_inflation_bips());
}
if (from._internal_tail_epoch_length() != 0) {
_this->_internal_set_tail_epoch_length(from._internal_tail_epoch_length());
}
if (from._internal_blockchain_version() != 0) {
_this->_internal_set_blockchain_version(from._internal_blockchain_version());
}

View File

@ -2527,6 +2527,8 @@ class ConsensusConstants final :
kValidatorNodeRegistrationMinDepositAmountFieldNumber = 31,
kValidatorNodeRegistrationMinLockHeightFieldNumber = 32,
kValidatorNodeRegistrationShuffleIntervalEpochFieldNumber = 33,
kInflationBipsFieldNumber = 35,
kTailEpochLengthFieldNumber = 36,
kBlockchainVersionFieldNumber = 2,
};
// repeated uint64 emission_decay = 11;
@ -2744,10 +2746,10 @@ class ConsensusConstants final :
void _internal_set_emission_initial(::uint64_t value);
public:
// uint64 emission_tail = 12;
void clear_emission_tail() ;
::uint64_t emission_tail() const;
void set_emission_tail(::uint64_t value);
// uint64 emission_tail = 12 [deprecated = true];
[[deprecated]] void clear_emission_tail() ;
[[deprecated]] ::uint64_t emission_tail() const;
[[deprecated]] void set_emission_tail(::uint64_t value);
private:
::uint64_t _internal_emission_tail() const;
@ -2883,6 +2885,26 @@ class ConsensusConstants final :
::uint64_t _internal_validator_node_registration_shuffle_interval_epoch() const;
void _internal_set_validator_node_registration_shuffle_interval_epoch(::uint64_t value);
public:
// uint64 inflation_bips = 35;
void clear_inflation_bips() ;
::uint64_t inflation_bips() const;
void set_inflation_bips(::uint64_t value);
private:
::uint64_t _internal_inflation_bips() const;
void _internal_set_inflation_bips(::uint64_t value);
public:
// uint64 tail_epoch_length = 36;
void clear_tail_epoch_length() ;
::uint64_t tail_epoch_length() const;
void set_tail_epoch_length(::uint64_t value);
private:
::uint64_t _internal_tail_epoch_length() const;
void _internal_set_tail_epoch_length(::uint64_t value);
public:
// uint32 blockchain_version = 2;
void clear_blockchain_version() ;
@ -2900,7 +2922,7 @@ class ConsensusConstants final :
friend class ::google::protobuf::internal::TcParser;
static const ::google::protobuf::internal::TcParseTable<
5, 31, 8,
5, 33, 8,
0, 7>
_table_;
friend class ::google::protobuf::MessageLite;
@ -2954,6 +2976,8 @@ class ConsensusConstants final :
::uint64_t validator_node_registration_min_deposit_amount_;
::uint64_t validator_node_registration_min_lock_height_;
::uint64_t validator_node_registration_shuffle_interval_epoch_;
::uint64_t inflation_bips_;
::uint64_t tail_epoch_length_;
::uint32_t blockchain_version_;
PROTOBUF_TSAN_DECLARE_MEMBER
};
@ -4324,7 +4348,7 @@ inline ::google::protobuf::RepeatedField<::uint64_t>* ConsensusConstants::_inter
return &_impl_.emission_decay_;
}
// uint64 emission_tail = 12;
// uint64 emission_tail = 12 [deprecated = true];
inline void ConsensusConstants::clear_emission_tail() {
PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
_impl_.emission_tail_ = ::uint64_t{0u};
@ -5247,6 +5271,52 @@ ConsensusConstants::_internal_mutable_permitted_range_proof_types() {
return &_impl_.permitted_range_proof_types_;
}
// uint64 inflation_bips = 35;
inline void ConsensusConstants::clear_inflation_bips() {
PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
_impl_.inflation_bips_ = ::uint64_t{0u};
}
inline ::uint64_t ConsensusConstants::inflation_bips() const {
// @@protoc_insertion_point(field_get:tari.rpc.ConsensusConstants.inflation_bips)
return _internal_inflation_bips();
}
inline void ConsensusConstants::set_inflation_bips(::uint64_t value) {
_internal_set_inflation_bips(value);
// @@protoc_insertion_point(field_set:tari.rpc.ConsensusConstants.inflation_bips)
}
inline ::uint64_t ConsensusConstants::_internal_inflation_bips() const {
PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
return _impl_.inflation_bips_;
}
inline void ConsensusConstants::_internal_set_inflation_bips(::uint64_t value) {
PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
;
_impl_.inflation_bips_ = value;
}
// uint64 tail_epoch_length = 36;
inline void ConsensusConstants::clear_tail_epoch_length() {
PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
_impl_.tail_epoch_length_ = ::uint64_t{0u};
}
inline ::uint64_t ConsensusConstants::tail_epoch_length() const {
// @@protoc_insertion_point(field_get:tari.rpc.ConsensusConstants.tail_epoch_length)
return _internal_tail_epoch_length();
}
inline void ConsensusConstants::set_tail_epoch_length(::uint64_t value) {
_internal_set_tail_epoch_length(value);
// @@protoc_insertion_point(field_set:tari.rpc.ConsensusConstants.tail_epoch_length)
}
inline ::uint64_t ConsensusConstants::_internal_tail_epoch_length() const {
PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
return _impl_.tail_epoch_length_;
}
inline void ConsensusConstants::_internal_set_tail_epoch_length(::uint64_t value) {
PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
;
_impl_.tail_epoch_length_ = value;
}
#ifdef __GNUC__
#pragma GCC diagnostic pop
#endif // __GNUC__

View File

@ -119,7 +119,7 @@ message ConsensusConstants {
uint64 median_timestamp_count = 9;
uint64 emission_initial = 10;
repeated uint64 emission_decay = 11;
uint64 emission_tail = 12;
uint64 emission_tail = 12 [deprecated=true];
uint64 min_sha3x_pow_difficulty = 13;
uint64 block_weight_inputs = 14;
uint64 block_weight_outputs = 15;
@ -141,4 +141,6 @@ message ConsensusConstants {
uint64 validator_node_registration_min_lock_height = 32;
uint64 validator_node_registration_shuffle_interval_epoch = 33;
repeated PermittedRangeProofs permitted_range_proof_types = 34;
uint64 inflation_bips = 35;
uint64 tail_epoch_length = 36;
}