This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/java-client/com.google.guava-guava-32.0.0-jre
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard d612defd8 build(deps): bump guava from 28.1-jre to 32.0.0-jre in
/java-client
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 f6a7e3553 build(deps): bump gopkg.in/yaml.v3 in /admin-cli (#1592)
add b5d520431 build(deps): bump gopkg.in/yaml.v3 in /pegic (#1591)
add 2a6cc71ee build(deps): bump golang.org/x/text from 0.3.5 to 0.3.8 in
/admin-cli (#1361)
add 211bbf313 chore(admin-cli&pegic): add go fmt in Makefile and fotmat
files (#1793)
add 63c3e67f0 fix(scripts): drop unnecessary dependencies for
pack_server.sh (#1794)
add 96cd89d31 fix(scripts): fix that librocksdb.so.8 was not found for the
executable binary generated by pack_server.sh (#1796)
add b48a6c8e3 feat(go): Unify and bump go version to 1.18 (#1797)
add 0b96bd769 build(deps): bump golang.org/x/net from 0.8.0 to 0.17.0 in
/collector (#1802)
add 1473a95de build(deps): bump golang.org/x/net in /admin-cli (#1801)
add a6edc7acc build(deps): bump google.golang.org/protobuf in /collector
(#1800)
add cde63a2c2 build(deps): bump golang.org/x/crypto from 0.7.0 to 0.17.0
in /collector (#1799)
add 8f3881257 build(deps): bump golang.org/x/net from
0.0.0-20191105084925-a882066a44e0 to 0.17.0 in /go-client (#1782)
add dec19d4b8 fix(rocksdb): force librocksdb.so* to be output into the
directory `lib` (#1804)
add 0504f777a fix(logger): logs fail to be printed to stdout and the
process is not terminated for fatal errors before logging is initialized (#1803)
add 908313d8e feat(run.sh): make it possible to build partial objects
(#1798)
add 05466d3e2 chore(CI): Improve github actions (#1791)
add 2f551c7ed refactor(logging): drop the unnecessary interface, use `log`
instead of `dsn_log` and improve the tests (#1809)
add a397c07ed fix: standby meta server exits abnormally with core dump
after receiving the http request `/meta/cluster` (#1816)
add 28df30ed0 chore(go-client-ci): build the server instead of downloading
it from external site (#1790)
add 6298bdec6 chore(nodejs-client-ci): build the server instead of
downloading it from external site (#1814)
add cbc160463 chore(scala-client-ci): build the server instead of
downloading it from external site (#1813)
add 1b44329a9 chore(python-client-ci): build the server instead of
downloading it from external site (#1815)
add 4e66ebe3f feat(fqdn): json decode & encode for rpc_host_port (#1811)
add 43aa01646 refactor(ranger): move ranger out of runtime (#1808)
add 394617b77 chore(CI): Improve github actions (2nd) (#1812)
add a2ccb9c7b feat(http): use scoped enum http_status_code instead of
magic numbers (#1776)
add e7a1d0b2b chore(github): add contributor limowang into apache
collaborators to use github actions (#1828)
add 746318392 chore: Update .gitignore (#1823)
add 82d981f51 fix(logging): remove too verbose log when key not found
(#1829)
add 9300a2926 fix(build): Fix Cpp build errors in recent github actions
(#1834)
add 14ca78e7e refactor(json_file): Refactor the load and dump functions of
JSON objects (#1818)
add 4093b4f27 chore(collector): add fmt job for collector CI (#1833)
add 43f2e3ba7 chore(version): update the version of pegasus server and
client of each language to 2.6.0-SNAPSHOT (#1831)
add 363d78988 feat(new_metrics): add some basic fields to the response to
metrics query (#1827)
add 71711592b refactor(security): Move security out of runtime (#1821)
add b75bd0388 feat(json_file): load and dump functions of JSON objects
support encryption (#1842)
add 655fc0913 fix(java-client): fix the failed java-client test (#1836)
add 4a98e96f1 fix: specify the 'single_master_cluster' cluster for
recovery_test (#1839)
add 4cd14640d build(deps): bump guava from 28.1-jre to 32.0.0-jre in
/java-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 (d612defd8)
\
N -- N -- N
refs/heads/dependabot/maven/java-client/com.google.guava-guava-32.0.0-jre
(4cd14640d)
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/actions/build_pegasus/action.yaml | 52 +
.../actions/download_artifact/action.yaml | 21 +-
.../rebuild_thirdparty_if_needed/action.yaml | 49 +
.../actions/run_server_tests/action.yaml | 15 +-
.../unpack_prebuilt_thirdparties/action.yaml | 22 +-
.github/actions/upload_artifact/action.yaml | 38 +
.github/workflows/build-push-env-docker.yml | 5 +-
.github/workflows/free_disk_space.sh | 70 +
.github/workflows/labeler.yml | 2 +-
.github/workflows/lint_and_test_admin-cli.yml | 7 +-
.../lint_and_test_admin-cli_always_pass.yml | 1 +
...t_admin-cli.yml => lint_and_test_collector.yml} | 59 +-
.github/workflows/lint_and_test_cpp.yaml | 458 ++----
.github/workflows/lint_and_test_go-client.yml | 117 +-
.github/workflows/lint_and_test_java-client.yml | 106 ++
.github/workflows/lint_and_test_pegic.yml | 5 +-
.../workflows/lint_and_test_pegic_always_pass.yml | 1 +
.github/workflows/lint_and_test_scala-client.yml | 111 ++
.github/workflows/module_labeler_conf.yml | 2 +
.github/workflows/regular-build.yml | 24 +-
.github/workflows/standardization_lint.yaml | 12 -
.github/workflows/test_java-client.yml | 57 -
.github/workflows/test_nodejs-client.yml | 45 +-
.github/workflows/test_python-client.yml | 67 +-
.github/workflows/test_scala-client.yml | 55 -
.github/workflows/thirdparty-regular-push.yml | 10 +-
.gitignore | 214 ++-
.licenserc.yaml | 107 +-
.rat-excludes | 4 +-
CMakeLists.txt | 8 +-
DISCLAIMER | 10 +
DISCLAIMER-WIP | 19 -
HISTORY.md | 40 +
LICENSE | 68 +-
NOTICE | 2 +-
admin-cli/Makefile | 3 +
admin-cli/client/meta.go | 4 +-
admin-cli/cmd/remote_command.go | 2 +-
admin-cli/executor/server_config.go | 2 +-
admin-cli/go.mod | 48 +-
admin-cli/go.sum | 16 +-
admin-cli/tabular/printer.go | 17 +-
admin-cli/util/pegasus_node.go | 4 +-
cmake_modules/BaseFunctions.cmake | 52 +-
.../scripts/format-all.sh => collector/Makefile | 13 +-
collector/README.md | 44 +
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 | 42 +-
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 | 42 +-
collector/go.mod | 101 ++
{pegic => collector}/go.sum | 293 +++-
.../kinit_context.h => collector/hotspot/algo.go | 13 +-
collector/main.go | 101 ++
.../metrics/meta_server_metrics.go | 16 +-
collector/metrics/metric_collector.go | 514 ++++++
.../metrics/replica_server_metrics.go | 16 +-
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 +
pegic/go.mod => collector/webui/tables.go | 43 +-
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 | 6 +-
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/README.md | 24 +-
go-client/admin/client_test.go | 6 +-
go-client/example/main.go | 2 +-
go-client/generator/main.go | 70 +-
go-client/go.mod | 15 +-
go-client/go.sum | 12 +-
go-client/idl/base/dsn_err_string.go | 1 -
go-client/session/admin_rpc_types.go | 35 +-
go-client/session/radmin_rpc_types.go | 35 +-
go-client/test.sh | 46 -
java-client/README.md | 51 +-
java-client/pom.xml | 36 +-
java-client/scripts/ci-test.sh | 72 -
.../org/apache/pegasus/base/TestRpcAddress.java | 30 +-
.../apache/pegasus/client/PegasusScannerTest.java | 156 +-
.../org/apache/pegasus/client/TestAdminClient.java | 35 +-
.../java/org/apache/pegasus/client/TestBasic.java | 1730 ++++++++++----------
.../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 | 110 +-
.../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 +-
.../java/org/apache/pegasus/tools/Toollet.java | 2 +-
.../src/test/resources/simplelogger.properties | 2 +-
nodejs-client/package.json | 2 +-
nodejs-client/test.sh | 35 -
pegic/Makefile | 3 +
pegic/go.mod | 29 +-
pegic/go.sum | 21 +-
python-client/README.md | 71 +-
python-client/pypegasus/__init__.py | 2 +-
python-client/test.sh | 44 -
run.sh | 99 +-
scala-client/README.md | 27 +-
scala-client/build.sbt | 4 +-
scala-client/scripts/ci-test.sh | 69 -
.../apache/pegasus/scalaclient/PegasusUtil.scala | 2 +-
.../scalaclient/ScalaPegasusAsyncTable.scala | 5 +-
scripts/check_license.py | 213 +++
scripts/config_hdfs.sh | 16 +-
scripts/pack_server.sh | 9 +-
scripts/pack_tools.sh | 3 +-
src/CMakeLists.txt | 3 +-
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 | 36 +-
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 | 379 ++---
src/block_service/local/local_service.h | 13 +-
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 | 76 +-
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 | 18 +-
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 | 11 +-
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 | 47 +-
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 | 13 +-
src/http/builtin_http_calls.h | 2 -
src/http/config_http_service.cpp | 9 +-
src/http/http_call_registry.h | 17 +-
src/http/http_client.cpp | 348 ++++
src/http/http_client.h | 158 ++
src/http/http_message_parser.cpp | 11 +-
src/http/{uri_decoder.h => http_method.h} | 29 +-
src/http/http_server.cpp | 45 +-
src/http/http_server.h | 23 +-
src/http/http_status_code.cpp | 46 +
src/http/http_status_code.h | 52 +
src/http/perf_counter_http_service.cpp | 66 -
src/http/pprof_http_service.cpp | 93 +-
src/http/test/CMakeLists.txt | 16 +-
.../config.ini => http/test/config-test.ini} | 78 +-
src/http/test/http_client_test.cpp | 223 +++
src/http/test/http_server_test.cpp | 33 +-
src/http/test/http_status_code_test.cpp | 68 +
src/http/test/main.cpp | 121 ++
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 | 56 +-
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 | 92 +-
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_http_service.cpp | 113 +-
src/meta/meta_options.cpp | 22 +-
src/meta/meta_options.h | 13 +-
src/meta/meta_server_failure_detector.cpp | 4 +-
src/meta/meta_service.cpp | 57 +-
src/meta/meta_service.h | 20 +-
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 | 96 +-
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 | 33 +-
src/meta/test/backup_test.cpp | 6 +-
src/meta/test/balancer_simulator/CMakeLists.txt | 24 +-
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 | 8 +-
src/meta/test/meta_data.cpp | 5 +-
src/meta/test/meta_duplication_service_test.cpp | 9 +-
src/meta/test/meta_http_service_test.cpp | 56 +-
src/meta/test/meta_mauanl_compaction_test.cpp | 5 +-
src/meta/test/meta_partition_guardian_test.cpp | 9 +-
src/meta/test/meta_service_test.cpp | 9 +-
src/meta/test/meta_split_service_test.cpp | 8 +-
src/meta/test/meta_state/CMakeLists.txt | 39 +-
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 | 9 +-
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 | 14 +-
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 | 30 +-
src/perf_counter/test/perf_counter_test.cpp | 14 +-
src/perf_counter/test/perf_counters_test.cpp | 42 +-
src/{test_util => ranger}/CMakeLists.txt | 15 +-
src/{runtime => }/ranger/access_type.h | 23 +-
src/ranger/ranger_resource_policy.cpp | 268 +++
src/ranger/ranger_resource_policy.h | 277 ++++
.../ranger/ranger_resource_policy_manager.cpp | 111 +-
.../ranger/ranger_resource_policy_manager.h | 14 +-
src/{http => ranger}/test/CMakeLists.txt | 23 +-
src/{utils => ranger}/test/main.cpp | 10 +-
.../test/ranger_resource_policy_manager_test.cpp | 266 ++-
src/ranger/test/ranger_resource_policy_test.cpp | 182 ++
.../format-all.sh => src/ranger/test/run.sh | 14 +-
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 | 21 +-
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 | 87 +-
src/replica/bulk_load/replica_bulk_loader.h | 12 +-
src/replica/bulk_load/test/CMakeLists.txt | 21 +-
src/replica/bulk_load/test/config-test.ini | 5 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 117 +-
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 | 21 +-
src/replica/duplication/test/config-test.ini | 5 +-
.../test/dup_replica_http_service_test.cpp | 17 +-
.../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 | 374 +++--
src/replica/replica.h | 119 +-
src/replica/replica_2pc.cpp | 27 +-
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 | 17 +-
src/replica/replica_context.cpp | 9 -
src/replica/replica_context.h | 4 +
src/replica/replica_disk_migrator.cpp | 13 +-
src/replica/replica_failover.cpp | 11 +-
src/replica/replica_http_service.cpp | 27 +-
src/replica/replica_http_service.h | 9 +-
src/replica/replica_init.cpp | 21 +-
src/replica/replica_learn.cpp | 46 +-
src/replica/replica_restore.cpp | 56 +-
src/replica/replica_stub.cpp | 944 ++++-------
src/replica/replica_stub.h | 148 +-
src/replica/replica_throttle.cpp | 11 +-
src/replica/replication_app_base.cpp | 208 +--
src/replica/replication_app_base.h | 43 +-
src/replica/split/replica_split_manager.cpp | 83 +-
src/replica/split/replica_split_manager.h | 8 +
src/replica/split/test/CMakeLists.txt | 18 +-
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 | 35 +-
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 | 48 +-
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 | 128 +-
.../storage/simple_kv/test/simple_kv.server.impl.h | 1 +
src/replica/test/CMakeLists.txt | 53 +-
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 | 55 +-
src/replica/test/replica_learn_test.cpp | 11 +-
src/replica/test/replica_test.cpp | 117 +-
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/CMakeLists.txt | 9 +-
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 | 30 -
src/runtime/ranger/ranger_resource_policy.cpp | 72 -
src/runtime/ranger/ranger_resource_policy.h | 75 -
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.cpp | 30 +-
src/runtime/rpc/rpc_host_port.h | 6 +
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/serverlet.h | 1 +
src/runtime/service_api_c.cpp | 5 +-
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 | 8 +-
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 | 24 +-
src/runtime/task/task_worker.h | 10 +-
src/runtime/test/CMakeLists.txt | 42 +-
src/runtime/test/address_test.cpp | 4 +-
src/runtime/test/async_call.cpp | 19 +-
src/runtime/test/corrupt_message.cpp | 4 +-
src/runtime/test/host_port_test.cpp | 19 +-
src/runtime/test/lpc.cpp | 15 +-
src/runtime/test/main.cpp | 13 +-
src/runtime/test/message_reader_test.cpp | 4 +-
src/runtime/test/message_utils_test.cpp | 4 +-
src/runtime/test/netprovider.cpp | 15 +-
src/runtime/test/pipeline_test.cpp | 5 +-
src/runtime/test/ranger_resource_policy_test.cpp | 86 -
src/runtime/test/rpc.cpp | 6 +-
src/runtime/test/rpc_holder_test.cpp | 4 +-
src/runtime/test/rpc_message.cpp | 13 +-
src/runtime/test/service_api_c.cpp | 13 +-
src/runtime/test/sim_lock.cpp | 13 +-
src/runtime/test/task_engine.cpp | 15 +-
src/runtime/test/task_test.cpp | 15 +-
src/runtime/test/thrift_message_parser_test.cpp | 4 +-
src/runtime/{test => }/test_utils.h | 9 -
src/runtime/tool_api.cpp | 9 -
src/runtime/tool_api.h | 16 +-
src/runtime/zlocks.cpp | 9 -
src/sample/CMakeLists.txt | 6 +-
src/{runtime => }/security/CMakeLists.txt | 27 +-
src/{runtime => }/security/access_controller.cpp | 0
src/{runtime => }/security/access_controller.h | 2 +-
src/{runtime => }/security/client_negotiation.cpp | 11 +-
src/{runtime => }/security/client_negotiation.h | 0
src/{runtime => }/security/init.cpp | 10 +
src/{runtime => }/security/init.h | 0
src/{runtime => }/security/kinit_context.cpp | 28 +
src/{runtime => }/security/kinit_context.h | 1 +
.../security/meta_access_controller.cpp | 6 +-
.../security/meta_access_controller.h | 0
src/{runtime => }/security/negotiation.cpp | 7 +-
src/{runtime => }/security/negotiation.h | 5 +
src/{runtime => }/security/negotiation_manager.cpp | 3 +-
src/{runtime => }/security/negotiation_manager.h | 2 +-
src/{runtime => }/security/negotiation_utils.h | 0
.../security/replica_access_controller.cpp | 7 +-
.../security/replica_access_controller.h | 13 +-
src/{runtime => }/security/sasl_client_wrapper.cpp | 8 +-
src/{runtime => }/security/sasl_client_wrapper.h | 0
src/{runtime => }/security/sasl_init.cpp | 4 +-
src/{runtime => }/security/sasl_init.h | 0
src/{runtime => }/security/sasl_server_wrapper.cpp | 8 +-
src/{runtime => }/security/sasl_server_wrapper.h | 0
src/{runtime => }/security/sasl_wrapper.cpp | 4 +-
src/{runtime => }/security/sasl_wrapper.h | 0
src/{runtime => }/security/server_negotiation.cpp | 11 +-
src/{runtime => }/security/server_negotiation.h | 2 -
src/{http => security}/test/CMakeLists.txt | 24 +-
.../test/client_negotiation_test.cpp | 9 +-
src/security/test/config.ini | 24 +
.../access_type.cpp => security/test/main.cpp} | 33 +-
.../test/meta_access_controller_test.cpp | 6 +-
.../test/negotiation_manager_test.cpp | 9 +-
.../test/replica_access_controller_test.cpp | 8 +-
.../format-all.sh => src/security/test/run.sh | 14 +-
.../test/server_negotiation_test.cpp | 11 +-
src/server/CMakeLists.txt | 63 +-
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 | 21 +-
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 | 51 +-
src/server/rocksdb_wrapper.h | 21 +-
src/server/test/CMakeLists.txt | 58 +-
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 | 76 +-
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 | 28 +-
.../{bulk_load_test => bulk_load}/main.cpp | 0
.../function_test/bulk_load/test_bulk_load.cpp | 358 ++++
.../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 | 18 +-
.../{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 | 163 +-
src/test/function_test/utils/test_util.h | 56 +-
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 | 11 +-
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 | 59 +-
src/utils/autoref_ptr.h | 11 +-
src/utils/binary_writer.h | 1 +
src/utils/blob.h | 7 +-
src/utils/builtin_metrics.cpp | 92 ++
.../builtin_metrics.h} | 30 +-
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 | 163 +-
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 | 352 ++--
src/utils/filesystem.h | 29 +-
src/utils/fixed_size_buffer_pool.h | 1 +
src/utils/flags.h | 3 +-
src/utils/fmt_logging.h | 47 +-
src/{runtime/security/init.h => utils/fmt_utils.h} | 17 +-
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/load_dump_object.h | 175 ++
src/utils/lockp.std.h | 9 -
src/utils/logging.cpp | 49 +-
src/utils/logging_provider.h | 19 +-
src/utils/long_adder_bench/CMakeLists.txt | 12 +-
src/utils/long_adder_bench/long_adder_bench.cpp | 23 +-
src/{runtime/security/init.h => utils/macros.h} | 20 +-
src/utils/memutil.h | 25 -
src/utils/metrics.cpp | 123 +-
src/utils/metrics.h | 432 ++++-
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 | 147 +-
src/utils/simple_logger.h | 41 +-
src/utils/singleton_store.h | 9 -
src/utils/smart_pointers.h | 132 --
src/utils/string_conv.h | 23 +-
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 | 6 +-
src/utils/test/enum_helper_test.cpp | 278 ++++
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 | 16 +-
src/utils/test/latency_tracer_test.cpp | 6 +-
src/utils/test/load_dump_object_test.cpp | 126 ++
src/utils/test/lock.std.cpp | 5 +-
src/utils/test/logger.cpp | 106 +-
src/utils/test/logging.cpp | 55 +-
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 | 319 +++-
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 | 372 +++--
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 ---
943 files changed, 23157 insertions(+), 20731 deletions(-)
create mode 100644 .devcontainer/devcontainer.json
create mode 100644 .github/actions/build_pegasus/action.yaml
copy java-client/src/test/resources/simplelogger.properties =>
.github/actions/download_artifact/action.yaml (62%)
create mode 100644 .github/actions/rebuild_thirdparty_if_needed/action.yaml
copy java-client/src/test/resources/simplelogger.properties =>
.github/actions/run_server_tests/action.yaml (69%)
copy src/test/function_test/CMakeLists.txt =>
.github/actions/unpack_prebuilt_thirdparties/action.yaml (65%)
create mode 100644 .github/actions/upload_artifact/action.yaml
create mode 100755 .github/workflows/free_disk_space.sh
copy .github/workflows/{lint_and_test_admin-cli.yml =>
lint_and_test_collector.yml} (60%)
create mode 100644 .github/workflows/lint_and_test_java-client.yml
create mode 100644 .github/workflows/lint_and_test_scala-client.yml
delete mode 100644 .github/workflows/test_java-client.yml
delete mode 100644 .github/workflows/test_scala-client.yml
create mode 100644 DISCLAIMER
delete mode 100644 DISCLAIMER-WIP
create mode 100644 HISTORY.md
copy scala-client/scripts/format-all.sh => collector/Makefile (86%)
mode change 100755 => 100644
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/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/backup/test/CMakeLists.txt => collector/config.yml (59%)
create mode 100644 collector/go.mod
copy {pegic => collector}/go.sum (65%)
copy src/runtime/security/kinit_context.h => collector/hotspot/algo.go (79%)
create mode 100644 collector/main.go
copy src/runtime/security/kinit_context.h =>
collector/metrics/meta_server_metrics.go (79%)
create mode 100644 collector/metrics/metric_collector.go
copy src/runtime/security/kinit_context.h =>
collector/metrics/replica_server_metrics.go (79%)
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 pegic/go.mod => 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 go-client/test.sh
delete mode 100755 java-client/scripts/ci-test.sh
delete mode 100755 nodejs-client/test.sh
delete mode 100755 python-client/test.sh
delete mode 100755 scala-client/scripts/ci-test.sh
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/{uri_decoder.h => http_method.h} (73%)
create mode 100644 src/http/http_status_code.cpp
create mode 100644 src/http/http_status_code.h
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/http_status_code_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/{test_util => ranger}/CMakeLists.txt (81%)
rename src/{runtime => }/ranger/access_type.h (69%)
create mode 100644 src/ranger/ranger_resource_policy.cpp
create mode 100644 src/ranger/ranger_resource_policy.h
rename src/{runtime => }/ranger/ranger_resource_policy_manager.cpp (89%)
rename src/{runtime => }/ranger/ranger_resource_policy_manager.h (91%)
copy src/{http => ranger}/test/CMakeLists.txt (81%)
copy src/{utils => ranger}/test/main.cpp (83%)
rename src/{runtime => ranger}/test/ranger_resource_policy_manager_test.cpp
(50%)
create mode 100644 src/ranger/test/ranger_resource_policy_test.cpp
copy scala-client/scripts/format-all.sh => src/ranger/test/run.sh (79%)
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
delete mode 100644 src/runtime/ranger/CMakeLists.txt
delete mode 100644 src/runtime/ranger/ranger_resource_policy.cpp
delete mode 100644 src/runtime/ranger/ranger_resource_policy.h
delete mode 100644 src/runtime/test/ranger_resource_policy_test.cpp
rename src/runtime/{test => }/test_utils.h (97%)
rename src/{runtime => }/security/CMakeLists.txt (72%)
rename src/{runtime => }/security/access_controller.cpp (100%)
rename src/{runtime => }/security/access_controller.h (98%)
rename src/{runtime => }/security/client_negotiation.cpp (95%)
rename src/{runtime => }/security/client_negotiation.h (100%)
rename src/{runtime => }/security/init.cpp (84%)
copy src/{runtime => }/security/init.h (100%)
rename src/{runtime => }/security/kinit_context.cpp (92%)
rename src/{runtime => }/security/kinit_context.h (95%)
rename src/{runtime => }/security/meta_access_controller.cpp (97%)
rename src/{runtime => }/security/meta_access_controller.h (100%)
rename src/{runtime => }/security/negotiation.cpp (90%)
rename src/{runtime => }/security/negotiation.h (91%)
rename src/{runtime => }/security/negotiation_manager.cpp (98%)
rename src/{runtime => }/security/negotiation_manager.h (98%)
rename src/{runtime => }/security/negotiation_utils.h (100%)
rename src/{runtime => }/security/replica_access_controller.cpp (93%)
rename src/{runtime => }/security/replica_access_controller.h (88%)
rename src/{runtime => }/security/sasl_client_wrapper.cpp (90%)
rename src/{runtime => }/security/sasl_client_wrapper.h (100%)
rename src/{runtime => }/security/sasl_init.cpp (97%)
rename src/{runtime => }/security/sasl_init.h (100%)
rename src/{runtime => }/security/sasl_server_wrapper.cpp (89%)
rename src/{runtime => }/security/sasl_server_wrapper.h (100%)
rename src/{runtime => }/security/sasl_wrapper.cpp (96%)
rename src/{runtime => }/security/sasl_wrapper.h (100%)
rename src/{runtime => }/security/server_negotiation.cpp (95%)
rename src/{runtime => }/security/server_negotiation.h (96%)
copy src/{http => security}/test/CMakeLists.txt (81%)
rename src/{runtime => security}/test/client_negotiation_test.cpp (96%)
create mode 100644 src/security/test/config.ini
rename src/{runtime/ranger/access_type.cpp => security/test/main.cpp} (59%)
rename src/{runtime => security}/test/meta_access_controller_test.cpp (95%)
rename src/{runtime => security}/test/negotiation_manager_test.cpp (96%)
rename src/{runtime => security}/test/replica_access_controller_test.cpp (92%)
rename scala-client/scripts/format-all.sh => src/security/test/run.sh (78%)
rename src/{runtime => security}/test/server_negotiation_test.cpp (96%)
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
(77%)
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
(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
(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/{replica/backup/replica_backup_server.h => utils/builtin_metrics.h}
(66%)
create mode 100644 src/utils/env.cpp
create mode 100644 src/utils/env.h
copy src/{runtime/security/init.h => utils/fmt_utils.h} (58%)
create mode 100644 src/utils/load_dump_object.h
rename src/{runtime/security/init.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
create mode 100644 src/utils/test/load_dump_object_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]
