This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/pip/python-client/cryptography-41.0.3
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard 0eee08874 build(deps): bump cryptography from 3.2 to 41.0.3 in
/python-client
add 8cad63e1d chore(github): free disk space for github workflows (#1577)
add 10a54350d fix: support core dump for fatal logging in
simple_logger::dsn_logv and call fatal logging exactly once for the assertion
(#1580)
add fc616286b Feature:Online Query and Dynamic Modification of Table-level
RocksDB Options (#1511)
add 7fe41d4bf chore(github): free disk space after packaging with jemalloc
in github workflows (#1581)
add 72c8f2f75 feat(security): Support to use the principal of Unix account
for authentication (#1569)
add c5a01c1f4 chore(github): free disk space for daily building on github
(#1586)
add be9119e75 fix: fix errors in format string for logging and macro
(#1588)
add 26b99e1e8 Revert "build(thirdparty): add thirdparty for centos6 build
env (#1017)" (#1600)
add 5489b43a8 build(thirdparty): bump fmtlib to 10.1.1 (#1605)
add 7cb159994 feat(build): make C++17 as required (#1603)
add e978e4c78 feat(thirdparty): upgrade rocksdb to 8.5.3 (#1601)
add b15d57714 fix(docker): fix build failure of rocksdb when PORTABLE=0
(#1607)
add fef5b16c3 chore(CI): unify to use Ubuntu 22.04 for CI (#1609)
add 31ce32858 fix(ASAN): avoid reporting false 'odr-violation' issues
(#1611)
add 9f3201755 build(thirdparty): use v8.5.3-pegasus-encrypt branch of
pegasus-kv/rocksdb (#1610)
add edd1e17c8 feat(build): build RocksDB with encryption enabled (#1612)
add 22c91816c fix(rocksdb): update rocksdb to fix build failure on lower
OpenSSL version (#1614)
add 7b2bd09b9 fix(build): fix a link error on macOS (#1615)
add 625cebcc9 feat(encryption): introduce PegasusEnv (#1606)
add 42136fa4b refactor(test): refactor bulk load function test (#1616)
add c8793d22d feat(slog): flush and remove all shared logs for garbage
collection (#1594)
add f1fee10dd refactor(aio_test): refactor aio unit test (#1617)
add 73d53dbbb refactor(hdfs): use rocksdb API to read/write file (#1618)
add 64abf9055 refactor(local service): use rocksdb API to read/write file
(#1619)
add a2f2ebd3d refactor(simple_meta_state): use rocksdb API to read/write
file (#1620)
add c4470fa4b refactor(nfs_test): use rocksdb API to read/write file
(#1621)
add 916c77414 refactor(simple_kv): use rocksdb API to read/write file
(#1622)
add a1c463d48 refactor(replica): use rocksdb API to read/write file (#1623)
add c65c39af3 refactor(misc): use rocksdb API to read/write file (#1625)
add c2d9affe8 refactor(configuration): use rocksdb API to read/write file
(#1626)
add 4a605825d fix(http_server): add deregister_http_call back (#1627)
add 58ac76575 refactor(file_system): use rocksdb API to read/write file
(#1624)
add 0db1ff90d feat(http): implement http client based on libcurl (#1583)
add 70d246739 refactor(file_system): remove useless read/write_file()
(#1628)
add b551e2627 refactor: some minor refactors without functional changes
(#1629)
add 4cb68284c fix(ut): fix flaky unit test test_rename_path_while_writing
(#1630)
add 0ccf1108f fix(jemalloc): enlarge the buffer size to dump jemalloc
stats (#1636)
add 6064d7085 build(thirdparty): bump libcurl from 7.47.0 to 8.4.0 (#1633)
add ed3d31ef7 refactor(filesystem): refactor file_utils unit tests (#1634)
add 0f92716dd feat(aio): use rocksdb APIs to re-implement the aio module
(#1637)
add 13a45ab73 feat(log): Redacted user key-values printed in logs (#1598)
add 8d7c91b04 feat(dup): parameterize the period seconds of duplication
sync (#1639)
add 36d8be42a feat(encryption): support data encrypt at rest (#1599)
add cacd0a8d8 chore(CI): remove the "Check issue" from Standardization
Lint (#1652)
add 21e25cad3 fix(CI): Fix the "Lint Dockerfile" action failure (#1656)
add 383ef0f1e fix: generate thrift sources for scala client (#1662)
add 1bdbfd3e5 fix(hotkey): never redact hot key for encryption (#1668)
add 565beab52 chore(version): update the version of pegasus server and
client of each language to 2.5.0 (#1660)
add 724ec0bb2 chore: update NOTICE year to 2023 (#1671)
add ee369d380 fix: parse timestamp from the name of data dir for gc
instead of the last update time (#1667)
add 85f3e74f2 chore(license): add license checker for copyright and fix
license files (#1674)
add aa9d31a89 feat(thirdparty): Introduce abseil (#1675)
add 5e9a2a9dc feat(thirdparty): Use facebook/rocksdb and pegasus-kv/encfs
as rocksdb thirdparty (#1678)
add dbd5f202e chore(thirdparty): find and use OpenSSL by CMake functions
(#1679)
add 97bde421d refactor: use fmt:join to simplify code (#1680)
add 3238686bf chore(thirdparty): Bump gperftools to 2.13 (#1682)
add a276661bd feat(pprof): Supports both heap profiling and heap sampling
(#1684)
add 64129e85c feat(thirdparty): compile curl with gssapi (#1683)
add b01a88417 refactor(build): Improve the project CMake (#1687)
add b580ccce2 fix: use libgcc instead of generic_fp as default stacktrace
(#1690)
add 1409d090e refactor(thirdparty): Bump googletest to 1.14.0 (#1689)
add 75744cb7d refactor(thirdparty): Bump s2geometry to 0.10.0 (#1688)
add 79cd226d9 refactor(absl): Use the abseil in thirdparty instead of the
internal copied one (#1694)
add da54c5881 chore: remove personal comments in file header (#1696)
add 6cb3f5e0a refactor(regex): use std::regex instead of boost::regex
(#1697)
add 16caf01f5 fix(bulk_load): rocksDB parameter allow_ingest_behind was
lost after replica migration (#1651)
add 432499f0b fix(admin-cli): fix the command reports incorrect
ERR_INVALID_PARAMETERS error (#1699)
add 2ff8c027c feat(ddl_client): add failure logs when backup or restore
command failed (#1701)
add 41ff58d83 refactor(FDS): Terminate the FDS supporting (#1695)
add 19876094e feat(HDFS): Add hdfs_service related configs in server.ini
and run.sh (#1705)
add 50563ea33 chore: add change log for version 2.5 (#1700)
add 3ffe54275 refactor(backup&restore): add more logs when backup or
restore failed (#1702)
add 05a90883c chore: switch to the standard Incubator DISCLAIMER instead
of current work-in-progress version (#1707)
add 63583da3e feat: source config_hdfs.sh automatically before starting
onebox (#1708)
add e15f9b275 feat(replica): add FileDataType as the parameter (#1703)
add 4b8b49a09 chore(CI): Use actions/labeler@v4 to keep compatiblity
(#1711)
add 18e378dc8 refactor(function_test): make [backup_]restore_test derive
from test_util (#1710)
add 50493b1fc chore(asf.yml): update collaborators (#1757)
add 4028c12f8 feat(new_metrics): add replica-level metric entity (#1345)
add 2d7cb40b8 feat(new_metrics): migrate replica-level metrics for write
service (#1351)
add c3f524002 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 1) (#1374)
add e6ce28b87 feat(new_metrics): migrate replica-level metrics for
pegasus_server_impl (part 2) (#1386)
add f5eafcbf3 feat(new_metrics): migrate replica-level metrics for
capacity_unit_calculator (#1387)
add 522626048 feat(new_metrics): migrate replica-level metrics for replica
class (#1397)
add c263b8b51 feat(new_metrics): migrate replica-level metrics for
pegasus_event_listener (#1407)
add 688b43630 feat(new_metrics): migrate replica-level metrics for
pegasus_mutation_duplicator (#1413)
add b1730fba5 feat(new_metrics): add server-level metric entity (#1415)
add 2d362f1e1 feat(new_metrics): migrate built-in server-level metrics
(#1418)
add 14c8a102d feat(new_metrics): migrate server-level metrics for nfs
(#1421)
add 659743d6d feat(new_metrics): add disk-level metric entity and migrate
disk-level metrics for fs_manager (#1427)
add dbaa01abd feat(new_metrics): add table-level metric entity and migrate
table-level metrics for server_state of meta (#1431)
add e2243751a feat(new_metrics): add partition-level metric entity and
migrate partition-level metrics for greedy_load_balancer of meta (#1435)
add fb5b5b017 feat(new_metrics): migrate server-level metrics for
meta_service (#1437)
add 3e88153a1 feat(new_metrics): add backup-policy-level metric entity and
migrate backup-policy-level metrics for meta_backup_service (#1438)
add 6bd8b9568 feat(new_metrics): migrate partition-level metrics for
partition_guardian (#1440)
add 23debd2d2 feat(new_metrics): migrate replica-level metrics for
pegasus_manual_compact_service (#1443)
add a5c841e2b feat(new_metrics): migrate metrics for replica_stub (part 1)
(#1455)
add 30221094d feat(new_metrics): migrate metrics for replica_stub (part 2)
(#1459)
add 15ab7a1d0 feat(collector): migrate the collector from
pegasus-kv/collector (#1461)
add f959ba4b4 feat(new_metrics): migrate metrics for replica_stub (part 3)
(#1462)
add 43a0b0e8a feat(new_metrics): migrate metrics for replica_stub (part 4)
(#1463)
add a5ae84682 feat(new_metrics): migrate metrics for replica_stub (part 5)
(#1469)
add ec9a1ae62 feat(new_metrics): migrate metrics for replica_stub (part 6)
(#1474)
add 5249fdc9e feat(new_metrics): migrate metrics for replica_stub (part 7)
(#1475)
add c4c835149 feat(new_metrics): migrate metrics for some duplication
class (#1482)
add cbfc0e842 feat(new_metrics): migrate metrics for task queue (#1484)
add ade5adfde refactor(new_metrics): refactor enum definition for metric
types and units (#1491)
add 8abadfc4d feat(new_metrics): migrate metrics for failure detector
(#1502)
add 556c6ac62 feat(new_metrics): migrate metrics for network (#1504)
add 79b4e6aa3 feat(new_metrics): migrate server-level metrics of rocksdb
(#1506)
add 93391cb2f feat: Aggregate table/server level metrics (#1517)
add 568227956 feat(new_metrics): migrate metrics for profiler (#1524)
add 71e516251 fix(new_metrics): profiled tasks are measured by the wrong
metrics (#1528)
add 8e3b1f036 feat(new_metrics): remove all table-level perf-counters for
each replica (#1531)
add 2169d9c43 refactor(new_metrics): remove perf-counters that are still
used in shared log (#1533)
add 50cf91606 feat(new_metrics): migrate metrics for latency tracer (#1537)
add 641e97bfa fix(new_metrics): total_capacity_mb/total_available_mb are
not atomic (#1542)
add e724b62c6 feat(new_metrics): remove http service for perf counters
(#1540)
add dfb50dcc0 feat(new_metrics): remove pegasus_counter_reporter (#1548)
add 83eeb8c4a feat(new_metrics): remove perf counter since shared log has
been deprecated
add 6be5e286f feat(new_metrics): remove deleted header files introduced
in source files for new metrics
add db8e780bc fix(new_metrics): fix unit tests in verifying values of
backup_requests and write_size_exceed_threshold_requests
add fa82854a3 fix(IWYU): fix the suggestions reported by IWYU while rebase
merging branch migrate-metrics-dev into master such as including
absl/strings/string_view.h
add 4dd2b7ab8 refactor(function_test): abstract some functions to reduce
duplicate code (#1756)
add d85837c2e fix(collector): fix lint and build errors for go collector
(#1762)
add 5ea2a8d4d feat(snappy/lz4/zstd): Build snappy/lz4/zstd as a thirdparty
libraries (#1709)
add 224cb818e feat(cpp-shell): make mlog_dump dump plog (#1760)
add 867174591 build(images): append branch name to the tag of each
build-env-* image to support building image for each branch (#1763)
add 5eb33cc75 refactor(local_service): minor refactor on file_metadata
(#1769)
add 2b7d6582f feat(slog): Remove slog related code (#1759)
add df61744fb refactor(function_test): generate bulk load files internally
(#1770)
add 89ee42cfe fix: use boost::filesystem::path instead of
std::filesystem::path to be compatible with lower gcc/clang versions (#1771)
add e5770a89a build(images): remove ci-env docker image (#1773)
add ba04f017c build(deps): bump cryptography from 3.2 to 41.0.3 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 (0eee08874)
\
N -- N -- N
refs/heads/dependabot/pip/python-client/cryptography-41.0.3 (ba04f017c)
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 | 3 +-
.github/workflows/build-push-env-docker.yml | 3 +-
.github/workflows/free_disk_space.sh | 70 ++
.github/workflows/labeler.yml | 2 +-
..._test_pegic.yml => lint_and_test_collector.yml} | 33 +-
.github/workflows/lint_and_test_cpp.yaml | 141 ++-
.github/workflows/module_labeler_conf.yml | 2 +
.github/workflows/regular-build.yml | 17 +-
.github/workflows/standardization_lint.yaml | 12 -
.github/workflows/thirdparty-regular-push.yml | 6 +-
.gitignore | 4 +-
.licenserc.yaml | 106 +-
.rat-excludes | 4 +-
CMakeLists.txt | 8 +-
DISCLAIMER | 10 +
DISCLAIMER-WIP | 19 -
HISTORY.md | 40 +
LICENSE | 68 +-
NOTICE | 2 +-
admin-cli/client/meta.go | 4 +-
admin-cli/go.sum | 1 -
cmake_modules/BaseFunctions.cmake | 41 +-
src/geo/CMakeLists.txt => collector/Makefile | 10 +-
collector/README.md | 28 +
collector/aggregate/aggregatable.go | 92 ++
collector/aggregate/aggregator.go | 173 +++
collector/aggregate/aggregator_test.go | 97 ++
collector/aggregate/history.go | 111 ++
.../aggregate/history_test.go | 34 +-
collector/aggregate/hook.go | 69 ++
collector/aggregate/hook_test.go | 51 +
collector/aggregate/perf_client.go | 237 ++++
collector/aggregate/perf_client_test.go | 49 +
collector/aggregate/perf_counter_decoder.go | 62 ++
collector/aggregate/perf_counter_decoder_test.go | 61 ++
collector/aggregate/perf_session.go | 91 ++
collector/aggregate/table_stats.go | 134 +++
collector/avail/detector.go | 152 +++
.../clear_onebox.sh => collector/config.yml | 38 +-
collector/go.mod | 47 +
{admin-cli => collector}/go.sum | 178 ++-
.../hotspot/algo.go | 8 +-
collector/main.go | 101 ++
.../metrics/meta_server_metrics.go | 9 +-
collector/metrics/metric_collector.go | 514 +++++++++
.../metrics/replica_server_metrics.go | 9 +-
collector/sink/falcon_sink.go | 144 +++
collector/sink/prometheus_sink.go | 110 ++
collector/sink/sink.go | 53 +
collector/templates/index.html | 80 ++
collector/usage/usage_recorder.go | 115 ++
collector/webui/index.go | 84 ++
src/utils/clock.cpp => collector/webui/tables.go | 49 +-
collector/webui/webserver.go | 61 ++
docker/README.md | 16 +-
docker/ci-env/Dockerfile | 33 -
docker/pegasus-build-env/centos7/Dockerfile | 6 +-
docker/pegasus-build-env/ubuntu1804/Dockerfile | 8 +-
docker/pegasus-build-env/ubuntu2004/Dockerfile | 6 +-
docker/pegasus-build-env/ubuntu2204/Dockerfile | 6 +-
docker/pegasus-docker-compose/README.md | 2 +-
docker/pegasus-docker-compose/build_docker.sh | 26 +-
docker/pegasus-docker-compose/config.min.ini | 6 +-
.../image_for_prebuilt_bin/Dockerfile | 3 +-
docker/thirdparties-bin/Dockerfile | 6 +-
docker/thirdparties-src/Dockerfile | 8 +-
java-client/pom.xml | 2 +-
java-client/scripts/ci-test.sh | 4 +-
nodejs-client/package.json | 2 +-
python-client/pypegasus/__init__.py | 2 +-
python-client/requirement.txt | 2 +-
python-client/setup.py | 2 +-
run.sh | 62 +-
scala-client/build.sbt | 4 +-
scala-client/scripts/ci-test.sh | 4 +
scripts/check_license.py | 213 ++++
scripts/config_hdfs.sh | 16 +-
scripts/pack_server.sh | 5 +-
scripts/pack_tools.sh | 3 +-
src/CMakeLists.txt | 1 -
src/aio/CMakeLists.txt | 7 +-
src/aio/aio_provider.h | 16 +-
src/aio/disk_engine.cpp | 8 +-
src/aio/disk_engine.h | 11 +-
src/aio/file_io.cpp | 48 +-
src/aio/file_io.h | 10 +-
src/aio/native_linux_aio_provider.cpp | 141 +--
src/aio/native_linux_aio_provider.h | 19 +-
src/aio/test/CMakeLists.txt | 14 +-
src/aio/test/aio.cpp | 444 +++++---
src/aio/test/config.ini | 5 +
src/base/idl_utils.h | 9 +
src/base/pegasus_const.cpp | 49 +
src/base/pegasus_const.h | 22 +
src/base/pegasus_utils.h | 29 +-
src/base/pegasus_value_schema.h | 18 +-
src/base/test/CMakeLists.txt | 10 +-
src/base/test/redact_sensitive_string_test.cpp | 67 ++
src/base/test/utils_test.cpp | 5 +-
src/base/test/value_manager_test.cpp | 8 +-
src/base/test/value_schema_test.cpp | 8 +-
src/base/value_field.h | 7 +-
src/base/value_schema_manager.cpp | 3 +-
src/base/value_schema_manager.h | 4 +-
src/base/value_schema_v0.cpp | 7 +-
src/base/value_schema_v0.h | 6 +-
src/base/value_schema_v1.cpp | 9 +-
src/base/value_schema_v1.h | 8 +-
src/base/value_schema_v2.cpp | 9 +-
src/base/value_schema_v2.h | 8 +-
src/block_service/CMakeLists.txt | 1 -
src/block_service/block_service.h | 6 +-
src/block_service/block_service_manager.cpp | 16 +-
src/block_service/directio_writable_file.cpp | 169 ---
src/block_service/directio_writable_file.h | 57 -
src/block_service/fds/CMakeLists.txt | 35 -
src/block_service/fds/fds_service.cpp | 717 ------------
src/block_service/fds/fds_service.h | 156 ---
src/block_service/hdfs/CMakeLists.txt | 13 +-
src/block_service/hdfs/hdfs_service.cpp | 182 ++--
src/block_service/local/CMakeLists.txt | 6 +-
src/block_service/local/local_service.cpp | 393 +++----
src/block_service/local/local_service.h | 19 +-
src/block_service/test/CMakeLists.txt | 31 +-
.../test/block_service_manager_test.cpp | 71 +-
src/block_service/test/config-test.ini | 9 +-
src/block_service/test/fds_service_test.cpp | 820 --------------
src/block_service/test/hdfs_service_test.cpp | 367 ++++---
src/block_service/test/local_service_test.cpp | 74 +-
src/client/replication_ddl_client.cpp | 36 +-
src/client/replication_ddl_client.h | 6 +-
src/client/test/CMakeLists.txt | 17 +-
src/client/test/ddl_client_test.cpp | 8 +-
src/client_lib/mutation.cpp | 2 +-
src/client_lib/pegasus_client_impl.cpp | 9 +-
src/common/duplication_common.h | 3 +
src/common/fs_manager.cpp | 134 ++-
src/common/fs_manager.h | 82 +-
src/common/gpid.h | 5 +
src/common/json_helper.h | 1 +
src/common/replica_envs.h | 6 +
src/common/replication.codes.h | 5 -
src/common/replication_common.cpp | 26 +-
src/common/replication_enums.h | 15 +
src/common/replication_other_types.h | 8 -
src/common/serialization_helper/thrift_helper.h | 7 +-
src/common/test/CMakeLists.txt | 8 +-
src/common/test/common_test.cpp | 6 +-
src/common/test/config-test.ini | 1 +
src/common/test/duplication_common_test.cpp | 4 +-
src/common/test/fs_manager_test.cpp | 26 +-
src/common/test/replication_common_test.cpp | 5 +-
src/common/test/run.sh | 21 +-
src/failure_detector/CMakeLists.txt | 4 +-
src/failure_detector/failure_detector.cpp | 17 +-
src/failure_detector/failure_detector.h | 62 +-
.../failure_detector_multimaster.cpp | 9 -
src/failure_detector/fd.client.h | 9 -
src/failure_detector/fd.server.h | 9 -
src/failure_detector/test/CMakeLists.txt | 21 +-
src/failure_detector/test/config-test.ini | 10 +-
.../test/config-whitelist-test-failed.ini | 10 +-
.../test/config-whitelist-test.ini | 10 +-
src/failure_detector/test/failure_detector.cpp | 5 +-
src/geo/bench/CMakeLists.txt | 12 +-
src/geo/bench/bench.cpp | 10 +-
src/geo/lib/geo_client.cpp | 60 +-
src/geo/lib/geo_client.h | 1 -
src/geo/lib/latlng_codec.h | 1 -
src/geo/test/CMakeLists.txt | 4 +-
src/geo/test/geo_test.cpp | 9 +-
src/geo/test/latlng_codec_test.cpp | 5 +-
src/http/builtin_http_calls.cpp | 6 -
src/http/builtin_http_calls.h | 2 -
src/http/http_call_registry.h | 17 +-
src/http/http_client.cpp | 346 ++++++
src/http/http_client.h | 157 +++
src/http/http_message_parser.cpp | 11 +-
src/http/{service_version.h => http_method.h} | 22 +-
src/http/http_server.cpp | 6 +-
src/http/http_server.h | 9 +-
src/http/perf_counter_http_service.cpp | 66 --
src/http/pprof_http_service.cpp | 84 +-
src/http/test/CMakeLists.txt | 16 +-
.../config.ini => http/test/config-test.ini} | 68 +-
src/http/test/http_client_test.cpp | 214 ++++
src/http/test/http_server_test.cpp | 26 +-
src/http/test/main.cpp | 120 +++
src/http/test/perf_counter_http_service_test.cpp | 78 --
src/http/test/uri_decoder_test.cpp | 4 +-
src/http/uri_decoder.cpp | 6 +-
src/http/uri_decoder.h | 4 +-
src/include/pegasus/client.h | 4 +
src/include/pegasus/version.h | 2 +-
src/meta/CMakeLists.txt | 40 +-
src/meta/app_env_validator.cpp | 59 +-
src/meta/app_env_validator.h | 2 +
src/meta/distributed_lock_service_simple.cpp | 9 -
src/meta/distributed_lock_service_simple.h | 12 +-
src/meta/dump_file.h | 2 +
src/meta/duplication/meta_duplication_service.cpp | 19 +-
src/meta/greedy_load_balancer.cpp | 48 +-
src/meta/greedy_load_balancer.h | 16 +-
src/meta/load_balance_policy.cpp | 5 +-
src/meta/meta_backup_service.cpp | 90 +-
src/meta/meta_backup_service.h | 33 +-
src/meta/meta_bulk_load_ingestion_context.cpp | 17 +-
src/meta/meta_bulk_load_service.cpp | 21 +-
src/meta/meta_bulk_load_service.h | 4 +
src/meta/meta_data.cpp | 20 +-
src/meta/meta_data.h | 8 -
src/meta/meta_options.cpp | 9 +-
src/meta/meta_options.h | 9 +-
src/meta/meta_server_failure_detector.cpp | 4 +-
src/meta/meta_service.cpp | 46 +-
src/meta/meta_service.h | 18 +-
src/meta/meta_service_app.h | 1 +
src/meta/meta_split_service.cpp | 5 +
src/meta/meta_state_service.h | 19 +-
src/meta/meta_state_service_simple.cpp | 128 ++-
src/meta/meta_state_service_simple.h | 11 +-
src/meta/meta_state_service_utils_impl.h | 9 +-
src/meta/meta_state_service_zookeeper.cpp | 5 +-
src/meta/meta_state_service_zookeeper.h | 8 -
src/meta/partition_guardian.cpp | 28 +-
src/meta/partition_guardian.h | 2 -
src/meta/server_load_balancer.h | 12 +-
src/meta/server_state.cpp | 93 +-
src/meta/server_state.h | 24 +-
src/meta/server_state_restore.cpp | 2 +
src/meta/table_metrics.cpp | 389 +++++++
src/meta/table_metrics.h | 257 +++++
src/meta/test/CMakeLists.txt | 10 +-
src/meta/test/backup_test.cpp | 6 +-
src/meta/test/balancer_simulator/CMakeLists.txt | 2 +-
src/meta/test/cluster_balance_policy_test.cpp | 5 +-
src/meta/test/config-test.ini | 5 +-
src/meta/test/copy_replica_operation_test.cpp | 5 +-
src/meta/test/dump_file.cpp | 6 +-
src/meta/test/duplication_info_test.cpp | 5 +-
src/meta/test/ford_fulkerson_test.cpp | 5 +-
src/meta/test/json_compacity.cpp | 4 +-
src/meta/test/main.cpp | 6 +-
src/meta/test/meta_app_envs_test.cpp | 28 +-
src/meta/test/meta_app_operation_test.cpp | 195 +++-
src/meta/test/meta_backup_test.cpp | 8 +-
src/meta/test/meta_bulk_load_ingestion_test.cpp | 5 +-
src/meta/test/meta_bulk_load_service_test.cpp | 4 +-
src/meta/test/meta_data.cpp | 5 +-
src/meta/test/meta_duplication_service_test.cpp | 4 +-
src/meta/test/meta_http_service_test.cpp | 5 +-
src/meta/test/meta_mauanl_compaction_test.cpp | 5 +-
src/meta/test/meta_partition_guardian_test.cpp | 4 +-
src/meta/test/meta_service_test.cpp | 9 +-
src/meta/test/meta_split_service_test.cpp | 8 +-
src/meta/test/meta_state/CMakeLists.txt | 2 +-
src/meta/test/meta_state/main.cpp | 9 -
src/meta/test/meta_state/meta_state_service.cpp | 91 +-
src/meta/test/meta_state_service_utils_test.cpp | 4 +-
src/meta/test/meta_test_base.cpp | 5 +-
src/meta/test/run.sh | 21 +-
src/meta/test/server_state_restore_test.cpp | 4 +-
src/meta/test/server_state_test.cpp | 4 +-
src/meta/test/state_sync_test.cpp | 6 +-
src/meta/test/update_configuration_test.cpp | 6 +-
src/nfs/nfs_client_impl.cpp | 65 +-
src/nfs/nfs_client_impl.h | 10 +-
src/nfs/nfs_code_definition.h | 8 -
src/nfs/{nfs_node_impl.cpp => nfs_node_simple.cpp} | 22 +-
src/nfs/nfs_node_simple.h | 22 +-
src/nfs/nfs_server_impl.cpp | 141 ++-
src/nfs/nfs_server_impl.h | 18 +-
src/nfs/test/CMakeLists.txt | 14 +-
src/nfs/test/main.cpp | 170 ++-
src/perf_counter/builtin_counters.cpp | 57 -
src/perf_counter/builtin_counters.h | 33 -
src/perf_counter/perf_counter.h | 2 +
src/perf_counter/perf_counter_atomic.cpp | 1 +
src/perf_counter/perf_counters.cpp | 14 -
src/perf_counter/perf_counters.h | 2 -
src/perf_counter/test/CMakeLists.txt | 12 +-
src/perf_counter/test/perf_counter_test.cpp | 14 +-
src/perf_counter/test/perf_counters_test.cpp | 42 +-
src/redis_protocol/proxy/CMakeLists.txt | 5 +-
src/redis_protocol/proxy/main.cpp | 4 -
src/redis_protocol/proxy_lib/redis_parser.cpp | 20 +-
src/redis_protocol/proxy_lib/redis_parser.h | 1 -
src/redis_protocol/proxy_ut/CMakeLists.txt | 4 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 6 +-
src/replica/CMakeLists.txt | 37 +-
src/replica/backup/cold_backup_context.cpp | 31 +-
src/replica/backup/replica_backup_manager.cpp | 32 +-
src/replica/backup/replica_backup_manager.h | 9 +-
src/replica/backup/replica_backup_server.cpp | 6 +
src/replica/backup/replica_backup_server.h | 1 +
src/replica/backup/test/CMakeLists.txt | 8 +-
src/replica/backup/test/config-test.ini | 3 +-
.../backup/test/replica_backup_manager_test.cpp | 8 +-
src/replica/backup/test/run.sh | 20 +-
src/replica/bulk_load/replica_bulk_loader.cpp | 85 +-
src/replica/bulk_load/replica_bulk_loader.h | 9 +
src/replica/bulk_load/test/CMakeLists.txt | 8 +-
src/replica/bulk_load/test/config-test.ini | 5 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 120 +--
src/replica/bulk_load/test/run.sh | 20 +-
src/replica/disk_cleaner.cpp | 200 +++-
src/replica/disk_cleaner.h | 24 +-
src/replica/duplication/duplication_pipeline.cpp | 21 +-
src/replica/duplication/duplication_pipeline.h | 4 +-
src/replica/duplication/duplication_sync_timer.cpp | 22 +-
src/replica/duplication/duplication_sync_timer.h | 5 -
src/replica/duplication/load_from_private_log.cpp | 106 +-
src/replica/duplication/load_from_private_log.h | 17 +-
src/replica/duplication/mutation_batch.cpp | 28 +-
src/replica/duplication/mutation_batch.h | 4 +-
src/replica/duplication/mutation_duplicator.h | 6 +-
src/replica/duplication/replica_duplicator.cpp | 15 +-
src/replica/duplication/replica_duplicator.h | 6 +
.../duplication/replica_duplicator_manager.cpp | 16 +-
.../duplication/replica_duplicator_manager.h | 13 +-
src/replica/duplication/replica_follower.cpp | 10 +-
src/replica/duplication/test/CMakeLists.txt | 8 +-
src/replica/duplication/test/config-test.ini | 5 +-
.../test/dup_replica_http_service_test.cpp | 8 +-
.../test/duplication_sync_timer_test.cpp | 21 +-
.../duplication/test/duplication_test_base.h | 6 +-
.../test/load_from_private_log_test.cpp | 126 ++-
.../duplication/test/mutation_batch_test.cpp | 13 +-
.../test/replica_duplicator_manager_test.cpp | 16 +-
.../duplication/test/replica_duplicator_test.cpp | 14 +-
.../duplication/test/replica_follower_test.cpp | 17 +-
src/replica/duplication/test/run.sh | 20 +-
.../duplication/test/ship_mutation_test.cpp | 12 +-
src/replica/log_file.cpp | 31 +-
src/replica/log_file.h | 19 +-
src/replica/log_file_stream.h | 3 +-
src/replica/mutation.cpp | 9 -
src/replica/mutation.h | 9 -
src/replica/mutation_cache.cpp | 5 -
src/replica/mutation_log.cpp | 619 +----------
src/replica/mutation_log.h | 133 +--
src/replica/mutation_log_replay.cpp | 10 +-
src/replica/mutation_log_utils.cpp | 9 +-
src/replica/mutation_log_utils.h | 13 +-
src/replica/prepare_list.h | 2 +
src/replica/replica.cpp | 367 ++++---
src/replica/replica.h | 117 +-
src/replica/replica_2pc.cpp | 21 +-
src/replica/replica_backup.cpp | 12 +-
.../replica_base.cpp} | 51 +-
src/replica/replica_base.h | 23 +-
src/replica/replica_check.cpp | 23 +-
src/replica/replica_chkpt.cpp | 26 +-
src/replica/replica_config.cpp | 15 +-
src/replica/replica_context.cpp | 9 -
src/replica/replica_context.h | 4 +
src/replica/replica_disk_migrator.cpp | 8 +-
src/replica/replica_failover.cpp | 11 +-
src/replica/replica_http_service.h | 9 +-
src/replica/replica_init.cpp | 21 +-
src/replica/replica_learn.cpp | 46 +-
src/replica/replica_restore.cpp | 46 +-
src/replica/replica_stub.cpp | 951 +++++-----------
src/replica/replica_stub.h | 144 +--
src/replica/replica_throttle.cpp | 11 +-
src/replica/replication_app_base.cpp | 158 +--
src/replica/replication_app_base.h | 57 +-
src/replica/split/replica_split_manager.cpp | 83 +-
src/replica/split/replica_split_manager.h | 8 +
src/replica/split/test/CMakeLists.txt | 2 +-
src/replica/split/test/config-test.ini | 5 +-
src/replica/split/test/replica_split_test.cpp | 51 +-
src/replica/split/test/run.sh | 20 +-
src/replica/storage/simple_kv/CMakeLists.txt | 13 +-
src/replica/storage/simple_kv/config.ini | 3 +-
src/replica/storage/simple_kv/run.sh | 19 +
.../storage/simple_kv/simple_kv.app.example.h | 9 -
.../storage/simple_kv/simple_kv.code.definition.h | 9 -
src/replica/storage/simple_kv/simple_kv.main.cpp | 9 -
src/replica/storage/simple_kv/simple_kv.server.h | 9 -
.../storage/simple_kv/simple_kv.server.impl.cpp | 137 ++-
.../storage/simple_kv/simple_kv.server.impl.h | 9 -
src/replica/storage/simple_kv/test/CMakeLists.txt | 29 +-
src/replica/storage/simple_kv/test/case-000.ini | 6 +-
src/replica/storage/simple_kv/test/case-001.ini | 6 +-
src/replica/storage/simple_kv/test/case-002.ini | 6 +-
src/replica/storage/simple_kv/test/case-003.ini | 6 +-
src/replica/storage/simple_kv/test/case-004.ini | 6 +-
src/replica/storage/simple_kv/test/case-005.ini | 6 +-
src/replica/storage/simple_kv/test/case-006.ini | 6 +-
src/replica/storage/simple_kv/test/case-100.ini | 6 +-
src/replica/storage/simple_kv/test/case-101.ini | 6 +-
src/replica/storage/simple_kv/test/case-102.ini | 6 +-
src/replica/storage/simple_kv/test/case-103.ini | 6 +-
src/replica/storage/simple_kv/test/case-104.ini | 6 +-
src/replica/storage/simple_kv/test/case-105.ini | 6 +-
src/replica/storage/simple_kv/test/case-106.ini | 6 +-
src/replica/storage/simple_kv/test/case-107.ini | 6 +-
src/replica/storage/simple_kv/test/case-108.ini | 6 +-
src/replica/storage/simple_kv/test/case-109.ini | 6 +-
src/replica/storage/simple_kv/test/case-200.ini | 6 +-
src/replica/storage/simple_kv/test/case-201.ini | 6 +-
src/replica/storage/simple_kv/test/case-202-0.ini | 6 +-
src/replica/storage/simple_kv/test/case-202-1.ini | 6 +-
src/replica/storage/simple_kv/test/case-203-0.ini | 6 +-
src/replica/storage/simple_kv/test/case-204.ini | 6 +-
src/replica/storage/simple_kv/test/case-205.ini | 6 +-
src/replica/storage/simple_kv/test/case-206.ini | 6 +-
src/replica/storage/simple_kv/test/case-207.ini | 6 +-
src/replica/storage/simple_kv/test/case-208.ini | 6 +-
src/replica/storage/simple_kv/test/case-209.ini | 6 +-
src/replica/storage/simple_kv/test/case-210.ini | 6 +-
src/replica/storage/simple_kv/test/case-211.ini | 6 +-
src/replica/storage/simple_kv/test/case-212.ini | 6 +-
src/replica/storage/simple_kv/test/case-213.ini | 6 +-
src/replica/storage/simple_kv/test/case-214.ini | 6 +-
src/replica/storage/simple_kv/test/case-215.ini | 6 +-
src/replica/storage/simple_kv/test/case-216.ini | 6 +-
src/replica/storage/simple_kv/test/case-300-0.ini | 6 +-
src/replica/storage/simple_kv/test/case-300-1.ini | 6 +-
src/replica/storage/simple_kv/test/case-300-2.ini | 6 +-
src/replica/storage/simple_kv/test/case-301.ini | 6 +-
src/replica/storage/simple_kv/test/case-302.ini | 6 +-
src/replica/storage/simple_kv/test/case-303.ini | 6 +-
src/replica/storage/simple_kv/test/case-304.ini | 6 +-
src/replica/storage/simple_kv/test/case-305.ini | 6 +-
src/replica/storage/simple_kv/test/case-306.ini | 6 +-
src/replica/storage/simple_kv/test/case-307.ini | 6 +-
src/replica/storage/simple_kv/test/case-400.ini | 6 +-
src/replica/storage/simple_kv/test/case-401.ini | 6 +-
src/replica/storage/simple_kv/test/case-402.ini | 6 +-
src/replica/storage/simple_kv/test/case-600.ini | 6 +-
src/replica/storage/simple_kv/test/case-601.ini | 6 +-
src/replica/storage/simple_kv/test/case-602.ini | 6 +-
src/replica/storage/simple_kv/test/case-603.ini | 6 +-
src/replica/storage/simple_kv/test/case.cpp | 10 -
src/replica/storage/simple_kv/test/case.h | 13 +-
src/replica/storage/simple_kv/test/checker.cpp | 9 -
src/replica/storage/simple_kv/test/checker.h | 9 -
src/replica/storage/simple_kv/test/client.cpp | 10 -
src/replica/storage/simple_kv/test/client.h | 9 -
src/replica/storage/simple_kv/test/common.cpp | 9 -
src/replica/storage/simple_kv/test/common.h | 14 +-
src/replica/storage/simple_kv/test/config.ini | 3 +-
src/replica/storage/simple_kv/test/injector.cpp | 9 -
src/replica/storage/simple_kv/test/injector.h | 9 -
src/replica/storage/simple_kv/test/run.sh | 27 +
.../storage/simple_kv/test/simple_kv.main.cpp | 9 -
.../simple_kv/test/simple_kv.server.impl.cpp | 131 ++-
.../storage/simple_kv/test/simple_kv.server.impl.h | 1 +
src/replica/test/CMakeLists.txt | 36 +-
src/replica/test/cold_backup_context_test.cpp | 5 +-
src/replica/test/config-test.ini | 5 +-
src/replica/test/log_block_test.cpp | 22 +-
src/replica/test/log_file_test.cpp | 8 +-
src/replica/test/main.cpp | 28 +-
src/replica/test/mock_utils.h | 26 -
src/replica/test/mutation_log_learn_test.cpp | 11 +-
src/replica/test/mutation_log_test.cpp | 106 +-
src/replica/test/open_replica_test.cpp | 11 +-
src/replica/test/replica_disk_migrate_test.cpp | 20 +-
src/replica/test/replica_disk_test.cpp | 100 +-
src/replica/test/replica_disk_test_base.h | 1 -
src/replica/test/replica_http_service_test.cpp | 50 +-
src/replica/test/replica_learn_test.cpp | 11 +-
src/replica/test/replica_test.cpp | 100 +-
src/replica/test/replica_test_base.h | 13 +-
src/replica/test/run.sh | 21 +-
src/replica/test/throttling_controller_test.cpp | 4 +-
src/reporter/CMakeLists.txt | 44 -
src/reporter/pegasus_counter_reporter.cpp | 381 -------
src/reporter/pegasus_counter_reporter.h | 119 --
src/reporter/pegasus_io_service.h | 65 --
src/runtime/env.sim.cpp | 9 -
src/runtime/env.sim.h | 9 -
src/runtime/fault_injector.cpp | 11 +-
src/runtime/global_config.cpp | 9 -
src/runtime/global_config.h | 9 -
src/runtime/nativerun.cpp | 9 -
src/runtime/nativerun.h | 10 +-
src/runtime/pipeline.h | 2 +-
src/runtime/profiler.cpp | 495 +++++----
src/runtime/profiler_header.h | 69 +-
src/runtime/providers.common.cpp | 10 -
src/runtime/ranger/CMakeLists.txt | 14 +-
.../ranger/ranger_resource_policy_manager.cpp | 3 +-
src/runtime/rpc/asio_net_provider.cpp | 21 +-
src/runtime/rpc/asio_rpc_session.cpp | 14 +-
src/runtime/rpc/dsn_message_parser.cpp | 9 -
src/runtime/rpc/dsn_message_parser.h | 10 +-
src/runtime/rpc/message_parser.cpp | 9 -
src/runtime/rpc/message_parser_manager.h | 9 -
src/runtime/rpc/network.cpp | 31 +-
src/runtime/rpc/network.h | 8 +-
src/runtime/rpc/network.sim.cpp | 9 -
src/runtime/rpc/raw_message_parser.cpp | 7 -
src/runtime/rpc/raw_message_parser.h | 9 +-
src/runtime/rpc/rpc_address.cpp | 4 +-
src/runtime/rpc/rpc_address.h | 8 +-
src/runtime/rpc/rpc_host_port.h | 4 +
src/runtime/rpc/rpc_message.cpp | 2 +-
src/runtime/rpc/rpc_message.h | 9 -
src/runtime/rpc/thrift_message_parser.cpp | 10 +-
src/runtime/scheduler.cpp | 17 +-
src/runtime/scheduler.h | 9 -
src/runtime/security/init.cpp | 10 +
src/runtime/security/kinit_context.cpp | 28 +
src/runtime/security/kinit_context.h | 1 +
src/runtime/security/negotiation_manager.cpp | 1 -
src/runtime/security/sasl_client_wrapper.cpp | 8 +-
src/runtime/security/sasl_server_wrapper.cpp | 8 +-
src/runtime/security/sasl_wrapper.cpp | 4 +-
src/runtime/serverlet.h | 1 +
src/runtime/service_app.h | 11 +-
src/runtime/service_engine.cpp | 1 -
src/runtime/service_engine.h | 9 -
src/runtime/simulator.cpp | 9 -
src/runtime/task/future_types.h | 1 +
src/runtime/task/hpc_task_queue.cpp | 2 +
src/runtime/task/simple_task_queue.cpp | 1 +
src/runtime/task/task.cpp | 4 +-
src/runtime/task/task.h | 2 +-
src/runtime/task/task_code.h | 11 +-
src/runtime/task/task_engine.cpp | 1 -
src/runtime/task/task_engine.h | 9 -
src/runtime/task/task_engine.sim.cpp | 9 -
src/runtime/task/task_engine.sim.h | 9 -
src/runtime/task/task_queue.cpp | 80 +-
src/runtime/task/task_queue.h | 19 +-
src/runtime/task/task_spec.h | 15 +-
src/runtime/task/task_worker.h | 10 +-
src/runtime/test/CMakeLists.txt | 16 +-
src/runtime/test/address_test.cpp | 4 +-
src/runtime/test/async_call.cpp | 14 +-
src/runtime/test/client_negotiation_test.cpp | 5 +-
src/runtime/test/corrupt_message.cpp | 2 +-
src/runtime/test/host_port_test.cpp | 4 +-
src/runtime/test/lpc.cpp | 13 +-
src/runtime/test/main.cpp | 11 +-
src/runtime/test/message_reader_test.cpp | 4 +-
src/runtime/test/message_utils_test.cpp | 4 +-
src/runtime/test/meta_access_controller_test.cpp | 4 +-
src/runtime/test/negotiation_manager_test.cpp | 5 +-
src/runtime/test/netprovider.cpp | 13 +-
src/runtime/test/pipeline_test.cpp | 5 +-
.../test/ranger_resource_policy_manager_test.cpp | 4 +-
src/runtime/test/ranger_resource_policy_test.cpp | 5 +-
.../test/replica_access_controller_test.cpp | 4 +-
src/runtime/test/rpc.cpp | 4 +-
src/runtime/test/rpc_holder_test.cpp | 4 +-
src/runtime/test/rpc_message.cpp | 13 +-
src/runtime/test/server_negotiation_test.cpp | 5 +-
src/runtime/test/service_api_c.cpp | 13 +-
src/runtime/test/sim_lock.cpp | 13 +-
src/runtime/test/task_engine.cpp | 13 +-
src/runtime/test/task_test.cpp | 15 +-
src/runtime/test/test_utils.h | 9 -
src/runtime/test/thrift_message_parser_test.cpp | 4 +-
src/runtime/tool_api.cpp | 9 -
src/runtime/tool_api.h | 16 +-
src/runtime/zlocks.cpp | 9 -
src/sample/CMakeLists.txt | 6 +-
src/server/CMakeLists.txt | 46 +-
src/server/available_detector.cpp | 3 +
src/server/capacity_unit_calculator.cpp | 149 +--
src/server/capacity_unit_calculator.h | 29 +-
src/server/compaction_filter_rule.cpp | 26 +-
src/server/compaction_filter_rule.h | 31 +-
src/server/compaction_operation.cpp | 19 +-
src/server/compaction_operation.h | 27 +-
src/server/config.ini | 20 +-
src/server/config.min.ini | 7 +-
src/server/hotkey_collector.cpp | 24 +-
src/server/hotkey_collector.h | 4 +-
src/server/hotspot_partition_calculator.cpp | 8 +-
src/server/hotspot_partition_calculator.h | 1 -
src/server/info_collector.h | 6 +-
src/server/info_collector_app.cpp | 11 +-
src/server/info_collector_app.h | 2 -
src/server/key_ttl_compaction_filter.h | 4 +-
src/server/main.cpp | 1 -
src/server/pegasus_event_listener.cpp | 124 +--
src/server/pegasus_event_listener.h | 26 +-
src/server/pegasus_manual_compact_service.cpp | 37 +-
src/server/pegasus_manual_compact_service.h | 6 +-
src/server/pegasus_mutation_duplicator.cpp | 49 +-
src/server/pegasus_mutation_duplicator.h | 12 +-
src/server/pegasus_scan_context.h | 2 +-
src/server/pegasus_server_impl.cpp | 664 +++++++-----
src/server/pegasus_server_impl.h | 114 +-
src/server/pegasus_server_impl_init.cpp | 457 ++++----
src/server/pegasus_server_write.cpp | 29 +-
src/server/pegasus_server_write.h | 4 +-
src/server/pegasus_service_app.h | 47 +-
src/server/pegasus_write_service.cpp | 290 ++---
src/server/pegasus_write_service.h | 52 +-
src/server/pegasus_write_service_impl.h | 86 +-
src/server/rocksdb_wrapper.cpp | 44 +-
src/server/rocksdb_wrapper.h | 21 +-
src/server/test/CMakeLists.txt | 16 +-
src/server/test/capacity_unit_calculator_test.cpp | 38 +-
src/server/test/compaction_filter_rule_test.cpp | 4 +-
src/server/test/compaction_operation_test.cpp | 4 +-
src/server/test/config.ini | 13 +-
src/server/test/hashkey_transform_test.cpp | 5 +-
src/server/test/hotkey_collector_test.cpp | 24 +-
src/server/test/hotspot_partition_test.cpp | 11 +-
src/server/test/manual_compact_service_test.cpp | 18 +-
.../test/pegasus_compression_options_test.cpp | 18 +-
.../test/pegasus_mutation_duplicator_test.cpp | 23 +-
src/server/test/pegasus_server_impl_test.cpp | 107 +-
src/server/test/pegasus_server_test_base.h | 15 +-
src/server/test/pegasus_server_write_test.cpp | 14 +-
src/server/test/pegasus_value_schema_test.cpp | 5 +-
.../test/pegasus_write_service_impl_test.cpp | 34 +-
src/server/test/pegasus_write_service_test.cpp | 20 +-
src/server/test/rocksdb_wrapper_test.cpp | 51 +-
src/server/test/run.sh | 21 +-
src/shell/CMakeLists.txt | 53 +-
src/shell/command_helper.h | 8 +-
src/shell/command_output.h | 1 -
src/shell/commands.h | 2 +-
src/shell/commands/bulk_load.cpp | 3 +-
src/shell/commands/cold_backup.cpp | 1 -
src/shell/commands/data_operations.cpp | 2 -
src/shell/commands/debugger.cpp | 70 +-
src/shell/commands/detect_hotkey.cpp | 3 -
src/shell/commands/duplication.cpp | 1 -
src/shell/commands/global_properties.cpp | 1 -
src/shell/commands/node_management.cpp | 1 -
src/shell/commands/rebalance.cpp | 1 -
src/shell/commands/recovery.cpp | 1 -
src/shell/commands/table_management.cpp | 2 -
src/shell/config.ini | 2 +-
src/shell/main.cpp | 4 +-
src/test/bench_test/CMakeLists.txt | 10 +-
src/test/bench_test/config.cpp | 4 +-
src/test/function_test/CMakeLists.txt | 16 +-
.../CMakeLists.txt | 22 +-
.../main.cpp | 0
.../backup_restore/test_backup_and_restore.cpp | 99 ++
.../test_backup_and_restore.cpp | 237 ----
.../{base_api_test => base_api}/CMakeLists.txt | 2 +-
.../integration_test.cpp | 10 +-
.../{base_api_test => base_api}/main.cpp | 0
.../{base_api_test => base_api}/test_basic.cpp | 4 +-
.../{base_api_test => base_api}/test_batch_get.cpp | 8 +-
.../test_check_and_mutate.cpp | 4 +-
.../test_check_and_set.cpp | 4 +-
.../{base_api_test => base_api}/test_copy.cpp | 23 +-
.../{base_api_test => base_api}/test_incr.cpp | 4 +-
.../test_range_read.cpp | 5 +-
.../{base_api_test => base_api}/test_recall.cpp | 8 +-
.../{base_api_test => base_api}/test_scan.cpp | 31 +-
.../{base_api_test => base_api}/test_ttl.cpp | 37 +-
.../{bulk_load_test => bulk_load}/CMakeLists.txt | 27 +-
.../{bulk_load_test => bulk_load}/main.cpp | 0
.../function_test/bulk_load/test_bulk_load.cpp | 374 +++++++
.../bulk_load_test/test_bulk_load.cpp | 317 ------
src/test/function_test/config.ini | 9 +-
.../CMakeLists.txt | 22 +-
.../main.cpp | 0
.../test_detect_hotspot.cpp | 45 +-
.../CMakeLists.txt | 2 +-
.../main.cpp | 0
.../test_split.cpp | 75 +-
.../{recovery_test => recovery}/CMakeLists.txt | 22 +-
.../{recovery_test => recovery}/main.cpp | 0
.../{recovery_test => recovery}/test_recovery.cpp | 13 +-
.../{restore_test => restore}/CMakeLists.txt | 23 +-
.../{restore_test => restore}/main.cpp | 0
src/test/function_test/restore/test_restore.cpp | 150 +++
.../function_test/restore_test/test_restore.cpp | 294 -----
src/test/function_test/run.sh | 2 +-
.../{throttle_test => throttle}/CMakeLists.txt | 2 +-
.../{throttle_test => throttle}/main.cpp | 0
.../{throttle_test => throttle}/test_throttle.cpp | 351 +++---
src/test/function_test/utils/global_env.cpp | 2 +-
src/test/function_test/utils/test_util.cpp | 161 ++-
src/test/function_test/utils/test_util.h | 53 +-
src/test/kill_test/CMakeLists.txt | 2 +-
src/test/kill_test/config.ini | 1 -
src/test/pressure_test/CMakeLists.txt | 2 +-
src/test_util/CMakeLists.txt | 7 +-
src/test_util/test_util.cpp | 26 +-
src/test_util/test_util.h | 68 +-
src/tools/mutation_log_tool.cpp | 62 +-
src/tools/mutation_log_tool.h | 15 +-
src/utils/CMakeLists.txt | 10 +-
src/utils/absl/base/internal/invoke.h | 218 ----
src/utils/absl/utility/utility.h | 207 ----
src/utils/alloc.h | 12 +-
src/utils/api_utilities.h | 3 +
src/utils/autoref_ptr.h | 11 +-
src/utils/binary_writer.h | 1 +
src/utils/blob.h | 7 +-
src/utils/builtin_metrics.cpp | 92 ++
src/utils/{preloadable.h => builtin_metrics.h} | 33 +-
src/utils/clock.cpp | 1 +
src/utils/command_manager.cpp | 3 +-
src/utils/config_api.cpp | 3 +
src/utils/config_api.h | 1 +
src/utils/configuration.cpp | 43 +-
src/utils/coredump.h | 9 -
src/utils/distributed_lock_service.h | 16 +-
src/utils/endians.h | 6 +-
src/utils/enum_helper.h | 72 +-
src/utils/env.cpp | 210 ++++
src/utils/env.h | 66 ++
src/utils/error_code.cpp | 1 +
src/utils/error_code.h | 12 +-
src/utils/errors.h | 16 +-
src/utils/exp_delay.h | 10 +-
src/utils/extensible_object.h | 10 +-
src/utils/factory_store.h | 10 +-
src/utils/fail_point.cpp | 30 +-
src/utils/fail_point.h | 6 +-
src/utils/fail_point_impl.h | 19 +-
src/utils/filesystem.cpp | 341 +++---
src/utils/filesystem.h | 27 +-
src/utils/fixed_size_buffer_pool.h | 1 +
src/utils/flags.h | 3 +-
src/utils/fmt_logging.h | 20 +-
.../hotspot_partition_stat.h => utils/fmt_utils.h} | 28 +-
src/utils/gpid.cpp | 1 +
src/utils/je_ctl.cpp | 2 +-
src/utils/join_point.h | 3 +-
src/utils/latency_tracer.cpp | 178 ++-
src/utils/latency_tracer.h | 3 -
src/utils/link.h | 11 +-
src/utils/lockp.std.h | 9 -
src/utils/long_adder_bench/CMakeLists.txt | 12 +-
src/utils/long_adder_bench/long_adder_bench.cpp | 23 +-
src/{http/uri_decoder.h => utils/macros.h} | 23 +-
src/utils/memutil.h | 25 -
src/utils/metrics.cpp | 18 +-
src/utils/metrics.h | 422 +++++++-
src/utils/output_utils.cpp | 1 +
src/utils/output_utils.h | 1 +
src/utils/priority_queue.h | 9 -
src/utils/shared_io_service.h | 9 -
src/utils/simple_logger.cpp | 41 +-
src/utils/simple_logger.h | 24 +-
src/utils/singleton_store.h | 9 -
src/utils/smart_pointers.h | 132 ---
src/utils/string_conv.h | 18 +-
src/utils/string_view.cpp | 106 --
src/utils/string_view.h | 430 --------
src/utils/strings.h | 1 +
src/utils/synchronize.h | 1 +
src/utils/test/CMakeLists.txt | 17 +-
src/utils/test/TokenBucketTest.cpp | 6 +-
src/utils/test/autoref_ptr_test.cpp | 6 +-
src/utils/test/binary_reader_test.cpp | 5 +-
src/utils/test/command_manager_test.cpp | 5 +-
src/utils/test/configuration.cpp | 6 +-
src/utils/test/endian_test.cpp | 5 +-
src/utils/test/enum_helper_test.cpp | 211 ++++
src/utils/test/env.cpp | 287 ++++-
src/utils/test/fail_point_test.cpp | 13 +-
src/utils/test/file_system_test.cpp | 148 ++-
src/utils/test/file_utils.cpp | 1137 +++++---------------
src/utils/test/flag_test.cpp | 4 +-
src/utils/test/fmt_logging_test.cpp | 13 +-
src/utils/test/hostname_test.cpp | 4 +-
src/utils/test/je_ctl_test.cpp | 33 +-
src/utils/test/join_point_test.cpp | 6 +-
src/utils/test/json_helper_test.cpp | 5 +-
src/utils/test/latency_tracer_test.cpp | 6 +-
src/utils/test/lock.std.cpp | 5 +-
src/utils/test/logger.cpp | 5 +-
src/utils/test/logging.cpp | 23 +-
src/utils/test/long_adder_test.cpp | 5 +-
src/utils/test/main.cpp | 1 +
src/utils/test/memutil_test.cpp | 33 -
src/utils/test/metrics_test.cpp | 186 +++-
src/utils/test/nth_element_bench/CMakeLists.txt | 12 +-
src/utils/test/nth_element_test.cpp | 6 +-
src/utils/test/nth_element_utils.h | 6 +-
src/utils/test/output_utils_test.cpp | 5 +-
src/utils/test/priority_queue.cpp | 13 +-
src/utils/test/rand_test.cpp | 5 +-
src/utils/test/sema.cpp | 15 +-
src/utils/test/smart_pointers_test.cpp | 118 --
src/utils/test/string_conv_test.cpp | 51 +-
src/utils/test/string_view_test.cpp | 441 --------
src/utils/test/time_utils_test.cpp | 4 +-
.../token_bucket_throttling_controller_test.cpp | 5 +-
src/utils/test/token_buckets_test.cpp | 4 +-
src/utils/test/utils.cpp | 15 +-
src/utils/thread_access_checker.h | 1 +
src/utils/threadpool_code.h | 3 +
src/utils/threadpool_spec.h | 1 +
src/utils/throttling_controller.cpp | 1 +
src/utils/time_utils.cpp | 3 -
src/utils/time_utils.h | 33 +-
src/utils/utils.cpp | 9 -
src/utils/utils.h | 2 +-
src/utils/work_queue.h | 10 +-
src/zookeeper/CMakeLists.txt | 2 +-
.../distributed_lock_service_zookeeper.cpp | 7 -
src/zookeeper/distributed_lock_service_zookeeper.h | 7 -
src/zookeeper/lock_struct.cpp | 8 -
src/zookeeper/lock_struct.h | 9 +-
src/zookeeper/lock_types.h | 7 -
src/zookeeper/test/CMakeLists.txt | 21 +-
src/zookeeper/test/config-test.ini | 4 +-
src/zookeeper/test/distributed_lock_zookeeper.cpp | 5 +-
src/zookeeper/zookeeper_error.cpp | 8 -
src/zookeeper/zookeeper_error.h | 7 -
src/zookeeper/zookeeper_session.cpp | 8 -
src/zookeeper/zookeeper_session.h | 12 +-
src/zookeeper/zookeeper_session_mgr.cpp | 8 -
src/zookeeper/zookeeper_session_mgr.h | 11 +-
thirdparty/CMakeLists.txt | 365 ++++---
thirdparty/fix_fds_for_macos.patch | 14 -
thirdparty/fix_rocksdb-cmake-PORTABLE-option.patch | 75 ++
thirdparty/fix_s2_build_with_absl_and_gtest.patch | 42 +
thirdparty/fix_s2_for_aarch64.patch | 10 -
thirdparty/fix_snappy-Wsign-compare-warning.patch | 26 +
thirdparty/rocksdb_fix_atomic_flush_0879c240.patch | 213 ----
821 files changed, 17172 insertions(+), 16039 deletions(-)
create mode 100755 .github/workflows/free_disk_space.sh
copy .github/workflows/{lint_and_test_pegic.yml =>
lint_and_test_collector.yml} (70%)
create mode 100644 DISCLAIMER
delete mode 100644 DISCLAIMER-WIP
create mode 100644 HISTORY.md
copy src/geo/CMakeLists.txt => collector/Makefile (90%)
create mode 100644 collector/README.md
create mode 100644 collector/aggregate/aggregatable.go
create mode 100644 collector/aggregate/aggregator.go
create mode 100644 collector/aggregate/aggregator_test.go
create mode 100644 collector/aggregate/history.go
copy src/runtime/ranger/access_type.cpp => collector/aggregate/history_test.go
(57%)
create mode 100644 collector/aggregate/hook.go
create mode 100644 collector/aggregate/hook_test.go
create mode 100644 collector/aggregate/perf_client.go
create mode 100644 collector/aggregate/perf_client_test.go
create mode 100644 collector/aggregate/perf_counter_decoder.go
create mode 100644 collector/aggregate/perf_counter_decoder_test.go
create mode 100644 collector/aggregate/perf_session.go
create mode 100644 collector/aggregate/table_stats.go
create mode 100644 collector/avail/detector.go
copy docker/pegasus-docker-compose/clear_onebox.sh => collector/config.yml
(59%)
mode change 100755 => 100644
create mode 100644 collector/go.mod
copy {admin-cli => collector}/go.sum (87%)
copy src/http/service_version.cpp => collector/hotspot/algo.go (89%)
create mode 100644 collector/main.go
copy src/perf_counter/test/main.cpp =>
collector/metrics/meta_server_metrics.go (82%)
create mode 100644 collector/metrics/metric_collector.go
copy src/perf_counter/test/main.cpp =>
collector/metrics/replica_server_metrics.go (81%)
create mode 100644 collector/sink/falcon_sink.go
create mode 100644 collector/sink/prometheus_sink.go
create mode 100644 collector/sink/sink.go
create mode 100644 collector/templates/index.html
create mode 100644 collector/usage/usage_recorder.go
create mode 100644 collector/webui/index.go
copy src/utils/clock.cpp => collector/webui/tables.go (53%)
create mode 100644 collector/webui/webserver.go
delete mode 100644 docker/ci-env/Dockerfile
create mode 100755 scripts/check_license.py
create mode 100644 src/base/test/redact_sensitive_string_test.cpp
delete mode 100644 src/block_service/directio_writable_file.cpp
delete mode 100644 src/block_service/directio_writable_file.h
delete mode 100644 src/block_service/fds/CMakeLists.txt
delete mode 100644 src/block_service/fds/fds_service.cpp
delete mode 100644 src/block_service/fds/fds_service.h
delete mode 100644 src/block_service/test/fds_service_test.cpp
create mode 100644 src/http/http_client.cpp
create mode 100644 src/http/http_client.h
copy src/http/{service_version.h => http_method.h} (74%)
delete mode 100644 src/http/perf_counter_http_service.cpp
copy src/{sample/config.ini => http/test/config-test.ini} (62%)
create mode 100644 src/http/test/http_client_test.cpp
create mode 100644 src/http/test/main.cpp
delete mode 100644 src/http/test/perf_counter_http_service_test.cpp
create mode 100644 src/meta/table_metrics.cpp
create mode 100644 src/meta/table_metrics.h
rename src/nfs/{nfs_node_impl.cpp => nfs_node_simple.cpp} (91%)
delete mode 100644 src/perf_counter/builtin_counters.cpp
delete mode 100644 src/perf_counter/builtin_counters.h
copy src/{meta/app_env_validator.h => replica/replica_base.cpp} (50%)
delete mode 100644 src/reporter/CMakeLists.txt
delete mode 100644 src/reporter/pegasus_counter_reporter.cpp
delete mode 100644 src/reporter/pegasus_counter_reporter.h
delete mode 100644 src/reporter/pegasus_io_service.h
rename src/test/function_test/{backup_restore_test =>
backup_restore}/CMakeLists.txt (79%)
rename src/test/function_test/{backup_restore_test => backup_restore}/main.cpp
(100%)
create mode 100644
src/test/function_test/backup_restore/test_backup_and_restore.cpp
delete mode 100644
src/test/function_test/backup_restore_test/test_backup_and_restore.cpp
rename src/test/function_test/{base_api_test => base_api}/CMakeLists.txt (95%)
rename src/test/function_test/{base_api_test => base_api}/integration_test.cpp
(95%)
rename src/test/function_test/{base_api_test => base_api}/main.cpp (100%)
rename src/test/function_test/{base_api_test => base_api}/test_basic.cpp (99%)
rename src/test/function_test/{base_api_test => base_api}/test_batch_get.cpp
(95%)
rename src/test/function_test/{base_api_test =>
base_api}/test_check_and_mutate.cpp (99%)
rename src/test/function_test/{base_api_test =>
base_api}/test_check_and_set.cpp (99%)
rename src/test/function_test/{base_api_test => base_api}/test_copy.cpp (91%)
rename src/test/function_test/{base_api_test => base_api}/test_incr.cpp (98%)
rename src/test/function_test/{base_api_test => base_api}/test_range_read.cpp
(97%)
rename src/test/function_test/{base_api_test => base_api}/test_recall.cpp (92%)
rename src/test/function_test/{base_api_test => base_api}/test_scan.cpp (93%)
rename src/test/function_test/{base_api_test => base_api}/test_ttl.cpp (82%)
rename src/test/function_test/{bulk_load_test => bulk_load}/CMakeLists.txt
(78%)
rename src/test/function_test/{bulk_load_test => bulk_load}/main.cpp (100%)
create mode 100644 src/test/function_test/bulk_load/test_bulk_load.cpp
delete mode 100644 src/test/function_test/bulk_load_test/test_bulk_load.cpp
rename src/test/function_test/{detect_hotspot_test =>
detect_hotspot}/CMakeLists.txt (83%)
rename src/test/function_test/{detect_hotspot_test => detect_hotspot}/main.cpp
(100%)
rename src/test/function_test/{detect_hotspot_test =>
detect_hotspot}/test_detect_hotspot.cpp (84%)
rename src/test/function_test/{partition_split_test =>
partition_split}/CMakeLists.txt (95%)
rename src/test/function_test/{partition_split_test =>
partition_split}/main.cpp (100%)
rename src/test/function_test/{partition_split_test =>
partition_split}/test_split.cpp (82%)
rename src/test/function_test/{recovery_test => recovery}/CMakeLists.txt (83%)
rename src/test/function_test/{recovery_test => recovery}/main.cpp (100%)
rename src/test/function_test/{recovery_test => recovery}/test_recovery.cpp
(94%)
rename src/test/function_test/{restore_test => restore}/CMakeLists.txt (83%)
rename src/test/function_test/{restore_test => restore}/main.cpp (100%)
create mode 100644 src/test/function_test/restore/test_restore.cpp
delete mode 100644 src/test/function_test/restore_test/test_restore.cpp
rename src/test/function_test/{throttle_test => throttle}/CMakeLists.txt (95%)
rename src/test/function_test/{throttle_test => throttle}/main.cpp (100%)
rename src/test/function_test/{throttle_test => throttle}/test_throttle.cpp
(65%)
delete mode 100644 src/utils/absl/base/internal/invoke.h
delete mode 100644 src/utils/absl/utility/utility.h
create mode 100644 src/utils/builtin_metrics.cpp
copy src/utils/{preloadable.h => builtin_metrics.h} (67%)
create mode 100644 src/utils/env.cpp
create mode 100644 src/utils/env.h
copy src/{server/hotspot_partition_stat.h => utils/fmt_utils.h} (58%)
copy src/{http/uri_decoder.h => utils/macros.h} (71%)
delete mode 100644 src/utils/memutil.h
delete mode 100644 src/utils/smart_pointers.h
delete mode 100644 src/utils/string_view.cpp
delete mode 100644 src/utils/string_view.h
create mode 100644 src/utils/test/enum_helper_test.cpp
delete mode 100644 src/utils/test/memutil_test.cpp
delete mode 100644 src/utils/test/smart_pointers_test.cpp
delete mode 100644 src/utils/test/string_view_test.cpp
delete mode 100644 thirdparty/fix_fds_for_macos.patch
create mode 100644 thirdparty/fix_rocksdb-cmake-PORTABLE-option.patch
create mode 100644 thirdparty/fix_s2_build_with_absl_and_gtest.patch
delete mode 100644 thirdparty/fix_s2_for_aarch64.patch
create mode 100644 thirdparty/fix_snappy-Wsign-compare-warning.patch
delete mode 100644 thirdparty/rocksdb_fix_atomic_flush_0879c240.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
