This is an automated email from the ASF dual-hosted git repository.
wangdan pushed a change to branch migrate-metrics-dev
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard 648abd505 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 2) (#1386)
omit 16c9766da feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 1) (#1374)
omit df20ea5cd feat(new_metrics): migrate replica-level metrics for write
service (#1351)
omit c623f9956 feat(new_metrics): add replica-level metric entity (#1345)
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)
new 18b06cf0e feat(new_metrics): add replica-level metric entity (#1345)
new 09931e8e1 feat(new_metrics): migrate replica-level metrics for write
service (#1351)
new 3210f71ae feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 1) (#1374)
new a94256684 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 2) (#1386)
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 (648abd505)
\
N -- N -- N refs/heads/migrate-metrics-dev (a94256684)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/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 | 79 ++--
.github/workflows/lint_and_test_go-client.yml | 4 +-
.github/workflows/lint_and_test_pegic.yml | 8 +-
.github/workflows/regular-build.yml | 19 +-
.github/workflows/standardization_lint.yaml | 8 +-
.github/workflows/test_java-client.yml | 2 +-
.github/workflows/test_scala-client.yml | 2 +-
.github/workflows/thirdparty-regular-push.yml | 16 +-
.licenserc.yaml | 1 +
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 +-
run.sh | 9 +
src/block_service/test/fds_service_test.cpp | 7 +-
src/client/replication_ddl_client.h | 3 +-
src/common/CMakeLists.txt | 14 +-
src/common/json_helper.h | 58 ++-
src/common/replication_common.cpp | 133 +-----
src/common/replication_common.h | 29 +-
src/common/test/config-test.ini | 3 -
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 | 13 +-
src/geo/lib/geo_client.cpp | 89 ++--
src/geo/lib/geo_client.h | 11 -
src/geo/test/geo_test.cpp | 7 +-
src/http/http_server.cpp | 5 +-
src/meta/app_balance_policy.cpp | 14 +-
src/meta/meta_data.cpp | 35 +-
src/meta/meta_http_service.cpp | 10 +-
src/meta/meta_options.cpp | 133 +-----
src/meta/meta_options.h | 31 +-
src/meta/meta_server_failure_detector.cpp | 23 +-
src/meta/meta_service.cpp | 75 +++-
src/meta/meta_service.h | 2 +
src/meta/meta_state_service_zookeeper.cpp | 5 +-
src/meta/partition_guardian.cpp | 19 +-
src/meta/server_state.cpp | 35 +-
src/meta/test/backup_test.cpp | 8 +-
src/meta/test/config-test.ini | 3 -
src/meta/test/main.cpp | 12 +-
src/meta/test/meta_app_operation_test.cpp | 12 +-
src/meta/test/meta_state/config-test.ini | 3 -
src/meta/test/meta_test_base.cpp | 6 +-
src/meta/test/server_state_test.cpp | 6 +-
src/meta/test/state_sync_test.cpp | 8 +-
src/meta/test/update_configuration_test.cpp | 6 +-
src/perf_counter/perf_counter_atomic.cpp | 73 +++
src/perf_counter/perf_counter_atomic.h | 48 +-
src/perf_counter/test/perf_counter_test.cpp | 13 +-
src/remote_cmd/CMakeLists.txt | 2 +-
src/replica/backup/replica_backup_server.cpp | 12 +-
src/replica/bulk_load/test/config-test.ini | 3 -
src/replica/disk_cleaner.cpp | 13 +-
src/replica/disk_cleaner.h | 2 +
src/replica/duplication/replica_follower.cpp | 3 +-
src/replica/replica.cpp | 6 +-
src/replica/replica.h | 16 -
src/replica/replica_2pc.cpp | 13 +-
src/replica/replica_backup.cpp | 6 +-
src/replica/replica_check.cpp | 3 +-
src/replica/replica_config.cpp | 25 +-
src/replica/replica_http_service.cpp | 2 +-
src/replica/replica_init.cpp | 136 +-----
src/replica/replica_stub.cpp | 257 ++++++++---
src/replica/replica_stub.h | 15 +-
src/replica/replication_app_base.cpp | 18 +-
src/replica/split/test/config-test.ini | 3 -
.../storage/simple_kv/simple_kv.server.impl.cpp | 6 +-
.../storage/simple_kv/simple_kv.server.impl.h | 1 -
src/replica/storage/simple_kv/test/checker.cpp | 4 +-
.../simple_kv/test/simple_kv.server.impl.cpp | 6 +-
.../storage/simple_kv/test/simple_kv.server.impl.h | 1 -
src/replica/test/config-test.ini | 3 -
src/replica/test/replica_http_service_test.cpp | 7 +-
src/replica/test/replica_test.cpp | 23 +-
src/runtime/CMakeLists.txt | 2 +
src/runtime/env.sim.cpp | 19 +-
src/runtime/env.sim.h | 2 -
src/runtime/profiler.cpp | 25 +-
src/runtime/{security => ranger}/CMakeLists.txt | 14 +-
.../ranger/access_type.cpp} | 29 +-
src/{utils/math.h => runtime/ranger/access_type.h} | 31 +-
src/runtime/ranger/ranger_resource_policy.cpp | 70 +++
src/runtime/ranger/ranger_resource_policy.h | 79 ++++
.../ranger/ranger_resource_policy_manager.cpp | 167 +++++++
.../ranger/ranger_resource_policy_manager.h | 95 ++++
src/runtime/rpc/asio_net_provider.cpp | 12 +-
src/runtime/rpc/network.cpp | 59 +--
src/runtime/rpc/network.h | 2 -
src/runtime/rpc/network.sim.cpp | 25 +-
src/runtime/rpc/network.sim.h | 2 -
src/runtime/rpc/rpc_engine.cpp | 4 +-
src/runtime/rpc/rpc_message.cpp | 23 +-
src/runtime/rpc/rpc_message.h | 3 -
src/runtime/security/CMakeLists.txt | 2 +-
src/runtime/security/access_controller.cpp | 27 +-
src/runtime/security/access_controller.h | 36 +-
src/runtime/security/replica_access_controller.cpp | 2 +-
src/runtime/security/replica_access_controller.h | 2 +-
src/runtime/service_api_c.cpp | 27 +-
src/runtime/service_engine.cpp | 16 +-
src/runtime/simulator.cpp | 6 +-
src/runtime/test/CMakeLists.txt | 1 +
src/runtime/test/main.cpp | 6 +-
src/runtime/test/netprovider.cpp | 39 +-
.../test/ranger_resource_policy_manager_test.cpp | 206 +++++++++
src/runtime/test/ranger_resource_policy_test.cpp | 80 ++++
src/runtime/test/service_api_c.cpp | 5 +-
src/runtime/tracer.cpp | 12 +-
src/server/available_detector.cpp | 106 ++---
src/server/available_detector.h | 6 -
src/server/capacity_unit_calculator.cpp | 43 +-
src/server/capacity_unit_calculator.h | 2 -
src/server/config.ini | 1 -
src/server/info_collector.cpp | 54 ++-
src/server/info_collector.h | 5 -
src/server/pegasus_manual_compact_service.cpp | 17 +-
src/server/pegasus_manual_compact_service.h | 1 -
src/server/pegasus_server_impl.cpp | 64 +--
src/server/pegasus_server_impl.h | 21 +-
src/server/pegasus_server_impl_init.cpp | 490 ++++++++++-----------
src/server/pegasus_server_write.cpp | 6 +-
src/server/pegasus_server_write.h | 4 +-
src/server/pegasus_write_service.cpp | 6 +
src/server/pegasus_write_service.h | 1 -
src/server/range_read_limiter.h | 1 -
src/server/test/capacity_unit_calculator_test.cpp | 8 +-
src/server/test/config.ini | 1 -
src/server/test/manual_compact_service_test.cpp | 11 +-
src/server/test/pegasus_server_write_test.cpp | 2 +-
.../test/pegasus_write_service_impl_test.cpp | 2 +-
src/server/test/pegasus_write_service_test.cpp | 2 +-
src/server/test/rocksdb_wrapper_test.cpp | 2 +-
src/test/bench_test/benchmark.cpp | 193 +++++++-
src/test/bench_test/benchmark.h | 2 +
src/test/bench_test/config.cpp | 34 +-
src/test/bench_test/config.h | 6 -
src/test/bench_test/config.ini | 5 +-
src/test/bench_test/statistics.cpp | 7 +-
src/test/bench_test/utils.h | 4 +-
.../function_test/recovery_test/test_recovery.cpp | 2 +-
src/test/kill_test/data_verifier.cpp | 70 +--
src/test/kill_test/data_verifier.h | 4 +
src/test/kill_test/kill_testor.cpp | 37 +-
src/test/kill_test/kill_testor.h | 6 -
src/test/kill_test/killer_handler_shell.cpp | 23 +-
src/test/kill_test/killer_handler_shell.h | 6 +-
src/test/kill_test/main.cpp | 4 +-
src/test/kill_test/partition_kill_testor.cpp | 8 +-
src/test/kill_test/process_kill_testor.cpp | 99 +++--
src/test/kill_test/process_kill_testor.h | 8 -
src/test/pressure_test/main.cpp | 93 ++--
src/utils/simple_logger.cpp | 10 -
src/utils/simple_logger.h | 3 +-
src/utils/string_conv.h | 2 +-
src/utils/test/logger.cpp | 2 +-
.../distributed_lock_service_zookeeper.cpp | 5 +-
src/zookeeper/test/config-test.ini | 3 -
src/zookeeper/zookeeper_session.cpp | 19 +-
src/zookeeper/zookeeper_session_mgr.cpp | 11 +-
src/zookeeper/zookeeper_session_mgr.h | 8 -
thirdparty/CMakeLists.txt | 3 +-
thirdparty/fix_prometheus-cpp_limits.patch | 10 +
170 files changed, 2572 insertions(+), 1836 deletions(-)
copy docker/pegasus-build-env/{ubuntu1804 => ubuntu2204}/Dockerfile (89%)
create mode 100644 src/perf_counter/perf_counter_atomic.cpp
copy src/runtime/{security => ranger}/CMakeLists.txt (81%)
copy src/{utils/sys_exit_hook.h => runtime/ranger/access_type.cpp} (66%)
copy src/{utils/math.h => runtime/ranger/access_type.h} (50%)
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/test/ranger_resource_policy_manager_test.cpp
create mode 100644 src/runtime/test/ranger_resource_policy_test.cpp
create mode 100644 thirdparty/fix_prometheus-cpp_limits.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
