This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/go-client/golang.org/x/sys-0.1.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard 2caac3c49 build(deps): bump golang.org/x/sys in /go-client
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 6b9fba392 refactor: minor refactor on class fs_manager (#1476)
add ccd01c593 refactor: remove some useless code (#1480)
add d5f225967 refactor: improve the single-responsibility of class
fs_manager (#1477)
add 5404c4047 refactor: update replica's dir_node status (part1) (#1487)
add 86181aac9 chore(github): remove directories and tarballs after packing
server and tools for github actions in case of running out of disk space (#1486)
add 766e64baa fix: fix start_onebox failed because of libjvm.so not found
(#1494)
add 8706026ad chore(github): remove CMakeFiles during Tar files in case of
running out of disk space (#1498)
add e4350d4c7 refactor: update replica's dir_node status (part2) (#1489)
add bbdb7041d feat(Ranger): remove ACL of RPC_CM_LIST_APPS from global
resource (#1500)
add 99477dac0 refactor: remove counter_info and counter_info_ptr (#1509)
add 09c962d01 chore: update rocksdb install url on thirdparty (#1516)
add a0881816f chore(build): separate the build directory of IWYU version
(#1519)
add 4dcbb1e28 feat: skip IO_ERROR dir_node when assign replicas (#1512)
add d216696e5 refactor: improve the single-responsibility of class
fs_manager (2/n) (#1522)
add f3d13881a feat(Ranger): add a default database policy name for legacy
table (#1507)
add 4ae39997b feat(FQDN): serialization format rpc_host_port (#1496)
add 6972752a5 fix: fix invaild build type (#1521)
add a509e8a92 fix(shell): fix the additional options not applied bug of
command "./run.sh test" (#1526)
add 96116f6dd fix(github): throttle_test failed frequently due to
insufficient disk space (#1530)
add 992cae4e4 feat(replica): close the replica and mark the dir_node as
IO_ERROR when encounter read/write IO error (#1473)
add 78136dd0a feat(Ranger): refactor the logic when ranger performs ACL
(#1518)
add df658a7a1 build: add a devcontainer.json (#1544)
add 93ccdc370 fix: fix build failure on older Ubuntu&GCC versions (#1555)
add 2c9dc39cd chore: remove the supporting of EOL OS ubuntu 16.04 (#1553)
add 5f83f7492 chore: remove the supporting of EOL OS CentOS 6 (#1557)
add 614623301 fix(docker): fix pegasus-build-env of ubuntu:18.04
Dockerfile (#1558)
add 99456f491 fix(rocksdb): turn off write_global_seqno by default (#1563)
add e3ffcbcaa chore(github): add some contributors into apache
collaborators to allow them to use github actions (#1566)
add 117f604f3 fix(logs): fix logs in FATAL level not take effect (#1573)
add 4b0ea2650 fix(slog): add an option to exit the process when find slog
error (#1574)
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 edb2ec422 fix(java-client): use junit5 as the only testing framework
(#1755)
add 223b5c708 chore(java-client-ci): build the server instead of
downloading it from external site (#1778)
add aacfd56f9 build(deps): bump github.com/valyala/fasthttp in /collector
(#1787)
add 025687262 build(deps): bump github.com/kataras/iris/v12 from 12.1.8 to
12.2.0 in /collector (#1786)
add b174ede24 build(deps): bump github.com/prometheus/client_golang in
/collector (#1785)
add 78256d0f0 build(deps): bump golang.org/x/net from
0.0.0-20210415231046-e915ea6b2b7d to 0.17.0 in /pegic (#1783)
add e1fce3488 fix(rocksdb): specify the HINTS for zstd/lz4/snappy in
third-party CMakeLists allowing rocksdb to find them (#1777)
add 703e61eff build(deps): bump golang.org/x/sys in /go-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 (2caac3c49)
\
N -- N -- N
refs/heads/dependabot/go_modules/go-client/golang.org/x/sys-0.1.0 (703e61eff)
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 | 6 +
.devcontainer/devcontainer.json | 11 +
.github/workflows/build-push-env-docker.yml | 7 +-
.github/workflows/free_disk_space.sh | 70 +
.github/workflows/labeler.yml | 4 +-
.github/workflows/lint_and_test_admin-cli.yml | 8 +-
..._test_pegic.yml => lint_and_test_collector.yml} | 35 +-
.github/workflows/lint_and_test_cpp.yaml | 278 +++-
.github/workflows/lint_and_test_go-client.yml | 4 +-
.github/workflows/lint_and_test_pegic.yml | 12 +-
.github/workflows/module_labeler_conf.yml | 2 +
.github/workflows/regular-build.yml | 55 +-
.github/workflows/standardization_lint.yaml | 20 +-
.github/workflows/test_java-client.yml | 75 +-
.github/workflows/test_scala-client.yml | 2 +-
.github/workflows/thirdparty-regular-push.yml | 24 +-
.gitignore | 5 +-
.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/replica/test/clear.sh => collector/Makefile | 10 +-
.../findbugs-exclude.xml => 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 | 43 +-
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 ++
.../test/CMakeLists.txt => collector/config.yml | 39 +-
{pegic => collector}/go.mod | 21 +-
{admin-cli => collector}/go.sum | 613 ++++----
.../kinit_context.h => collector/hotspot/algo.go | 11 +-
collector/main.go | 101 ++
.../metrics/meta_server_metrics.go | 14 +-
collector/metrics/metric_collector.go | 514 +++++++
.../metrics/replica_server_metrics.go | 14 +-
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 | 50 +-
collector/webui/webserver.go | 61 +
docker/README.md | 18 +-
docker/ci-env/Dockerfile | 33 -
docker/pegasus-build-env/centos6/Dockerfile | 87 --
docker/pegasus-build-env/centos7/Dockerfile | 11 +-
docker/pegasus-build-env/ubuntu1604/Dockerfile | 69 -
docker/pegasus-build-env/ubuntu1804/Dockerfile | 11 +-
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 +-
go-client/pegasus/table_connector.go | 3 +
go-client/pegasus/table_connector_test.go | 2 +-
go-client/session/session.go | 12 +-
idl/dsn.thrift | 5 +
idl/metadata.thrift | 7 +-
java-client/dev-support/findbugs-exclude.xml | 2 +
java-client/pom.xml | 50 +-
java-client/scripts/ci-test.sh | 72 -
.../org/apache/pegasus/client/ListAppInfoType.java | 20 +-
.../apache/pegasus/client/PegasusAdminClient.java | 31 +
.../client/PegasusAdminClientInterface.java | 12 +
.../org/apache/pegasus/client/PegasusTable.java | 2 +
.../pegasus/operator/list_apps_operator.java | 68 +
.../org/apache/pegasus/rpc/async/MetaSession.java | 3 +
.../apache/pegasus/security/KerberosProtocol.java | 40 +-
.../org/apache/pegasus/base/TestRpcAddress.java | 30 +-
.../apache/pegasus/client/PegasusScannerTest.java | 156 +-
.../org/apache/pegasus/client/TestAdminClient.java | 58 +-
.../java/org/apache/pegasus/client/TestBasic.java | 1478 +++++++++---------
.../java/org/apache/pegasus/client/TestBatch.java | 41 +-
.../pegasus/client/TestBatchGetByPartitions.java | 21 +-
.../java/org/apache/pegasus/client/TestBench.java | 30 +-
.../apache/pegasus/client/TestCheckAndMutate.java | 787 +++++-----
.../org/apache/pegasus/client/TestCheckAndSet.java | 761 ++++-----
.../org/apache/pegasus/client/TestFutureGroup.java | 23 +-
.../java/org/apache/pegasus/client/TestIncr.java | 46 +-
.../org/apache/pegasus/client/TestMultiThread.java | 12 +-
.../org/apache/pegasus/client/TestNoOperate.java | 2 +-
.../org/apache/pegasus/client/TestPException.java | 22 +-
.../java/org/apache/pegasus/client/TestPing.java | 58 +-
.../java/org/apache/pegasus/client/TestPingZK.java | 10 +-
.../org/apache/pegasus/client/TestTimeout.java | 2 +-
.../apache/pegasus/metrics/MetricsPoolTest.java | 73 +-
.../pegasus/operator/ClientOperatorTest.java | 16 +-
.../pegasus/rpc/async/ClusterManagerTest.java | 32 +-
.../apache/pegasus/rpc/async/InterceptorTest.java | 19 +-
.../apache/pegasus/rpc/async/MetaSessionTest.java | 51 +-
.../pegasus/rpc/async/ReplicaSessionTest.java | 51 +-
.../apache/pegasus/rpc/async/TableHandlerTest.java | 59 +-
.../apache/pegasus/rpc/async/TimeoutBenchmark.java | 12 +-
.../apache/pegasus/security/NegotiationTest.java | 47 +-
.../org/apache/pegasus/tools/TestZstdWrapper.java | 21 +-
.../src/test/resources/simplelogger.properties | 2 +-
nodejs-client/package.json | 2 +-
pegic/go.mod | 3 +-
pegic/go.sum | 38 +-
python-client/pypegasus/__init__.py | 2 +-
run.sh | 237 ++-
scala-client/build.sbt | 4 +-
scala-client/scripts/ci-test.sh | 4 +
scripts/check_license.py | 213 +++
scripts/config_hdfs.sh | 16 +-
scripts/downgrade_node.sh | 50 +-
scripts/migrate_node.sh | 49 +-
scripts/pack_client.sh | 14 +-
scripts/pack_common.sh | 10 +-
scripts/pack_server.sh | 23 +-
scripts/pack_tools.sh | 27 +-
src/CMakeLists.txt | 3 +-
src/aio/CMakeLists.txt | 7 +-
src/aio/aio_provider.cpp | 4 +
src/aio/aio_provider.h | 25 +-
src/aio/aio_task.cpp | 21 +-
src/aio/aio_task.h | 11 +
src/aio/disk_engine.cpp | 32 +-
src/aio/disk_engine.h | 21 +-
src/aio/file_io.cpp | 57 +-
src/aio/file_io.h | 22 +-
src/aio/native_linux_aio_provider.cpp | 140 +-
src/aio/native_linux_aio_provider.h | 24 +-
src/aio/test/CMakeLists.txt | 14 +-
src/aio/test/aio.cpp | 456 ++++--
src/aio/test/config.ini | 5 +
src/base/idl_utils.h | 18 +-
src/base/pegasus_const.cpp | 49 +
src/base/pegasus_const.h | 22 +
src/base/pegasus_utils.cpp | 9 +-
src/base/pegasus_utils.h | 43 +-
src/base/pegasus_value_schema.h | 33 +-
src/base/test/CMakeLists.txt | 10 +-
src/base/test/main.cpp | 3 -
src/base/test/redact_sensitive_string_test.cpp | 67 +
src/base/test/utils_test.cpp | 5 +-
src/base/test/value_manager_test.cpp | 11 +-
src/base/test/value_schema_test.cpp | 25 +-
src/base/value_field.h | 7 +-
src/base/value_schema_manager.cpp | 15 +-
src/base/value_schema_manager.h | 7 +-
src/base/value_schema_v0.cpp | 19 +-
src/base/value_schema_v0.h | 11 +-
src/base/value_schema_v1.cpp | 23 +-
src/base/value_schema_v1.h | 13 +-
src/base/value_schema_v2.cpp | 23 +-
src/base/value_schema_v2.h | 13 +-
src/block_service/CMakeLists.txt | 1 -
src/block_service/block_service.h | 6 +-
src/block_service/block_service_manager.cpp | 29 +-
src/block_service/block_service_manager.h | 10 +-
src/block_service/directio_writable_file.cpp | 169 --
src/block_service/directio_writable_file.h | 55 -
src/block_service/fds/CMakeLists.txt | 35 -
src/block_service/fds/fds_service.cpp | 713 ---------
src/block_service/fds/fds_service.h | 143 --
src/block_service/hdfs/CMakeLists.txt | 13 +-
src/block_service/hdfs/hdfs_service.cpp | 201 ++-
src/block_service/hdfs/hdfs_service.h | 19 +-
src/block_service/local/CMakeLists.txt | 6 +-
src/block_service/local/local_service.cpp | 409 ++---
src/block_service/local/local_service.h | 28 +-
src/block_service/test/CMakeLists.txt | 31 +-
.../test/block_service_manager_test.cpp | 85 +-
src/block_service/test/config-test.ini | 9 +-
src/block_service/test/fds_service_test.cpp | 808 ----------
src/block_service/test/hdfs_service_test.cpp | 382 +++--
src/block_service/test/local_service_test.cpp | 74 +-
src/block_service/test/main.cpp | 16 +-
src/client/CMakeLists.txt | 2 +
src/client/partition_resolver.cpp | 11 +-
src/client/partition_resolver.h | 16 +-
src/client/partition_resolver_manager.cpp | 6 +-
src/client/partition_resolver_manager.h | 9 +-
src/client/partition_resolver_simple.cpp | 21 +-
src/client/partition_resolver_simple.h | 20 +-
src/client/replication_ddl_client.cpp | 318 ++--
src/client/replication_ddl_client.h | 155 +-
src/{replica/backup => client}/test/CMakeLists.txt | 20 +-
src/{shell => client/test}/config.ini | 0
src/client/test/ddl_client_test.cpp | 150 ++
.../builtin_counters.h => client/test/main.cpp} | 19 +-
src/{replica/test/clear.sh => client/test/run.sh} | 12 +-
src/client_lib/mutation.cpp | 6 +
src/client_lib/pegasus_client_factory_impl.cpp | 11 +
src/client_lib/pegasus_client_factory_impl.h | 12 +-
src/client_lib/pegasus_client_impl.cpp | 43 +-
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 | 16 +-
src/common/fs_manager.cpp | 647 +++++---
src/common/fs_manager.h | 186 ++-
src/common/gpid.h | 5 +
src/common/json_helper.h | 59 +-
src/common/replica_envs.h | 7 +
src/common/replication.codes.h | 6 +-
src/common/replication_common.cpp | 162 +-
src/common/replication_common.h | 57 +-
src/common/replication_enums.h | 21 +
src/common/replication_other_types.h | 8 -
src/common/serialization_helper/thrift_helper.h | 107 +-
src/common/storage_serverlet.h | 37 +-
src/common/test/CMakeLists.txt | 8 +-
src/common/test/common_test.cpp | 5 +-
src/common/test/config-test.ini | 4 +-
src/common/test/duplication_common_test.cpp | 6 +-
src/common/test/fs_manager_test.cpp | 183 ++-
src/common/test/main.cpp | 16 +-
src/common/test/replication_common_test.cpp | 8 +-
src/common/test/run.sh | 21 +-
src/failure_detector/CMakeLists.txt | 4 +-
src/failure_detector/failure_detector.cpp | 30 +-
src/failure_detector/failure_detector.h | 81 +-
.../failure_detector_multimaster.cpp | 17 +-
.../failure_detector_multimaster.h | 7 +
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 | 13 +-
.../test/config-whitelist-test-failed.ini | 13 +-
.../test/config-whitelist-test.ini | 13 +-
src/failure_detector/test/failure_detector.cpp | 47 +-
src/failure_detector/test/main.cpp | 25 +-
src/geo/bench/CMakeLists.txt | 12 +-
src/geo/bench/bench.cpp | 34 +-
src/geo/lib/geo_client.cpp | 106 +-
src/geo/lib/geo_client.h | 19 +-
src/geo/lib/latlng_codec.cpp | 19 +-
src/geo/lib/latlng_codec.h | 5 +-
src/geo/test/CMakeLists.txt | 4 +-
src/geo/test/geo_test.cpp | 39 +-
src/geo/test/latlng_codec_test.cpp | 9 +-
src/geo/test/main.cpp | 6 +-
src/http/builtin_http_calls.cpp | 16 +-
src/http/builtin_http_calls.h | 8 +-
src/http/config_http_service.cpp | 6 +-
src/http/http_call_registry.h | 18 +-
src/http/http_client.cpp | 346 +++++
src/http/http_client.h | 157 ++
src/http/http_message_parser.cpp | 23 +-
src/http/http_message_parser.h | 13 +-
src/http/{uri_decoder.h => http_method.h} | 27 +-
src/http/http_server.cpp | 31 +-
src/http/http_server.h | 17 +-
src/http/perf_counter_http_service.cpp | 57 -
src/http/pprof_http_service.cpp | 107 +-
src/http/pprof_http_service.h | 4 +
src/http/test/CMakeLists.txt | 16 +-
.../config.ini => http/test/config-test.ini} | 78 +-
src/http/test/http_client_test.cpp | 214 +++
src/http/test/http_server_test.cpp | 41 +-
src/http/test/main.cpp | 120 ++
src/http/test/perf_counter_http_service_test.cpp | 73 -
src/http/test/uri_decoder_test.cpp | 7 +-
src/http/uri_decoder.cpp | 10 +-
src/http/uri_decoder.h | 4 +-
src/include/pegasus/client.h | 5 +
src/include/pegasus/version.h | 2 +-
src/meta/CMakeLists.txt | 40 +-
src/meta/app_balance_policy.cpp | 32 +-
src/meta/app_balance_policy.h | 12 +
src/meta/app_env_validator.cpp | 73 +-
src/meta/app_env_validator.h | 2 +
src/meta/backup_engine.cpp | 37 +-
src/meta/backup_engine.h | 19 +-
src/meta/cluster_balance_policy.cpp | 14 +-
src/meta/cluster_balance_policy.h | 24 +-
src/meta/distributed_lock_service_simple.cpp | 15 +-
src/meta/distributed_lock_service_simple.h | 27 +-
src/meta/dump_file.h | 2 +
src/meta/duplication/duplication_info.cpp | 5 +-
src/meta/duplication/duplication_info.h | 29 +-
src/meta/duplication/meta_duplication_service.cpp | 49 +-
src/meta/duplication/meta_duplication_service.h | 19 +-
src/meta/greedy_load_balancer.cpp | 81 +-
src/meta/greedy_load_balancer.h | 25 +-
src/meta/load_balance_policy.cpp | 21 +-
src/meta/load_balance_policy.h | 28 +-
src/meta/meta_backup_service.cpp | 156 +-
src/meta/meta_backup_service.h | 72 +-
src/meta/meta_bulk_load_ingestion_context.cpp | 22 +-
src/meta/meta_bulk_load_ingestion_context.h | 12 +-
src/meta/meta_bulk_load_service.cpp | 51 +-
src/meta/meta_bulk_load_service.h | 32 +-
src/meta/meta_data.cpp | 40 +-
src/meta/meta_data.h | 51 +-
src/meta/meta_http_service.cpp | 70 +-
src/meta/meta_http_service.h | 7 +-
src/meta/meta_options.cpp | 110 +-
src/meta/meta_options.h | 50 +-
src/meta/meta_server_failure_detector.cpp | 21 +-
src/meta/meta_server_failure_detector.h | 25 +-
src/meta/meta_service.cpp | 334 ++--
src/meta/meta_service.h | 223 ++-
src/meta/meta_service_app.cpp | 40 +-
src/meta/meta_service_app.h | 7 +-
src/meta/meta_split_service.cpp | 36 +-
src/meta/meta_split_service.h | 12 +-
src/meta/meta_state_service.h | 45 +-
src/meta/meta_state_service_simple.cpp | 134 +-
src/meta/meta_state_service_simple.h | 38 +-
src/meta/meta_state_service_utils.cpp | 26 +-
src/meta/meta_state_service_utils.h | 11 +-
src/meta/meta_state_service_utils_impl.h | 7 +-
src/meta/meta_state_service_zookeeper.cpp | 32 +-
src/meta/meta_state_service_zookeeper.h | 26 +-
src/meta/partition_guardian.cpp | 45 +-
src/meta/partition_guardian.h | 15 +-
src/meta/server_load_balancer.cpp | 16 +-
src/meta/server_load_balancer.h | 46 +-
src/meta/server_state.cpp | 158 +-
src/meta/server_state.h | 68 +-
src/meta/server_state_restore.cpp | 80 +-
src/meta/table_metrics.cpp | 389 +++++
src/meta/table_metrics.h | 257 ++++
src/meta/test/CMakeLists.txt | 10 +-
src/meta/test/backup_test.cpp | 66 +-
src/meta/test/balancer_simulator/CMakeLists.txt | 2 +-
.../test/balancer_simulator/balancer_simulator.cpp | 17 +-
src/meta/test/balancer_validator.cpp | 142 +-
src/meta/test/cluster_balance_policy_test.cpp | 23 +-
src/meta/test/config-test.ini | 8 +-
src/meta/test/copy_replica_operation_test.cpp | 18 +-
src/meta/test/dump_file.cpp | 12 +-
src/meta/test/duplication_info_test.cpp | 6 +-
src/meta/test/ford_fulkerson_test.cpp | 12 +-
src/meta/test/json_compacity.cpp | 32 +-
src/meta/test/main.cpp | 39 +-
src/meta/test/meta_app_envs_test.cpp | 38 +-
src/meta/test/meta_app_operation_test.cpp | 237 ++-
src/meta/test/meta_backup_test.cpp | 32 +-
src/meta/test/meta_bulk_load_ingestion_test.cpp | 20 +-
src/meta/test/meta_bulk_load_service_test.cpp | 52 +-
src/meta/test/meta_data.cpp | 13 +-
src/meta/test/meta_duplication_service_test.cpp | 53 +-
src/meta/test/meta_http_service_test.cpp | 41 +-
src/meta/test/meta_mauanl_compaction_test.cpp | 22 +-
src/meta/test/meta_partition_guardian_test.cpp | 48 +-
src/meta/test/meta_service_test.cpp | 29 +-
src/meta/test/meta_service_test_app.h | 11 +-
src/meta/test/meta_split_service_test.cpp | 64 +-
src/meta/test/meta_state/CMakeLists.txt | 2 +-
src/meta/test/meta_state/config-test.ini | 3 -
src/meta/test/meta_state/main.cpp | 34 +-
src/meta/test/meta_state/meta_state_service.cpp | 93 +-
src/meta/test/meta_state_service_utils_test.cpp | 40 +-
src/meta/test/meta_test_base.cpp | 45 +-
src/meta/test/meta_test_base.h | 22 +-
src/meta/test/misc/misc.cpp | 45 +-
src/meta/test/misc/misc.h | 31 +-
src/meta/test/run.sh | 21 +-
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 | 56 +-
src/nfs/nfs.thrift | 2 +
src/nfs/nfs_client_impl.cpp | 74 +-
src/nfs/nfs_client_impl.h | 53 +-
src/nfs/nfs_code_definition.h | 8 -
src/nfs/nfs_node.cpp | 15 +-
src/nfs/nfs_node.h | 30 +-
src/nfs/{nfs_node_impl.cpp => nfs_node_simple.cpp} | 53 +-
src/nfs/nfs_node_simple.h | 37 +-
src/nfs/nfs_server_impl.cpp | 154 +-
src/nfs/nfs_server_impl.h | 47 +-
src/nfs/test/CMakeLists.txt | 14 +-
src/nfs/test/main.cpp | 191 ++-
src/perf_counter/builtin_counters.cpp | 54 -
src/perf_counter/perf_counter.h | 7 +-
src/perf_counter/perf_counter_atomic.cpp | 13 +-
src/perf_counter/perf_counter_atomic.h | 27 +-
src/perf_counter/perf_counters.cpp | 24 +-
src/perf_counter/perf_counters.h | 9 +-
src/perf_counter/test/CMakeLists.txt | 12 +-
src/perf_counter/test/main.cpp | 13 -
src/perf_counter/test/perf_counter_test.cpp | 23 +-
src/perf_counter/test/perf_counters_test.cpp | 52 +-
src/redis_protocol/proxy/CMakeLists.txt | 5 +-
src/redis_protocol/proxy/main.cpp | 22 +-
src/redis_protocol/proxy_lib/proxy_layer.cpp | 8 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 28 +-
src/redis_protocol/proxy_lib/redis_parser.cpp | 62 +-
src/redis_protocol/proxy_lib/redis_parser.h | 19 +-
src/redis_protocol/proxy_ut/CMakeLists.txt | 4 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 44 +-
src/remote_cmd/CMakeLists.txt | 2 +-
src/remote_cmd/remote_command.cpp | 21 +-
src/remote_cmd/remote_command.h | 9 +-
src/replica/CMakeLists.txt | 36 +-
src/replica/backup/cold_backup_context.cpp | 41 +-
src/replica/backup/cold_backup_context.h | 17 +
src/replica/backup/replica_backup_manager.cpp | 56 +-
src/replica/backup/replica_backup_manager.h | 23 +-
src/replica/backup/replica_backup_server.cpp | 35 +-
src/replica/backup/replica_backup_server.h | 11 +-
src/replica/backup/test/CMakeLists.txt | 6 +-
src/replica/backup/test/config-test.ini | 3 +-
src/replica/backup/test/main.cpp | 16 +-
.../backup/test/replica_backup_manager_test.cpp | 13 +-
src/replica/backup/test/run.sh | 20 +-
src/replica/bulk_load/replica_bulk_loader.cpp | 123 +-
src/replica/bulk_load/replica_bulk_loader.h | 35 +-
src/replica/bulk_load/test/CMakeLists.txt | 8 +-
src/replica/bulk_load/test/config-test.ini | 8 +-
src/replica/bulk_load/test/main.cpp | 16 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 136 +-
src/replica/bulk_load/test/run.sh | 20 +-
src/replica/disk_cleaner.cpp | 241 ++-
src/replica/disk_cleaner.h | 35 +-
src/replica/duplication/duplication_pipeline.cpp | 34 +-
src/replica/duplication/duplication_pipeline.h | 15 +-
src/replica/duplication/duplication_sync_timer.cpp | 47 +-
src/replica/duplication/duplication_sync_timer.h | 19 +-
src/replica/duplication/load_from_private_log.cpp | 121 +-
src/replica/duplication/load_from_private_log.h | 26 +-
src/replica/duplication/mutation_batch.cpp | 39 +-
src/replica/duplication/mutation_batch.h | 14 +-
src/replica/duplication/mutation_duplicator.h | 6 +-
src/replica/duplication/replica_duplicator.cpp | 43 +-
src/replica/duplication/replica_duplicator.h | 36 +-
.../duplication/replica_duplicator_manager.cpp | 26 +-
.../duplication/replica_duplicator_manager.h | 35 +-
src/replica/duplication/replica_follower.cpp | 37 +-
src/replica/duplication/replica_follower.h | 15 +-
src/replica/duplication/test/CMakeLists.txt | 8 +-
src/replica/duplication/test/config-test.ini | 5 +-
.../test/dup_replica_http_service_test.cpp | 20 +-
.../test/duplication_sync_timer_test.cpp | 39 +-
.../duplication/test/duplication_test_base.h | 12 +-
.../test/load_from_private_log_test.cpp | 164 +-
src/replica/duplication/test/main.cpp | 16 +-
.../duplication/test/mutation_batch_test.cpp | 24 +-
.../test/replica_duplicator_manager_test.cpp | 37 +-
.../duplication/test/replica_duplicator_test.cpp | 39 +-
.../duplication/test/replica_follower_test.cpp | 44 +-
src/replica/duplication/test/run.sh | 20 +-
.../duplication/test/ship_mutation_test.cpp | 26 +-
src/replica/log_block.cpp | 4 +
src/replica/log_block.h | 9 +
src/replica/log_file.cpp | 56 +-
src/replica/log_file.h | 45 +-
src/replica/log_file_stream.h | 8 +-
src/replica/mutation.cpp | 28 +-
src/replica/mutation.h | 36 +-
src/replica/mutation_cache.cpp | 5 +
src/replica/mutation_cache.h | 8 +-
src/replica/mutation_log.cpp | 650 +-------
src/replica/mutation_log.h | 166 +-
src/replica/mutation_log_replay.cpp | 31 +-
src/replica/mutation_log_utils.cpp | 16 +-
src/replica/mutation_log_utils.h | 22 +-
src/replica/prepare_list.cpp | 9 +-
src/replica/prepare_list.h | 12 +-
src/replica/replica.cpp | 451 ++++--
src/replica/replica.h | 229 +--
src/replica/replica_2pc.cpp | 77 +-
src/replica/replica_backup.cpp | 67 +-
...ca_backup_manager_test.cpp => replica_base.cpp} | 44 +-
src/replica/replica_base.h | 23 +-
src/replica/replica_check.cpp | 61 +-
src/replica/replica_chkpt.cpp | 61 +-
src/replica/replica_config.cpp | 96 +-
src/replica/replica_context.cpp | 32 +-
src/replica/replica_context.h | 31 +-
src/replica/replica_disk_migrator.cpp | 80 +-
src/replica/replica_disk_migrator.h | 7 +
src/replica/replica_failover.cpp | 30 +-
src/replica/replica_http_service.cpp | 16 +-
src/replica/replica_http_service.h | 17 +-
src/replica/replica_init.cpp | 197 +--
src/replica/replica_learn.cpp | 130 +-
src/replica/replica_restore.cpp | 88 +-
src/replica/replica_stub.cpp | 1608 ++++++++------------
src/replica/replica_stub.h | 261 ++--
src/replica/replica_test_utils.cpp | 66 -
src/replica/replica_test_utils.h | 52 -
src/replica/replica_throttle.cpp | 30 +-
src/replica/replication_app_base.cpp | 295 ++--
src/replica/replication_app_base.h | 101 +-
src/replica/replication_service_app.cpp | 9 +-
src/replica/replication_service_app.h | 12 +-
src/replica/split/replica_split_manager.cpp | 144 +-
src/replica/split/replica_split_manager.h | 42 +-
src/replica/split/test/CMakeLists.txt | 2 +-
src/replica/split/test/config-test.ini | 8 +-
src/replica/split/test/main.cpp | 16 +-
src/replica/split/test/replica_split_test.cpp | 82 +-
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 | 20 +-
src/replica/storage/simple_kv/simple_kv.server.h | 15 +-
.../storage/simple_kv/simple_kv.server.impl.cpp | 159 +-
.../storage/simple_kv/simple_kv.server.impl.h | 28 +-
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 | 44 +-
src/replica/storage/simple_kv/test/case.h | 32 +-
src/replica/storage/simple_kv/test/checker.cpp | 54 +-
src/replica/storage/simple_kv/test/checker.h | 31 +-
src/replica/storage/simple_kv/test/client.cpp | 31 +-
src/replica/storage/simple_kv/test/client.h | 29 +-
src/replica/storage/simple_kv/test/common.cpp | 23 +-
src/replica/storage/simple_kv/test/common.h | 40 +-
src/replica/storage/simple_kv/test/config.ini | 3 +-
src/replica/storage/simple_kv/test/injector.cpp | 31 +-
src/replica/storage/simple_kv/test/injector.h | 11 +-
src/replica/storage/simple_kv/test/run.sh | 27 +
.../storage/simple_kv/test/simple_kv.main.cpp | 24 +-
.../simple_kv/test/simple_kv.server.impl.cpp | 155 +-
.../storage/simple_kv/test/simple_kv.server.impl.h | 22 +-
src/replica/test/CMakeLists.txt | 35 +-
src/replica/test/clear.sh | 2 +-
src/replica/test/cold_backup_context_test.cpp | 24 +-
src/replica/test/config-test.ini | 8 +-
src/replica/test/log_block_test.cpp | 33 +-
src/replica/test/log_file_test.cpp | 17 +-
src/replica/test/main.cpp | 39 +-
src/replica/test/mock_utils.h | 112 +-
src/replica/test/mutation_log_learn_test.cpp | 30 +-
src/replica/test/mutation_log_test.cpp | 126 +-
src/replica/test/open_replica_test.cpp | 112 +-
src/replica/test/replica_disk_migrate_test.cpp | 83 +-
src/replica/test/replica_disk_test.cpp | 228 ++-
src/replica/test/replica_disk_test_base.h | 108 +-
src/replica/test/replica_http_service_test.cpp | 68 +-
src/replica/test/replica_learn_test.cpp | 35 +-
src/replica/test/replica_test.cpp | 247 ++-
src/replica/test/replica_test_base.h | 24 +-
src/replica/test/run.sh | 21 +-
src/replica/test/throttling_controller_test.cpp | 2 +-
src/reporter/CMakeLists.txt | 44 -
src/reporter/pegasus_counter_reporter.cpp | 362 -----
src/reporter/pegasus_counter_reporter.h | 105 --
src/reporter/pegasus_io_service.h | 65 -
src/runtime/CMakeLists.txt | 2 +
src/runtime/api_task.h | 2 +
src/runtime/core_main.cpp | 8 +-
src/runtime/env.sim.cpp | 19 +-
src/runtime/env.sim.h | 13 +-
src/runtime/fault_injector.cpp | 37 +-
src/runtime/fault_injector.h | 2 +
src/runtime/global_config.cpp | 27 +-
src/runtime/global_config.h | 21 +-
src/runtime/message_utils.cpp | 4 +
src/runtime/message_utils.h | 15 +-
src/runtime/nativerun.cpp | 17 +-
src/runtime/nativerun.h | 12 +-
src/runtime/pipeline.h | 16 +-
src/runtime/profiler.cpp | 570 ++++---
src/runtime/profiler.h | 2 +
src/runtime/profiler_header.h | 92 +-
src/runtime/providers.common.cpp | 29 +-
src/runtime/providers.common.h | 2 -
.../clear.sh => runtime/ranger/CMakeLists.txt} | 12 +-
.../access_type.cpp} | 28 +-
src/runtime/ranger/access_type.h | 64 +
src/runtime/ranger/ranger_resource_policy.cpp | 268 ++++
src/runtime/ranger/ranger_resource_policy.h | 277 ++++
.../ranger/ranger_resource_policy_manager.cpp | 658 ++++++++
.../ranger/ranger_resource_policy_manager.h | 153 ++
src/runtime/rpc/asio_net_provider.cpp | 58 +-
src/runtime/rpc/asio_net_provider.h | 21 +-
src/runtime/rpc/asio_rpc_session.cpp | 39 +
src/runtime/rpc/asio_rpc_session.h | 13 +-
src/runtime/rpc/dns_resolver.cpp | 110 ++
src/runtime/rpc/dns_resolver.h | 54 +
src/runtime/rpc/dsn_message_parser.cpp | 25 +-
src/runtime/rpc/dsn_message_parser.h | 14 +-
src/runtime/rpc/group_host_port.h | 257 ++++
src/runtime/rpc/message_parser.cpp | 26 +-
src/runtime/rpc/message_parser.h | 13 +-
src/runtime/rpc/message_parser_manager.h | 9 -
src/runtime/rpc/network.cpp | 86 +-
src/runtime/rpc/network.h | 34 +-
src/runtime/rpc/network.sim.cpp | 32 +-
src/runtime/rpc/network.sim.h | 12 +-
src/runtime/rpc/raw_message_parser.cpp | 26 +-
src/runtime/rpc/raw_message_parser.h | 15 +-
src/runtime/rpc/rpc_address.cpp | 19 +-
src/runtime/rpc/rpc_address.h | 13 +
src/runtime/rpc/rpc_engine.cpp | 30 +-
src/runtime/rpc/rpc_engine.h | 24 +-
src/runtime/rpc/rpc_holder.h | 43 +-
src/runtime/rpc/rpc_host_port.cpp | 201 +++
src/runtime/rpc/rpc_host_port.h | 139 ++
src/runtime/rpc/rpc_message.cpp | 23 +-
src/runtime/rpc/rpc_message.h | 29 +-
src/runtime/rpc/rpc_task.cpp | 17 +-
src/runtime/rpc/thrift_message_parser.cpp | 29 +-
src/runtime/rpc/thrift_message_parser.h | 11 +-
src/runtime/scheduler.cpp | 38 +-
src/runtime/scheduler.h | 25 +-
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 | 23 +-
src/runtime/security/client_negotiation.h | 7 +
src/runtime/security/init.cpp | 18 +-
src/runtime/security/kinit_context.cpp | 54 +-
src/runtime/security/kinit_context.h | 3 +
src/runtime/security/meta_access_controller.cpp | 102 +-
src/runtime/security/meta_access_controller.h | 22 +-
src/runtime/security/negotiation.cpp | 12 +-
src/runtime/security/negotiation.h | 12 +-
src/runtime/security/negotiation_manager.cpp | 21 +-
src/runtime/security/negotiation_manager.h | 12 +-
src/runtime/security/replica_access_controller.cpp | 92 +-
src/runtime/security/replica_access_controller.h | 53 +-
src/runtime/security/sasl_client_wrapper.cpp | 8 +-
src/runtime/security/sasl_client_wrapper.h | 5 +
src/runtime/security/sasl_init.cpp | 7 +-
src/runtime/security/sasl_server_wrapper.cpp | 10 +-
src/runtime/security/sasl_server_wrapper.h | 5 +
src/runtime/security/sasl_wrapper.cpp | 13 +-
src/runtime/security/sasl_wrapper.h | 7 +
src/runtime/security/server_negotiation.cpp | 17 +-
src/runtime/security/server_negotiation.h | 9 +-
src/runtime/serverlet.h | 1 +
src/runtime/service_api_c.cpp | 46 +-
src/runtime/service_app.h | 11 +-
src/runtime/service_engine.cpp | 30 +-
src/runtime/service_engine.h | 36 +-
src/runtime/simulator.cpp | 22 +-
src/runtime/simulator.h | 8 +-
src/runtime/task/future_types.h | 1 +
src/runtime/task/hpc_task_queue.cpp | 11 +-
src/runtime/task/hpc_task_queue.h | 6 +-
src/runtime/task/simple_task_queue.cpp | 24 +
src/runtime/task/simple_task_queue.h | 13 +-
src/runtime/task/task.cpp | 29 +-
src/runtime/task/task.h | 44 +-
src/runtime/task/task_code.cpp | 7 +-
src/runtime/task/task_code.h | 27 +-
src/runtime/task/task_engine.cpp | 20 +-
src/runtime/task/task_engine.h | 27 +-
src/runtime/task/task_engine.sim.cpp | 21 +-
src/runtime/task/task_engine.sim.h | 21 +-
src/runtime/task/task_queue.cpp | 88 +-
src/runtime/task/task_queue.h | 23 +-
src/runtime/task/task_spec.cpp | 8 +-
src/runtime/task/task_spec.h | 40 +-
src/runtime/task/task_tracker.cpp | 5 +-
src/runtime/task/task_tracker.h | 4 +-
src/runtime/task/task_worker.cpp | 24 +-
src/runtime/task/task_worker.h | 22 +-
src/runtime/test/CMakeLists.txt | 15 +-
src/runtime/test/address_test.cpp | 6 +-
src/runtime/test/async_call.cpp | 45 +-
src/runtime/test/client_negotiation_test.cpp | 20 +-
src/runtime/test/corrupt_message.cpp | 24 +-
src/runtime/test/host_port_test.cpp | 240 +++
src/runtime/test/lpc.cpp | 26 +-
src/runtime/test/main.cpp | 21 +-
src/runtime/test/message_reader_test.cpp | 5 +-
src/runtime/test/message_utils_test.cpp | 10 +-
src/runtime/test/meta_access_controller_test.cpp | 42 +-
src/runtime/test/negotiation_manager_test.cpp | 19 +-
src/runtime/test/netprovider.cpp | 44 +-
src/runtime/test/pipeline_test.cpp | 23 +-
.../test/ranger_resource_policy_manager_test.cpp | 523 +++++++
src/runtime/test/ranger_resource_policy_test.cpp | 182 +++
.../test/replica_access_controller_test.cpp | 39 +-
src/runtime/test/rpc.cpp | 38 +-
src/runtime/test/rpc_holder_test.cpp | 20 +-
src/runtime/test/rpc_message.cpp | 29 +-
src/runtime/test/server_negotiation_test.cpp | 18 +-
src/runtime/test/service_api_c.cpp | 40 +-
src/runtime/test/sim_lock.cpp | 31 +-
src/runtime/test/task_engine.cpp | 25 +-
src/runtime/test/task_test.cpp | 19 +-
src/runtime/test/test_utils.h | 23 +-
src/runtime/test/thrift_message_parser_test.cpp | 28 +-
src/runtime/tool_api.cpp | 28 +-
src/runtime/tool_api.h | 38 +-
src/runtime/tracer.cpp | 31 +-
src/runtime/tracer.h | 6 +-
src/runtime/zlocks.cpp | 18 +-
src/sample/CMakeLists.txt | 6 +-
src/sample/main.cpp | 2 +
src/server/CMakeLists.txt | 43 +-
src/server/available_detector.cpp | 86 +-
src/server/available_detector.h | 24 +-
src/server/capacity_unit_calculator.cpp | 156 +-
src/server/capacity_unit_calculator.h | 43 +-
src/server/compaction_filter_rule.cpp | 27 +-
src/server/compaction_filter_rule.h | 39 +-
src/server/compaction_operation.cpp | 23 +-
src/server/compaction_operation.h | 35 +-
src/server/config.ini | 21 +-
src/server/config.min.ini | 8 +-
src/server/hashkey_transform.h | 6 +-
src/server/hotkey_collector.cpp | 43 +-
src/server/hotkey_collector.h | 25 +-
src/server/hotspot_partition_calculator.cpp | 26 +-
src/server/hotspot_partition_calculator.h | 15 +-
src/server/info_collector.cpp | 43 +-
src/server/info_collector.h | 49 +-
src/server/info_collector_app.cpp | 34 +-
src/server/info_collector_app.h | 10 +-
src/server/key_ttl_compaction_filter.h | 4 +-
src/server/main.cpp | 25 +-
src/server/meta_store.cpp | 37 +-
src/server/meta_store.h | 19 +-
src/server/pegasus_event_listener.cpp | 128 +-
src/server/pegasus_event_listener.h | 32 +-
src/server/pegasus_manual_compact_service.cpp | 58 +-
src/server/pegasus_manual_compact_service.h | 25 +-
src/server/pegasus_mutation_duplicator.cpp | 80 +-
src/server/pegasus_mutation_duplicator.h | 40 +-
src/server/pegasus_read_service.h | 7 +-
src/server/pegasus_scan_context.h | 2 +-
src/server/pegasus_server_impl.cpp | 828 ++++++----
src/server/pegasus_server_impl.h | 182 ++-
src/server/pegasus_server_impl_init.cpp | 687 +++++----
src/server/pegasus_server_write.cpp | 70 +-
src/server/pegasus_server_write.h | 24 +-
src/server/pegasus_service_app.h | 47 +-
src/server/pegasus_write_service.cpp | 314 ++--
src/server/pegasus_write_service.h | 104 +-
src/server/pegasus_write_service_impl.h | 110 +-
src/server/result_writer.cpp | 10 +
src/server/result_writer.h | 8 +-
src/server/rocksdb_wrapper.cpp | 84 +-
src/server/rocksdb_wrapper.h | 45 +-
src/server/test/CMakeLists.txt | 16 +-
src/server/test/capacity_unit_calculator_test.cpp | 59 +-
src/server/test/compaction_filter_rule_test.cpp | 8 +-
src/server/test/compaction_operation_test.cpp | 26 +-
src/server/test/config.ini | 13 +-
src/server/test/hashkey_transform_test.cpp | 5 +-
src/server/test/hotkey_collector_test.cpp | 51 +-
src/server/test/hotspot_partition_test.cpp | 23 +-
src/server/test/main.cpp | 20 +-
src/server/test/manual_compact_service_test.cpp | 31 +-
.../test/pegasus_compression_options_test.cpp | 21 +-
.../test/pegasus_mutation_duplicator_test.cpp | 47 +-
src/server/test/pegasus_server_impl_test.cpp | 120 +-
src/server/test/pegasus_server_test_base.h | 44 +-
src/server/test/pegasus_server_write_test.cpp | 36 +-
src/server/test/pegasus_value_schema_test.cpp | 4 +-
.../test/pegasus_write_service_impl_test.cpp | 45 +-
src/server/test/pegasus_write_service_test.cpp | 40 +-
src/server/test/rocksdb_wrapper_test.cpp | 82 +-
src/server/test/run.sh | 21 +-
src/shell/CMakeLists.txt | 49 +-
src/shell/command_helper.h | 8 +-
src/shell/command_output.h | 3 +-
src/shell/command_utils.cpp | 6 +
src/shell/command_utils.h | 4 +-
src/shell/commands.h | 2 +-
src/shell/commands/bulk_load.cpp | 26 +
src/shell/commands/cold_backup.cpp | 19 +
src/shell/commands/data_operations.cpp | 45 +-
src/shell/commands/debugger.cpp | 105 +-
src/shell/commands/detect_hotkey.cpp | 19 +-
src/shell/commands/duplication.cpp | 24 +-
src/shell/commands/global_properties.cpp | 6 +
src/shell/commands/misc.cpp | 8 +
src/shell/commands/node_management.cpp | 29 +
src/shell/commands/rebalance.cpp | 21 +
src/shell/commands/recovery.cpp | 24 +-
src/shell/commands/table_management.cpp | 37 +-
src/shell/config.ini | 2 +-
src/shell/main.cpp | 30 +-
src/test/bench_test/CMakeLists.txt | 10 +-
src/test/bench_test/benchmark.cpp | 176 ++-
src/test/bench_test/benchmark.h | 15 +-
src/test/bench_test/config.cpp | 29 +-
src/test/bench_test/config.h | 8 +-
src/test/bench_test/config.ini | 1 +
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 +-
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 | 229 ---
.../{base_api_test => base_api}/CMakeLists.txt | 3 +-
.../function_test/base_api/integration_test.cpp | 201 +++
.../{base_api_test => base_api}/main.cpp | 0
.../{base_api_test => base_api}/test_basic.cpp | 21 +-
.../{base_api_test => base_api}/test_batch_get.cpp | 27 +-
.../test_check_and_mutate.cpp | 16 +-
.../test_check_and_set.cpp | 15 +-
.../{base_api_test => base_api}/test_copy.cpp | 68 +-
.../{base_api_test => base_api}/test_incr.cpp | 16 +-
.../test_range_read.cpp | 22 +-
.../{base_api_test => base_api}/test_recall.cpp | 31 +-
.../{base_api_test => base_api}/test_scan.cpp | 48 +-
.../{base_api_test => base_api}/test_ttl.cpp | 45 +-
.../{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 | 306 ----
src/test/function_test/config.ini | 9 +-
.../CMakeLists.txt | 22 +-
.../main.cpp | 0
.../test_detect_hotspot.cpp | 64 +-
.../CMakeLists.txt | 3 +-
.../main.cpp | 0
.../test_split.cpp | 197 ++-
.../{recovery_test => recovery}/CMakeLists.txt | 22 +-
.../{recovery_test => recovery}/main.cpp | 0
.../{recovery_test => recovery}/test_recovery.cpp | 36 +-
.../{restore_test => restore}/CMakeLists.txt | 22 +-
.../{restore_test => restore}/main.cpp | 0
src/test/function_test/restore/test_restore.cpp | 150 ++
.../function_test/restore_test/test_restore.cpp | 326 ----
src/test/function_test/run.sh | 35 +-
.../{throttle_test => throttle}/CMakeLists.txt | 3 +-
.../{throttle_test => throttle}/main.cpp | 0
.../{throttle_test => throttle}/test_throttle.cpp | 495 +++---
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 | 228 ++-
src/test/function_test/utils/test_util.h | 70 +-
src/test/function_test/utils/utils.h | 19 +-
src/test/kill_test/CMakeLists.txt | 2 +-
src/test/kill_test/config.ini | 1 -
src/test/kill_test/data_verifier.cpp | 61 +-
src/test/kill_test/data_verifier.h | 4 +
src/test/kill_test/job.cpp | 2 +
src/test/kill_test/kill_testor.cpp | 55 +-
src/test/kill_test/kill_testor.h | 16 +-
src/test/kill_test/killer_handler_shell.cpp | 33 +-
src/test/kill_test/killer_handler_shell.h | 9 +-
src/test/kill_test/main.cpp | 8 +-
src/test/kill_test/partition_kill_testor.cpp | 21 +-
src/test/kill_test/partition_kill_testor.h | 4 -
src/test/kill_test/process_kill_testor.cpp | 40 +-
src/test/kill_test/process_kill_testor.h | 9 +-
src/test/pressure_test/CMakeLists.txt | 2 +-
src/test/pressure_test/main.cpp | 54 +-
src/{sample => test_util}/CMakeLists.txt | 23 +-
src/test_util/test_util.cpp | 136 ++
src/test_util/test_util.h | 147 ++
src/tools/mutation_log_tool.cpp | 78 +-
src/tools/mutation_log_tool.h | 23 +-
src/utils/CMakeLists.txt | 10 +-
src/utils/absl/base/internal/invoke.h | 218 ---
src/utils/absl/utility/utility.h | 207 ---
src/utils/alloc.cpp | 11 +-
src/utils/alloc.h | 19 +-
src/utils/api_utilities.h | 3 +
src/utils/apply.h | 35 -
src/utils/autoref_ptr.h | 11 +-
src/utils/binary_reader.cpp | 5 +-
src/utils/binary_reader.h | 6 +-
src/utils/binary_writer.cpp | 3 +
src/utils/binary_writer.h | 5 +
src/utils/blob.h | 8 +-
src/utils/builtin_metrics.cpp | 92 ++
.../builtin_metrics.h} | 28 +-
src/utils/clock.cpp | 4 +-
src/utils/clock.h | 1 +
src/utils/command_manager.cpp | 14 +-
src/utils/command_manager.h | 7 +-
src/utils/config_api.cpp | 4 +-
src/utils/config_api.h | 4 +-
src/utils/configuration.cpp | 51 +-
src/utils/configuration.h | 12 +-
src/utils/coredump.h | 9 -
src/utils/coredump.posix.cpp | 9 +-
src/utils/defer.h | 10 +-
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 | 3 +
src/utils/error_code.h | 33 +-
src/utils/errors.h | 28 +-
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 | 33 +-
src/utils/fail_point_impl.h | 19 +-
src/utils/filesystem.cpp | 359 ++---
src/utils/filesystem.h | 35 +-
src/utils/fixed_size_buffer_pool.h | 1 +
src/utils/flags.cpp | 23 +-
src/utils/flags.h | 10 +-
src/utils/fmt_logging.h | 47 +-
.../fmt_utils.h} | 29 +-
src/utils/gpid.cpp | 6 +-
src/utils/hpc_locks/sema.h | 1 +
src/utils/je_ctl.cpp | 2 +-
src/utils/join_point.h | 12 +-
src/utils/latency_tracer.cpp | 191 ++-
src/utils/latency_tracer.h | 17 +-
src/utils/link.h | 11 +-
src/utils/lockp.std.h | 9 -
src/utils/logging.cpp | 24 +-
src/utils/logging_provider.h | 3 +-
src/utils/long_adder.cpp | 4 +-
src/utils/long_adder_bench/CMakeLists.txt | 12 +-
src/utils/long_adder_bench/long_adder_bench.cpp | 32 +-
.../security/kinit_context.h => utils/macros.h} | 17 +-
src/utils/math.cpp | 2 +-
src/utils/memutil.h | 25 -
src/utils/metrics.cpp | 25 +-
src/utils/metrics.h | 451 +++++-
src/utils/nth_element.h | 6 +-
src/utils/output_utils.cpp | 7 +-
src/utils/output_utils.h | 14 +-
src/utils/priority_queue.h | 14 +-
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 | 5 +
src/utils/shared_io_service.h | 12 +-
src/utils/simple_logger.cpp | 54 +-
src/utils/simple_logger.h | 34 +-
src/utils/singleton_store.h | 9 -
src/utils/smart_pointers.h | 130 --
src/utils/string_conv.h | 27 +-
src/utils/string_view.cpp | 106 --
src/utils/string_view.h | 428 ------
src/utils/strings.cpp | 10 +-
src/utils/strings.h | 2 +
src/utils/synchronize.h | 1 +
src/utils/test/CMakeLists.txt | 17 +-
src/utils/test/TokenBucketTest.cpp | 9 +-
src/utils/test/TokenBucketTest.h | 2 +-
src/utils/test/autoref_ptr_test.cpp | 4 +-
src/utils/test/binary_reader_test.cpp | 3 +-
src/utils/test/command_manager_test.cpp | 5 +-
src/utils/test/configuration.cpp | 10 +-
src/utils/test/endian_test.cpp | 7 +-
src/utils/test/enum_helper_test.cpp | 211 +++
src/utils/test/env.cpp | 284 +++-
src/utils/test/fail_point_test.cpp | 13 +-
src/utils/test/file_system_test.cpp | 149 +-
src/utils/test/file_utils.cpp | 1153 ++++----------
src/utils/test/flag_test.cpp | 10 +-
src/utils/test/fmt_logging_test.cpp | 17 +-
src/utils/test/hostname_test.cpp | 5 +-
src/utils/test/je_ctl_test.cpp | 33 +-
src/utils/test/join_point_test.cpp | 5 +-
src/utils/test/json_helper_test.cpp | 13 +-
src/utils/test/latency_tracer_test.cpp | 29 +-
src/utils/test/lock.std.cpp | 6 +-
src/utils/test/logger.cpp | 22 +-
src/utils/test/logging.cpp | 27 +-
src/utils/test/long_adder_test.cpp | 8 +-
src/utils/test/main.cpp | 2 +-
src/utils/test/memutil_test.cpp | 31 -
src/utils/test/metrics_test.cpp | 217 ++-
src/utils/test/nth_element_bench/CMakeLists.txt | 12 +-
.../test/nth_element_bench/nth_element_bench.cpp | 10 +-
src/utils/test/nth_element_test.cpp | 5 +-
src/utils/test/nth_element_utils.h | 8 +-
src/utils/test/output_utils_test.cpp | 7 +-
src/utils/test/priority_queue.cpp | 18 +-
src/utils/test/rand_test.cpp | 6 +-
src/utils/test/sema.cpp | 15 +-
src/utils/test/smart_pointers_test.cpp | 112 --
src/utils/test/string_conv_test.cpp | 48 +-
src/utils/test/string_view_test.cpp | 436 ------
src/utils/test/time_utils_test.cpp | 6 +-
.../token_bucket_throttling_controller_test.cpp | 5 +-
src/utils/test/token_buckets_test.cpp | 7 +-
src/utils/test/utils.cpp | 22 +-
src/utils/test_macros.h | 41 +
src/utils/thread_access_checker.cpp | 1 -
src/utils/thread_access_checker.h | 1 +
src/utils/threadpool_code.h | 3 +
src/utils/threadpool_spec.h | 1 +
src/utils/throttling_controller.cpp | 5 +
src/utils/time_utils.cpp | 15 +-
src/utils/time_utils.h | 42 +-
src/utils/token_bucket_throttling_controller.cpp | 5 +-
src/utils/token_bucket_throttling_controller.h | 3 +
src/utils/token_buckets.cpp | 2 +
src/utils/token_buckets.h | 4 +-
src/utils/utils.cpp | 36 +-
src/utils/utils.h | 12 +-
src/utils/work_queue.h | 10 +-
src/utils/zlocks.h | 1 +
src/zookeeper/CMakeLists.txt | 2 +-
.../distributed_lock_service_zookeeper.cpp | 24 +-
src/zookeeper/distributed_lock_service_zookeeper.h | 24 +-
src/zookeeper/lock_struct.cpp | 30 +-
src/zookeeper/lock_struct.h | 18 +-
src/zookeeper/lock_types.h | 7 -
src/zookeeper/test/CMakeLists.txt | 21 +-
src/zookeeper/test/config-test.ini | 7 +-
src/zookeeper/test/distributed_lock_zookeeper.cpp | 31 +-
src/zookeeper/test/main.cpp | 25 +-
src/zookeeper/zookeeper_error.cpp | 15 +-
src/zookeeper/zookeeper_error.h | 10 -
src/zookeeper/zookeeper_session.cpp | 31 +-
src/zookeeper/zookeeper_session.h | 30 +-
src/zookeeper/zookeeper_session_mgr.cpp | 24 +-
src/zookeeper/zookeeper_session_mgr.h | 36 +-
thirdparty/CMakeLists.txt | 373 +++--
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 ---
1089 files changed, 35455 insertions(+), 23508 deletions(-)
create mode 100644 .devcontainer/devcontainer.json
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/replica/test/clear.sh => collector/Makefile (90%)
mode change 100755 => 100644
copy java-client/dev-support/findbugs-exclude.xml => collector/README.md (50%)
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/utils/clock.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 src/replica/bulk_load/test/CMakeLists.txt => collector/config.yml (59%)
copy {pegic => collector}/go.mod (66%)
copy {admin-cli => collector}/go.sum (62%)
copy src/runtime/security/kinit_context.h => collector/hotspot/algo.go (80%)
create mode 100644 collector/main.go
copy src/runtime/security/kinit_context.h =>
collector/metrics/meta_server_metrics.go (80%)
create mode 100644 collector/metrics/metric_collector.go
copy src/runtime/security/kinit_context.h =>
collector/metrics/replica_server_metrics.go (80%)
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
delete mode 100644 docker/pegasus-build-env/centos6/Dockerfile
delete mode 100644 docker/pegasus-build-env/ubuntu1604/Dockerfile
delete mode 100755 java-client/scripts/ci-test.sh
copy src/test/function_test/base_api_test/main.cpp =>
java-client/src/main/java/org/apache/pegasus/client/ListAppInfoType.java (76%)
create mode 100644
java-client/src/main/java/org/apache/pegasus/operator/list_apps_operator.java
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
copy src/{replica/backup => client}/test/CMakeLists.txt (79%)
copy src/{shell => client/test}/config.ini (100%)
create mode 100644 src/client/test/ddl_client_test.cpp
rename src/{perf_counter/builtin_counters.h => client/test/main.cpp} (72%)
copy src/{replica/test/clear.sh => client/test/run.sh} (83%)
create mode 100644 src/http/http_client.cpp
create mode 100644 src/http/http_client.h
copy src/http/{uri_decoder.h => http_method.h} (73%)
delete mode 100644 src/http/perf_counter_http_service.cpp
copy src/{shell/config.ini => http/test/config-test.ini} (58%)
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} (67%)
delete mode 100644 src/perf_counter/builtin_counters.cpp
copy src/replica/{backup/test/replica_backup_manager_test.cpp =>
replica_base.cpp} (51%)
delete mode 100644 src/replica/replica_test_utils.cpp
delete mode 100644 src/replica/replica_test_utils.h
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
copy src/{replica/test/clear.sh => runtime/ranger/CMakeLists.txt} (81%)
mode change 100755 => 100644
copy src/runtime/{security/meta_access_controller.h => 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
create mode 100644 src/runtime/rpc/dns_resolver.h
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
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%)
create mode 100644 src/test/function_test/base_api/integration_test.cpp
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
(92%)
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 (84%)
rename src/test/function_test/{base_api_test => base_api}/test_incr.cpp (97%)
rename src/test/function_test/{base_api_test => base_api}/test_range_read.cpp
(95%)
rename src/test/function_test/{base_api_test => base_api}/test_recall.cpp (89%)
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 (83%)
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 (83%)
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 (62%)
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
(93%)
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
(56%)
copy src/{sample => test_util}/CMakeLists.txt (76%)
create mode 100644 src/test_util/test_util.cpp
create mode 100644 src/test_util/test_util.h
delete mode 100644 src/utils/absl/base/internal/invoke.h
delete mode 100644 src/utils/absl/utility/utility.h
delete mode 100644 src/utils/apply.h
create mode 100644 src/utils/builtin_metrics.cpp
copy src/{runtime/security/meta_access_controller.h =>
utils/builtin_metrics.h} (67%)
create mode 100644 src/utils/env.cpp
create mode 100644 src/utils/env.h
copy src/{runtime/security/replica_access_controller.h => utils/fmt_utils.h}
(58%)
copy src/{runtime/security/kinit_context.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
create mode 100644 src/utils/test_macros.h
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]
