This is an automated email from the ASF dual-hosted git repository.
wangdan pushed a change to branch
dependabot/pip/python-client/cryptography-44.0.1
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
from ec46e8766 build(deps): bump cryptography from 43.0.1 to 44.0.1 in
/python-client
add cb9a1d33c feat(duplication): make the task code for incremental
loading from private logs configurable (#2184)
add df0eb5a55 feat(go-client): add DelRange API to go-client (#2199)
add d42d83939 fix(bulk_load): fix core dump while downloading sst files
(#2077)
add 933ac39de feat(make_idempotent): support making write requests
idempotent for primary replicas (#2198)
add 5ccb32213 feat(bulk_load): reduce partition ingest time (#2195)
add e561ed629 build(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 in
/go-client (#1980)
add 1eeac73db build(deps): bump golang.org/x/net from 0.23.0 to 0.33.0 in
/pegic (#2177)
add 28dc6958c build(deps): bump golang.org/x/crypto from 0.21.0 to 0.31.0
in /collector(#2178)
add 61ccc5b75 Add the --config parameter to pegasus_manual_compact.sh
(#2204)
add a875cb426 build(deps): bump golang.org/x/net from 0.23.0 to 0.33.0 in
/go-client (#2176)
add ac642639e refactor(FQDN): Minor refactor on remove_node() (#1994)
add 76cd79896 feat(make_idempotent): introduce new table-level APIs to
meta servers to list/control idempotence for atomic writes (#2205)
add e612d2cd8 ci: bump dorny/paths-filter from v2 to v3.0.2 (#2218)
add cebbfae84 perf(make_idempotent): introduce row lock to improve 2PC for
idempotent atomic writes (#2214)
add fc416e3ac feat(make_idempotent): sync `atomic_idempotent` from meta
server into `.app-info` file for each replica (#2220)
add 03a2c92c9 feat(make_idempotent): support `atomic_idempotent` for
`create` and `ls` commands on shell (#2221)
add 2da689c18 feat(make_idempotent): each primary replica uses
`atomic_idempotent` to decide whether to make all atomic writes idempotent
(#2222)
add ff4a7d376 feat(new_metrics): support `server_stat` command showing
some important server-level metrics (part 2) (#2223)
add 5bc6421a4 build(deps): bump golang.org/x/net from 0.23.0 to 0.36.0 in
/admin-cli (#2207)
add 7144844d8 build(deps): bump golang.org/x/crypto in /collector (#2225)
add 586119a03 build(deps): bump golang.org/x/net from 0.23.0 to 0.36.0 in
/collector (#2228)
add 980ee2805 feat(new_metrics): introduce metrics for memory usage of
RocksDB Write Buffer Manager (#2224)
add 034d79a0e feat(make_idempotent): support getting/enabling/disabling
`atomic_idempotent` on shell (#2229)
add 600b34f88 fix(learn): avoid learn use DEFAULT_POOL (#2126)
add 682d960c6 feat(make_idempotent): support making `check_and_set`
request idempotent in `pegasus_write_service::impl` (#2230)
add 60bb031de ci(github): bump actions/cache from v2 to v3 for Java
workflows (#2234)
add a59acd01c ci(github): fix that sbt could not be found while checking
format for Scala (#2236)
add bed48daa9 ci(github): fix Go workflows which failed due to Ubuntu
20.04 retirement (#2240)
add 908d3ee8e build(deps): bump golang.org/x/net from 0.33.0 to 0.36.0 in
/go-client (#2226)
add 34f556219 build(deps): bump golang.org/x/net from 0.33.0 to 0.38.0 in
/pegic (#2231)
add 6a40395d1 build(deps): bump golang.org/x/net from 0.36.0 to 0.38.0 in
/collector (#2232)
add e64faa7d0 feat(make_idempotent): support making `check_and_set`
request idempotent in `pegasus_write_service` (#2239)
add 980689707 feat(duplication): support resumable download for checkpoint
files during full duplication on the server side (#2238)
add 9fed575f8 build: restrict the `CMake` version installed on Ubuntu
20.04 and 22.04 to 3.x.x (#2245)
add 5b229e53d feat(make_idempotent): support making `check_and_mutate`
request idempotent in `pegasus_write_service::impl` (#2246)
add ae6ace22a ci: introduce `revive` as the linter replacement for
`golint` (#2247)
add ce267cbd2 refactor(FQDN): further more refator on
idl/dsn.layer2.thrift v2 (#2217)
add e09804161 fix: fix build failure on Apple M chips (#2252)
add 656d84903 fix(shell): Fix potential vulnerable cloned function (#2253)
add 154bb16f1 feat(make_idempotent): re-adapt `make_idempotent()` and
`put()` to support batched single-update requests for atomic writes (#2249)
add 06e06d47b fix(go-client): fix the data race issue caused by concurrent
read/write access to the session list of `metaCall` (#2257)
add c11158d2c feat(go-client): generate interfaces for the hotkey
detection (#2255)
add b86817054 fix(security): fix DDD diagnose request failure with `app_id
= -1` and improve ACL handling (#2259)
add c6cf82b49 fix: use RTTI to do double-check for `down_cast` only in
debug mode (#2260)
add d4693fd2b perf(make_idempotent): improve performance of idempotent
writes by reducing deserialization and removing the mapping table for atomic
write handlers (#2261)
add 18e8aeb74 test: enable validation logic in debug-only code to run
during unit tests (#2262)
add c6e52b077 build: support building and testing Java and Scala Clients
with JDK 17 (#2263)
add 123427eda test: terminate the test case once `SetUp()` of the base
fixture fails (#2265)
add 6bcca89f7 chore: update NOTICE year to 2025 (#2268)
add a987da91b fix: fix undefined behavior due to overflow or underflow
when handling `incr` requests (#2269)
add 4f824e2a9 build(deps): bump org.apache.commons:commons-lang3 in
/java-client (#2271)
add 065063834 build(deps): bump io.netty:netty-bom from 4.1.85.Final to
4.1.123.Final in /java-client (#2273)
add fd39e6fc4 ci(github): pin the action `dorny/paths-filter` to the
commit SHA pointing to `v3.0.2` (#2275)
add 2b7020f17 build(deps): bump org.apache.zookeeper:zookeeper from 3.7.2
to 3.9.3 in /java-client (#2274)
add e42f1a65f fix(java-client): use `remove_result` instead of
`put_result` for `rrdb_remove_operator` (#2280)
add bf37fc5ef perf(network): support client RPC connection pool to each
server address (#2272)
add 7c0fd2574 fix(build): replace variable-length arrays with proper
structures to fix compilation errors on macOS (#2290)
add 8fbebd8a6 build(thirdparty): bump zookeeper-client-c from 3.7.0 to
3.9.4 (#2289)
add a5782f1b4 fix(scripts): fix the issue where running
pegasus_manual_compact.sh on small tables sometimes hangs (#2298)
add 05fe09c5f build(deps): bump both Thrift compiler and
org.apache.thrift:libthrift from 0.11.0 to 0.13.0 in /java-client (#2279)
add 4935ea01c build(thirdparty): fix thirdparties build failure on macOS
caused by removal of compatibility with CMake versions < 3.5 (#2294)
add b89ef3e2b build(images): install pluggable authentication modules for
Cyrus SASL on Ubuntu to provide auth mechanisms required for tests (#2296)
add fdbd6ebb4 feat(utils): update `get_last_component()` to support
`std::string_view` (#2299)
add 44400f6e3 build(deps): bump org.apache.zookeeper:zookeeper in
/java-client (#2301)
add 7fec15785 test(make_idempotent): refactor framework and add idempotent
cases for `incr` API in function tests (#2267)
add ea554b23c feat: support encrypted password file during SASL
authentication for ZooKeeper C client (#2293)
add 0fc00015a fix(go-client): Changed the validation logic for new
configuration during queryconfig operation (#2287)
add e637541f5 fix(zookeeper): fix potential dangling path pointer issue
when calling ZooKeeper APIs (#2302)
add 468bc0538 ci: fix the failure in Python client tests caused by
"version `GLIBC_2.38' not found" (#2311)
add 0f32557e8 fix(shell): make the returned scanners sorted in ascending
order by partition index to support fetching specified partition in shell
(#2312)
add 46b019830 fix(Python-client):prevent logger override and migrate
config to YAML (#2303)
add 3290bcae9 test: fix heap-use-after-free issue in
`test_disable_backup_policy` caused by unfinished task (#2315)
add 89b7c33b2 feat(go-client): introduce Prometheus for go-client
monitoring and added multiple metric collection sites (#2285)
add d56ea4699 Merge branch 'master' into
dependabot/pip/python-client/cryptography-44.0.1
No new revisions were added by this update.
Summary of changes:
.clang-tidy | 2 +-
.../rebuild_thirdparty_if_needed/action.yaml | 2 +-
.github/workflows/build-push-env-docker.yml | 38 +
.github/workflows/lint_and_test_admin-cli.yml | 16 +-
.github/workflows/lint_and_test_collector.yml | 19 +-
.github/workflows/lint_and_test_cpp.yaml | 12 +-
.github/workflows/lint_and_test_go-client.yml | 17 +-
.github/workflows/lint_and_test_java-client.yml | 11 +-
.github/workflows/lint_and_test_pegic.yml | 16 +-
.github/workflows/lint_and_test_scala-client.yml | 33 +-
.github/workflows/regular-build.yml | 33 +-
.github/workflows/test_nodejs-client.yml | 1 +
.github/workflows/test_python-client.yml | 3 +-
.golangci.yml | 21 +-
.licenserc.yaml | 1 -
NOTICE | 2 +-
admin-cli/client/fake_meta_test.go | 36 +-
admin-cli/client/meta.go | 12 +-
admin-cli/executor/server_config.go | 4 +-
admin-cli/executor/table_version.go | 13 +-
admin-cli/go.mod | 6 +-
admin-cli/go.sum | 12 +-
admin-cli/tabular/template.go | 2 +-
admin-cli/util/common_utils.go | 14 +-
admin_tools/pegasus_manual_compact.sh | 104 +-
admin_tools/start_zk.sh | 24 +-
build_tools/clang_tidy.py | 3 +
collector/avail/detector.go | 6 +-
collector/go.mod | 8 +-
collector/go.sum | 16 +-
collector/metrics/metric_collector.go | 2 +-
collector/usage/usage_recorder.go | 2 +-
.../{ubuntu2204 => go}/Dockerfile | 54 +-
docker/pegasus-build-env/ubuntu1804/Dockerfile | 1 +
docker/pegasus-build-env/ubuntu2004/Dockerfile | 3 +-
docker/pegasus-build-env/ubuntu2204/Dockerfile | 10 +-
go-client/.golangci.yml | 14 +
go-client/Makefile | 1 +
go-client/admin/client.go | 3 +-
go-client/admin/client_test.go | 9 +-
go-client/admin/remote_cmd_client.go | 2 +-
go-client/config/config.go | 62 +
go-client/example/full_scan.md | 131 +-
go-client/example/main.go | 3 +-
go-client/example/pegasus-client-config.json | 8 +-
go-client/generator/radmin.csv | 1 +
go-client/go.mod | 18 +-
go-client/go.sum | 42 +-
go-client/idl/admin/backup.go | 222 ++-
go-client/idl/admin/bulk_load.go | 140 +-
go-client/idl/admin/duplication-consts.go | 2 +
go-client/idl/admin/duplication.go | 1142 +++++++++++-
go-client/idl/admin/meta_admin-consts.go | 2 +
go-client/idl/admin/meta_admin.go | 1959 +++++++++++++++-----
go-client/idl/admin/metadata.go | 40 +-
go-client/idl/admin/partition_split.go | 94 +-
go-client/idl/cmd/command.go | 10 +-
go-client/idl/radmin/replica_admin.go | 394 +++-
go-client/idl/replication/dsn.layer2.go | 123 +-
go-client/idl/rrdb/rrdb.go | 645 +++++--
.../idl/{rrdb => utils}/GoUnusedProtection__.go | 2 +-
.../command-consts.go => utils/utils-consts.go} | 2 +-
go-client/idl/utils/utils.go | 167 ++
go-client/integration/failover-test/main.go | 3 +-
go-client/metrics/metrics.go | 97 +
go-client/pegasus/client.go | 24 +-
go-client/pegasus/client_test.go | 15 +-
go-client/pegasus/config.go | 25 -
go-client/pegasus/error.go | 2 +
go-client/pegasus/error_test.go | 3 +
go-client/pegasus/scanner.go | 6 +-
go-client/pegasus/table_connector.go | 160 +-
go-client/pegasus/table_connector_test.go | 147 +-
go-client/session/meta_call.go | 65 +-
go-client/session/meta_session.go | 11 +-
go-client/session/radmin_rpc_types.go | 16 +
go-client/session/replica_session.go | 13 +-
go-client/session/session.go | 39 +-
go-client/session/session_test.go | 20 +-
idl/dsn.layer2.thrift | 5 +
idl/meta_admin.thrift | 35 +
idl/replica_admin.thrift | 2 +
idl/rrdb.thrift | 54 +-
idl/utils.thrift | 13 +
java-client/pom.xml | 8 +-
java-client/scripts/download_thrift.sh | 25 +-
.../pegasus/operator/rrdb_remove_operator.java | 2 +-
pegic/go.mod | 4 +-
pegic/go.sum | 8 +-
pegic/interactive/cmd/compression.go | 2 +-
pegic/interactive/cmd/encoding.go | 2 +-
pegic/shell/app.go | 4 +-
python-client/pypegasus/logger.conf | 36 -
.../pypegasus/logger.yaml | 34 +-
python-client/pypegasus/pgclient.py | 10 +-
python-client/requirement.txt | 1 +
python-client/setup.py | 4 +-
run.sh | 34 +-
scala-client/build.sbt | 4 +-
scala-client/project/build.properties | 2 +-
scala-client/project/plugins.sbt | 2 +
src/aio/test/aio.cpp | 30 +-
src/base/idl_utils.h | 1 +
src/base/pegasus_key_schema.h | 10 +-
src/block_service/block_service.h | 4 +-
src/block_service/hdfs/hdfs_service.cpp | 5 +-
src/block_service/local/local_service.cpp | 3 +-
.../test/block_service_manager_test.cpp | 27 +-
src/client/replication_ddl_client.cpp | 38 +-
src/client/replication_ddl_client.h | 21 +-
src/client_lib/pegasus_client_impl.cpp | 30 +-
src/common/bulk_load_common.cpp | 9 +-
src/common/bulk_load_common.h | 1 +
src/common/consensus.thrift | 15 +
src/common/json_helper.h | 91 +-
src/common/replication.codes.h | 2 +
src/common/replication_other_types.h | 11 -
src/geo/test/geo_test.cpp | 5 +-
src/meta/backup_engine.cpp | 2 +-
src/meta/distributed_lock_service_simple.cpp | 71 +-
src/meta/distributed_lock_service_simple.h | 72 +-
src/meta/duplication/meta_duplication_service.cpp | 11 +-
src/meta/greedy_load_balancer.cpp | 9 +-
src/meta/meta_backup_service.cpp | 34 +-
src/meta/meta_bulk_load_service.cpp | 28 +-
src/meta/meta_data.h | 12 +-
src/meta/meta_rpc_types.h | 91 +-
src/meta/meta_server_failure_detector.cpp | 16 +-
src/meta/meta_server_failure_detector.h | 2 +-
src/meta/meta_service.cpp | 150 +-
src/meta/meta_service.h | 172 +-
src/meta/meta_split_service.cpp | 23 +-
src/meta/meta_state_service.h | 24 +-
src/meta/meta_state_service_simple.h | 79 +-
src/meta/meta_state_service_zookeeper.cpp | 3 +-
src/meta/meta_state_service_zookeeper.h | 81 +-
src/meta/partition_guardian.cpp | 42 +-
src/meta/partition_guardian.h | 13 +-
src/meta/server_state.cpp | 349 +++-
src/meta/server_state.h | 59 +-
src/meta/server_state_restore.cpp | 10 +-
src/meta/test/backup_test.cpp | 12 +-
src/meta/test/meta_app_envs_test.cpp | 10 +-
src/meta/test/meta_app_operation_test.cpp | 242 ++-
src/meta/test/meta_backup_test.cpp | 11 +-
src/meta/test/meta_bulk_load_ingestion_test.cpp | 22 +-
src/meta/test/meta_bulk_load_service_test.cpp | 32 +-
src/meta/test/meta_http_service_test.cpp | 15 +-
src/meta/test/meta_mauanl_compaction_test.cpp | 15 +-
src/meta/test/meta_partition_guardian_test.cpp | 7 +-
src/meta/test/meta_split_service_test.cpp | 16 +-
src/meta/test/meta_state/meta_state_service.cpp | 188 +-
src/meta/test/misc/misc.cpp | 6 +-
src/meta/test/server_state_restore_test.cpp | 9 +-
src/meta/test/state_sync_test.cpp | 30 +-
src/meta/test/update_configuration_test.cpp | 7 +-
src/nfs/nfs_code_definition.h | 19 +-
src/nfs/test/config.ini | 12 +-
src/ranger/ranger_resource_policy.cpp | 108 +-
src/ranger/ranger_resource_policy.h | 56 +-
src/ranger/ranger_resource_policy_manager.cpp | 48 +-
src/ranger/ranger_resource_policy_manager.h | 16 +-
.../test/ranger_resource_policy_manager_test.cpp | 7 +
src/replica/bulk_load/replica_bulk_loader.cpp | 72 +-
src/replica/bulk_load/replica_bulk_loader.h | 3 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 32 +-
src/replica/duplication/replica_duplicator.cpp | 24 +-
.../duplication/test/replica_duplicator_test.cpp | 17 +-
src/replica/idempotent_writer.h | 136 ++
src/replica/log_file.cpp | 119 +-
src/replica/log_file.h | 4 +-
src/replica/mutation.cpp | 424 ++++-
src/replica/mutation.h | 329 +++-
src/replica/mutation_cache.cpp | 34 +-
src/replica/prepare_list.cpp | 5 +-
src/replica/replica.cpp | 67 +-
src/replica/replica.h | 203 +-
src/replica/replica_2pc.cpp | 168 +-
src/replica/replica_backup.cpp | 1 +
src/replica/replica_base.h | 12 +-
src/replica/replica_check.cpp | 2 +-
src/replica/replica_chkpt.cpp | 84 +-
src/replica/replica_config.cpp | 64 +-
src/replica/replica_context.cpp | 16 +-
src/replica/replica_context.h | 5 +-
src/replica/replica_disk_migrator.cpp | 4 +-
src/replica/replica_init.cpp | 5 +-
src/replica/replica_stub.cpp | 40 +-
src/replica/replica_stub.h | 15 +-
src/replica/replication_app_base.cpp | 57 +-
src/replica/replication_app_base.h | 88 +-
src/replica/split/replica_split_manager.cpp | 4 +-
src/replica/split/test/replica_split_test.cpp | 45 +-
src/replica/storage/simple_kv/simple_kv.server.h | 4 +-
src/replica/storage/simple_kv/test/case-000.ini | 4 +-
src/replica/storage/simple_kv/test/case-001.ini | 2 +-
src/replica/storage/simple_kv/test/case-002.ini | 2 +-
src/replica/storage/simple_kv/test/case-003.ini | 2 +-
src/replica/storage/simple_kv/test/case-004.ini | 2 +-
src/replica/storage/simple_kv/test/case-005.ini | 2 +-
src/replica/storage/simple_kv/test/case-006.ini | 2 +-
src/replica/storage/simple_kv/test/case-100.ini | 2 +-
src/replica/storage/simple_kv/test/case-101.ini | 2 +-
src/replica/storage/simple_kv/test/case-102.ini | 2 +-
src/replica/storage/simple_kv/test/case-103.ini | 2 +-
src/replica/storage/simple_kv/test/case-104.ini | 2 +-
src/replica/storage/simple_kv/test/case-105.ini | 2 +-
src/replica/storage/simple_kv/test/case-106.ini | 2 +-
src/replica/storage/simple_kv/test/case-107.ini | 2 +-
src/replica/storage/simple_kv/test/case-108.ini | 2 +-
src/replica/storage/simple_kv/test/case-109.ini | 2 +-
src/replica/storage/simple_kv/test/case-200.ini | 2 +-
src/replica/storage/simple_kv/test/case-201.ini | 2 +-
src/replica/storage/simple_kv/test/case-202-0.ini | 2 +-
src/replica/storage/simple_kv/test/case-202-1.ini | 2 +-
src/replica/storage/simple_kv/test/case-203-0.ini | 2 +-
src/replica/storage/simple_kv/test/case-204.ini | 2 +-
src/replica/storage/simple_kv/test/case-205.ini | 2 +-
src/replica/storage/simple_kv/test/case-206.ini | 2 +-
src/replica/storage/simple_kv/test/case-207.ini | 2 +-
src/replica/storage/simple_kv/test/case-208.ini | 2 +-
src/replica/storage/simple_kv/test/case-209.ini | 2 +-
src/replica/storage/simple_kv/test/case-210.ini | 2 +-
src/replica/storage/simple_kv/test/case-211.ini | 2 +-
src/replica/storage/simple_kv/test/case-212.ini | 2 +-
src/replica/storage/simple_kv/test/case-213.ini | 2 +-
src/replica/storage/simple_kv/test/case-214.ini | 2 +-
src/replica/storage/simple_kv/test/case-215.ini | 2 +-
src/replica/storage/simple_kv/test/case-216.ini | 2 +-
src/replica/storage/simple_kv/test/case-300-0.ini | 2 +-
src/replica/storage/simple_kv/test/case-300-1.ini | 2 +-
src/replica/storage/simple_kv/test/case-300-2.ini | 2 +-
src/replica/storage/simple_kv/test/case-301.ini | 2 +-
src/replica/storage/simple_kv/test/case-302.ini | 2 +-
src/replica/storage/simple_kv/test/case-303.ini | 2 +-
src/replica/storage/simple_kv/test/case-304.ini | 2 +-
src/replica/storage/simple_kv/test/case-305.ini | 2 +-
src/replica/storage/simple_kv/test/case-306.ini | 2 +-
src/replica/storage/simple_kv/test/case-307.ini | 2 +-
src/replica/storage/simple_kv/test/case-400.ini | 2 +-
src/replica/storage/simple_kv/test/case-401.ini | 2 +-
src/replica/storage/simple_kv/test/case-402.ini | 2 +-
src/replica/storage/simple_kv/test/case-600.ini | 2 +-
src/replica/storage/simple_kv/test/case-601.ini | 2 +-
src/replica/storage/simple_kv/test/case-602.ini | 2 +-
src/replica/storage/simple_kv/test/case-603.ini | 2 +-
src/replica/storage/simple_kv/test/config.ini | 2 +-
src/replica/test/cold_backup_context_test.cpp | 1 -
src/replica/test/log_file_test.cpp | 115 +-
src/replica/test/mock_utils.h | 4 +-
src/replica/test/replica_dir_test.cpp | 47 +-
src/replica/test/replica_disk_migrate_test.cpp | 4 +-
src/replica/test/replica_test.cpp | 153 +-
src/rpc/asio_net_provider.cpp | 95 +-
src/rpc/asio_net_provider.h | 10 +-
src/rpc/asio_rpc_session.cpp | 238 ++-
src/rpc/asio_rpc_session.h | 79 +-
src/rpc/dsn_message_parser.cpp | 79 +-
src/rpc/network.cpp | 628 ++++---
src/rpc/network.h | 221 ++-
src/rpc/network.sim.cpp | 7 +-
src/rpc/network.sim.h | 21 +-
src/rpc/raw_message_parser.cpp | 50 +-
src/rpc/rpc_holder.h | 11 +-
src/rpc/rpc_host_port.cpp | 18 +
src/rpc/rpc_host_port.h | 13 +
src/rpc/rpc_message.cpp | 24 +-
src/rpc/rpc_message.h | 26 +-
src/rpc/test/message_utils_test.cpp | 7 +-
src/rpc/test/net_provider_test.cpp | 591 ++++--
src/rpc/test/rpc_message_test.cpp | 4 +-
src/runtime/CMakeLists.txt | 1 -
src/runtime/message_utils.cpp | 53 -
src/runtime/message_utils.h | 59 +-
src/runtime/profiler.cpp | 1 +
src/runtime/serverlet.h | 38 +-
src/runtime/tool_api.cpp | 1 +
src/security/access_controller.cpp | 17 +-
src/security/access_controller.h | 47 +-
src/security/meta_access_controller.cpp | 54 +-
src/security/meta_access_controller.h | 9 +-
src/security/replica_access_controller.h | 3 +-
src/security/test/meta_access_controller_test.cpp | 188 +-
src/server/pegasus_server_impl.cpp | 56 +-
src/server/pegasus_server_impl.h | 14 +-
src/server/pegasus_server_impl_init.cpp | 14 +
src/server/pegasus_server_write.cpp | 195 +-
src/server/pegasus_server_write.h | 113 +-
src/server/pegasus_write_service.cpp | 198 +-
src/server/pegasus_write_service.h | 112 +-
src/server/pegasus_write_service_impl.h | 638 +++++--
src/server/rocksdb_wrapper.cpp | 20 +
src/server/rocksdb_wrapper.h | 15 +-
src/server/test/CMakeLists.txt | 1 +
src/server/test/capacity_unit_calculator_test.cpp | 4 +-
src/server/test/hotkey_collector_test.cpp | 4 +-
src/server/test/manual_compact_service_test.cpp | 6 +-
.../test/pegasus_compression_options_test.cpp | 1 -
src/server/test/pegasus_server_impl_test.cpp | 280 ++-
src/server/test/pegasus_server_test_base.h | 52 +-
src/server/test/pegasus_server_write_test.cpp | 24 +-
.../test/pegasus_write_service_impl_test.cpp | 43 +-
src/server/test/pegasus_write_service_test.cpp | 2 +-
src/server/test/rocksdb_wrapper_test.cpp | 25 +-
src/shell/command_helper.h | 24 +
src/shell/command_utils.h | 25 +-
src/shell/commands.h | 72 +-
src/shell/commands/detect_hotkey.cpp | 2 +-
src/shell/commands/duplication.cpp | 2 +-
src/shell/commands/local_partition_split.cpp | 2 +-
src/shell/commands/node_management.cpp | 92 +-
src/shell/commands/table_management.cpp | 194 +-
src/shell/main.cpp | 21 +-
src/shell/sds/sds.c | 7 +-
src/task/task_spec.cpp | 58 +-
src/task/task_worker.cpp | 10 +-
src/test/function_test/CMakeLists.txt | 1 +
.../{restore => atomic_write}/CMakeLists.txt | 14 +-
.../atomic_write/atomic_write_test.cpp | 80 +
.../function_test/atomic_write/atomic_write_test.h | 69 +
src/test/function_test/atomic_write/incr_test.cpp | 357 ++++
.../function_test/atomic_write}/main.cpp | 0
src/test/function_test/base_api/test_copy.cpp | 108 +-
src/test/function_test/base_api/test_incr.cpp | 249 ---
src/test/function_test/base_api/test_scan.cpp | 32 +-
src/test/function_test/base_api/test_ttl.cpp | 10 +-
.../function_test/bulk_load/test_bulk_load.cpp | 91 +-
.../detect_hotspot/test_detect_hotspot.cpp | 2 +-
.../function_test/partition_split/test_split.cpp | 2 +-
src/test/function_test/recovery/test_recovery.cpp | 47 +-
src/test/function_test/restore/test_restore.cpp | 21 +-
src/test/function_test/utils/test_util.cpp | 54 +-
src/test/function_test/utils/test_util.h | 55 +-
src/test_util/test_util.cpp | 40 +-
src/test_util/test_util.h | 41 +-
src/utils/alloc.h | 9 +-
src/utils/binary_reader.h | 6 +-
src/utils/binary_writer.cpp | 25 +-
src/utils/blob.h | 36 +-
src/utils/{preloadable.h => bytes.h} | 25 +-
src/utils/casts.h | 9 +-
src/utils/{math.h => checksum.cpp} | 41 +-
.../sasl_client_wrapper.h => utils/checksum.h} | 33 +-
src/utils/distributed_lock_service.h | 31 +-
src/utils/errors.h | 2 +-
src/utils/fmt_logging.h | 11 +
src/utils/metrics.h | 1 +
src/utils/safe_arithmetic.h | 76 +
src/utils/strings.cpp | 27 +-
src/utils/strings.h | 3 +-
src/utils/test/CMakeLists.txt | 3 +-
src/utils/test/blob_test.cpp | 4 -
src/utils/test/checksum_test.cpp | 106 ++
src/utils/test/safe_arithmetic_test.cpp | 192 ++
src/utils/test/utils.cpp | 123 +-
src/utils/test_macros.h | 28 +-
src/utils/threadpool_code.h | 1 +
.../distributed_lock_service_zookeeper.cpp | 71 +-
src/zookeeper/distributed_lock_service_zookeeper.h | 74 +-
src/zookeeper/lock_struct.cpp | 495 ++---
src/zookeeper/lock_struct.h | 40 +-
src/zookeeper/lock_types.h | 11 +-
src/zookeeper/test/CMakeLists.txt | 2 +
src/zookeeper/test/config-test.ini | 1 -
.../test/sasl_auth}/CMakeLists.txt | 23 +-
.../test/sasl_auth}/config-test.ini | 31 +-
.../test => zookeeper/test/sasl_auth}/main.cpp | 41 +-
.../test => zookeeper/test/sasl_auth}/run.sh | 21 +-
.../sasl_auth/zookeeper_session_sasl_auth_test.cpp | 125 ++
.../test/zookeeper_session_no_auth_test.cpp} | 35 +-
src/zookeeper/test/zookeeper_session_test.h | 178 ++
src/zookeeper/test/zookeeper_session_test_base.cpp | 282 +++
src/zookeeper/test/zookeeper_session_test_base.h | 158 ++
src/zookeeper/zookeeper_session.cpp | 276 ++-
src/zookeeper/zookeeper_session.h | 49 +-
thirdparty/CMakeLists.txt | 12 +-
thirdparty/fix_absl_build_on_macos_arm64.patch | 13 +
thirdparty/fix_hdfs_native_client.patch | 101 +-
378 files changed, 15190 insertions(+), 5626 deletions(-)
copy docker/pegasus-build-env/{ubuntu2204 => go}/Dockerfile (53%)
create mode 100644 go-client/config/config.go
copy go-client/idl/{rrdb => utils}/GoUnusedProtection__.go (91%)
copy go-client/idl/{cmd/command-consts.go => utils/utils-consts.go} (96%)
create mode 100644 go-client/idl/utils/utils.go
create mode 100644 go-client/metrics/metrics.go
delete mode 100644 go-client/pegasus/config.go
delete mode 100644 python-client/pypegasus/logger.conf
copy admin-cli/check_and_format.sh => python-client/pypegasus/logger.yaml (58%)
mode change 100755 => 100644
create mode 100644 src/replica/idempotent_writer.h
delete mode 100644 src/runtime/message_utils.cpp
copy src/test/function_test/{restore => atomic_write}/CMakeLists.txt (88%)
create mode 100644 src/test/function_test/atomic_write/atomic_write_test.cpp
create mode 100644 src/test/function_test/atomic_write/atomic_write_test.h
create mode 100644 src/test/function_test/atomic_write/incr_test.cpp
copy src/{client/test => test/function_test/atomic_write}/main.cpp (100%)
delete mode 100644 src/test/function_test/base_api/test_incr.cpp
copy src/utils/{preloadable.h => bytes.h} (71%)
copy src/utils/{math.h => checksum.cpp} (53%)
copy src/{security/sasl_client_wrapper.h => utils/checksum.h} (50%)
create mode 100644 src/utils/safe_arithmetic.h
create mode 100644 src/utils/test/checksum_test.cpp
create mode 100644 src/utils/test/safe_arithmetic_test.cpp
copy src/{test/function_test/partition_split =>
zookeeper/test/sasl_auth}/CMakeLists.txt (76%)
copy src/{http/test => zookeeper/test/sasl_auth}/config-test.ini (75%)
copy src/{block_service/test => zookeeper/test/sasl_auth}/main.cpp (59%)
copy src/{client/test => zookeeper/test/sasl_auth}/run.sh (58%)
create mode 100644
src/zookeeper/test/sasl_auth/zookeeper_session_sasl_auth_test.cpp
copy src/{utils/builtin_metrics.h =>
zookeeper/test/zookeeper_session_no_auth_test.cpp} (63%)
create mode 100644 src/zookeeper/test/zookeeper_session_test.h
create mode 100644 src/zookeeper/test/zookeeper_session_test_base.cpp
create mode 100644 src/zookeeper/test/zookeeper_session_test_base.h
create mode 100644 thirdparty/fix_absl_build_on_macos_arm64.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
