This is an automated email from the ASF dual-hosted git repository. saipranav pushed a commit to branch ResViewCrow in repository https://gitbox.apache.org/repos/asf/incubator-resilientdb.git
commit 41d5bfa5b73e98ad75231c450ebc58fa1f7df34e Merge: d69b74c5 a145249f Author: Saipranav Kotamreddy <[email protected]> AuthorDate: Thu Mar 7 18:00:08 2024 -0800 Merge branch 'master' into ResViewCrow .asf.yaml | 40 +++ .bazelversion | 1 + .github/workflows/build-push.yml | 4 +- CHANGELOG.md | 8 + NOTICE | 5 + README.md | 240 ++++++++++++++--- WORKSPACE | 4 +- benchmark/protocols/pbft/BUILD | 1 + benchmark/protocols/pbft/kv_server_performance.cpp | 39 ++- benchmark/protocols/pbft/kv_service_tools.cpp | 34 +-- chain/state/BUILD | 2 +- chain/state/chain_state.cpp | 98 ++----- chain/state/chain_state.h | 54 ++-- chain/state/chain_state_test.cpp | 75 +++--- chain/storage/BUILD | 50 ++-- chain/storage/README.md | 13 - chain/storage/kv_storage_test.cpp | 232 ++++++++++++++++ chain/storage/leveldb.cpp | 290 ++++++++++++++++++++ chain/storage/leveldb.h | 81 ++++++ chain/storage/memory_db.cpp | 170 ++++++++++++ chain/storage/memory_db.h | 88 +++++++ chain/storage/mock_storage.h | 52 ++-- chain/storage/proto/BUILD | 36 +++ chain/storage/proto/kv.proto | 13 + chain/storage/proto/leveldb_config.proto | 9 + chain/storage/proto/rocksdb_config.proto | 11 + chain/storage/res_leveldb.cpp | 169 ------------ chain/storage/res_leveldb.h | 65 ----- chain/storage/res_leveldb_test.cpp | 111 -------- chain/storage/res_rocksdb.cpp | 171 ------------ chain/storage/res_rocksdb.h | 61 ----- chain/storage/res_rocksdb_test.cpp | 109 -------- chain/storage/rocksdb.cpp | 291 +++++++++++++++++++++ chain/storage/rocksdb.h | 80 ++++++ {executor/kv => chain/storage/setting}/BUILD | 23 -- chain/storage/storage.h | 65 ++--- chain/storage/txn_memory_db.cpp | 50 ---- chain/storage/txn_memory_db.h | 48 ---- chain/storage/txn_memory_db_test.cpp | 71 ----- documents/doxygen/Doxyfile | 8 +- documents/doxygen/doxygen_html_style.css | 4 + documents/doxygen/header | 60 +++++ documents/doxygen/logo.png | Bin 803 -> 71672 bytes documents/file/prometheus.yml | 4 +- executor/common/custom_query.h | 34 +-- executor/common/mock_transaction_manager.h | 34 +-- executor/common/transaction_manager.cpp | 34 +-- executor/common/transaction_manager.h | 34 +-- executor/contract/executor/contract_executor.cpp | 34 +-- executor/contract/executor/contract_executor.h | 34 +-- .../contract/executor/contract_executor_test.cpp | 34 +-- executor/contract/manager/address_manager.cpp | 34 +-- executor/contract/manager/address_manager.h | 34 +-- executor/contract/manager/address_manager_test.cpp | 34 +-- executor/contract/manager/contract_manager.cpp | 34 +-- executor/contract/manager/contract_manager.h | 34 +-- .../contract/manager/contract_manager_test.cpp | 34 +-- executor/contract/manager/utils.h | 34 +-- executor/kv/BUILD | 32 +-- executor/kv/kv_executor.cpp | 124 +++++++-- executor/kv/kv_executor.h | 52 ++-- executor/kv/kv_executor_test.cpp | 270 +++++++++++++++---- executor/utxo/executor/utxo_executor.cpp | 34 +-- executor/utxo/executor/utxo_executor.h | 34 +-- executor/utxo/executor/utxo_executor_test.cpp | 34 +-- executor/utxo/manager/transaction.cpp | 34 +-- executor/utxo/manager/transaction.h | 34 +-- executor/utxo/manager/transaction_test.cpp | 34 +-- executor/utxo/manager/tx_mempool.cpp | 34 +-- executor/utxo/manager/tx_mempool.h | 34 +-- executor/utxo/manager/tx_mempool_test.cpp | 34 +-- executor/utxo/manager/wallet.cpp | 34 +-- executor/utxo/manager/wallet.h | 34 +-- executor/utxo/manager/wallet_test.cpp | 34 +-- img/resdb-v2.png | Bin 0 -> 41784 bytes interface/common/mock_resdb_txn_accessor.h | 34 +-- interface/common/resdb_state_accessor.cpp | 55 ++-- interface/common/resdb_state_accessor.h | 36 ++- interface/common/resdb_state_accessor_test.cpp | 48 ++-- interface/common/resdb_txn_accessor.cpp | 87 ++++-- interface/common/resdb_txn_accessor.h | 35 ++- interface/common/resdb_txn_accessor_test.cpp | 39 ++- interface/contract/contract_client.cpp | 34 +-- interface/contract/contract_client.h | 34 +-- interface/kv/kv_client.cpp | 107 ++++++-- interface/kv/kv_client.h | 62 +++-- interface/rdbc/mock_net_channel.h | 34 +-- interface/rdbc/mock_resdb_txn_accessor.h | 34 +-- interface/rdbc/net_channel.cpp | 34 +-- interface/rdbc/net_channel.h | 34 +-- interface/rdbc/net_channel_test.cpp | 34 +-- interface/rdbc/transaction_constructor.cpp | 34 +-- interface/rdbc/transaction_constructor.h | 34 +-- interface/rdbc/transaction_constructor_test.cpp | 34 +-- interface/utxo/utxo_client.cpp | 34 +-- interface/utxo/utxo_client.h | 34 +-- platform/common/data_comm/data_comm.h | 34 +-- platform/common/data_comm/network_comm.h | 34 +-- platform/common/network/mock_socket.h | 34 +-- platform/common/network/network_utils.cpp | 34 +-- platform/common/network/network_utils.h | 34 +-- platform/common/network/network_utils_test.cpp | 34 +-- platform/common/network/socket.h | 34 +-- platform/common/network/tcp_socket.cpp | 34 +-- platform/common/network/tcp_socket.h | 34 +-- platform/common/network/tcp_socket_test.cpp | 34 +-- platform/common/queue/batch_queue.h | 34 +-- platform/common/queue/batch_queue_test.cpp | 34 +-- platform/common/queue/blocking_queue.h | 34 +-- platform/common/queue/lock_free_queue.h | 36 ++- platform/common/queue/lock_free_queue_test.cpp | 34 +-- platform/config/resdb_config.cpp | 34 +-- platform/config/resdb_config.h | 34 +-- platform/config/resdb_config_test.cpp | 34 +-- platform/config/resdb_config_utils.cpp | 34 +-- platform/config/resdb_config_utils.h | 34 +-- platform/config/resdb_poc_config.cpp | 34 +-- platform/config/resdb_poc_config.h | 34 +-- platform/consensus/checkpoint/checkpoint.h | 34 +-- platform/consensus/checkpoint/mock_checkpoint.h | 34 +-- platform/consensus/execution/duplicate_manager.cpp | 34 +-- platform/consensus/execution/duplicate_manager.h | 34 +-- .../consensus/execution/geo_global_executor.cpp | 34 +-- platform/consensus/execution/geo_global_executor.h | 34 +-- .../execution/geo_global_executor_test.cpp | 34 +-- .../execution/geo_transaction_executor.cpp | 34 +-- .../consensus/execution/geo_transaction_executor.h | 34 +-- .../execution/geo_transaction_executor_test.cpp | 34 +-- .../consensus/execution/mock_geo_global_executor.h | 34 +-- platform/consensus/execution/system_info.cpp | 34 +-- platform/consensus/execution/system_info.h | 34 +-- platform/consensus/execution/system_info_test.cpp | 34 +-- .../consensus/execution/transaction_executor.cpp | 34 +-- .../consensus/execution/transaction_executor.h | 34 +-- .../execution/transaction_executor_test.cpp | 34 +-- .../ordering/common/transaction_utils.cpp | 34 +-- .../consensus/ordering/common/transaction_utils.h | 34 +-- .../geo_pbft/consensus_manager_geo_pbft.cpp | 34 +-- .../ordering/geo_pbft/consensus_manager_geo_pbft.h | 34 +-- .../ordering/geo_pbft/geo_pbft_commitment.cpp | 34 +-- .../ordering/geo_pbft/geo_pbft_commitment.h | 34 +-- .../ordering/geo_pbft/geo_pbft_commitment_test.cpp | 34 +-- platform/consensus/ordering/geo_pbft/hash_set.h | 34 +-- platform/consensus/ordering/pbft/BUILD | 4 +- .../consensus/ordering/pbft/checkpoint_manager.cpp | 41 ++- .../consensus/ordering/pbft/checkpoint_manager.h | 40 ++- .../ordering/pbft/checkpoint_manager_test.cpp | 34 +-- platform/consensus/ordering/pbft/commitment.cpp | 37 ++- platform/consensus/ordering/pbft/commitment.h | 34 +-- .../consensus/ordering/pbft/commitment_test.cpp | 34 +-- .../ordering/pbft/consensus_manager_pbft.cpp | 34 +-- .../ordering/pbft/consensus_manager_pbft.h | 34 +-- .../ordering/pbft/lock_free_collector_pool.cpp | 34 +-- .../ordering/pbft/lock_free_collector_pool.h | 34 +-- .../pbft/lock_free_collector_pool_test.cpp | 34 +-- .../consensus/ordering/pbft/message_manager.cpp | 34 +-- platform/consensus/ordering/pbft/message_manager.h | 38 ++- .../ordering/pbft/mock_checkpoint_manager.h | 34 +-- .../ordering/pbft/performance_manager.cpp | 34 +-- .../consensus/ordering/pbft/performance_manager.h | 34 +-- .../pbft/pre_very_consensus_service_pbft.h | 34 +-- platform/consensus/ordering/pbft/query.cpp | 34 +-- platform/consensus/ordering/pbft/query.h | 34 +-- platform/consensus/ordering/pbft/query_test.cpp | 34 +-- .../consensus/ordering/pbft/response_manager.cpp | 34 +-- .../consensus/ordering/pbft/response_manager.h | 34 +-- .../ordering/pbft/response_manager_test.cpp | 34 +-- .../ordering/pbft/transaction_collector.cpp | 34 +-- .../ordering/pbft/transaction_collector.h | 34 +-- .../ordering/pbft/transaction_collector_test.cpp | 34 +-- .../consensus/ordering/pbft/transaction_utils.cpp | 34 +-- .../consensus/ordering/pbft/transaction_utils.h | 34 +-- .../consensus/ordering/pbft/viewchange_manager.cpp | 34 +-- .../consensus/ordering/pbft/viewchange_manager.h | 34 +-- .../ordering/pbft/viewchange_manager_test.cpp | 34 +-- platform/consensus/recovery/recovery.cpp | 34 +-- platform/consensus/recovery/recovery.h | 34 +-- platform/consensus/recovery/recovery_test.cpp | 48 ++-- platform/networkstrate/async_acceptor.cpp | 34 +-- platform/networkstrate/async_acceptor.h | 34 +-- platform/networkstrate/async_acceptor_test.cpp | 34 +-- platform/networkstrate/async_replica_client.cpp | 34 +-- platform/networkstrate/async_replica_client.h | 34 +-- .../networkstrate/async_replica_client_test.cpp | 34 +-- platform/networkstrate/consensus_manager.cpp | 42 ++- platform/networkstrate/consensus_manager.h | 34 +-- platform/networkstrate/consensus_manager_test.cpp | 34 +-- platform/networkstrate/mock_async_replica_client.h | 34 +-- platform/networkstrate/mock_replica_communicator.h | 34 +-- platform/networkstrate/mock_service_interface.h | 34 +-- platform/networkstrate/replica_communicator.cpp | 34 +-- platform/networkstrate/replica_communicator.h | 34 +-- .../networkstrate/replica_communicator_test.cpp | 34 +-- platform/networkstrate/server_comm.h | 34 +-- platform/networkstrate/service_interface.cpp | 34 +-- platform/networkstrate/service_interface.h | 34 +-- platform/networkstrate/service_network.cpp | 34 +-- platform/networkstrate/service_network.h | 34 +-- platform/networkstrate/service_network_test.cpp | 34 +-- platform/proto/BUILD | 18 +- platform/proto/durable.proto | 18 -- platform/proto/replica_info.proto | 7 +- platform/proto/resdb.proto | 1 + platform/rdbc/acceptor.cpp | 34 +-- platform/rdbc/acceptor.h | 34 +-- platform/statistic/prometheus_handler.cpp | 34 +-- platform/statistic/prometheus_handler.h | 34 +-- platform/statistic/set_random_data.cpp | 34 +-- platform/statistic/stats.cpp | 34 +-- platform/statistic/stats.h | 34 +-- platform/test/resdb_test.cpp | 36 ++- proto/kv/kv.proto | 31 +++ scripts/deploy/performance/calculate_result.py | 18 +- service/contract/contract_service.cpp | 34 +-- service/kv/BUILD | 10 +- service/kv/kv_service.cpp | 63 +++-- service/tools/config/server/server.config | 2 - .../tools/contract/api_tools/contract_tools.cpp | 34 +-- .../service_tools/start_contract_service.sh | 6 +- service/tools/kv/api_tools/kv_client_txn_tools.cpp | 34 +-- service/tools/kv/api_tools/kv_service_tools.cpp | 245 ++++++++++++++--- .../utxo/wallet_tool/cpp/utxo_client_tools.cpp | 73 +++--- service/tools/utxo/wallet_tool/py/addr.py | 37 ++- service/tools/utxo/wallet_tool/py/keys.py | 38 ++- service/tools/utxo/wallet_tool/test/key_tester.py | 37 ++- .../utxo/wallet_tool/test/key_tester_utils.cpp | 34 +-- service/utils/server_factory.cpp | 34 +-- service/utils/server_factory.h | 34 +-- service/utxo/utxo_service.cpp | 34 +-- tools/certificate_tools.cpp | 34 +-- tools/certificate_tools_test.cpp | 34 +-- tools/generate_mulregion_config.py | 17 ++ tools/generate_region_config.py | 17 ++ tools/key_generator_tools.cpp | 34 +-- tools/resdb_state_accessor_tools.cpp | 40 ++- tools/resdb_txn_accessor_tools.cpp | 34 +-- 236 files changed, 5179 insertions(+), 4976 deletions(-) diff --cc service/tools/config/server/server.config index 26f12a02,20a8b771..405d7fc9 --- a/service/tools/config/server/server.config +++ b/service/tools/config/server/server.config @@@ -32,12 -31,8 +31,11 @@@ leveldb_info : { write_buffer_size_mb:128, write_batch_size:1, - generate_unique_pathnames:true, }, - require_txn_validation:false, + require_txn_validation:true, + enable_viewchange:true, + enable_resview:true, + enable_faulty_switch:true }
