This is an automated email from the ASF dual-hosted git repository.
wangdan pushed a change to branch migrate-metrics-dev
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard d6fdb358b feat(new_metrics): migrate replica-level metrics for
capacity_unit_calculator (#1387)
omit a94256684 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 2) (#1386)
omit 3210f71ae feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 1) (#1374)
omit 09931e8e1 feat(new_metrics): migrate replica-level metrics for write
service (#1351)
omit 18b06cf0e feat(new_metrics): add replica-level metric entity (#1345)
add 7b40abcdd chore(script): support specifying config file while
downgrading node by shell (#1369)
add c27590bf3 chore(script): support specifying config file while
migrating node by shell (#1370)
add e55cd3681 refactor(IWYU): introduce IWYU and fix related issues (#1354)
new a95410103 feat(new_metrics): add replica-level metric entity (#1345)
new fdc9d17ea feat(new_metrics): migrate replica-level metrics for write
service (#1351)
new ec7f3df26 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 1) (#1374)
new 1a8a0aa51 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 2) (#1386)
new 3e3085539 feat(new_metrics): migrate replica-level metrics for
capacity_unit_calculator (#1387)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d6fdb358b)
\
N -- N -- N refs/heads/migrate-metrics-dev (3e3085539)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/lint_and_test_cpp.yaml | 44 +++++++++++++
.licenserc.yaml | 1 -
run.sh | 60 ++++++++++++++---
scripts/downgrade_node.sh | 50 ++++++++++----
scripts/migrate_node.sh | 49 ++++++++++----
src/CMakeLists.txt | 1 +
src/aio/aio_provider.cpp | 4 ++
src/aio/aio_provider.h | 9 +--
src/aio/aio_task.cpp | 21 +++++-
src/aio/aio_task.h | 11 ++++
src/aio/disk_engine.cpp | 26 ++++++--
src/aio/disk_engine.h | 10 ++-
src/aio/file_io.cpp | 9 ++-
src/aio/file_io.h | 12 +++-
src/aio/native_linux_aio_provider.cpp | 7 +-
src/aio/native_linux_aio_provider.h | 5 ++
src/aio/test/aio.cpp | 30 +++++++--
src/base/idl_utils.h | 9 ++-
src/base/pegasus_utils.cpp | 9 +--
src/base/pegasus_utils.h | 16 +++--
src/base/pegasus_value_schema.h | 17 ++---
src/base/test/main.cpp | 3 -
src/base/test/utils_test.cpp | 8 ++-
src/base/test/value_manager_test.cpp | 11 +++-
src/base/test/value_schema_test.cpp | 25 +++++--
src/base/value_schema_manager.cpp | 12 +++-
src/base/value_schema_manager.h | 5 ++
src/base/value_schema_v0.cpp | 12 +++-
src/base/value_schema_v0.h | 7 ++
src/base/value_schema_v1.cpp | 14 ++--
src/base/value_schema_v1.h | 7 ++
src/base/value_schema_v2.cpp | 14 ++--
src/base/value_schema_v2.h | 7 ++
src/block_service/block_service_manager.cpp | 13 +++-
src/block_service/block_service_manager.h | 10 ++-
src/block_service/directio_writable_file.cpp | 8 +--
src/block_service/directio_writable_file.h | 2 +
src/block_service/fds/fds_service.cpp | 22 ++++---
src/block_service/fds/fds_service.h | 21 ++++--
src/block_service/hdfs/hdfs_service.cpp | 21 ++++--
src/block_service/hdfs/hdfs_service.h | 19 +++++-
src/block_service/local/local_service.cpp | 28 ++++++--
src/block_service/local/local_service.h | 9 ++-
.../test/block_service_manager_test.cpp | 22 +++++--
src/block_service/test/fds_service_test.cpp | 20 ++++--
src/block_service/test/hdfs_service_test.cpp | 23 ++++++-
src/block_service/test/local_service_test.cpp | 10 ++-
src/block_service/test/main.cpp | 16 ++---
src/client/partition_resolver.cpp | 11 +++-
src/client/partition_resolver.h | 16 ++++-
src/client/partition_resolver_manager.cpp | 6 +-
src/client/partition_resolver_manager.h | 9 ++-
src/client/partition_resolver_simple.cpp | 21 +++++-
src/client/partition_resolver_simple.h | 20 ++++--
src/client/replication_ddl_client.cpp | 77 ++++++++++++----------
src/client/replication_ddl_client.h | 42 ++++++------
src/client_lib/mutation.cpp | 6 ++
src/client_lib/pegasus_client_factory_impl.cpp | 11 ++++
src/client_lib/pegasus_client_factory_impl.h | 12 +++-
src/client_lib/pegasus_client_impl.cpp | 36 +++++++---
src/client_lib/pegasus_client_impl.h | 22 ++++++-
src/client_lib/pegasus_scanner_impl.cpp | 28 +++++++-
src/common/backup_common.cpp | 5 +-
src/common/backup_common.h | 8 ++-
src/common/bulk_load_common.h | 14 +++-
src/common/duplication_common.cpp | 16 +++--
src/common/duplication_common.h | 13 ++--
src/common/fs_manager.cpp | 16 ++++-
src/common/fs_manager.h | 27 ++++----
src/common/replication_common.cpp | 9 +++
src/common/replication_common.h | 29 ++++----
src/common/replication_enums.h | 5 ++
src/common/serialization_helper/thrift_helper.h | 2 +
src/common/test/common_test.cpp | 3 +
src/common/test/duplication_common_test.cpp | 6 ++
src/common/test/fs_manager_test.cpp | 6 +-
src/common/test/main.cpp | 16 ++---
src/common/test/replication_common_test.cpp | 11 +++-
src/failure_detector/failure_detector.cpp | 15 ++++-
src/failure_detector/failure_detector.h | 19 ++++++
.../failure_detector_multimaster.cpp | 10 ++-
.../failure_detector_multimaster.h | 7 ++
src/failure_detector/test/failure_detector.cpp | 48 ++++++++++----
src/failure_detector/test/main.cpp | 25 ++-----
src/geo/bench/bench.cpp | 26 +++++---
src/geo/lib/geo_client.cpp | 43 +++++++-----
src/geo/lib/geo_client.h | 20 ++++--
src/geo/lib/latlng_codec.cpp | 19 ++----
src/geo/lib/latlng_codec.h | 6 +-
src/geo/test/geo_test.cpp | 36 +++++++---
src/geo/test/latlng_codec_test.cpp | 10 ++-
src/geo/test/main.cpp | 6 +-
src/http/builtin_http_calls.cpp | 10 ++-
src/http/builtin_http_calls.h | 6 +-
src/http/config_http_service.cpp | 6 +-
src/http/http_call_registry.h | 1 +
src/http/http_message_parser.cpp | 10 +--
src/http/http_message_parser.h | 13 ++--
src/http/http_server.cpp | 20 ++++--
src/http/http_server.h | 8 +++
src/http/perf_counter_http_service.cpp | 11 +++-
src/http/pprof_http_service.cpp | 21 ++++--
src/http/pprof_http_service.h | 4 ++
src/http/test/http_server_test.cpp | 19 +++++-
src/http/test/perf_counter_http_service_test.cpp | 9 ++-
src/http/test/uri_decoder_test.cpp | 7 +-
src/http/uri_decoder.cpp | 4 +-
src/http/uri_decoder.h | 2 +
src/include/pegasus/client.h | 1 +
src/meta/app_balance_policy.cpp | 18 +++--
src/meta/app_balance_policy.h | 12 ++++
src/meta/app_env_validator.cpp | 13 ++--
src/meta/backup_engine.cpp | 37 +++++++++--
src/meta/backup_engine.h | 19 +++++-
src/meta/cluster_balance_policy.cpp | 14 +++-
src/meta/cluster_balance_policy.h | 24 ++++++-
src/meta/distributed_lock_service_simple.cpp | 6 +-
src/meta/distributed_lock_service_simple.h | 15 ++++-
src/meta/duplication/duplication_info.cpp | 5 +-
src/meta/duplication/duplication_info.h | 29 ++++----
src/meta/duplication/meta_duplication_service.cpp | 36 ++++++++--
src/meta/duplication/meta_duplication_service.h | 19 +++++-
src/meta/greedy_load_balancer.cpp | 37 +++++++----
src/meta/greedy_load_balancer.h | 11 ++++
src/meta/load_balance_policy.cpp | 18 ++++-
src/meta/load_balance_policy.h | 28 +++++++-
src/meta/meta_backup_service.cpp | 36 ++++++++--
src/meta/meta_backup_service.h | 41 +++++++++---
src/meta/meta_bulk_load_ingestion_context.cpp | 7 ++
src/meta/meta_bulk_load_ingestion_context.h | 12 +++-
src/meta/meta_bulk_load_service.cpp | 34 +++++++++-
src/meta/meta_bulk_load_service.h | 28 +++++++-
src/meta/meta_data.cpp | 20 ++----
src/meta/meta_data.h | 43 +++++++-----
src/meta/meta_http_service.cpp | 54 +++++++++------
src/meta/meta_http_service.h | 7 +-
src/meta/meta_options.cpp | 6 ++
src/meta/meta_options.h | 18 +----
src/meta/meta_server_failure_detector.cpp | 13 +++-
src/meta/meta_server_failure_detector.h | 25 ++++++-
src/meta/meta_service.cpp | 61 +++++++++++------
src/meta/meta_service.h | 60 ++++++++++++-----
src/meta/meta_service_app.cpp | 40 ++++-------
src/meta/meta_service_app.h | 6 +-
src/meta/meta_split_service.cpp | 31 ++++++++-
src/meta/meta_split_service.h | 12 +++-
src/meta/meta_state_service.h | 26 ++++----
src/meta/meta_state_service_simple.cpp | 10 +++
src/meta/meta_state_service_simple.h | 27 +++++++-
src/meta/meta_state_service_utils.cpp | 26 +++-----
src/meta/meta_state_service_utils.h | 11 +++-
src/meta/meta_state_service_utils_impl.h | 2 +
src/meta/meta_state_service_zookeeper.cpp | 27 ++++----
src/meta/meta_state_service_zookeeper.h | 18 +++--
src/meta/partition_guardian.cpp | 15 +++++
src/meta/partition_guardian.h | 15 +++++
src/meta/server_load_balancer.cpp | 16 +++--
src/meta/server_load_balancer.h | 34 ++++------
src/meta/server_state.cpp | 44 +++++++++++--
src/meta/server_state.h | 43 +++++++++---
src/meta/server_state_restore.cpp | 35 ++++++++--
src/meta/test/backup_test.cpp | 58 +++++++++++-----
.../test/balancer_simulator/balancer_simulator.cpp | 17 ++++-
src/meta/test/balancer_validator.cpp | 42 +++++-------
src/meta/test/cluster_balance_policy_test.cpp | 24 ++++++-
src/meta/test/copy_replica_operation_test.cpp | 19 +++++-
src/meta/test/dump_file.cpp | 10 +++
src/meta/test/duplication_info_test.cpp | 7 +-
src/meta/test/ford_fulkerson_test.cpp | 13 ++++
src/meta/test/json_compacity.cpp | 32 +++++----
src/meta/test/main.cpp | 33 +++++-----
src/meta/test/meta_app_envs_test.cpp | 16 +++--
src/meta/test/meta_app_operation_test.cpp | 46 +++++++++----
src/meta/test/meta_backup_test.cpp | 28 ++++++--
src/meta/test/meta_bulk_load_ingestion_test.cpp | 21 ++++--
src/meta/test/meta_bulk_load_service_test.cpp | 52 ++++++++++++---
src/meta/test/meta_data.cpp | 14 +++-
src/meta/test/meta_duplication_service_test.cpp | 53 +++++++++++----
src/meta/test/meta_http_service_test.cpp | 42 +++++++++---
src/meta/test/meta_mauanl_compaction_test.cpp | 25 +++++--
src/meta/test/meta_partition_guardian_test.cpp | 50 ++++++++------
src/meta/test/meta_service_test.cpp | 23 ++++++-
src/meta/test/meta_service_test_app.h | 6 +-
src/meta/test/meta_split_service_test.cpp | 60 ++++++++++++-----
src/meta/test/meta_state/main.cpp | 25 ++-----
src/meta/test/meta_state/meta_state_service.cpp | 8 ++-
src/meta/test/meta_state_service_utils_test.cpp | 40 +++++------
src/meta/test/meta_test_base.cpp | 42 +++++++++---
src/meta/test/meta_test_base.h | 22 +++----
src/meta/test/misc/misc.cpp | 23 +++++--
src/meta/test/misc/misc.h | 31 +++++----
src/meta/test/server_state_restore_test.cpp | 25 +++++--
src/meta/test/server_state_test.cpp | 25 +++++--
src/meta/test/state_sync_test.cpp | 36 ++++++----
src/meta/test/update_configuration_test.cpp | 54 ++++++++++-----
src/nfs/nfs_client_impl.cpp | 11 +++-
src/nfs/nfs_client_impl.h | 45 +++++++++----
src/nfs/nfs_node.cpp | 11 ++--
src/nfs/nfs_node.h | 12 ++--
src/nfs/nfs_node_impl.cpp | 8 ++-
src/nfs/nfs_server_impl.cpp | 19 ++++--
src/nfs/nfs_server_impl.h | 25 +++++--
src/nfs/test/main.cpp | 21 ++++--
src/perf_counter/builtin_counters.cpp | 7 +-
src/perf_counter/builtin_counters.h | 1 +
src/perf_counter/perf_counter.h | 5 +-
src/perf_counter/perf_counter_atomic.cpp | 12 +++-
src/perf_counter/perf_counter_atomic.h | 27 ++++----
src/perf_counter/perf_counters.cpp | 10 ++-
src/perf_counter/perf_counters.h | 7 +-
src/perf_counter/test/main.cpp | 13 ----
src/perf_counter/test/perf_counter_test.cpp | 13 +++-
src/perf_counter/test/perf_counters_test.cpp | 16 ++++-
src/redis_protocol/proxy/main.cpp | 20 ++++--
src/redis_protocol/proxy_lib/proxy_layer.cpp | 8 ++-
src/redis_protocol/proxy_lib/proxy_layer.h | 28 ++++----
src/redis_protocol/proxy_lib/redis_parser.cpp | 23 ++++++-
src/redis_protocol/proxy_lib/redis_parser.h | 20 +++++-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 46 ++++++++++---
src/remote_cmd/remote_command.cpp | 21 ++++--
src/remote_cmd/remote_command.h | 9 ++-
src/replica/backup/cold_backup_context.cpp | 16 ++++-
src/replica/backup/cold_backup_context.h | 17 +++++
src/replica/backup/replica_backup_manager.cpp | 26 +++++++-
src/replica/backup/replica_backup_manager.h | 14 ++--
src/replica/backup/replica_backup_server.cpp | 17 ++++-
src/replica/backup/replica_backup_server.h | 10 +--
src/replica/backup/test/main.cpp | 16 ++---
.../backup/test/replica_backup_manager_test.cpp | 11 +++-
src/replica/bulk_load/replica_bulk_loader.cpp | 44 +++++++++++--
src/replica/bulk_load/replica_bulk_loader.h | 26 ++++++--
src/replica/bulk_load/test/main.cpp | 16 ++---
.../bulk_load/test/replica_bulk_loader_test.cpp | 26 ++++++--
src/replica/disk_cleaner.cpp | 14 ++--
src/replica/disk_cleaner.h | 4 +-
src/replica/duplication/duplication_pipeline.cpp | 17 ++++-
src/replica/duplication/duplication_pipeline.h | 13 +++-
src/replica/duplication/duplication_sync_timer.cpp | 29 +++++---
src/replica/duplication/duplication_sync_timer.h | 14 +++-
src/replica/duplication/load_from_private_log.cpp | 19 ++++--
src/replica/duplication/load_from_private_log.h | 13 +++-
src/replica/duplication/mutation_batch.cpp | 27 ++++++--
src/replica/duplication/mutation_batch.h | 8 ++-
src/replica/duplication/replica_duplicator.cpp | 32 +++++++--
src/replica/duplication/replica_duplicator.h | 30 ++++-----
.../duplication/replica_duplicator_manager.cpp | 12 +++-
.../duplication/replica_duplicator_manager.h | 22 ++++---
src/replica/duplication/replica_follower.cpp | 25 +++++--
src/replica/duplication/replica_follower.h | 15 ++++-
.../test/dup_replica_http_service_test.cpp | 18 ++++-
.../test/duplication_sync_timer_test.cpp | 26 ++++++--
.../duplication/test/duplication_test_base.h | 6 +-
.../test/load_from_private_log_test.cpp | 52 +++++++++++++--
src/replica/duplication/test/main.cpp | 16 ++---
.../duplication/test/mutation_batch_test.cpp | 17 +++++
.../test/replica_duplicator_manager_test.cpp | 27 ++++++--
.../duplication/test/replica_duplicator_test.cpp | 31 +++++++--
.../duplication/test/replica_follower_test.cpp | 35 ++++++----
.../duplication/test/ship_mutation_test.cpp | 22 ++++++-
src/replica/log_block.cpp | 4 ++
src/replica/log_block.h | 9 +++
src/replica/log_file.cpp | 25 +++++--
src/replica/log_file.h | 26 +++++++-
src/replica/log_file_stream.h | 5 +-
src/replica/mutation.cpp | 19 +++++-
src/replica/mutation.h | 27 +++++++-
src/replica/mutation_cache.cpp | 10 +++
src/replica/mutation_cache.h | 8 ++-
src/replica/mutation_log.cpp | 35 +++++++---
src/replica/mutation_log.h | 37 ++++++++---
src/replica/mutation_log_replay.cpp | 23 ++++++-
src/replica/mutation_log_utils.cpp | 7 +-
src/replica/mutation_log_utils.h | 11 ++--
src/replica/prepare_list.cpp | 9 ++-
src/replica/prepare_list.h | 7 +-
src/replica/replica.cpp | 60 +++++++++++------
src/replica/replica.h | 66 +++++++++++++++----
src/replica/replica_2pc.cpp | 51 ++++++++++++--
src/replica/replica_backup.cpp | 53 ++++++++++++---
src/replica/replica_check.cpp | 37 +++++++++--
src/replica/replica_chkpt.cpp | 39 +++++++++--
src/replica/replica_config.cpp | 48 ++++++++++++--
src/replica/replica_context.cpp | 14 ++--
src/replica/replica_context.h | 25 +++++--
src/replica/replica_disk_migrator.cpp | 23 +++++--
src/replica/replica_disk_migrator.h | 7 ++
src/replica/replica_failover.cpp | 13 +++-
src/replica/replica_http_service.cpp | 14 +++-
src/replica/replica_http_service.h | 8 ++-
src/replica/replica_init.cpp | 29 ++++++--
src/replica/replica_learn.cpp | 46 +++++++++++--
src/replica/replica_restore.cpp | 44 +++++++++----
src/replica/replica_stub.cpp | 70 ++++++++++++++------
src/replica/replica_stub.h | 48 +++++++++++---
src/replica/replica_test_utils.cpp | 3 +
src/replica/replica_test_utils.h | 5 +-
src/replica/replica_throttle.cpp | 23 +++++--
src/replica/replication_app_base.cpp | 52 ++++++++++-----
src/replica/replication_app_base.h | 25 ++++---
src/replica/replication_service_app.cpp | 9 ++-
src/replica/replication_service_app.h | 12 ++--
src/replica/split/replica_split_manager.cpp | 43 +++++++++---
src/replica/split/replica_split_manager.h | 34 +++++++++-
src/replica/split/test/main.cpp | 16 ++---
src/replica/split/test/replica_split_test.cpp | 39 +++++++++--
src/replica/storage/simple_kv/simple_kv.main.cpp | 11 ++--
.../storage/simple_kv/simple_kv.server.impl.cpp | 20 +++++-
.../storage/simple_kv/simple_kv.server.impl.h | 18 ++++-
src/replica/storage/simple_kv/test/case.cpp | 36 ++++++----
src/replica/storage/simple_kv/test/case.h | 19 +++++-
src/replica/storage/simple_kv/test/checker.cpp | 41 ++++++++----
src/replica/storage/simple_kv/test/checker.h | 22 +++++--
src/replica/storage/simple_kv/test/client.cpp | 23 ++++++-
src/replica/storage/simple_kv/test/client.h | 20 +++---
src/replica/storage/simple_kv/test/common.cpp | 14 ++--
src/replica/storage/simple_kv/test/common.h | 26 ++++----
src/replica/storage/simple_kv/test/injector.cpp | 22 ++++---
src/replica/storage/simple_kv/test/injector.h | 2 +
.../storage/simple_kv/test/simple_kv.main.cpp | 17 ++++-
.../simple_kv/test/simple_kv.server.impl.cpp | 22 ++++++-
.../storage/simple_kv/test/simple_kv.server.impl.h | 20 +++++-
src/replica/test/cold_backup_context_test.cpp | 25 +++++++
src/replica/test/log_block_test.cpp | 15 ++++-
src/replica/test/log_file_test.cpp | 13 ++++
src/replica/test/main.cpp | 13 ++--
src/replica/test/mock_utils.h | 4 +-
src/replica/test/mutation_log_learn_test.cpp | 27 ++++++--
src/replica/test/mutation_log_test.cpp | 27 +++++++-
src/replica/test/open_replica_test.cpp | 21 +++++-
src/replica/test/replica_disk_migrate_test.cpp | 34 ++++++++--
src/replica/test/replica_disk_test.cpp | 29 ++++++--
src/replica/test/replica_disk_test_base.h | 2 +-
src/replica/test/replica_http_service_test.cpp | 13 +++-
src/replica/test/replica_learn_test.cpp | 17 ++++-
src/replica/test/replica_test.cpp | 46 +++++++++++--
src/replica/test/replica_test_base.h | 2 +-
src/replica/test/throttling_controller_test.cpp | 2 +
src/reporter/pegasus_counter_reporter.cpp | 51 +++++++++-----
src/reporter/pegasus_counter_reporter.h | 28 ++++++--
src/runtime/api_task.h | 2 +
src/runtime/core_main.cpp | 8 +--
src/runtime/env.sim.cpp | 10 ++-
src/runtime/env.sim.h | 4 +-
src/runtime/fault_injector.cpp | 26 ++++++--
src/runtime/fault_injector.h | 2 +
src/runtime/global_config.cpp | 18 ++---
src/runtime/global_config.h | 12 +++-
src/runtime/message_utils.cpp | 4 ++
src/runtime/message_utils.h | 15 +++--
src/runtime/nativerun.cpp | 8 +++
src/runtime/nativerun.h | 2 +
src/runtime/pipeline.h | 16 ++---
src/runtime/profiler.cpp | 27 ++++++--
src/runtime/profiler.h | 2 +
src/runtime/providers.common.cpp | 23 ++++---
src/runtime/providers.common.h | 2 -
src/runtime/ranger/access_type.cpp | 2 -
src/runtime/ranger/access_type.h | 1 +
src/runtime/ranger/ranger_resource_policy.cpp | 2 +
src/runtime/ranger/ranger_resource_policy.h | 4 --
.../ranger/ranger_resource_policy_manager.cpp | 10 ++-
.../ranger/ranger_resource_policy_manager.h | 12 ++--
src/runtime/rpc/asio_net_provider.cpp | 39 ++++++++++-
src/runtime/rpc/asio_net_provider.h | 21 +++++-
src/runtime/rpc/asio_rpc_session.cpp | 27 ++++++++
src/runtime/rpc/asio_rpc_session.h | 13 ++--
src/runtime/rpc/dsn_message_parser.cpp | 16 +++--
src/runtime/rpc/dsn_message_parser.h | 4 +-
src/runtime/rpc/message_parser.cpp | 19 ++++--
src/runtime/rpc/message_parser.h | 13 ++--
src/runtime/rpc/network.cpp | 16 ++++-
src/runtime/rpc/network.h | 28 ++++----
src/runtime/rpc/network.sim.cpp | 25 ++++---
src/runtime/rpc/network.sim.h | 12 +++-
src/runtime/rpc/raw_message_parser.cpp | 19 ++++--
src/runtime/rpc/raw_message_parser.h | 6 +-
src/runtime/rpc/rpc_address.cpp | 6 +-
src/runtime/rpc/rpc_address.h | 3 +
src/runtime/rpc/rpc_engine.cpp | 30 +++++----
src/runtime/rpc/rpc_engine.h | 24 +++++--
src/runtime/rpc/rpc_holder.h | 43 ++++++------
src/runtime/rpc/rpc_message.cpp | 23 +++++--
src/runtime/rpc/rpc_message.h | 20 +++---
src/runtime/rpc/rpc_task.cpp | 17 ++++-
src/runtime/rpc/thrift_message_parser.cpp | 23 +++++--
src/runtime/rpc/thrift_message_parser.h | 11 ++--
src/runtime/scheduler.cpp | 23 ++++---
src/runtime/scheduler.h | 16 ++++-
src/runtime/security/access_controller.cpp | 10 +--
src/runtime/security/access_controller.h | 3 +-
src/runtime/security/client_negotiation.cpp | 23 +++++--
src/runtime/security/client_negotiation.h | 7 ++
src/runtime/security/init.cpp | 8 ++-
src/runtime/security/kinit_context.cpp | 26 ++++++--
src/runtime/security/kinit_context.h | 2 +
src/runtime/security/meta_access_controller.cpp | 4 ++
src/runtime/security/meta_access_controller.h | 6 +-
src/runtime/security/negotiation.cpp | 12 ++--
src/runtime/security/negotiation.h | 12 ++--
src/runtime/security/negotiation_manager.cpp | 22 +++++--
src/runtime/security/negotiation_manager.h | 12 +++-
src/runtime/security/replica_access_controller.cpp | 4 +-
src/runtime/security/replica_access_controller.h | 7 +-
src/runtime/security/sasl_client_wrapper.cpp | 2 +
src/runtime/security/sasl_client_wrapper.h | 5 ++
src/runtime/security/sasl_init.cpp | 7 +-
src/runtime/security/sasl_server_wrapper.cpp | 4 +-
src/runtime/security/sasl_server_wrapper.h | 5 ++
src/runtime/security/sasl_wrapper.cpp | 11 ++--
src/runtime/security/sasl_wrapper.h | 7 ++
src/runtime/security/server_negotiation.cpp | 17 +++--
src/runtime/security/server_negotiation.h | 9 ++-
src/runtime/service_api_c.cpp | 36 ++++++++--
src/runtime/service_engine.cpp | 31 ++++++---
src/runtime/service_engine.h | 27 ++++----
src/runtime/simulator.cpp | 13 +++-
src/runtime/simulator.h | 8 ++-
src/runtime/task/hpc_task_queue.cpp | 9 ++-
src/runtime/task/hpc_task_queue.h | 6 +-
src/runtime/task/simple_task_queue.cpp | 23 +++++++
src/runtime/task/simple_task_queue.h | 13 +++-
src/runtime/task/task.cpp | 25 ++++---
src/runtime/task/task.h | 44 +++++++------
src/runtime/task/task_code.cpp | 7 +-
src/runtime/task/task_code.h | 13 +++-
src/runtime/task/task_engine.cpp | 21 +++++-
src/runtime/task/task_engine.h | 18 +++--
src/runtime/task/task_engine.sim.cpp | 14 +++-
src/runtime/task/task_engine.sim.h | 12 +++-
src/runtime/task/task_queue.cpp | 14 +++-
src/runtime/task/task_queue.h | 8 ++-
src/runtime/task/task_spec.cpp | 8 ++-
src/runtime/task/task_spec.h | 25 +++----
src/runtime/task/task_tracker.cpp | 5 +-
src/runtime/task/task_tracker.h | 4 +-
src/runtime/task/task_worker.cpp | 24 +++++--
src/runtime/task/task_worker.h | 12 +++-
src/runtime/test/address_test.cpp | 6 ++
src/runtime/test/async_call.cpp | 39 ++++++-----
src/runtime/test/client_negotiation_test.cpp | 23 +++++--
src/runtime/test/corrupt_message.cpp | 24 ++-----
src/runtime/test/lpc.cpp | 19 +++---
src/runtime/test/main.cpp | 8 ++-
src/runtime/test/message_reader_test.cpp | 5 ++
src/runtime/test/message_utils_test.cpp | 12 +++-
src/runtime/test/meta_access_controller_test.cpp | 27 ++++----
src/runtime/test/negotiation_manager_test.cpp | 20 ++++--
src/runtime/test/netprovider.cpp | 37 ++++++-----
src/runtime/test/pipeline_test.cpp | 22 ++-----
.../test/ranger_resource_policy_manager_test.cpp | 13 ++++
src/runtime/test/ranger_resource_policy_test.cpp | 6 ++
.../test/replica_access_controller_test.cpp | 31 ++++-----
src/runtime/test/rpc.cpp | 38 +++++------
src/runtime/test/rpc_holder_test.cpp | 22 +++++--
src/runtime/test/rpc_message.cpp | 22 ++++++-
src/runtime/test/server_negotiation_test.cpp | 19 ++++--
src/runtime/test/service_api_c.cpp | 32 +++++----
src/runtime/test/sim_lock.cpp | 24 +++----
src/runtime/test/task_engine.cpp | 18 ++++-
src/runtime/test/task_test.cpp | 10 ++-
src/runtime/test/thrift_message_parser_test.cpp | 28 ++++++--
src/runtime/tool_api.cpp | 19 +++++-
src/runtime/tool_api.h | 22 +++++--
src/runtime/tracer.cpp | 19 +++++-
src/runtime/tracer.h | 6 +-
src/runtime/zlocks.cpp | 11 +++-
src/sample/main.cpp | 2 +
src/server/CMakeLists.txt | 3 +
src/server/available_detector.cpp | 27 ++++++--
src/server/available_detector.h | 21 +++++-
src/server/capacity_unit_calculator.cpp | 15 ++++-
src/server/capacity_unit_calculator.h | 15 ++++-
src/server/compaction_filter_rule.cpp | 1 -
src/server/compaction_filter_rule.h | 12 +++-
src/server/compaction_operation.cpp | 4 ++
src/server/compaction_operation.h | 10 +++
src/server/hashkey_transform.h | 6 +-
src/server/hotkey_collector.cpp | 19 ++++--
src/server/hotkey_collector.h | 23 ++++---
src/server/hotspot_partition_calculator.cpp | 20 ++++--
src/server/hotspot_partition_calculator.h | 16 ++++-
src/server/info_collector.cpp | 31 +++++----
src/server/info_collector.h | 45 +++++--------
src/server/info_collector_app.cpp | 25 ++-----
src/server/info_collector_app.h | 10 ++-
src/server/main.cpp | 26 +++++---
src/server/meta_store.cpp | 6 +-
src/server/meta_store.h | 13 ++--
src/server/pegasus_event_listener.cpp | 16 ++++-
src/server/pegasus_event_listener.h | 6 +-
src/server/pegasus_manual_compact_service.cpp | 19 ++++--
src/server/pegasus_manual_compact_service.h | 19 +++---
src/server/pegasus_mutation_duplicator.cpp | 41 ++++++++++--
src/server/pegasus_mutation_duplicator.h | 32 +++++++--
src/server/pegasus_server_impl.cpp | 66 +++++++++++++++----
src/server/pegasus_server_impl.h | 67 ++++++++++++++-----
src/server/pegasus_server_impl_init.cpp | 49 +++++++++++---
src/server/pegasus_server_write.cpp | 27 ++++++--
src/server/pegasus_server_write.h | 18 ++++-
src/server/pegasus_write_service.cpp | 33 ++++++++--
src/server/pegasus_write_service.h | 44 +++++++++----
src/server/pegasus_write_service_impl.h | 2 +-
src/server/result_writer.cpp | 10 +++
src/server/result_writer.h | 8 +--
src/server/rocksdb_wrapper.cpp | 24 +++++--
src/server/rocksdb_wrapper.h | 19 ++++--
src/server/test/capacity_unit_calculator_test.cpp | 31 +++++++--
src/server/test/compaction_filter_rule_test.cpp | 8 ++-
src/server/test/compaction_operation_test.cpp | 26 +++++---
src/server/test/hashkey_transform_test.cpp | 4 ++
src/server/test/hotkey_collector_test.cpp | 30 +++++++--
src/server/test/hotspot_partition_test.cpp | 18 ++++-
src/server/test/main.cpp | 20 +++---
src/server/test/manual_compact_service_test.cpp | 19 +++++-
.../test/pegasus_compression_options_test.cpp | 11 ++++
.../test/pegasus_mutation_duplicator_test.cpp | 30 +++++++--
src/server/test/pegasus_server_impl_test.cpp | 27 +++++++-
src/server/test/pegasus_server_test_base.h | 4 +-
src/server/test/pegasus_server_write_test.cpp | 30 +++++++--
src/server/test/pegasus_value_schema_test.cpp | 3 +
.../test/pegasus_write_service_impl_test.cpp | 19 +++++-
src/server/test/pegasus_write_service_test.cpp | 28 +++++++-
src/server/test/rocksdb_wrapper_test.cpp | 23 ++++++-
src/shell/CMakeLists.txt | 3 +
src/shell/command_output.h | 2 +-
src/shell/command_utils.cpp | 6 ++
src/shell/command_utils.h | 4 +-
src/shell/commands/bulk_load.cpp | 27 ++++++++
src/shell/commands/cold_backup.cpp | 20 ++++++
src/shell/commands/data_operations.cpp | 47 ++++++++++++-
src/shell/commands/debugger.cpp | 47 ++++++++++++-
src/shell/commands/detect_hotkey.cpp | 22 +++++--
src/shell/commands/duplication.cpp | 25 +++++--
src/shell/commands/global_properties.cpp | 7 ++
src/shell/commands/misc.cpp | 8 +++
src/shell/commands/node_management.cpp | 30 +++++++++
src/shell/commands/rebalance.cpp | 22 +++++++
src/shell/commands/recovery.cpp | 23 +++++++
src/shell/commands/table_management.cpp | 39 ++++++++++-
src/shell/main.cpp | 28 ++++++--
src/test/bench_test/benchmark.cpp | 16 ++++-
src/test/bench_test/benchmark.h | 13 +++-
src/test/bench_test/config.cpp | 3 +-
src/test/bench_test/config.h | 6 +-
src/test/bench_test/main.cpp | 7 +-
src/test/bench_test/rand.cpp | 3 +
src/test/bench_test/statistics.cpp | 9 ++-
src/test/bench_test/statistics.h | 8 ++-
.../test_backup_and_restore.cpp | 28 +++++---
.../function_test/base_api_test/test_basic.cpp | 23 +++----
.../function_test/base_api_test/test_batch_get.cpp | 27 ++++----
.../base_api_test/test_check_and_mutate.cpp | 18 ++---
.../base_api_test/test_check_and_set.cpp | 17 ++---
src/test/function_test/base_api_test/test_copy.cpp | 35 ++++++----
src/test/function_test/base_api_test/test_incr.cpp | 18 ++---
.../base_api_test/test_range_read.cpp | 21 +++---
.../function_test/base_api_test/test_recall.cpp | 29 ++++----
src/test/function_test/base_api_test/test_scan.cpp | 35 ++++++----
src/test/function_test/base_api_test/test_ttl.cpp | 18 ++++-
.../bulk_load_test/test_bulk_load.cpp | 27 +++++---
.../detect_hotspot_test/test_detect_hotspot.cpp | 23 ++++---
.../partition_split_test/test_split.cpp | 26 ++++++--
.../function_test/recovery_test/test_recovery.cpp | 29 ++++----
.../function_test/restore_test/test_restore.cpp | 33 ++++++++--
.../function_test/throttle_test/test_throttle.cpp | 43 ++++++------
src/test/function_test/utils/global_env.cpp | 18 ++---
src/test/function_test/utils/global_env.h | 1 -
src/test/function_test/utils/test_util.cpp | 8 ++-
src/test/function_test/utils/test_util.h | 9 ++-
src/test/function_test/utils/utils.h | 3 +
src/test/kill_test/data_verifier.cpp | 37 ++++-------
src/test/kill_test/job.cpp | 2 +
src/test/kill_test/kill_testor.cpp | 33 ++++------
src/test/kill_test/kill_testor.h | 14 ++--
src/test/kill_test/killer_handler_shell.cpp | 12 ++--
src/test/kill_test/killer_handler_shell.h | 3 +-
src/test/kill_test/main.cpp | 4 +-
src/test/kill_test/partition_kill_testor.cpp | 21 +++---
src/test/kill_test/partition_kill_testor.h | 4 --
src/test/kill_test/process_kill_testor.cpp | 28 ++++----
src/test/kill_test/process_kill_testor.h | 9 ++-
src/test/pressure_test/main.cpp | 23 +++++--
src/tools/mutation_log_tool.cpp | 14 +++-
src/tools/mutation_log_tool.h | 8 ++-
src/utils/alloc.cpp | 1 +
src/utils/alloc.h | 3 +-
src/utils/apply.h | 35 ----------
src/utils/binary_reader.cpp | 5 +-
src/utils/binary_reader.h | 6 +-
src/utils/binary_writer.cpp | 3 +
src/utils/binary_writer.h | 4 ++
src/utils/blob.h | 1 +
src/utils/clock.cpp | 3 +-
src/utils/clock.h | 1 +
src/utils/command_manager.cpp | 13 ++--
src/utils/command_manager.h | 7 +-
src/utils/config_api.cpp | 1 -
src/utils/config_api.h | 3 +-
src/utils/configuration.cpp | 8 +--
src/utils/configuration.h | 12 ++--
src/utils/coredump.posix.cpp | 9 ++-
src/utils/error_code.cpp | 2 +
src/utils/error_code.h | 13 +++-
src/utils/errors.h | 2 +-
src/utils/fail_point.cpp | 24 +++++--
src/utils/fail_point.h | 3 +
src/utils/filesystem.cpp | 31 +++++----
src/utils/filesystem.h | 8 +++
src/utils/flags.cpp | 23 ++++---
src/utils/flags.h | 7 +-
src/utils/fmt_logging.h | 2 +
src/utils/gpid.cpp | 5 +-
src/utils/hpc_locks/sema.h | 1 +
src/utils/join_point.h | 13 ++--
src/utils/latency_tracer.cpp | 17 ++---
src/utils/latency_tracer.h | 14 ++--
src/utils/logging.cpp | 24 ++++---
src/utils/logging_provider.h | 3 +-
src/utils/long_adder.cpp | 4 +-
src/utils/long_adder_bench/long_adder_bench.cpp | 9 ++-
src/utils/math.cpp | 2 +-
src/utils/metrics.cpp | 7 +-
src/utils/metrics.h | 29 +++++---
src/utils/nth_element.h | 6 +-
src/utils/output_utils.cpp | 6 +-
src/utils/output_utils.h | 12 ++--
src/utils/priority_queue.h | 5 +-
src/utils/process_utils.cpp | 23 ++++---
src/utils/process_utils.h | 1 +
src/utils/rand.h | 1 -
src/utils/safe_strerror_posix.cpp | 1 +
src/utils/safe_strerror_posix.h | 1 +
src/utils/shared_io_service.cpp | 5 ++
src/utils/shared_io_service.h | 3 +-
src/utils/simple_logger.cpp | 13 +++-
src/utils/simple_logger.h | 7 +-
src/utils/smart_pointers.h | 14 ++--
src/utils/string_conv.h | 7 ++
src/utils/string_view.h | 2 +
src/utils/strings.cpp | 10 ++-
src/utils/strings.h | 1 +
src/utils/test/TokenBucketTest.cpp | 9 +++
src/utils/test/TokenBucketTest.h | 2 +-
src/utils/test/autoref_ptr_test.cpp | 6 +-
src/utils/test/binary_reader_test.cpp | 4 ++
src/utils/test/command_manager_test.cpp | 4 +-
src/utils/test/configuration.cpp | 12 +++-
src/utils/test/endian_test.cpp | 10 ++-
src/utils/test/env.cpp | 5 ++
src/utils/test/fail_point_test.cpp | 8 ++-
src/utils/test/file_system_test.cpp | 7 +-
src/utils/test/file_utils.cpp | 22 +++----
src/utils/test/flag_test.cpp | 10 ++-
src/utils/test/fmt_logging_test.cpp | 14 +++-
src/utils/test/hostname_test.cpp | 5 +-
src/utils/test/join_point_test.cpp | 5 ++
src/utils/test/json_helper_test.cpp | 14 ++++
src/utils/test/latency_tracer_test.cpp | 29 ++++++--
src/utils/test/lock.std.cpp | 7 +-
src/utils/test/logger.cpp | 23 +++++--
src/utils/test/logging.cpp | 4 +-
src/utils/test/long_adder_test.cpp | 11 +++-
src/utils/test/main.cpp | 1 -
src/utils/test/memutil_test.cpp | 2 +
src/utils/test/metrics_test.cpp | 21 ++++--
.../test/nth_element_bench/nth_element_bench.cpp | 10 +--
src/utils/test/nth_element_test.cpp | 5 +-
src/utils/test/nth_element_utils.h | 2 +-
src/utils/test/output_utils_test.cpp | 6 +-
src/utils/test/priority_queue.cpp | 9 +++
src/utils/test/rand_test.cpp | 5 ++
src/utils/test/sema.cpp | 4 ++
src/utils/test/smart_pointers_test.cpp | 24 ++++---
src/utils/test/string_conv_test.cpp | 5 ++
src/utils/test/string_view_test.cpp | 5 ++
src/utils/test/time_utils_test.cpp | 4 +-
.../token_bucket_throttling_controller_test.cpp | 4 ++
src/utils/test/token_buckets_test.cpp | 7 ++
src/utils/test/utils.cpp | 15 ++++-
src/utils/thread_access_checker.cpp | 1 -
src/utils/throttling_controller.cpp | 4 ++
src/utils/time_utils.cpp | 12 +++-
src/utils/time_utils.h | 5 +-
src/utils/token_bucket_throttling_controller.cpp | 5 +-
src/utils/token_bucket_throttling_controller.h | 3 +
src/utils/token_buckets.cpp | 2 +
src/utils/token_buckets.h | 4 +-
src/utils/utils.cpp | 29 ++------
src/utils/utils.h | 12 +++-
src/utils/zlocks.h | 1 +
.../distributed_lock_service_zookeeper.cpp | 29 ++++----
src/zookeeper/distributed_lock_service_zookeeper.h | 17 ++++-
src/zookeeper/lock_struct.cpp | 22 ++++---
src/zookeeper/lock_struct.h | 9 ++-
src/zookeeper/test/distributed_lock_zookeeper.cpp | 34 +++++-----
src/zookeeper/test/main.cpp | 25 ++-----
src/zookeeper/zookeeper_error.cpp | 7 +-
src/zookeeper/zookeeper_error.h | 3 -
src/zookeeper/zookeeper_session.cpp | 12 ++--
src/zookeeper/zookeeper_session.h | 18 +++--
src/zookeeper/zookeeper_session_mgr.cpp | 7 +-
src/zookeeper/zookeeper_session_mgr.h | 19 ++----
thirdparty/CMakeLists.txt | 3 +
703 files changed, 9111 insertions(+), 3352 deletions(-)
delete mode 100644 src/utils/apply.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
