This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a change to branch
dependabot/go_modules/go-client/golang.org/x/net-0.23.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
from 0955bd473 build(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 in
/go-client
add b0033c83d feat: Add some useful time and filesystem utilies (#2020)
add 9b44580c4 fix(ut): fix the dsn.meta.test using a directorty may has
not permission (#2019)
add 1196e9568 feat(logging): Support to specify log directory (#2021)
add b39e18b74 refactor(logging): Minor refactor on logging module (#2022)
add 80fcc79cc feat(logging): Fill timestamp in log file name and limit
single file size and total count (#2024)
add 3f55ed619 refactor(host_port): Unify the hostname lookup function
(#2023)
add 7edbb2dfd feat(restore): Add 'restore_path' parameter for 'restore'
command in Cpp CLI tool (#2008)
add de4253625 feat: Distinguish log file names (#2010)
add bcc5f658b fix(backup): validate backup policy name (#2029)
add 4683a78a3 fix(duplication): fix the table name while checking if the
table of the remote cluster has been created completely (#2026)
add 4a4b113a4 fix(duplication): parameters are not recognized while
parsing add_dup shell command (#2027)
add da129c6d8 fix(duplication): use get_current_dup_cluster_name() instead
of get_current_cluster_name() for duplication (#2033)
add dff177388 chore(CI): Add building debug version on CentOS 7 job and
fix some build errors (#2032)
add 7a1c461fc feat(build): Support to specify THIRDPARTY_ROOT by setting
the environment variable (#2035)
add 53dd218d5 feat(shell): add JSON format data output to some
backup_policy commands (#2030)
add dbe66a23a chore(pack): support to pack server binaries separately
(#2034)
add 6c96b5ade fix(duplication): add warning message while trying to add a
duplication that has been existing for the same table with the same remote
cluster (#2038)
add 8fd89029c fix(shell): Add PARSE_OPT_STRS marco for shell command
execute flag input mode (#2040)
add 44e83503b chore(go-client): add generation thrift files of go-client
(#1917)
add 2ab5be67a fix(go-client): update config once replica server failed and
forward to primary meta server if it was changed (#1916)
add 1fbfd47fd fix(FQDN): Fix the bug of crash caused by un-resolved IP
address (#2044)
add 6a30e9b1d chore: fix dead link http://open-falcon.org/ (#2046)
add 7e95f31cc feat(remote_command): provide the query for the progress of
decrees including both local writes and duplications (#2045)
add a774afea1 fix(duplication): reduce the delay before last mutation is
duplicated to the remote cluster (#2048)
add 596603cae feat(java-client): use thrift-maven-plugin to generate
thrift sources instead of script (#1997)
add 8877aba8b chore(run.sh): link pegasus_shell only doesnt exist (#2053)
add 48f69d1f8 fix: Fix a typo in log when [network].enable_udp is disabled
(#2055)
add 877c6bd01 fix(scripts): downgrade_node does not work with set -e
(#2056)
add efe950dba feat(backup): Add --force option for 'disable_backup_policy'
shell command (#2057)
add 7f5039456 fix(backup): Fix the stack overflow when read large sst file
(#2059)
add 57dd0e1e5 feat(remote_command): change some remote_command shell
output to JSON format (#2058)
add 3f78d2255 fix(rocksdb): fix the problem that the usage of block cache
is not set for the metric (#2060)
add d5621be1f fix(duplication): create checkpoint for the replica with 0
or 1 record (#2054)
add 60606a4a8 refactor(format): bump clang-format to 14 (#2063)
add 42bd5bb7a chore(CI): Add envs in build_debug_on_centos7 to ensure job
can be ran on centOS 7 (#2065)
add 5cfba5569 feat(FQDN): Add host_port structures for clients and bump
actions/checkout from v3 to v4 (#2062)
add a4279ecd6 chore(CI): Force CI to run on node16 (#2070)
add 115f75dae chore(CI): Force to use actions/checkout@v3 when OS maybe
CentOS 7 or Ubuntu 18.04 (#2072)
add 102e0874d fix(CI): fix java regular workflow (#2074)
add abd1794a2 refactor(FQDN): update some logs in cpp-shell CLI (#2064)
add a12856515 fix(Dockerfile): Fix the yum install failure caused by its
EOL (#2075)
add b72274f5f refactor: Simplify code on partition_configuration (#2051)
add c05e3f65c refactor(shell): Refactor on 'remote_command' command (#2052)
add 013e2e16b feat(logging): Make it possible to print logs to stderr when
using screen_logger (#2079)
add 722af2e40 feat(docker): support arm64 (#2081)
add 34ab9cbea feat(util): Introduce map utilities (#2076)
add 097068d2f feat(logging): Introduce spdlog to thirdparty (#2084)
add 581a81125 chore(CI): Reduce the target size when build on GitHub
actions (#2086)
add 5057aadab fix(util): Fix the key doesn't print when check failed
(#2090)
add af3677e3f feat(logging): Move the logger remote_command handler to
command_manager (#2087)
add ad7b18b3c refactor(string_view): Use std::string_view instead of
absl::string_view (#2091)
add 3d39af1a4 chore(CI): Introduce clang tidy linter (#2094)
add 01b875450 refactor(scripts): Separate admin and build scripts to
independent directories (#2096)
add 9efe8d6b5 fix(duplication): fix unexpected ERR_NOT_ENOUGH_MEMBER while
checking if the remote table with only one replica is ready for duplication
(#2093)
add e68c2b9b9 fix(duplication): fix the dangling pointer after `blob`
object is moved (#2088)
add 2f843db2a fix(duplication): `min_checkpoint_decree` was reset to the
invalid decree after replica server was restarted (#2097)
add a8d99fd53 feat(duplication): add a new option to configure the
duration of the delay until the next execution if there is no mutation to be
loaded (#2099)
add 5b9f46a2e fix(github): add write permission to module labeler (#2106)
add c99cfd642 feat(new_metrics): support `server_stat` command showing
some important server-level metrics (part 1) (#2085)
add d0e926010 fix(blob): allow `blob` object to be initialized with
null-pointer char array whose length must be zero (#2110)
add adb886d3e fix(asio): fix the crash caused by early invalidated socket
(#2111)
add c90aa4854 refactor(tests): Simplify the runtime module unit tests
(#2115)
add b1fa5dc7b refactor(rpc): move rpc out of runtime (#1844)
add 88a29a461 chore(CI): Bump actions/labeler to v5 (#2116)
add ebb74e038 chore(CI): Sort disabled clang-tidy checks option (#2117)
add 8f21d7ae2 refator(tests): Use GTEST_SKIP macro to skip useless tests
(#2118)
add ecbfc8a4b chore(CI): Update actions/labeler configuration file (#2120)
add 8da31e487 build(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 in
/collector (#1982)
add 8a7681aa9 build(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 in
/admin-cli (#1981)
add 3ba32b371 build(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 in
/pegic (#1979)
add 13f9e3310 build(deps): bump k8s.io/apimachinery in /admin-cli (#2003)
add 42dad5784 build(deps): bump k8s.io/apimachinery in /collector (#2002)
add 25a32ff5a build(deps): bump k8s.io/apimachinery in /pegic (#2001)
add 9daece425 refactor(task): move task out of runtime (#1845)
add d1f6d618a build(deps): bump cryptography from 3.2 to 43.0.1 in
/python-client (#2121)
add a6965acd5 refactor(java-client): optimize the code style for checking
if the list is empty (#2122)
add dc2714a51 refactor(java-client): introduce validateHashKey() to
simplify code (#2123)
add 2bd86c1d6 fix(build): Fix a linkage error for thrift (#2125)
add 20a478dab build(deps): bump k8s.io/apimachinery in /go-client (#2004)
add 3ea016a83 Merge branch 'master' into
dependabot/go_modules/go-client/golang.org/x/net-0.23.0
No new revisions were added by this update.
Summary of changes:
.clang-format | 110 +-
.clang-tidy | 31 +
.github/actions/build_pegasus/action.yaml | 4 +-
.../rebuild_thirdparty_if_needed/action.yaml | 4 +-
.github/workflows/build-push-env-docker.yml | 19 +-
.github/workflows/labeler.yml | 9 +-
.github/workflows/lint_and_test_admin-cli.yml | 4 +-
.github/workflows/lint_and_test_collector.yml | 6 +-
.github/workflows/lint_and_test_cpp.yaml | 105 +-
.github/workflows/lint_and_test_go-client.yml | 8 +-
.github/workflows/lint_and_test_java-client.yml | 10 +-
.github/workflows/lint_and_test_pegic.yml | 4 +-
.github/workflows/lint_and_test_scala-client.yml | 10 +-
.github/workflows/module_labeler_conf.yml | 74 +-
.github/workflows/regular-build.yml | 24 +-
.github/workflows/standardization_lint.yaml | 6 +-
.github/workflows/test_nodejs-client.yml | 4 +-
.github/workflows/test_python-client.yml | 4 +-
.github/workflows/thirdparty-regular-push.yml | 22 +-
.gitignore | 5 -
.licenserc.yaml | 315 +-
CMakeLists.txt | 8 +-
LICENSE | 25 +-
admin-cli/go.mod | 8 +-
admin-cli/go.sum | 20 +-
{scripts => admin_tools}/config_hdfs.sh | 0
{scripts => admin_tools}/downgrade_node.sh | 4 +-
{scripts => admin_tools}/learn_stat.py | 0
{scripts => admin_tools}/migrate_node.sh | 0
{scripts => admin_tools}/minos_common.sh | 0
{scripts => admin_tools}/pegasus_add_node_list.sh | 4 +-
{scripts => admin_tools}/pegasus_bench_run.sh | 0
.../pegasus_check_arguments.sh | 2 +-
{scripts => admin_tools}/pegasus_kill_test.sh | 0
{scripts => admin_tools}/pegasus_manual_compact.sh | 0
.../pegasus_migrate_zookeeper.sh | 2 +-
{scripts => admin_tools}/pegasus_offline_node.sh | 2 +-
.../pegasus_offline_node_list.sh | 4 +-
.../pegasus_rebalance_cluster.sh | 0
{scripts => admin_tools}/pegasus_replica_thread.sh | 0
{scripts => admin_tools}/pegasus_restart_node.sh | 2 +-
{scripts => admin_tools}/pegasus_rolling_update.sh | 4 +-
.../pegasus_set_usage_scenario.sh | 0
{scripts => admin_tools}/pegasus_stat_available.sh | 0
.../pegasus_update_ingest_behind.sh | 2 +-
{scripts => admin_tools}/sendmail.sh | 0
{scripts => build_tools}/bump_version.sh | 0
{scripts => build_tools}/check_license.py | 0
build_tools/clang_tidy.py | 131 +
{scripts => build_tools}/clear_zk.sh | 0
.../collector_table_counter_gen.py | 2 +-
{scripts => build_tools}/compile_thrift.py | 10 +-
{scripts => build_tools}/download_hadoop.sh | 0
{scripts => build_tools}/download_package.sh | 0
{scripts => build_tools}/download_zk.sh | 0
{scripts => build_tools}/format_files.sh | 4 +-
{scripts => build_tools}/pack_client.sh | 8 +-
{scripts => build_tools}/pack_common.sh | 6 +-
{scripts => build_tools}/pack_server.sh | 51 +-
{scripts => build_tools}/pack_tools.sh | 47 +-
{scripts => build_tools}/recompile_thrift.sh | 3 +-
{scripts => build_tools}/redis_proto_check.py | 0
{scripts => build_tools}/run-clang-format.py | 2 +-
{scripts => build_tools}/start_zk.sh | 0
{scripts => build_tools}/stop_zk.sh | 0
cmake_modules/BaseFunctions.cmake | 12 +-
collector/go.mod | 8 +-
collector/go.sum | 21 +-
docker/clang-format-3.9/Dockerfile | 28 -
docker/pegasus-build-env/centos7/Dockerfile | 20 +-
docker/thirdparties-bin/Dockerfile | 4 +-
go-client/admin/client_test.go | 2 +-
go-client/go.mod | 4 +-
go-client/go.sum | 18 +-
go-client/idl/admin/GoUnusedProtection__.go | 6 +
go-client/idl/admin/backup-consts.go | 27 +
go-client/idl/admin/backup.go | 5299 ++++++
go-client/idl/admin/bulk_load-consts.go | 27 +
go-client/idl/admin/bulk_load.go | 4536 ++++++
go-client/idl/admin/duplication-consts.go | 27 +
go-client/idl/admin/duplication.go | 2606 +++
go-client/idl/admin/meta_admin-consts.go | 27 +
go-client/idl/admin/meta_admin.go | 16081 +++++++++++++++++++
go-client/idl/admin/metadata-consts.go | 27 +
go-client/idl/admin/metadata.go | 1373 ++
go-client/idl/admin/partition_split-consts.go | 27 +
go-client/idl/admin/partition_split.go | 3245 ++++
go-client/idl/cmd/GoUnusedProtection__.go | 6 +
go-client/idl/cmd/command-consts.go | 22 +
go-client/idl/cmd/command.go | 535 +
go-client/idl/radmin/GoUnusedProtection__.go | 6 +
go-client/idl/radmin/replica_admin-consts.go | 29 +
go-client/idl/radmin/replica_admin.go | 3681 +++++
go-client/idl/replication/GoUnusedProtection__.go | 6 +
go-client/idl/replication/dsn.layer2-consts.go | 25 +
go-client/idl/replication/dsn.layer2.go | 2136 +++
go-client/idl/rrdb/GoUnusedProtection__.go | 6 +
go-client/idl/rrdb/meta-remote/meta-remote.go | 183 +
go-client/idl/rrdb/rrdb-consts.go | 27 +
go-client/idl/rrdb/rrdb-remote/rrdb-remote.go | 536 +
go-client/idl/rrdb/rrdb.go | 12123 ++++++++++++++
go-client/pegasus/table_connector.go | 1 +
go-client/pegasus/table_connector_test.go | 8 +-
go-client/session/meta_call.go | 70 +-
go-client/session/meta_session.go | 18 +-
go-client/session/meta_session_test.go | 18 +-
idl/backup.thrift | 7 +-
java-client/README.md | 6 +-
java-client/pom.xml | 31 +
.../{recompile_thrift.sh => download_thrift.sh} | 17 -
.../org/apache/pegasus/client/PegasusTable.java | 147 +-
nodejs-client/src/dsn/dsn_types.js | 36 +
pegic/go.mod | 6 +-
pegic/go.sum | 17 +-
python-client/pypegasus/base/ttypes.py | 75 +-
python-client/pypegasus/pgclient.py | 22 +-
python-client/requirement.txt | 4 +-
python-client/setup.py | 2 +-
rfcs/2020-08-27-metric-api.md | 2 +-
run.sh | 48 +-
src/CMakeLists.txt | 3 +
src/aio/aio_task.cpp | 8 +-
src/aio/aio_task.h | 4 +-
src/aio/disk_engine.cpp | 6 +-
src/aio/file_io.h | 6 +-
src/aio/native_linux_aio_provider.cpp | 2 +-
src/aio/test/aio.cpp | 48 +-
src/base/idl_utils.h | 9 +-
src/base/pegasus_rpc_types.h | 2 +-
src/base/pegasus_utils.cpp | 21 -
src/base/pegasus_utils.h | 13 +-
src/base/pegasus_value_schema.h | 18 +-
src/base/test/value_manager_test.cpp | 4 +-
src/base/test/value_schema_test.cpp | 8 +-
src/base/value_field.h | 4 +-
src/base/value_schema_manager.cpp | 4 +-
src/base/value_schema_manager.h | 4 +-
src/base/value_schema_v0.cpp | 8 +-
src/base/value_schema_v0.h | 6 +-
src/base/value_schema_v1.cpp | 10 +-
src/base/value_schema_v1.h | 8 +-
src/base/value_schema_v2.cpp | 10 +-
src/base/value_schema_v2.h | 8 +-
src/block_service/block_service.h | 18 +-
src/block_service/block_service_manager.cpp | 22 +-
src/block_service/hdfs/hdfs_service.cpp | 9 +-
src/block_service/hdfs/hdfs_service.h | 4 +-
src/block_service/local/local_service.cpp | 6 +-
src/block_service/local/local_service.h | 10 +-
src/block_service/test/hdfs_service_test.cpp | 134 +-
src/client/partition_resolver.cpp | 58 +-
src/client/partition_resolver.h | 12 +-
src/client/partition_resolver_manager.cpp | 4 +-
src/client/partition_resolver_simple.cpp | 73 +-
src/client/partition_resolver_simple.h | 10 +-
src/client/replication_ddl_client.cpp | 184 +-
src/client/replication_ddl_client.h | 45 +-
src/client/test/ddl_client_test.cpp | 4 +-
src/client_lib/client_factory.cpp | 2 +-
src/client_lib/mutation.cpp | 2 +-
src/client_lib/pegasus_client_factory_impl.h | 4 +-
src/client_lib/pegasus_client_impl.cpp | 50 +-
src/client_lib/pegasus_client_impl.h | 2 +-
src/client_lib/pegasus_scanner_impl.cpp | 29 +-
src/common/backup_common.cpp | 2 +-
src/common/backup_common.h | 2 +-
src/common/bulk_load_common.h | 2 +-
src/common/consensus.thrift | 13 +
src/common/duplication_common.cpp | 1 +
src/common/duplication_common.h | 2 +-
src/common/fs_manager.cpp | 17 +-
src/common/fs_manager.h | 16 +-
src/common/json_helper.h | 12 +-
src/common/manual_compact.h | 2 +-
src/common/partition_split_common.h | 2 +-
src/common/replication.codes.h | 2 +-
src/common/replication_common.cpp | 26 +-
src/common/replication_common.h | 7 +-
src/common/replication_other_types.h | 16 +-
src/common/serialization_helper/dsn_types.h | 2 +-
src/common/serialization_helper/thrift_helper.h | 10 +-
src/common/storage_serverlet.h | 8 +-
src/failure_detector/failure_detector.cpp | 92 +-
src/failure_detector/failure_detector.h | 12 +-
.../failure_detector_multimaster.cpp | 14 +-
.../failure_detector_multimaster.h | 9 +-
src/failure_detector/fd.client.h | 6 +-
src/failure_detector/fd.code.definition.h | 10 +-
src/failure_detector/fd.server.h | 4 +-
src/failure_detector/test/failure_detector.cpp | 26 +-
src/failure_detector/test/run.sh | 6 +-
src/geo/bench/bench.cpp | 5 +-
src/geo/lib/geo_client.cpp | 51 +-
src/geo/lib/geo_client.h | 2 +-
src/geo/test/geo_test.cpp | 2 +-
src/{sample/run.sh => gutil/CMakeLists.txt} | 11 +-
src/gutil/map_traits.h | 80 +
src/gutil/map_util.h | 717 +
src/gutil/no_destructor.h | 114 +
.../gutil/test/CMakeLists.txt | 33 +-
src/{utils => gutil}/test/main.cpp | 11 +-
src/gutil/test/map_traits_test.cpp | 78 +
src/gutil/test/map_util_test.h | 475 +
src/gutil/test/map_util_unittest.cpp | 523 +
src/gutil/test/no_destructor_test.cpp | 184 +
src/{sample => gutil/test}/run.sh | 9 +-
src/http/http_call_registry.h | 8 +-
src/http/http_client.cpp | 6 +-
src/http/http_client.h | 8 +-
src/http/http_message_parser.cpp | 2 +-
src/http/http_message_parser.h | 6 +-
src/http/http_server.cpp | 14 +-
src/http/http_server.h | 2 +-
src/http/http_server_impl.h | 2 +-
src/http/test/http_server_test.cpp | 4 +-
src/http/test/uri_decoder_test.cpp | 2 +-
src/http/uri_decoder.cpp | 6 +-
src/http/uri_decoder.h | 4 +-
src/include/pegasus/error.h | 2 +-
src/include/rrdb/rrdb.client.h | 7 +-
src/include/rrdb/rrdb.code.definition.h | 4 +-
src/meta/CMakeLists.txt | 1 +
src/meta/app_balance_policy.cpp | 4 +-
src/meta/app_env_validator.cpp | 34 +-
src/meta/backup_engine.cpp | 49 +-
src/meta/backup_engine.h | 2 +-
src/meta/cluster_balance_policy.cpp | 31 +-
src/meta/cluster_balance_policy.h | 3 +-
src/meta/distributed_lock_service_simple.cpp | 19 +-
src/meta/distributed_lock_service_simple.h | 12 +-
src/meta/dump_file.h | 8 +-
src/meta/duplication/duplication_info.cpp | 1 +
src/meta/duplication/duplication_info.h | 22 +-
src/meta/duplication/meta_duplication_service.cpp | 283 +-
src/meta/duplication/meta_duplication_service.h | 4 +-
src/meta/greedy_load_balancer.cpp | 2 +-
src/meta/load_balance_policy.cpp | 19 +-
src/meta/load_balance_policy.h | 3 +-
src/meta/meta_backup_service.cpp | 298 +-
src/meta/meta_backup_service.h | 7 +-
src/meta/meta_bulk_load_ingestion_context.cpp | 24 +-
src/meta/meta_bulk_load_ingestion_context.h | 10 +-
src/meta/meta_bulk_load_service.cpp | 199 +-
src/meta/meta_bulk_load_service.h | 24 +-
src/meta/meta_data.cpp | 44 +-
src/meta/meta_data.h | 62 +-
src/meta/meta_http_service.cpp | 67 +-
src/meta/meta_rpc_types.h | 2 +-
src/meta/meta_server_failure_detector.cpp | 12 +-
src/meta/meta_server_failure_detector.h | 11 +-
src/meta/meta_service.cpp | 107 +-
src/meta/meta_service.h | 20 +-
src/meta/meta_split_service.cpp | 71 +-
src/meta/meta_split_service.h | 2 +-
src/meta/meta_state_service.h | 10 +-
src/meta/meta_state_service_simple.cpp | 29 +-
src/meta/meta_state_service_simple.h | 16 +-
src/meta/meta_state_service_utils_impl.h | 48 +-
src/meta/meta_state_service_zookeeper.cpp | 87 +-
src/meta/meta_state_service_zookeeper.h | 12 +-
src/meta/partition_guardian.cpp | 27 +-
src/meta/partition_guardian.h | 2 +-
src/meta/server_load_balancer.cpp | 4 +-
src/meta/server_load_balancer.h | 3 +-
src/meta/server_state.cpp | 610 +-
src/meta/server_state.h | 36 +-
src/meta/server_state_restore.cpp | 14 +-
src/meta/table_metrics.cpp | 2 +-
src/meta/test/backup_test.cpp | 18 +-
.../test/balancer_simulator/balancer_simulator.cpp | 23 +-
src/meta/test/balancer_validator.cpp | 14 +-
src/meta/test/cluster_balance_policy_test.cpp | 30 +-
src/meta/test/copy_replica_operation_test.cpp | 2 +-
src/meta/test/ford_fulkerson_test.cpp | 14 +-
src/meta/test/json_compacity.cpp | 4 +-
src/meta/test/main.cpp | 2 +-
src/meta/test/meta_app_operation_test.cpp | 99 +-
src/meta/test/meta_backup_test.cpp | 28 +-
src/meta/test/meta_bulk_load_ingestion_test.cpp | 58 +-
src/meta/test/meta_bulk_load_service_test.cpp | 86 +-
src/meta/test/meta_data.cpp | 30 +-
src/meta/test/meta_duplication_service_test.cpp | 132 +-
src/meta/test/meta_http_service_test.cpp | 8 +-
src/meta/test/meta_mauanl_compaction_test.cpp | 2 +-
src/meta/test/meta_partition_guardian_test.cpp | 51 +-
src/meta/test/meta_service_test.cpp | 12 +-
src/meta/test/meta_service_test_app.h | 12 +-
src/meta/test/meta_split_service_test.cpp | 62 +-
src/meta/test/meta_state/meta_state_service.cpp | 2 +-
src/meta/test/meta_state/run.sh | 6 +-
src/meta/test/meta_state_service_utils_test.cpp | 2 +-
src/meta/test/meta_test_base.cpp | 12 +-
src/meta/test/meta_test_base.h | 9 +-
src/meta/test/misc/misc.cpp | 80 +-
src/meta/test/misc/misc.h | 4 +-
src/meta/test/run.sh | 6 +-
src/meta/test/server_state_restore_test.cpp | 4 +-
src/meta/test/server_state_test.cpp | 4 +-
src/meta/test/state_sync_test.cpp | 38 +-
src/meta/test/update_configuration_test.cpp | 49 +-
src/nfs/nfs_client_impl.cpp | 52 +-
src/nfs/nfs_client_impl.h | 9 +-
src/nfs/nfs_code_definition.h | 4 +-
src/nfs/nfs_node.cpp | 2 +-
src/nfs/nfs_node.h | 8 +-
src/nfs/nfs_server_impl.cpp | 28 +-
src/nfs/nfs_server_impl.h | 4 +-
src/nfs/test/main.cpp | 101 +-
src/perf_counter/perf_counter.h | 6 +-
src/perf_counter/perf_counter_atomic.h | 2 +-
src/perf_counter/perf_counter_wrapper.h | 2 +-
src/perf_counter/perf_counters.cpp | 2 +-
src/ranger/ranger_resource_policy_manager.cpp | 41 +-
src/ranger/ranger_resource_policy_manager.h | 2 +-
.../test/ranger_resource_policy_manager_test.cpp | 2 +-
src/redis_protocol/proxy_lib/proxy_layer.cpp | 19 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 15 +-
src/redis_protocol/proxy_lib/redis_parser.cpp | 49 +-
src/redis_protocol/proxy_lib/redis_parser.h | 10 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 8 +-
src/remote_cmd/remote_command.cpp | 8 +-
src/remote_cmd/remote_command.h | 2 +-
src/replica/backup/cold_backup_context.cpp | 230 +-
src/replica/backup/replica_backup_manager.cpp | 42 +-
src/replica/backup/replica_backup_manager.h | 2 +-
src/replica/backup/replica_backup_server.cpp | 2 +-
src/replica/backup/test/run.sh | 2 +-
src/replica/bulk_load/replica_bulk_loader.cpp | 109 +-
src/replica/bulk_load/replica_bulk_loader.h | 2 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 22 +-
src/replica/bulk_load/test/run.sh | 2 +-
src/replica/disk_cleaner.cpp | 4 +-
src/replica/duplication/duplication_pipeline.cpp | 27 +-
src/replica/duplication/duplication_sync_timer.cpp | 21 +-
src/replica/duplication/duplication_sync_timer.h | 2 +-
src/replica/duplication/load_from_private_log.cpp | 4 +-
src/replica/duplication/mutation_batch.cpp | 59 +-
src/replica/duplication/mutation_batch.h | 10 +-
src/replica/duplication/mutation_duplicator.h | 4 +-
src/replica/duplication/replica_duplicator.cpp | 128 +-
src/replica/duplication/replica_duplicator.h | 35 +-
.../duplication/replica_duplicator_manager.cpp | 77 +-
.../duplication/replica_duplicator_manager.h | 48 +-
src/replica/duplication/replica_follower.cpp | 75 +-
src/replica/duplication/replica_follower.h | 47 +-
.../test/dup_replica_http_service_test.cpp | 3 +-
.../test/duplication_sync_timer_test.cpp | 42 +-
.../duplication/test/duplication_test_base.h | 19 +-
.../test/load_from_private_log_test.cpp | 19 +-
.../duplication/test/mutation_batch_test.cpp | 212 +-
.../test/replica_duplicator_manager_test.cpp | 64 +-
.../duplication/test/replica_duplicator_test.cpp | 79 +-
.../duplication/test/replica_follower_test.cpp | 38 +-
src/replica/duplication/test/run.sh | 2 +-
src/replica/log_file.h | 2 +-
src/replica/log_file_stream.h | 2 +-
src/replica/mutation.cpp | 6 +-
src/replica/mutation.h | 11 +-
src/replica/mutation_cache.cpp | 4 +-
src/replica/mutation_cache.h | 4 +-
src/replica/mutation_log.cpp | 196 +-
src/replica/mutation_log.h | 175 +-
src/replica/mutation_log_replay.cpp | 70 +-
src/replica/mutation_log_utils.cpp | 8 +-
src/replica/mutation_log_utils.h | 4 +-
src/replica/prepare_list.cpp | 32 +-
src/replica/replica.cpp | 12 +-
src/replica/replica.h | 83 +-
src/replica/replica_2pc.cpp | 50 +-
src/replica/replica_backup.cpp | 53 +-
src/replica/replica_base.cpp | 4 +-
src/replica/replica_base.h | 4 +-
src/replica/replica_check.cpp | 59 +-
src/replica/replica_chkpt.cpp | 141 +-
src/replica/replica_config.cpp | 156 +-
src/replica/replica_context.cpp | 33 +-
src/replica/replica_context.h | 8 +-
src/replica/replica_disk_migrator.cpp | 11 +-
src/replica/replica_disk_migrator.h | 2 +-
src/replica/replica_failover.cpp | 12 +-
src/replica/replica_init.cpp | 34 +-
src/replica/replica_learn.cpp | 170 +-
src/replica/replica_restore.cpp | 27 +-
src/replica/replica_stub.cpp | 216 +-
src/replica/replica_stub.h | 24 +-
src/replica/replica_throttle.cpp | 32 +-
src/replica/replication_app_base.cpp | 12 +-
src/replica/replication_app_base.h | 6 +
src/replica/split/replica_split_manager.cpp | 105 +-
src/replica/split/replica_split_manager.h | 2 +-
src/replica/split/test/replica_split_test.cpp | 34 +-
src/replica/split/test/run.sh | 2 +-
src/replica/storage/simple_kv/run.sh | 6 +-
.../storage/simple_kv/simple_kv.app.example.h | 9 +-
src/replica/storage/simple_kv/simple_kv.client.h | 8 +-
.../storage/simple_kv/simple_kv.code.definition.h | 6 +-
src/replica/storage/simple_kv/simple_kv.server.h | 6 +-
.../storage/simple_kv/simple_kv.server.impl.cpp | 6 +-
.../storage/simple_kv/simple_kv.server.impl.h | 10 +-
src/replica/storage/simple_kv/test/case.cpp | 16 +-
src/replica/storage/simple_kv/test/case.h | 9 +-
src/replica/storage/simple_kv/test/checker.cpp | 11 +-
src/replica/storage/simple_kv/test/checker.h | 10 +-
src/replica/storage/simple_kv/test/client.cpp | 36 +-
src/replica/storage/simple_kv/test/client.h | 10 +-
src/replica/storage/simple_kv/test/common.cpp | 18 +-
src/replica/storage/simple_kv/test/common.h | 10 +-
src/replica/storage/simple_kv/test/injector.cpp | 10 +-
src/replica/storage/simple_kv/test/injector.h | 6 +-
src/replica/storage/simple_kv/test/run.sh | 4 +-
.../simple_kv/test/simple_kv.server.impl.cpp | 54 +-
.../storage/simple_kv/test/simple_kv.server.impl.h | 58 +-
src/replica/test/backup_block_service_mock.h | 4 +-
src/replica/test/log_block_test.cpp | 6 +-
src/replica/test/log_file_test.cpp | 37 +-
src/replica/test/mock_utils.h | 19 +-
src/replica/test/mutation_log_learn_test.cpp | 2 +-
src/replica/test/mutation_log_test.cpp | 41 +-
src/replica/test/open_replica_test.cpp | 16 +-
src/replica/test/replica_disk_migrate_test.cpp | 6 +-
src/replica/test/replica_disk_test.cpp | 2 +-
src/replica/test/replica_learn_test.cpp | 5 +-
src/replica/test/replica_test.cpp | 92 +-
src/replica/test/replica_test_base.h | 16 +-
src/replica/test/replication_service_test_app.h | 2 +-
src/replica/test/throttling_controller_test.cpp | 6 +-
scripts/download_zk.sh => src/rpc/CMakeLists.txt | 26 +-
src/{runtime => }/rpc/asio_net_provider.cpp | 9 +-
src/{runtime => }/rpc/asio_net_provider.h | 13 +-
src/{runtime => }/rpc/asio_rpc_session.cpp | 25 +-
src/{runtime => }/rpc/asio_rpc_session.h | 13 +-
src/{runtime => }/rpc/dns_resolver.cpp | 8 +-
src/{runtime => }/rpc/dns_resolver.h | 4 +-
src/{runtime => }/rpc/dsn_message_parser.cpp | 8 +-
.../node_scoper.h => rpc/dsn_message_parser.h} | 35 +-
src/{runtime => }/rpc/group_address.h | 2 +-
src/{runtime => }/rpc/group_host_port.h | 17 +-
src/{runtime => }/rpc/message_parser.cpp | 6 +-
src/{runtime => }/rpc/message_parser.h | 4 +-
src/{runtime => }/rpc/message_parser_manager.h | 4 +-
src/{runtime => }/rpc/network.cpp | 23 +-
src/{runtime => }/rpc/network.h | 15 +-
src/{runtime => }/rpc/network.sim.cpp | 10 +-
src/{runtime => }/rpc/network.sim.h | 32 +-
src/{runtime => }/rpc/raw_message_parser.cpp | 10 +-
.../raw_message_parser.h} | 42 +-
src/{runtime => }/rpc/request_meta.thrift | 0
src/{runtime => }/rpc/rpc_address.cpp | 8 +-
src/{runtime => }/rpc/rpc_address.h | 3 +-
src/{runtime => }/rpc/rpc_engine.cpp | 19 +-
src/{runtime => }/rpc/rpc_engine.h | 16 +-
src/{runtime => }/rpc/rpc_holder.h | 18 +-
src/{runtime => }/rpc/rpc_host_port.cpp | 47 +-
src/{runtime => }/rpc/rpc_host_port.h | 6 +-
src/{runtime => }/rpc/rpc_message.cpp | 6 +-
src/{runtime => }/rpc/rpc_message.h | 12 +-
src/{runtime => }/rpc/rpc_stream.h | 4 +-
src/{runtime => }/rpc/rpc_task.cpp | 12 +-
src/{runtime => }/rpc/serialization.h | 6 +-
src/{sample/run.sh => rpc/test/CMakeLists.txt} | 20 +-
src/{runtime => rpc}/test/address_test.cpp | 4 +-
src/rpc/test/config.ini | 125 +
.../test/corrupt_message_test.cpp} | 33 +-
src/{runtime => rpc}/test/host_port_test.cpp | 45 +-
src/{security => rpc}/test/main.cpp | 0
src/{runtime => rpc}/test/message_reader_test.cpp | 2 +-
src/{runtime => rpc}/test/message_utils_test.cpp | 10 +-
.../test/net_provider_test.cpp} | 52 +-
src/{runtime => rpc}/test/rpc_holder_test.cpp | 14 +-
.../test/rpc_message_test.cpp} | 19 +-
.../test/rpc.cpp => rpc/test/rpc_test.cpp} | 24 +-
src/{sample => rpc/test}/run.sh | 15 +-
.../test/thrift_message_parser_test.cpp | 12 +-
src/{runtime => }/rpc/thrift_message_parser.cpp | 8 +-
src/{runtime => }/rpc/thrift_message_parser.h | 4 +-
src/runtime/CMakeLists.txt | 6 +-
src/runtime/api_layer1.h | 8 +-
src/runtime/api_task.h | 4 +-
src/runtime/env.sim.cpp | 2 +-
src/runtime/env.sim.h | 4 +-
src/runtime/fault_injector.cpp | 12 +-
src/runtime/fault_injector.h | 4 +-
src/runtime/global_config.cpp | 2 +-
src/runtime/global_config.h | 10 +-
src/runtime/message_utils.cpp | 2 +-
src/runtime/message_utils.h | 6 +-
src/runtime/nativerun.cpp | 2 +-
src/runtime/nativerun.h | 4 +-
src/runtime/node_scoper.h | 4 +-
src/runtime/pipeline.h | 39 +-
src/runtime/profiler.cpp | 13 +-
src/runtime/providers.common.cpp | 18 +-
src/runtime/providers.common.h | 2 +-
src/runtime/rpc/CMakeLists.txt | 45 -
src/runtime/rpc/dsn_message_parser.h | 58 -
src/runtime/rpc/raw_message_parser.h | 55 -
src/runtime/scheduler.cpp | 10 +-
src/runtime/scheduler.h | 4 +-
src/runtime/serverlet.h | 6 +-
src/runtime/service_api_c.cpp | 167 +-
src/runtime/service_app.h | 5 +-
src/runtime/service_engine.cpp | 10 +-
src/runtime/service_engine.h | 2 +-
src/runtime/simulator.cpp | 4 +-
src/runtime/simulator.h | 5 +-
src/runtime/test/CMakeLists.txt | 4 +-
src/runtime/test/config-test-corrupt-message.ini | 141 -
src/runtime/test/config-test-sim.ini | 10 +-
src/runtime/test/config-test.ini | 16 +-
src/runtime/test/dns_resolver_test.cpp | 10 +-
src/runtime/test/gtest.filter | 3 -
src/runtime/test/pipeline_test.cpp | 2 +-
src/runtime/test/run.sh | 19 +-
src/runtime/test/service_api_c.cpp | 12 +-
src/runtime/test/sim_lock.cpp | 18 +-
src/runtime/test_utils.h | 25 +-
src/runtime/threadpool_code.cpp | 2 +-
src/runtime/tool_api.cpp | 7 +-
src/runtime/tool_api.h | 13 +-
src/runtime/tracer.cpp | 10 +-
src/sample/run.sh | 22 +-
src/security/client_negotiation.cpp | 4 +-
src/security/client_negotiation.h | 2 +-
src/security/meta_access_controller.cpp | 8 +-
src/security/negotiation.h | 6 +-
src/security/negotiation_manager.cpp | 6 +-
src/security/replica_access_controller.cpp | 4 +-
src/security/sasl_client_wrapper.cpp | 8 +-
src/security/sasl_server_wrapper.cpp | 8 +-
src/security/sasl_wrapper.cpp | 4 +-
src/security/server_negotiation.cpp | 4 +-
src/security/server_negotiation.h | 2 +-
src/security/test/client_negotiation_test.cpp | 8 +-
src/security/test/meta_access_controller_test.cpp | 10 +-
src/security/test/negotiation_manager_test.cpp | 12 +-
.../test/replica_access_controller_test.cpp | 8 +-
src/security/test/server_negotiation_test.cpp | 6 +-
src/server/available_detector.cpp | 25 +-
src/server/available_detector.h | 8 +-
src/server/capacity_unit_calculator.cpp | 4 +-
src/server/compaction_filter_rule.cpp | 26 +-
src/server/compaction_filter_rule.h | 26 +-
src/server/compaction_operation.cpp | 20 +-
src/server/compaction_operation.h | 27 +-
src/server/hotkey_collector.cpp | 10 +-
src/server/hotkey_collector.h | 4 +-
src/server/hotspot_partition_calculator.cpp | 17 +-
src/server/hotspot_partition_calculator.h | 2 +-
src/server/info_collector.cpp | 42 +-
src/server/info_collector.h | 6 +-
src/server/info_collector_app.cpp | 4 +-
src/server/info_collector_app.h | 4 +-
src/server/key_ttl_compaction_filter.h | 4 +-
src/server/pegasus_event_listener.cpp | 2 +-
src/server/pegasus_manual_compact_service.cpp | 6 +-
src/server/pegasus_mutation_duplicator.cpp | 23 +-
src/server/pegasus_mutation_duplicator.h | 10 +-
src/server/pegasus_scan_context.h | 4 +-
src/server/pegasus_server_impl.cpp | 171 +-
src/server/pegasus_server_impl.h | 10 +-
src/server/pegasus_server_impl_init.cpp | 5 +-
src/server/pegasus_server_write.cpp | 6 +-
src/server/pegasus_server_write.h | 2 +-
src/server/pegasus_write_service.cpp | 6 +-
src/server/pegasus_write_service_impl.h | 24 +-
src/server/result_writer.cpp | 4 +-
src/server/result_writer.h | 2 +-
src/server/rocksdb_wrapper.cpp | 24 +-
src/server/rocksdb_wrapper.h | 14 +-
src/server/test/capacity_unit_calculator_test.cpp | 2 +-
src/server/test/hotkey_collector_test.cpp | 10 +-
.../test/pegasus_mutation_duplicator_test.cpp | 26 +-
src/server/test/pegasus_server_impl_test.cpp | 3 +-
src/server/test/pegasus_server_write_test.cpp | 2 +-
.../test/pegasus_write_service_impl_test.cpp | 6 +-
src/server/test/pegasus_write_service_test.cpp | 4 +-
src/server/test/rocksdb_wrapper_test.cpp | 8 +-
src/shell/command_helper.h | 261 +-
src/shell/command_utils.cpp | 22 +-
src/shell/command_utils.h | 2 +-
src/shell/commands.h | 3 +-
src/shell/commands/bulk_load.cpp | 8 +-
src/shell/commands/cold_backup.cpp | 141 +-
src/shell/commands/data_operations.cpp | 42 +-
src/shell/commands/debugger.cpp | 16 +-
src/shell/commands/detect_hotkey.cpp | 8 +-
src/shell/commands/duplication.cpp | 118 +-
src/shell/commands/local_partition_split.cpp | 12 +-
src/shell/commands/node_management.cpp | 423 +-
src/shell/commands/rebalance.cpp | 2 +-
src/shell/commands/recovery.cpp | 15 +-
src/shell/commands/table_management.cpp | 77 +-
src/shell/main.cpp | 144 +-
src/{runtime => }/task/CMakeLists.txt | 17 +-
src/{runtime => }/task/async_calls.h | 8 +-
src/{runtime => }/task/future_types.h | 2 +-
src/{runtime => }/task/hpc_task_queue.cpp | 12 +-
src/{runtime => }/task/hpc_task_queue.h | 8 +-
src/{runtime => }/task/simple_task_queue.cpp | 10 +-
src/{runtime => }/task/simple_task_queue.h | 6 +-
src/{runtime => }/task/task.cpp | 7 +-
src/{runtime => }/task/task.h | 12 +-
src/{runtime => }/task/task_code.cpp | 4 +-
src/{runtime => }/task/task_code.h | 6 +-
src/{runtime => }/task/task_engine.cpp | 28 +-
src/{runtime => }/task/task_engine.h | 2 +-
src/{runtime => }/task/task_engine.sim.cpp | 8 +-
src/{runtime => }/task/task_engine.sim.h | 4 +-
src/{runtime => }/task/task_queue.cpp | 13 +-
src/{runtime => }/task/task_queue.h | 0
src/{runtime => }/task/task_spec.cpp | 9 +-
src/{runtime => }/task/task_spec.h | 13 +-
src/{runtime => }/task/task_tracker.cpp | 2 +-
src/{runtime => }/task/task_tracker.h | 2 +-
src/{runtime => }/task/task_worker.cpp | 10 +-
src/{runtime => }/task/task_worker.h | 2 +-
.../task/tests/CMakeLists.txt | 29 +-
.../tests/async_call_test.cpp} | 54 +-
src/task/tests/config-test-sim.ini | 38 +
src/task/tests/config-test.ini | 52 +
.../test/lpc.cpp => task/tests/lpc_test.cpp} | 8 +-
src/task/tests/main.cpp | 79 +
src/task/tests/run.sh | 47 +
.../tests/task_engine_test.cpp} | 13 +-
src/{runtime/test => task/tests}/task_test.cpp | 6 +-
src/{runtime => }/task/timer_service.h | 2 +-
src/test/function_test/base_api/test_basic.cpp | 3 +-
src/test/function_test/base_api/test_batch_get.cpp | 34 +-
src/test/function_test/base_api/test_copy.cpp | 2 +-
src/test/function_test/base_api/test_scan.cpp | 20 +-
.../function_test/bulk_load/test_bulk_load.cpp | 5 +-
.../detect_hotspot/test_detect_hotspot.cpp | 29 +-
src/test/function_test/recovery/test_recovery.cpp | 2 +-
src/test/function_test/restore/test_restore.cpp | 12 +-
src/test/function_test/utils/global_env.cpp | 2 +-
src/test/function_test/utils/test_util.cpp | 39 +-
src/test/function_test/utils/test_util.h | 38 +-
src/test/function_test/utils/utils.h | 10 +-
src/test/kill_test/job.cpp | 4 +-
src/test/kill_test/job.h | 4 +-
src/test/kill_test/kill_testor.cpp | 38 +-
src/test/kill_test/kill_testor.h | 4 +-
src/test/kill_test/killer_handler.h | 4 +-
src/test/kill_test/killer_handler_shell.cpp | 4 +-
src/test/kill_test/killer_handler_shell.h | 4 +-
src/test/kill_test/partition_kill_testor.cpp | 16 +-
src/test/pressure_test/main.cpp | 6 +-
src/tools/mutation_log_tool.cpp | 4 +-
src/utils/TokenBucket.h | 4 +-
src/utils/binary_reader.cpp | 4 +-
src/utils/binary_reader.h | 8 +-
src/utils/binary_writer.cpp | 6 +-
src/utils/binary_writer.h | 2 +-
src/utils/blob.h | 128 +-
src/utils/builtin_metrics.cpp | 2 +-
src/utils/chrono_literals.h | 4 +-
src/utils/command_manager.cpp | 125 +-
src/utils/command_manager.h | 53 +-
src/utils/config_helper.h | 5 +-
src/utils/configuration.cpp | 2 +-
src/utils/crc.cpp | 8 +-
src/utils/crc.h | 4 +-
src/utils/customizable_id.h | 4 +-
src/utils/distributed_lock_service.h | 52 +-
src/utils/endians.h | 6 +-
src/utils/error_code.cpp | 2 +-
src/utils/error_code.h | 5 +
src/utils/errors.h | 10 +-
src/utils/exp_delay.h | 2 +-
src/utils/factory_store.h | 4 +-
src/utils/fail_point.cpp | 10 +-
src/utils/fail_point.h | 6 +-
src/utils/fail_point_impl.h | 10 +-
src/utils/filesystem.cpp | 53 +-
src/utils/filesystem.h | 10 +
src/utils/function_traits.h | 2 +-
src/utils/gpid.cpp | 2 +-
src/utils/je_ctl.cpp | 10 +-
src/utils/latency_tracer.cpp | 2 +-
src/utils/latency_tracer.h | 2 +-
src/utils/lockp.std.h | 4 +-
src/utils/logging.cpp | 12 +-
src/utils/logging_provider.h | 17 +-
src/utils/metrics.cpp | 8 +-
src/utils/metrics.h | 118 +-
src/utils/optional.h | 6 +-
src/utils/preloadable.h | 4 +-
src/utils/priority_queue.h | 4 +-
src/utils/process_utils.cpp | 6 +-
src/utils/process_utils.h | 4 +-
src/utils/safe_strerror_posix.cpp | 4 +-
src/utils/safe_strerror_posix.h | 4 +-
src/utils/simple_logger.cpp | 381 +-
src/utils/simple_logger.h | 45 +-
src/utils/singleton_store.h | 4 +-
src/utils/string_conv.h | 22 +-
src/utils/strings.cpp | 4 +-
src/utils/synchronize.h | 6 +-
src/utils/test/TokenBucketTest.cpp | 5 +-
src/utils/test/blob_test.cpp | 145 +
src/utils/test/clear.sh | 2 +-
src/utils/test/env.cpp | 2 +-
src/utils/test/fail_point_test.cpp | 8 +-
src/utils/test/file_system_test.cpp | 37 +
src/utils/test/fmt_logging_test.cpp | 10 +-
src/utils/test/hostname_test.cpp | 42 -
src/utils/test/json_helper_test.cpp | 2 +-
src/utils/test/logger.cpp | 157 +-
src/utils/test/long_adder_test.cpp | 2 +-
src/utils/test/main.cpp | 2 +-
src/utils/test/metrics_test.cpp | 64 +-
src/utils/test/output_utils_test.cpp | 4 +-
src/utils/test/run.sh | 6 +-
src/utils/test/string_conv_test.cpp | 46 +-
src/utils/test/time_utils_test.cpp | 25 +-
src/utils/thread_access_checker.cpp | 2 +-
src/utils/thread_access_checker.h | 2 +-
src/utils/threadpool_code.h | 2 +-
src/utils/threadpool_spec.h | 2 +-
src/utils/time_utils.cpp | 15 +-
src/utils/time_utils.h | 11 +-
src/utils/uniq_timestamp_us.h | 2 +-
src/utils/utils.cpp | 80 -
src/utils/utils.h | 15 -
src/utils/work_queue.h | 2 +-
src/utils/zlock_provider.h | 2 +-
src/utils/zlocks.h | 8 +-
.../distributed_lock_service_zookeeper.cpp | 6 +-
src/zookeeper/distributed_lock_service_zookeeper.h | 10 +-
src/zookeeper/lock_struct.cpp | 19 +-
src/zookeeper/lock_struct.h | 6 +-
src/zookeeper/lock_types.h | 6 +-
src/zookeeper/test/distributed_lock_zookeeper.cpp | 41 +-
src/zookeeper/test/run.sh | 6 +-
src/zookeeper/zookeeper_error.cpp | 4 +-
src/zookeeper/zookeeper_error.h | 2 +-
src/zookeeper/zookeeper_session.cpp | 6 +-
src/zookeeper/zookeeper_session.h | 4 +-
src/zookeeper/zookeeper_session_mgr.cpp | 4 +-
thirdparty/CMakeLists.txt | 25 +-
...atch => fix_thrift_build_and_link_errors.patch} | 13 +
741 files changed, 64672 insertions(+), 7283 deletions(-)
create mode 100644 .clang-tidy
rename {scripts => admin_tools}/config_hdfs.sh (100%)
rename {scripts => admin_tools}/downgrade_node.sh (98%)
rename {scripts => admin_tools}/learn_stat.py (100%)
rename {scripts => admin_tools}/migrate_node.sh (100%)
rename {scripts => admin_tools}/minos_common.sh (100%)
rename {scripts => admin_tools}/pegasus_add_node_list.sh (92%)
rename {scripts => admin_tools}/pegasus_bench_run.sh (100%)
rename {scripts => admin_tools}/pegasus_check_arguments.sh (98%)
rename {scripts => admin_tools}/pegasus_kill_test.sh (100%)
rename {scripts => admin_tools}/pegasus_manual_compact.sh (100%)
rename {scripts => admin_tools}/pegasus_migrate_zookeeper.sh (99%)
rename {scripts => admin_tools}/pegasus_offline_node.sh (99%)
rename {scripts => admin_tools}/pegasus_offline_node_list.sh (96%)
rename {scripts => admin_tools}/pegasus_rebalance_cluster.sh (100%)
rename {scripts => admin_tools}/pegasus_replica_thread.sh (100%)
rename {scripts => admin_tools}/pegasus_restart_node.sh (99%)
rename {scripts => admin_tools}/pegasus_rolling_update.sh (98%)
rename {scripts => admin_tools}/pegasus_set_usage_scenario.sh (100%)
rename {scripts => admin_tools}/pegasus_stat_available.sh (100%)
rename {scripts => admin_tools}/pegasus_update_ingest_behind.sh (99%)
rename {scripts => admin_tools}/sendmail.sh (100%)
rename {scripts => build_tools}/bump_version.sh (100%)
rename {scripts => build_tools}/check_license.py (100%)
create mode 100755 build_tools/clang_tidy.py
rename {scripts => build_tools}/clear_zk.sh (100%)
rename {scripts => build_tools}/collector_table_counter_gen.py (98%)
rename {scripts => build_tools}/compile_thrift.py (96%)
copy {scripts => build_tools}/download_hadoop.sh (100%)
rename {scripts => build_tools}/download_package.sh (100%)
copy {scripts => build_tools}/download_zk.sh (100%)
rename {scripts => build_tools}/format_files.sh (96%)
rename {scripts => build_tools}/pack_client.sh (93%)
rename {scripts => build_tools}/pack_common.sh (93%)
rename {scripts => build_tools}/pack_server.sh (78%)
rename {scripts => build_tools}/pack_tools.sh (74%)
rename {scripts => build_tools}/recompile_thrift.sh (81%)
rename {scripts => build_tools}/redis_proto_check.py (100%)
rename {scripts => build_tools}/run-clang-format.py (99%)
rename {scripts => build_tools}/start_zk.sh (100%)
rename {scripts => build_tools}/stop_zk.sh (100%)
delete mode 100644 docker/clang-format-3.9/Dockerfile
create mode 100644 go-client/idl/admin/GoUnusedProtection__.go
create mode 100644 go-client/idl/admin/backup-consts.go
create mode 100644 go-client/idl/admin/backup.go
create mode 100644 go-client/idl/admin/bulk_load-consts.go
create mode 100644 go-client/idl/admin/bulk_load.go
create mode 100644 go-client/idl/admin/duplication-consts.go
create mode 100644 go-client/idl/admin/duplication.go
create mode 100644 go-client/idl/admin/meta_admin-consts.go
create mode 100644 go-client/idl/admin/meta_admin.go
create mode 100644 go-client/idl/admin/metadata-consts.go
create mode 100644 go-client/idl/admin/metadata.go
create mode 100644 go-client/idl/admin/partition_split-consts.go
create mode 100644 go-client/idl/admin/partition_split.go
create mode 100644 go-client/idl/cmd/GoUnusedProtection__.go
create mode 100644 go-client/idl/cmd/command-consts.go
create mode 100644 go-client/idl/cmd/command.go
create mode 100644 go-client/idl/radmin/GoUnusedProtection__.go
create mode 100644 go-client/idl/radmin/replica_admin-consts.go
create mode 100644 go-client/idl/radmin/replica_admin.go
create mode 100644 go-client/idl/replication/GoUnusedProtection__.go
create mode 100644 go-client/idl/replication/dsn.layer2-consts.go
create mode 100644 go-client/idl/replication/dsn.layer2.go
create mode 100644 go-client/idl/rrdb/GoUnusedProtection__.go
create mode 100755 go-client/idl/rrdb/meta-remote/meta-remote.go
create mode 100644 go-client/idl/rrdb/rrdb-consts.go
create mode 100755 go-client/idl/rrdb/rrdb-remote/rrdb-remote.go
create mode 100644 go-client/idl/rrdb/rrdb.go
rename java-client/scripts/{recompile_thrift.sh => download_thrift.sh} (73%)
copy src/{sample/run.sh => gutil/CMakeLists.txt} (81%)
mode change 100755 => 100644
create mode 100644 src/gutil/map_traits.h
create mode 100644 src/gutil/map_util.h
create mode 100644 src/gutil/no_destructor.h
copy scripts/download_zk.sh => src/gutil/test/CMakeLists.txt (66%)
mode change 100755 => 100644
copy src/{utils => gutil}/test/main.cpp (82%)
create mode 100644 src/gutil/test/map_traits_test.cpp
create mode 100644 src/gutil/test/map_util_test.h
create mode 100644 src/gutil/test/map_util_unittest.cpp
create mode 100644 src/gutil/test/no_destructor_test.cpp
copy src/{sample => gutil/test}/run.sh (81%)
rename scripts/download_zk.sh => src/rpc/CMakeLists.txt (67%)
mode change 100755 => 100644
rename src/{runtime => }/rpc/asio_net_provider.cpp (98%)
rename src/{runtime => }/rpc/asio_net_provider.h (95%)
rename src/{runtime => }/rpc/asio_rpc_session.cpp (93%)
rename src/{runtime => }/rpc/asio_rpc_session.h (88%)
rename src/{runtime => }/rpc/dns_resolver.cpp (97%)
rename src/{runtime => }/rpc/dns_resolver.h (97%)
rename src/{runtime => }/rpc/dsn_message_parser.cpp (98%)
copy src/{runtime/node_scoper.h => rpc/dsn_message_parser.h} (63%)
rename src/{runtime => }/rpc/group_address.h (99%)
rename src/{runtime => }/rpc/group_host_port.h (93%)
rename src/{runtime => }/rpc/message_parser.cpp (98%)
rename src/{runtime => }/rpc/message_parser.h (98%)
rename src/{runtime => }/rpc/message_parser_manager.h (97%)
rename src/{runtime => }/rpc/network.cpp (96%)
rename src/{runtime => }/rpc/network.h (97%)
rename src/{runtime => }/rpc/network.sim.cpp (96%)
rename src/{runtime => }/rpc/network.sim.h (82%)
rename src/{runtime => }/rpc/raw_message_parser.cpp (97%)
copy src/{runtime/threadpool_code.cpp => rpc/raw_message_parser.h} (62%)
rename src/{runtime => }/rpc/request_meta.thrift (100%)
rename src/{runtime => }/rpc/rpc_address.cpp (98%)
rename src/{runtime => }/rpc/rpc_address.h (99%)
rename src/{runtime => }/rpc/rpc_engine.cpp (98%)
rename src/{runtime => }/rpc/rpc_engine.h (97%)
rename src/{runtime => }/rpc/rpc_holder.h (96%)
rename src/{runtime => }/rpc/rpc_host_port.cpp (80%)
rename src/{runtime => }/rpc/rpc_host_port.h (99%)
rename src/{runtime => }/rpc/rpc_message.cpp (99%)
rename src/{runtime => }/rpc/rpc_message.h (95%)
rename src/{runtime => }/rpc/rpc_stream.h (98%)
rename src/{runtime => }/rpc/rpc_task.cpp (95%)
rename src/{runtime => }/rpc/serialization.h (97%)
copy src/{sample/run.sh => rpc/test/CMakeLists.txt} (73%)
mode change 100755 => 100644
rename src/{runtime => rpc}/test/address_test.cpp (99%)
create mode 100644 src/rpc/test/config.ini
rename src/{runtime/test/corrupt_message.cpp =>
rpc/test/corrupt_message_test.cpp} (67%)
rename src/{runtime => rpc}/test/host_port_test.cpp (93%)
copy src/{security => rpc}/test/main.cpp (100%)
rename src/{runtime => rpc}/test/message_reader_test.cpp (98%)
rename src/{runtime => rpc}/test/message_utils_test.cpp (92%)
rename src/{runtime/test/netprovider.cpp => rpc/test/net_provider_test.cpp}
(88%)
rename src/{runtime => rpc}/test/rpc_holder_test.cpp (95%)
rename src/{runtime/test/rpc_message.cpp => rpc/test/rpc_message_test.cpp}
(95%)
rename src/{runtime/test/rpc.cpp => rpc/test/rpc_test.cpp} (95%)
copy src/{sample => rpc/test}/run.sh (79%)
rename src/{runtime => rpc}/test/thrift_message_parser_test.cpp (98%)
rename src/{runtime => }/rpc/thrift_message_parser.cpp (98%)
rename src/{runtime => }/rpc/thrift_message_parser.h (98%)
delete mode 100644 src/runtime/rpc/CMakeLists.txt
delete mode 100644 src/runtime/rpc/dsn_message_parser.h
delete mode 100644 src/runtime/rpc/raw_message_parser.h
delete mode 100644 src/runtime/test/config-test-corrupt-message.ini
delete mode 100644 src/runtime/test/gtest.filter
rename src/{runtime => }/task/CMakeLists.txt (83%)
rename src/{runtime => }/task/async_calls.h (98%)
rename src/{runtime => }/task/future_types.h (98%)
rename src/{runtime => }/task/hpc_task_queue.cpp (94%)
rename src/{runtime => }/task/hpc_task_queue.h (94%)
rename src/{runtime => }/task/simple_task_queue.cpp (96%)
rename src/{runtime => }/task/simple_task_queue.h (95%)
rename src/{runtime => }/task/task.cpp (99%)
rename src/{runtime => }/task/task.h (98%)
rename src/{runtime => }/task/task_code.cpp (99%)
rename src/{runtime => }/task/task_code.h (99%)
rename src/{runtime => }/task/task_engine.cpp (94%)
rename src/{runtime => }/task/task_engine.h (99%)
rename src/{runtime => }/task/task_engine.sim.cpp (98%)
rename src/{runtime => }/task/task_engine.sim.h (99%)
rename src/{runtime => }/task/task_queue.cpp (95%)
rename src/{runtime => }/task/task_queue.h (100%)
rename src/{runtime => }/task/task_spec.cpp (98%)
rename src/{runtime => }/task/task_spec.h (98%)
rename src/{runtime => }/task/task_tracker.cpp (99%)
rename src/{runtime => }/task/task_tracker.h (99%)
rename src/{runtime => }/task/task_worker.cpp (97%)
rename src/{runtime => }/task/task_worker.h (99%)
rename scripts/download_hadoop.sh => src/task/tests/CMakeLists.txt (70%)
mode change 100755 => 100644
rename src/{runtime/test/async_call.cpp => task/tests/async_call_test.cpp}
(87%)
create mode 100644 src/task/tests/config-test-sim.ini
create mode 100644 src/task/tests/config-test.ini
rename src/{runtime/test/lpc.cpp => task/tests/lpc_test.cpp} (93%)
create mode 100644 src/task/tests/main.cpp
create mode 100755 src/task/tests/run.sh
rename src/{runtime/test/task_engine.cpp => task/tests/task_engine_test.cpp}
(91%)
rename src/{runtime/test => task/tests}/task_test.cpp (96%)
rename src/{runtime => }/task/timer_service.h (99%)
create mode 100644 src/utils/test/blob_test.cpp
delete mode 100644 src/utils/test/hostname_test.cpp
delete mode 100644 src/utils/utils.cpp
rename thirdparty/{fix_thrift_for_cpp11.patch =>
fix_thrift_build_and_link_errors.patch} (80%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
