You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by gi...@apache.org on 2023/05/17 09:02:54 UTC
[incubator-pegasus] branch dependabot/pip/python-client/twisted-22.10.0 updated (3cedd3aac -> cf2c288ef)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/pip/python-client/twisted-22.10.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard 3cedd3aac build(deps): bump twisted from 21.2.0 to 22.10.0 in /python-client
add 79e58f2fe refactor(log): use LOG_* instead of LOG_*_F (#1322)
add d83ce3d12 refactor(conf): use DSN_DEFINE_int32 to load int32 type of configs (#1324)
add a0be562f9 chore(CI): Add unit test workflow for node.js client (#1332)
add 4f25086f0 refactor(idl): unify the *.thrift files used by cpp and nodejs-client (#1335)
add 390ccf8ff feat(utils): add an utility function to find string prefix by separator (#1338)
add 624cae5ac feat(new_metrics): retire stale metric entities that are not used by any other object (#1304)
add 447621904 fix: fix rocksdb build type (#1340)
add d6c15b835 refactor(conf): use DSN_DEFINE_int32 to load int32 type of configs (part 2) (#1346)
add c37bacd9f build: support Ubuntu 22.04 and clang 14 (#1350)
add 4c76112a5 refactor(conf): use DSN_DEFINE_uint32 to load uint32 type of configs (#1352)
add ec905d991 refactor(conf): use DSN_DEFINE_int64 to load int64 type of configs (#1357)
add 3598aa6cc refactor(conf): use DSN_DEFINE_uint64 to load uint64 type of configs (#1359)
add 51b57615c refactor(conf): use DSN_DEFINE_double to load double type of configs (#1362)
add 9b160a935 refactor(conf): use DSN_DEFINE_bool to load bool type of configs (#1363)
add cd01040d8 feat(security): Use Apache Ranger for access control(1/n) (#1360)
add 2c6911779 feat(security): Use Apache Ranger for access control(2/n) (#1375)
add 98e359888 refactor(conf): use DSN_DEFINE_string to load string type of configs (#1371)
add 0922a9ac8 chore(cmake): fix project load failure by CLion (#1376)
add 5088b2929 feat(test): add bench type multi set/get (#1373)
add f628e87a5 fix: fix centos image build (#1356)
add 6ee7a953f chore(CI): Use Ubuntu 22.04 as the default test platform (#1381)
add 37434d28d refactor: Move some functions from 'replica' to 'replica_stub' (#1384)
add 84ce5fb97 feat(Ranger): Compatible with the old ACL and the new ACL (#1379)
add ca6ee39de feat(Ranger): Support encode and decode Ranger policies (#1378)
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)
add 1d2e0c6ff fix: resolve undeclared names that are reported while building alloc.h in debug mode (#1392)
add fd5a4350c chore(CI): include cmath to fix ambiguous std::abs on ubuntu1604 (#1395)
add fc50c1c1d fix: fix kerberos authentication based on keytab for java client (#1393)
add e4fee118c chore(build): make build dir standalone and speedup re-build (#1401)
add 034cb9d10 feat(Ranger): Pull policies from the Ranger Service and update using resources policies (#1388)
add ad80389cb chore(github): try to add some contributors into apache collaborators to allow them to use github actions (#1409)
add 169333005 check leader status (#1406)
add 576189319 batchGetByPartitions (#1411)
add 58bad7471 refactor: return Status::code instead of meanless integer (#1417)
add 254f6d4a7 chore(CI): fix regularly build failure (#1420)
add 039e2fd3f refactor: minor refactor on replica module (#1423)
add 87f169a80 feat(Ranger): Use Apache Ranger for meta access controller (#1402)
add f630ce148 feat: add new macro definitions (#1429)
add 0199edee8 fix: log error but not crash if found an imcomplete replica path (#1428)
add ababcc08a fix(java-client): Fix java spotbug (#1416)
add 9303c3aba fix: Fix the corruption RocksDB instance will be reused bug (#1422)
add fe0e0284d feat(FQDN): Implement of struct rpc_host_port (#1430)
add a2e87bcdc refactor: retry function test when run failed (#1179)
add cf997de7f fix(IWYU): fix include errors for rpc_host_port reported by IWYU (#1434)
add d16e65cd8 feat(Ranger): Use Apache Ranger for replica access controller (#1433)
add 1beb24a76 fix(ut): fix a flaky test integration_test.write_corrupt_db (#1442)
add 0dc3e4b31 doc(go-client): add deprecated marker to TableConnector.Close() (#1448)
add b4937faa6 fix(go-client): loopForRequest not return and retry forever (#1444)
add ce0af37c1 feat(Ranger): Use Apache Ranger for ACL when replica master-slave learn (#1445)
add b676991a6 refactor: remove useless function 'last_flushed_decree()' (#1456)
add 079de23e2 feat(util): add cancel() for class defer (#1458)
add 5ab400dea refactor(log): make macros LOG_AND_RETURN_NOT_* more general (#1457)
add 7a6c28e4a fix: fix a crash bug when open an incomplete created RocksDB instance (#1451)
add 64414e601 feat(Ranger): Use Apache Ranger for ACL when replica performs nfs copy (#1452)
add 12c8b56e2 fix: Fault-tolerant storage engine errors for read operations (#1447)
add b11b45d64 fix(ddl_client): sleep for a while before retry once meta server is busy (#1453)
add e655400af feat(FQDN): Implemention of struct host_port_group (#1436)
add d37fca91f fix(log): fix using of macro LOG_AND_RETURN_NOT_* print duplicate prefixes (#1465)
add 5d1ce0b42 fix: fix garble words of time filed in logs (#1468)
add ee03ffee8 feat(FQDN): Implemention of struct dns_resolver (#1464)
add 48fd4e87f feat(java-client): add listApps interface (#1471)
add cf2c288ef build(deps): bump twisted from 21.2.0 to 22.10.0 in /python-client
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 (3cedd3aac)
\
N -- N -- N refs/heads/dependabot/pip/python-client/twisted-22.10.0 (cf2c288ef)
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.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 5 +
.github/workflows/build-push-env-docker.yml | 3 +-
.github/workflows/labeler.yml | 2 +-
.github/workflows/lint_and_test_admin-cli.yml | 8 +-
.github/workflows/lint_and_test_cpp.yaml | 126 +-
.github/workflows/lint_and_test_go-client.yml | 4 +-
.github/workflows/lint_and_test_pegic.yml | 8 +-
.github/workflows/regular-build.yml | 38 +-
.github/workflows/standardization_lint.yaml | 8 +-
.github/workflows/test_java-client.yml | 2 +-
...st_python-client.yml => test_nodejs-client.yml} | 13 +-
.github/workflows/test_scala-client.yml | 2 +-
.github/workflows/thirdparty-regular-push.yml | 16 +-
.gitignore | 1 -
.licenserc.yaml | 3 +-
cmake_modules/BaseFunctions.cmake | 2 +-
docker/README.md | 2 +
docker/pegasus-build-env/centos6/Dockerfile | 2 +-
docker/pegasus-build-env/centos7/Dockerfile | 5 +-
.../{ubuntu1804 => ubuntu2204}/Dockerfile | 16 +-
go-client/pegasus/table_connector.go | 3 +
go-client/pegasus/table_connector_test.go | 2 +-
go-client/session/session.go | 12 +-
idl/dsn.layer2.thrift | 1 -
idl/rrdb.thrift | 1 -
java-client/dev-support/findbugs-exclude.xml | 2 +
java-client/pom.xml | 14 +-
.../org/apache/pegasus/client/ListAppInfoType.java | 21 +-
.../apache/pegasus/client/PegasusAdminClient.java | 31 +
.../client/PegasusAdminClientInterface.java | 12 +
.../org/apache/pegasus/client/PegasusTable.java | 2 +
...p_app_operator.java => list_apps_operator.java} | 32 +-
.../org/apache/pegasus/rpc/async/MetaSession.java | 3 +
.../apache/pegasus/security/KerberosProtocol.java | 40 +-
.../org/apache/pegasus/client/TestAdminClient.java | 31 +
nodejs-client/idl/base.thrift | 42 -
nodejs-client/idl/recompile_thrift.sh | 40 -
nodejs-client/idl/replication.thrift | 226 --
nodejs-client/idl/rrdb.thrift | 170 --
nodejs-client/recompile_thrift.sh | 61 +
nodejs-client/src/connection.js | 4 +-
.../src/dsn/{base_types.js => dsn_types.js} | 18 +-
nodejs-client/src/dsn/meta.js | 1956 --------------
nodejs-client/src/dsn/replication_types.js | 2767 --------------------
nodejs-client/src/dsn/rrdb.js | 2072 ---------------
nodejs-client/src/dsn/rrdb_types.js | 1564 -----------
nodejs-client/src/errors.js | 2 +-
nodejs-client/src/operator.js | 2 +-
nodejs-client/src/session.js | 4 +-
nodejs-client/src/table_handler.js | 8 +-
{python-client => nodejs-client}/test.sh | 15 +-
nodejs-client/test/client.test.js | 2 +-
run.sh | 144 +-
scripts/downgrade_node.sh | 50 +-
scripts/migrate_node.sh | 49 +-
scripts/pack_client.sh | 14 +-
scripts/pack_common.sh | 10 +-
scripts/pack_server.sh | 18 +-
scripts/pack_tools.sh | 24 +-
src/CMakeLists.txt | 2 +
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 | 34 +-
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 | 24 +-
src/aio/native_linux_aio_provider.h | 5 +
src/aio/test/aio.cpp | 32 +-
src/base/idl_utils.h | 9 +-
src/base/pegasus_utils.cpp | 9 +-
src/base/pegasus_utils.h | 16 +-
src/base/pegasus_value_schema.h | 21 +-
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 | 45 +-
src/block_service/block_service_manager.h | 10 +-
src/block_service/directio_writable_file.cpp | 44 +-
src/block_service/directio_writable_file.h | 2 +
src/block_service/fds/fds_service.cpp | 155 +-
src/block_service/fds/fds_service.h | 21 +-
src/block_service/hdfs/hdfs_service.cpp | 112 +-
src/block_service/hdfs/hdfs_service.h | 19 +-
src/block_service/local/local_service.cpp | 100 +-
src/block_service/local/local_service.h | 9 +-
.../test/block_service_manager_test.cpp | 22 +-
src/block_service/test/fds_service_test.cpp | 31 +-
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/CMakeLists.txt | 2 +
src/client/partition_resolver.cpp | 19 +-
src/client/partition_resolver.h | 16 +-
src/client/partition_resolver_manager.cpp | 8 +-
src/client/partition_resolver_manager.h | 9 +-
src/client/partition_resolver_simple.cpp | 47 +-
src/client/partition_resolver_simple.h | 20 +-
src/client/replication_ddl_client.cpp | 292 ++-
src/client/replication_ddl_client.h | 158 +-
src/{http => client}/test/CMakeLists.txt | 10 +-
src/{shell => client/test}/config.ini | 0
src/client/test/ddl_client_test.cpp | 154 ++
src/{aio => client}/test/main.cpp | 6 +-
.../proxy_ut => client/test}/run.sh | 8 +-
src/client_lib/mutation.cpp | 6 +
src/client_lib/pegasus_client_factory_impl.cpp | 17 +-
src/client_lib/pegasus_client_factory_impl.h | 12 +-
src/client_lib/pegasus_client_impl.cpp | 128 +-
src/client_lib/pegasus_client_impl.h | 22 +-
src/client_lib/pegasus_scanner_impl.cpp | 28 +-
src/common/CMakeLists.txt | 14 +-
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 | 80 +-
src/common/fs_manager.h | 31 +-
src/common/json_helper.h | 58 +-
src/common/replica_envs.h | 1 +
src/common/replication.codes.h | 1 +
src/common/replication_common.cpp | 393 +--
src/common/replication_common.h | 94 +-
src/common/replication_enums.h | 5 +
src/common/serialization_helper/thrift_helper.h | 2 +
src/common/storage_serverlet.h | 45 +-
src/common/test/common_test.cpp | 3 +
src/common/test/config-test.ini | 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 | 101 +-
src/failure_detector/failure_detector.h | 19 +
.../failure_detector_multimaster.cpp | 28 +-
.../failure_detector_multimaster.h | 7 +
src/failure_detector/test/config-test.ini | 3 -
.../test/config-whitelist-test-failed.ini | 3 -
.../test/config-whitelist-test.ini | 3 -
src/failure_detector/test/failure_detector.cpp | 83 +-
src/failure_detector/test/main.cpp | 25 +-
src/geo/bench/bench.cpp | 26 +-
src/geo/lib/geo_client.cpp | 241 +-
src/geo/lib/geo_client.h | 31 +-
src/geo/lib/latlng_codec.cpp | 21 +-
src/geo/lib/latlng_codec.h | 6 +-
src/geo/test/geo_test.cpp | 43 +-
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 | 18 +-
src/http/http_message_parser.h | 13 +-
src/http/http_server.cpp | 27 +-
src/http/http_server.h | 8 +
src/http/perf_counter_http_service.cpp | 11 +-
src/http/pprof_http_service.cpp | 47 +-
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 | 62 +-
src/meta/app_balance_policy.h | 12 +
src/meta/app_env_validator.cpp | 18 +-
src/meta/backup_engine.cpp | 113 +-
src/meta/backup_engine.h | 19 +-
src/meta/cluster_balance_policy.cpp | 62 +-
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/dump_file.h | 12 +-
src/meta/duplication/duplication_info.cpp | 11 +-
src/meta/duplication/duplication_info.h | 39 +-
src/meta/duplication/meta_duplication_service.cpp | 102 +-
src/meta/duplication/meta_duplication_service.h | 19 +-
src/meta/greedy_load_balancer.cpp | 43 +-
src/meta/greedy_load_balancer.h | 11 +
src/meta/load_balance_policy.cpp | 71 +-
src/meta/load_balance_policy.h | 28 +-
src/meta/meta_backup_service.cpp | 456 ++--
src/meta/meta_backup_service.h | 41 +-
src/meta/meta_bulk_load_ingestion_context.cpp | 25 +-
src/meta/meta_bulk_load_ingestion_context.h | 12 +-
src/meta/meta_bulk_load_service.cpp | 659 ++---
src/meta/meta_bulk_load_service.h | 28 +-
src/meta/meta_data.cpp | 129 +-
src/meta/meta_data.h | 43 +-
src/meta/meta_http_service.cpp | 70 +-
src/meta/meta_http_service.h | 7 +-
src/meta/meta_options.cpp | 139 +-
src/meta/meta_options.h | 49 +-
src/meta/meta_server_failure_detector.cpp | 118 +-
src/meta/meta_server_failure_detector.h | 25 +-
src/meta/meta_service.cpp | 424 +--
src/meta/meta_service.h | 211 +-
src/meta/meta_service_app.cpp | 40 +-
src/meta/meta_service_app.h | 6 +-
src/meta/meta_split_service.cpp | 191 +-
src/meta/meta_split_service.h | 12 +-
src/meta/meta_state_service.h | 26 +-
src/meta/meta_state_service_simple.cpp | 14 +-
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 | 8 +-
src/meta/meta_state_service_zookeeper.cpp | 52 +-
src/meta/meta_state_service_zookeeper.h | 18 +-
src/meta/partition_guardian.cpp | 232 +-
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 | 986 +++----
src/meta/server_state.h | 46 +-
src/meta/server_state_restore.cpp | 96 +-
src/meta/test/backup_test.cpp | 80 +-
.../test/balancer_simulator/balancer_simulator.cpp | 21 +-
src/meta/test/balancer_validator.cpp | 66 +-
src/meta/test/cluster_balance_policy_test.cpp | 24 +-
src/meta/test/config-test.ini | 3 -
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 | 45 +-
src/meta/test/meta_app_envs_test.cpp | 16 +-
src/meta/test/meta_app_operation_test.cpp | 58 +-
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 | 84 +-
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 | 32 +-
src/meta/test/meta_service_test_app.h | 11 +-
src/meta/test/meta_split_service_test.cpp | 66 +-
src/meta/test/meta_state/config-test.ini | 3 -
src/meta/test/meta_state/main.cpp | 25 +-
src/meta/test/meta_state/meta_state_service.cpp | 10 +-
src/meta/test/meta_state_service_utils_test.cpp | 40 +-
src/meta/test/meta_test_base.cpp | 56 +-
src/meta/test/meta_test_base.h | 22 +-
src/meta/test/misc/misc.cpp | 39 +-
src/meta/test/misc/misc.h | 31 +-
src/meta/test/server_state_restore_test.cpp | 25 +-
src/meta/test/server_state_test.cpp | 31 +-
src/meta/test/state_sync_test.cpp | 44 +-
src/meta/test/update_configuration_test.cpp | 62 +-
src/nfs/nfs.thrift | 2 +
src/nfs/nfs_client_impl.cpp | 67 +-
src/nfs/nfs_client_impl.h | 45 +-
src/nfs/nfs_node.cpp | 15 +-
src/nfs/nfs_node.h | 30 +-
src/nfs/nfs_node_impl.cpp | 33 +-
src/nfs/nfs_node_simple.h | 15 +-
src/nfs/nfs_server_impl.cpp | 39 +-
src/nfs/nfs_server_impl.h | 29 +-
src/nfs/test/main.cpp | 29 +-
src/perf_counter/builtin_counters.cpp | 9 +-
src/perf_counter/builtin_counters.h | 1 +
src/perf_counter/perf_counter.h | 5 +-
src/perf_counter/perf_counter_atomic.cpp | 83 +
src/perf_counter/perf_counter_atomic.h | 73 +-
src/perf_counter/perf_counters.cpp | 13 +-
src/perf_counter/perf_counters.h | 7 +-
src/perf_counter/test/main.cpp | 13 -
src/perf_counter/test/perf_counter_test.cpp | 34 +-
src/perf_counter/test/perf_counters_test.cpp | 16 +-
src/redis_protocol/proxy/main.cpp | 20 +-
src/redis_protocol/proxy_lib/proxy_layer.cpp | 20 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 28 +-
src/redis_protocol/proxy_lib/redis_parser.cpp | 114 +-
src/redis_protocol/proxy_lib/redis_parser.h | 20 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 48 +-
src/remote_cmd/CMakeLists.txt | 2 +-
src/remote_cmd/remote_command.cpp | 21 +-
src/remote_cmd/remote_command.h | 9 +-
src/replica/CMakeLists.txt | 1 +
src/replica/backup/cold_backup_context.cpp | 411 +--
src/replica/backup/cold_backup_context.h | 17 +
src/replica/backup/replica_backup_manager.cpp | 47 +-
src/replica/backup/replica_backup_manager.h | 14 +-
src/replica/backup/replica_backup_server.cpp | 51 +-
src/replica/backup/replica_backup_server.h | 10 +-
src/replica/backup/test/CMakeLists.txt | 2 +-
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/config-test.ini | 3 -
src/replica/bulk_load/test/main.cpp | 16 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 30 +-
src/replica/disk_cleaner.cpp | 49 +-
src/replica/disk_cleaner.h | 6 +-
src/replica/duplication/duplication_pipeline.cpp | 17 +-
src/replica/duplication/duplication_pipeline.h | 13 +-
src/replica/duplication/duplication_sync_timer.cpp | 44 +-
src/replica/duplication/duplication_sync_timer.h | 14 +-
src/replica/duplication/load_from_private_log.cpp | 21 +-
src/replica/duplication/load_from_private_log.h | 13 +-
src/replica/duplication/mutation_batch.cpp | 27 +-
src/replica/duplication/mutation_batch.h | 10 +-
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 | 28 +-
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 | 54 +-
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 | 65 +-
src/replica/log_file.h | 26 +-
src/replica/log_file_stream.h | 5 +-
src/replica/mutation.cpp | 25 +-
src/replica/mutation.h | 27 +-
src/replica/mutation_cache.cpp | 10 +
src/replica/mutation_cache.h | 10 +-
src/replica/mutation_log.cpp | 392 +--
src/replica/mutation_log.h | 37 +-
src/replica/mutation_log_replay.cpp | 49 +-
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 | 10 +-
src/replica/replica.cpp | 116 +-
src/replica/replica.h | 97 +-
src/replica/replica_2pc.cpp | 137 +-
src/replica/replica_backup.cpp | 259 +-
src/replica/replica_check.cpp | 49 +-
src/replica/replica_chkpt.cpp | 68 +-
src/replica/replica_config.cpp | 91 +-
src/replica/replica_context.cpp | 20 +-
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 | 17 +-
src/replica/replica_http_service.cpp | 16 +-
src/replica/replica_http_service.h | 8 +-
src/replica/replica_init.cpp | 198 +-
src/replica/replica_learn.cpp | 102 +-
src/replica/replica_restore.cpp | 90 +-
src/replica/replica_stub.cpp | 877 ++++---
src/replica/replica_stub.h | 116 +-
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 | 225 +-
src/replica/replication_app_base.h | 44 +-
src/replica/replication_service_app.cpp | 9 +-
src/replica/replication_service_app.h | 12 +-
src/replica/split/replica_split_manager.cpp | 69 +-
src/replica/split/replica_split_manager.h | 34 +-
src/replica/split/test/config-test.ini | 3 -
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 +-
src/replica/storage/simple_kv/simple_kv.server.h | 6 +-
.../storage/simple_kv/simple_kv.server.impl.cpp | 34 +-
.../storage/simple_kv/simple_kv.server.impl.h | 19 +-
src/replica/storage/simple_kv/test/case.cpp | 58 +-
src/replica/storage/simple_kv/test/case.h | 19 +-
src/replica/storage/simple_kv/test/checker.cpp | 59 +-
src/replica/storage/simple_kv/test/checker.h | 22 +-
src/replica/storage/simple_kv/test/client.cpp | 27 +-
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 | 19 +-
.../simple_kv/test/simple_kv.server.impl.cpp | 60 +-
.../storage/simple_kv/test/simple_kv.server.impl.h | 21 +-
src/replica/test/clear.sh | 2 +-
src/replica/test/cold_backup_context_test.cpp | 25 +
src/replica/test/config-test.ini | 3 -
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 | 25 +-
src/replica/test/mutation_log_learn_test.cpp | 27 +-
src/replica/test/mutation_log_test.cpp | 29 +-
src/replica/test/open_replica_test.cpp | 21 +-
src/replica/test/replica_disk_migrate_test.cpp | 34 +-
src/replica/test/replica_disk_test.cpp | 31 +-
src/replica/test/replica_disk_test_base.h | 2 +-
src/replica/test/replica_http_service_test.cpp | 20 +-
src/replica/test/replica_learn_test.cpp | 17 +-
src/replica/test/replica_test.cpp | 117 +-
src/replica/test/replica_test_base.h | 2 +-
src/replica/test/throttling_controller_test.cpp | 2 +
src/reporter/pegasus_counter_reporter.cpp | 77 +-
src/reporter/pegasus_counter_reporter.h | 28 +-
src/runtime/CMakeLists.txt | 2 +
src/runtime/api_task.h | 2 +
src/runtime/core_main.cpp | 8 +-
src/runtime/env.sim.cpp | 27 +-
src/runtime/env.sim.h | 6 +-
src/runtime/fault_injector.cpp | 90 +-
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 | 52 +-
src/runtime/profiler.h | 2 +
src/runtime/providers.common.cpp | 23 +-
src/runtime/providers.common.h | 2 -
src/runtime/{security => ranger}/CMakeLists.txt | 14 +-
.../rand.cpp => runtime/ranger/access_type.cpp} | 18 +-
src/runtime/ranger/access_type.h | 53 +
src/runtime/ranger/ranger_resource_policy.cpp | 72 +
src/runtime/ranger/ranger_resource_policy.h | 75 +
.../ranger/ranger_resource_policy_manager.cpp | 648 +++++
.../ranger/ranger_resource_policy_manager.h | 150 ++
src/runtime/rpc/asio_net_provider.cpp | 107 +-
src/runtime/rpc/asio_net_provider.h | 21 +-
src/runtime/rpc/asio_rpc_session.cpp | 65 +-
src/runtime/rpc/asio_rpc_session.h | 13 +-
src/runtime/rpc/dns_resolver.cpp | 110 +
.../kill_test/job.h => runtime/rpc/dns_resolver.h} | 63 +-
src/runtime/rpc/dsn_message_parser.cpp | 34 +-
src/runtime/rpc/dsn_message_parser.h | 4 +-
src/runtime/rpc/group_address.h | 2 +-
src/runtime/rpc/group_host_port.h | 257 ++
src/runtime/rpc/message_parser.cpp | 19 +-
src/runtime/rpc/message_parser.h | 13 +-
src/runtime/rpc/network.cpp | 151 +-
src/runtime/rpc/network.h | 30 +-
src/runtime/rpc/network.sim.cpp | 52 +-
src/runtime/rpc/network.sim.h | 14 +-
src/runtime/rpc/raw_message_parser.cpp | 23 +-
src/runtime/rpc/raw_message_parser.h | 6 +-
src/runtime/rpc/rpc_address.cpp | 35 +-
src/runtime/rpc/rpc_address.h | 7 +
src/runtime/rpc/rpc_engine.cpp | 129 +-
src/runtime/rpc/rpc_engine.h | 24 +-
src/runtime/rpc/rpc_holder.h | 43 +-
src/runtime/rpc/rpc_host_port.cpp | 201 ++
src/runtime/rpc/rpc_host_port.h | 124 +
src/runtime/rpc/rpc_message.cpp | 46 +-
src/runtime/rpc/rpc_message.h | 23 +-
src/runtime/rpc/rpc_task.cpp | 17 +-
src/runtime/rpc/thrift_message_parser.cpp | 31 +-
src/runtime/rpc/thrift_message_parser.h | 11 +-
src/runtime/scheduler.cpp | 23 +-
src/runtime/scheduler.h | 16 +-
src/runtime/security/CMakeLists.txt | 2 +-
src/runtime/security/access_controller.cpp | 44 +-
src/runtime/security/access_controller.h | 49 +-
src/runtime/security/client_negotiation.cpp | 62 +-
src/runtime/security/client_negotiation.h | 7 +
src/runtime/security/init.cpp | 24 +-
src/runtime/security/kinit_context.cpp | 48 +-
src/runtime/security/kinit_context.h | 2 +
src/runtime/security/meta_access_controller.cpp | 100 +-
src/runtime/security/meta_access_controller.h | 22 +-
src/runtime/security/negotiation.cpp | 20 +-
src/runtime/security/negotiation.h | 12 +-
src/runtime/security/negotiation_manager.cpp | 28 +-
src/runtime/security/negotiation_manager.h | 12 +-
src/runtime/security/replica_access_controller.cpp | 91 +-
src/runtime/security/replica_access_controller.h | 46 +-
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 | 47 +-
src/runtime/security/server_negotiation.h | 9 +-
src/runtime/service_api_c.cpp | 75 +-
src/runtime/service_engine.cpp | 47 +-
src/runtime/service_engine.h | 27 +-
src/runtime/simulator.cpp | 19 +-
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 | 25 +-
src/runtime/task/simple_task_queue.h | 13 +-
src/runtime/task/task.cpp | 35 +-
src/runtime/task/task.h | 53 +-
src/runtime/task/task_code.cpp | 7 +-
src/runtime/task/task_code.h | 16 +-
src/runtime/task/task_engine.cpp | 29 +-
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 | 32 +-
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 | 38 +-
src/runtime/task/task_worker.h | 12 +-
src/runtime/test/CMakeLists.txt | 1 +
src/runtime/test/address_test.cpp | 6 +
src/runtime/test/async_call.cpp | 51 +-
src/runtime/test/client_negotiation_test.cpp | 23 +-
src/runtime/test/corrupt_message.cpp | 24 +-
src/runtime/test/host_port_test.cpp | 205 ++
src/runtime/test/lpc.cpp | 19 +-
src/runtime/test/main.cpp | 12 +-
src/runtime/test/message_reader_test.cpp | 5 +
src/runtime/test/message_utils_test.cpp | 12 +-
src/runtime/test/meta_access_controller_test.cpp | 42 +-
src/runtime/test/negotiation_manager_test.cpp | 20 +-
src/runtime/test/netprovider.cpp | 86 +-
src/runtime/test/pipeline_test.cpp | 22 +-
.../test/ranger_resource_policy_manager_test.cpp | 362 +++
src/runtime/test/ranger_resource_policy_test.cpp | 86 +
.../test/replica_access_controller_test.cpp | 39 +-
src/runtime/test/rpc.cpp | 44 +-
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 | 35 +-
src/runtime/test/sim_lock.cpp | 24 +-
src/runtime/test/task_engine.cpp | 18 +-
src/runtime/test/task_test.cpp | 10 +-
src/runtime/test/test_utils.h | 10 +-
src/runtime/test/thrift_message_parser_test.cpp | 28 +-
src/runtime/tool_api.cpp | 21 +-
src/runtime/tool_api.h | 22 +-
src/runtime/tracer.cpp | 179 +-
src/runtime/tracer.h | 6 +-
src/runtime/zlocks.cpp | 27 +-
src/sample/main.cpp | 2 +
src/server/CMakeLists.txt | 3 +
src/server/available_detector.cpp | 253 +-
src/server/available_detector.h | 27 +-
src/server/capacity_unit_calculator.cpp | 56 +-
src/server/capacity_unit_calculator.h | 18 +-
src/server/compaction_filter_rule.cpp | 3 +-
src/server/compaction_filter_rule.h | 12 +-
src/server/compaction_operation.cpp | 8 +-
src/server/compaction_operation.h | 10 +
src/server/config.ini | 1 -
src/server/hashkey_transform.h | 6 +-
src/server/hotkey_collector.cpp | 19 +-
src/server/hotkey_collector.h | 23 +-
src/server/hotspot_partition_calculator.cpp | 60 +-
src/server/hotspot_partition_calculator.h | 16 +-
src/server/info_collector.cpp | 127 +-
src/server/info_collector.h | 50 +-
src/server/info_collector_app.cpp | 25 +-
src/server/info_collector_app.h | 10 +-
src/server/main.cpp | 28 +-
src/server/meta_store.cpp | 37 +-
src/server/meta_store.h | 19 +-
src/server/pegasus_event_listener.cpp | 16 +-
src/server/pegasus_event_listener.h | 6 +-
src/server/pegasus_manual_compact_service.cpp | 42 +-
src/server/pegasus_manual_compact_service.h | 20 +-
src/server/pegasus_mutation_duplicator.cpp | 43 +-
src/server/pegasus_mutation_duplicator.h | 32 +-
src/server/pegasus_read_service.h | 7 +-
src/server/pegasus_server_impl.cpp | 206 +-
src/server/pegasus_server_impl.h | 90 +-
src/server/pegasus_server_impl_init.cpp | 675 +++--
src/server/pegasus_server_write.cpp | 51 +-
src/server/pegasus_server_write.h | 22 +-
src/server/pegasus_write_service.cpp | 50 +-
src/server/pegasus_write_service.h | 57 +-
src/server/pegasus_write_service_impl.h | 24 +-
src/server/range_read_limiter.h | 1 -
src/server/result_writer.cpp | 46 +-
src/server/result_writer.h | 8 +-
src/server/rocksdb_wrapper.cpp | 37 +-
src/server/rocksdb_wrapper.h | 26 +-
src/server/test/capacity_unit_calculator_test.cpp | 39 +-
src/server/test/compaction_filter_rule_test.cpp | 8 +-
src/server/test/compaction_operation_test.cpp | 26 +-
src/server/test/config.ini | 1 -
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 | 30 +-
.../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 | 4 +
src/shell/command_helper.h | 34 +-
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 | 62 +-
src/shell/commands/debugger.cpp | 47 +-
src/shell/commands/detect_hotkey.cpp | 22 +-
src/shell/commands/duplication.cpp | 27 +-
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 | 25 +-
src/shell/commands/table_management.cpp | 39 +-
src/shell/main.cpp | 28 +-
src/test/bench_test/benchmark.cpp | 229 +-
src/test/bench_test/benchmark.h | 15 +-
src/test/bench_test/config.cpp | 41 +-
src/test/bench_test/config.h | 22 +-
src/test/bench_test/config.ini | 5 +-
src/test/bench_test/main.cpp | 7 +-
src/test/bench_test/rand.cpp | 3 +
src/test/bench_test/statistics.cpp | 16 +-
src/test/bench_test/statistics.h | 8 +-
src/test/bench_test/utils.h | 4 +-
.../test_backup_and_restore.cpp | 28 +-
.../function_test/base_api_test/CMakeLists.txt | 1 +
.../base_api_test/integration_test.cpp | 203 ++
.../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 | 63 +-
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 | 39 +-
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/CMakeLists.txt | 1 +
.../partition_split_test/test_split.cpp | 152 +-
.../function_test/recovery_test/test_recovery.cpp | 31 +-
src/test/function_test/restore_test/CMakeLists.txt | 1 +
.../function_test/restore_test/test_restore.cpp | 150 +-
src/test/function_test/run.sh | 16 +-
.../function_test/throttle_test/CMakeLists.txt | 1 +
.../function_test/throttle_test/test_throttle.cpp | 109 +-
src/test/function_test/utils/global_env.cpp | 22 +-
src/test/function_test/utils/global_env.h | 1 -
src/test/function_test/utils/test_util.cpp | 73 +-
src/test/function_test/utils/test_util.h | 17 +-
src/test/function_test/utils/utils.h | 19 +-
src/test/kill_test/data_verifier.cpp | 340 ++-
src/test/kill_test/data_verifier.h | 4 +
src/test/kill_test/job.cpp | 2 +
src/test/kill_test/kill_testor.cpp | 92 +-
src/test/kill_test/kill_testor.h | 20 +-
src/test/kill_test/killer_handler_shell.cpp | 49 +-
src/test/kill_test/killer_handler_shell.h | 9 +-
src/test/kill_test/main.cpp | 8 +-
src/test/kill_test/partition_kill_testor.cpp | 37 +-
src/test/kill_test/partition_kill_testor.h | 4 -
src/test/kill_test/process_kill_testor.cpp | 162 +-
src/test/kill_test/process_kill_testor.h | 17 +-
src/test/pressure_test/main.cpp | 126 +-
src/{http => test_util}/CMakeLists.txt | 11 +-
src/test_util/test_util.cpp | 118 +
src/test_util/test_util.h | 81 +
src/tools/mutation_log_tool.cpp | 16 +-
src/tools/mutation_log_tool.h | 8 +-
src/utils/alloc.cpp | 11 +-
src/utils/alloc.h | 17 +-
src/utils/api_utilities.h | 2 +-
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 | 11 +-
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/defer.h | 10 +-
src/utils/error_code.cpp | 2 +
src/utils/error_code.h | 19 +-
src/utils/errors.h | 14 +-
src/utils/fail_point.cpp | 44 +-
src/utils/fail_point.h | 27 +-
src/utils/filesystem.cpp | 109 +-
src/utils/filesystem.h | 8 +
src/utils/flags.cpp | 23 +-
src/utils/flags.h | 7 +-
src/utils/fmt_logging.h | 47 +-
src/utils/gpid.cpp | 5 +-
src/utils/hpc_locks/sema.h | 1 +
src/utils/join_point.h | 13 +-
src/utils/latency_tracer.cpp | 21 +-
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 | 198 +-
src/utils/metrics.h | 222 +-
src/utils/nth_element.h | 6 +-
src/utils/output_utils.cpp | 6 +-
src/utils/output_utils.h | 13 +-
src/utils/priority_queue.h | 5 +-
src/utils/process_utils.cpp | 27 +-
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 | 7 +-
src/utils/shared_io_service.h | 3 +-
src/utils/simple_logger.cpp | 23 +-
src/utils/simple_logger.h | 10 +-
src/utils/smart_pointers.h | 14 +-
src/utils/string_conv.h | 9 +-
src/utils/string_view.h | 2 +
src/utils/strings.cpp | 19 +-
src/utils/strings.h | 5 +
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 | 234 +-
.../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 | 6 +-
.../token_bucket_throttling_controller_test.cpp | 4 +
src/utils/test/token_buckets_test.cpp | 7 +
src/utils/test/utils.cpp | 37 +-
.../test_macros.h} | 48 +-
src/utils/thread_access_checker.cpp | 1 -
src/utils/throttling_controller.cpp | 4 +
src/utils/time_utils.cpp | 14 +-
src/utils/time_utils.h | 9 +-
src/utils/token_bucket_throttling_controller.cpp | 10 +-
src/utils/token_bucket_throttling_controller.h | 3 +
src/utils/token_buckets.cpp | 2 +
src/utils/token_buckets.h | 4 +-
src/utils/utils.cpp | 39 +-
src/utils/utils.h | 12 +-
src/utils/zlocks.h | 1 +
.../distributed_lock_service_zookeeper.cpp | 47 +-
src/zookeeper/distributed_lock_service_zookeeper.h | 17 +-
src/zookeeper/lock_struct.cpp | 180 +-
src/zookeeper/lock_struct.h | 9 +-
src/zookeeper/test/config-test.ini | 3 -
src/zookeeper/test/distributed_lock_zookeeper.cpp | 45 +-
src/zookeeper/test/main.cpp | 25 +-
src/zookeeper/zookeeper_error.cpp | 7 +-
src/zookeeper/zookeeper_error.h | 3 -
src/zookeeper/zookeeper_session.cpp | 51 +-
src/zookeeper/zookeeper_session.h | 18 +-
src/zookeeper/zookeeper_session_mgr.cpp | 18 +-
src/zookeeper/zookeeper_session_mgr.h | 27 +-
thirdparty/CMakeLists.txt | 7 +-
thirdparty/fix_prometheus-cpp_limits.patch | 10 +
819 files changed, 20507 insertions(+), 19291 deletions(-)
copy .github/workflows/{test_python-client.yml => test_nodejs-client.yml} (87%)
copy docker/pegasus-build-env/{ubuntu1804 => ubuntu2204}/Dockerfile (89%)
copy go-client/rpc/main_test.go => java-client/src/main/java/org/apache/pegasus/client/ListAppInfoType.java (76%)
copy java-client/src/main/java/org/apache/pegasus/operator/{drop_app_operator.java => list_apps_operator.java} (62%)
delete mode 100644 nodejs-client/idl/base.thrift
delete mode 100755 nodejs-client/idl/recompile_thrift.sh
delete mode 100644 nodejs-client/idl/replication.thrift
delete mode 100644 nodejs-client/idl/rrdb.thrift
create mode 100755 nodejs-client/recompile_thrift.sh
rename nodejs-client/src/dsn/{base_types.js => dsn_types.js} (89%)
delete mode 100644 nodejs-client/src/dsn/meta.js
delete mode 100644 nodejs-client/src/dsn/replication_types.js
delete mode 100644 nodejs-client/src/dsn/rrdb.js
delete mode 100644 nodejs-client/src/dsn/rrdb_types.js
copy {python-client => nodejs-client}/test.sh (78%)
copy src/{http => client}/test/CMakeLists.txt (88%)
copy src/{shell => client/test}/config.ini (100%)
create mode 100644 src/client/test/ddl_client_test.cpp
copy src/{aio => client}/test/main.cpp (89%)
copy src/{redis_protocol/proxy_ut => client/test}/run.sh (84%)
create mode 100644 src/perf_counter/perf_counter_atomic.cpp
copy src/runtime/{security => ranger}/CMakeLists.txt (81%)
copy src/{utils/rand.cpp => runtime/ranger/access_type.cpp} (67%)
create mode 100644 src/runtime/ranger/access_type.h
create mode 100644 src/runtime/ranger/ranger_resource_policy.cpp
create mode 100644 src/runtime/ranger/ranger_resource_policy.h
create mode 100644 src/runtime/ranger/ranger_resource_policy_manager.cpp
create mode 100644 src/runtime/ranger/ranger_resource_policy_manager.h
create mode 100644 src/runtime/rpc/dns_resolver.cpp
copy src/{test/kill_test/job.h => runtime/rpc/dns_resolver.h} (50%)
create mode 100644 src/runtime/rpc/group_host_port.h
create mode 100644 src/runtime/rpc/rpc_host_port.cpp
create mode 100644 src/runtime/rpc/rpc_host_port.h
create mode 100644 src/runtime/test/host_port_test.cpp
create mode 100644 src/runtime/test/ranger_resource_policy_manager_test.cpp
create mode 100644 src/runtime/test/ranger_resource_policy_test.cpp
create mode 100644 src/test/function_test/base_api_test/integration_test.cpp
copy src/{http => test_util}/CMakeLists.txt (81%)
create mode 100644 src/test_util/test_util.cpp
create mode 100644 src/test_util/test_util.h
delete mode 100644 src/utils/apply.h
copy src/{block_service/directio_writable_file.h => utils/test_macros.h} (50%)
create mode 100644 thirdparty/fix_prometheus-cpp_limits.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org