You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by gi...@apache.org on 2023/01/20 02:34:49 UTC
[incubator-pegasus] branch dependabot/pip/python-client/twisted-22.10.0 updated (3a203e811 -> 3cedd3aac)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/pip/python-client/twisted-22.10.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard 3a203e811 build(deps): bump twisted from 21.2.0 to 22.10.0 in /python-client
add 0f4bd1501 refactor(macro): use CHECK_* to replace dassert_* (part 2) (#1217)
add c7638fc14 update commons-configuration2 version to 2.8.0 (#1222)
add e2a0088f8 refactor(macro): use CHECK_* to replace dassert_* (part 3) (#1226)
add ba723a991 feat: overload stream insertion operator(<<) to support formatting by {fmt} (#1225)
add 0ffc3c9dd refactor(macro): use DCHECK* to replace dbg_dassert and self defined ASSERT_* (#1228)
add afca62fc1 refactor(macro): use the more general CHECK_PREFIX* to replace dassert_replica (#1230)
add de1d02b5c feat: improve checking if C string is empty (#1229)
add 01ca71c3e feat(thirdparty): use official rocksdb (#1048)
add e7c0589c4 refactor: use linux_fd_t instead of dsn_handle_t for file descriptor (#1238)
add 405ce5fef refactor: use command_deregister to auto deregister from command_manager (#1241)
add 162f39986 refactor: use state machine to improve split_args for strings (#1240)
add 14995745b refactor: remove api_common.h and dlib.h header files (#1235)
add e9537a64e fix: fix log header not corresponding to level (#1246)
add b26a1130c feat(new_metrics): support filters for selected metric fields in response (#1237)
add a24bb90e9 feat: support showing true expression in message for CHECK* macro (#1253)
add 478b07e09 refactor(log): adjust default log level from DEBUG to INFO (#1250)
add d54e05fb7 refactor: enable build warning on unused result (#1248)
add 9cb11f90b build(pom): use --release when building java client with java11+ (#1256)
add 2938389c3 build(pom): inherit apache pom (#1260)
add 1e9fe8e5f refactor: Remove assembly and output debug output to console when running UTs for java client (#1266)
add 607884b40 refactor: remove zkclient dependency (#1264)
add 6f90ccabe refactor: Use spotless plugin to format pom file (#1271)
add 5229a614c chore(action): support checking issue number prefixed with '#' in github actions for PRs (#1270)
add 25dd45a4e refactor: Remove usage of commons-configuration (#1273)
add 2e0574218 build: bump netty's version and shade it (#1274)
add 3f957893e build: use maven flatten plugin to generate resolved pom (#1277)
add 06a0ad9bb refactor(rpc_address): simple refactor on rpc_address (#1251)
add d4b2ce986 feat(config): Make the configs take effect for the FLAGS_* only used once (#1198)
add 450944dbe build: support publish artifacts to repository.a.o (#1278)
add 8205f245a feat(new_metrics): take snapshot of each entity as json format (#1258)
add caf5c1ebf fix: fix some bad links of docs (#1282)
add 06b2033ea feat(new_metrics): traverse the whole registry to choose entities and metrics according to the filters (#1285)
add c1435758d refactor(idl): unify the *.thrift files used by cpp and go-client (#1284)
add 6804b3bbd refactor: let cmds deregister automatically (#1287)
add 1bb62a2d2 fix: fix judgment to disk for partition split (#1289)
add 2fe716b5e feat: add rename_app interface (#1272)
add 67b35b190 chore(ci): use ubuntu-20.04 and install thrift-0.13 specially (#1292)
add 2aaf021ff refactor(idl): unify the *.thrift files used by cpp and java-client (#1290)
add 608847829 fix: fix ubuntu-16.04 build (#1295)
add 17bd73310 feat(new_metrics): provide http service to process client query for metrics (#1298)
add 9a6702ae2 feat(server): disable UDP service by default (#1132)
add cb99a6b70 feat: expose parameter success_if_exist for interface create_app (#1148)
add 86f7e02ab feat: decide whether two C strings are equal and support CHECK_STREQ* and CHECK_STRNE* (#1300)
add ad0299570 feat(new_metrics): support frequently-used combinations of metric fields in the query string (#1302)
add 180277a28 refactor(log): use LOG_DEBUG_F instead of LOG_DEBUG (#1306)
add 966e9002a refactor(FLAG): remove the quotes of section field of FLAG (#1308)
add 948682211 refactor(log): use LOG_INFO_F instead of LOG_INFO (1/3) (#1307)
add 8d3b42c43 refactor(log): use LOG_INFO_F instead of LOG_INFO (2/3) (#1310)
add 9df5bdaab refactor(log): use LOG_INFO_F instead of LOG_INFO (3/3) (#1311)
add 0dcb32ffa refactor(log): use LOG_FATAL_F instead of LOG_FATAL (#1312)
add 5ed43a1f1 chore(CI): Add unit test workflow for python client (#1314)
add f781f6c08 refactor(log): use LOG_WARNING_F instead of LOG_WARNING (1/3) (#1315)
add 16d9e3253 refactor(log): use LOG_WARNING_F instead of LOG_WARNING (2/3) (#1316)
add b81cb43e6 refactor(log): use LOG_ERROR_F instead of LOG_ERROR (1/2) (#1318)
add 3a4e1cbac refactor(log): use LOG_WARNING_F instead of LOG_WARNING (3/3) (#1319)
add d17f1ff40 refactor(log): use LOG_ERROR_F instead of LOG_ERROR (2/2) (#1320)
add 831fb5c43 refactor(idl): unify the *.thrift files used by cpp and python-client (#1317)
add 3cedd3aac build(deps): bump twisted from 21.2.0 to 22.10.0 in /python-client
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (3a203e811)
\
N -- N -- N refs/heads/dependabot/pip/python-client/twisted-22.10.0 (3cedd3aac)
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:
.github/workflows/lint_and_test_admin-cli.yml | 4 +
.github/workflows/lint_and_test_go-client.yml | 27 +-
.github/workflows/regular-build.yml | 50 +-
.github/workflows/standardization_lint.yaml | 1 +
...test_java-client.yml => test_python-client.yml} | 33 +-
.gitignore | 2 +-
.licenserc.yaml | 21 +-
README.md | 6 +-
admin-cli/README.md | 2 -
admin-cli/executor/partition_split.go | 2 +-
cmake_modules/BaseFunctions.cmake | 1 -
go-client/Makefile | 15 +-
go-client/admin/client.go | 18 +-
go-client/docs/how_to_add_new_interface.md | 11 +-
go-client/generator/admin.csv | 22 +-
go-client/idl/admin.thrift | 767 -
go-client/idl/admin/GoUnusedProtection__.go | 6 -
go-client/idl/admin/admin-consts.go | 25 -
go-client/idl/admin/admin.go | 20627 -------------------
go-client/idl/base.thrift | 33 -
go-client/idl/base/error_code.go | 2 +-
go-client/idl/cmd.thrift | 30 -
go-client/idl/cmd/GoUnusedProtection__.go | 6 -
go-client/idl/cmd/cmd-consts.go | 23 -
go-client/idl/cmd/cmd.go | 536 -
go-client/idl/radmin.thrift | 99 -
go-client/idl/radmin/GoUnusedProtection__.go | 6 -
go-client/idl/radmin/radmin-consts.go | 25 -
go-client/idl/radmin/radmin.go | 2353 ---
go-client/idl/replication.thrift | 58 -
go-client/idl/replication/GoUnusedProtection__.go | 6 -
go-client/idl/replication/replication-consts.go | 25 -
go-client/idl/replication/replication.go | 1135 -
go-client/idl/rrdb.thrift | 293 -
go-client/idl/rrdb/GoUnusedProtection__.go | 6 -
go-client/idl/rrdb/rrdb-consts.go | 27 -
go-client/idl/rrdb/rrdb.go | 10824 ----------
go-client/pegalog/logger.go | 3 +-
go-client/pegasus/op/multidel.go | 4 +-
go-client/pegasus/op/multiget.go | 4 +-
go-client/pegasus/scanner.go | 2 +-
go-client/session/admin_rpc_types.go | 88 +-
go-client/session/codec.go | 32 +-
go-client/session/meta_session.go | 1 -
{src/common => idl}/backup.thrift | 6 +-
{src/common => idl}/bulk_load.thrift | 6 +-
{src/remote_cmd => idl}/command.thrift | 6 +
idl/dsn.layer2.thrift | 16 +-
idl/dsn.thrift | 3 +
{src/common => idl}/duplication.thrift | 6 +-
{src/common => idl}/meta_admin.thrift | 79 +-
{src/common => idl}/metadata.thrift | 6 +-
{src/common => idl}/partition_split.thrift | 6 +-
{src/common => idl}/replica_admin.thrift | 16 +-
idl/rrdb.thrift | 61 +-
{src/runtime/security => idl}/security.thrift | 9 +-
java-client/README.md | 10 +-
java-client/configuration/log4j.properties | 42 -
java-client/idl/apache-licence-template | 18 -
java-client/idl/base.thrift | 42 -
java-client/idl/meta_admin.thrift | 63 -
java-client/idl/replication.thrift | 59 -
java-client/idl/rrdb.thrift | 322 -
java-client/idl/security.thrift | 79 -
java-client/pom.xml | 281 +-
java-client/scripts/ci-test.sh | 2 +-
java-client/{idl => scripts}/recompile_thrift.sh | 18 +-
java-client/src/assembly/dep.xml | 57 -
.../org/apache/pegasus/client/ClientOptions.java | 79 +-
.../org/apache/pegasus/client/PConfigUtil.java | 23 +-
.../apache/pegasus/client/PegasusAdminClient.java | 16 +-
.../client/PegasusAdminClientInterface.java | 10 +
.../org/apache/pegasus/client/PegasusScanner.java | 2 +-
.../pegasus/operator/create_app_operator.java | 7 +-
.../apache/pegasus/operator/drop_app_operator.java | 7 +-
.../org/apache/pegasus/security/Credential.java | 5 +-
.../pegasus/security/KerberosCredential.java | 12 +-
.../org/apache/pegasus/util/PropertyUtils.java | 51 +
.../java/org/apache/pegasus/client/TestPingZK.java | 42 +-
java-client/src/test/resource/pegasus.properties | 25 -
.../test/resources}/pegasus.properties | 0
.../src/test/resources/simplelogger.properties | 7 +-
python-client/README.md | 9 +-
python-client/idl/base.thrift | 43 -
python-client/idl/replication.thrift | 60 -
python-client/idl/rrdb.thrift | 294 -
python-client/pypegasus/__init__.py | 2 +-
python-client/pypegasus/base/constants.py | 15 +-
python-client/pypegasus/base/ttypes.py | 10 +-
python-client/pypegasus/replication/__init__.py | 18 -
python-client/pypegasus/replication/constants.py | 28 -
python-client/pypegasus/replication/replication.py | 23 -
python-client/pypegasus/replication/ttypes.py | 533 -
python-client/pypegasus/rrdb/__init__.py | 18 -
python-client/pypegasus/rrdb/constants.py | 28 -
python-client/pypegasus/rrdb/meta.py | 258 -
python-client/pypegasus/rrdb/rrdb.py | 2625 ---
python-client/pypegasus/rrdb/ttypes.py | 2824 ---
python-client/requirement.txt | 5 +
python-client/sample.py | 2 +-
python-client/setup.py | 4 +-
{go-client => python-client}/test.sh | 36 +-
python-client/tests/test_basics.py | 11 +-
scripts/recompile_thrift.sh | 2 +-
src/aio/aio_provider.h | 23 +-
src/aio/aio_task.cpp | 7 +-
src/aio/aio_task.h | 13 +-
src/aio/disk_engine.cpp | 34 +-
src/aio/disk_engine.h | 7 +-
src/aio/file_io.cpp | 15 +-
src/aio/native_linux_aio_provider.cpp | 60 +-
src/aio/native_linux_aio_provider.h | 6 +-
src/aio/test/aio.cpp | 15 +-
src/aio/test/main.cpp | 14 +-
src/base/pegasus_key_schema.h | 19 +-
src/base/pegasus_utils.h | 8 +-
src/base/pegasus_value_schema.h | 14 +-
src/base/test/main.cpp | 1 -
src/base/value_schema_v0.cpp | 2 +-
src/base/value_schema_v1.cpp | 2 +-
src/base/value_schema_v2.cpp | 5 +-
src/block_service/block_service.h | 3 +-
src/block_service/block_service_manager.cpp | 25 +-
src/block_service/directio_writable_file.cpp | 73 +-
src/block_service/directio_writable_file.h | 2 +
src/block_service/fds/fds_service.cpp | 147 +-
src/block_service/hdfs/hdfs_service.cpp | 12 +-
src/block_service/local/local_service.cpp | 90 +-
src/block_service/test/fds_service_test.cpp | 26 +-
src/block_service/test/hdfs_service_test.cpp | 24 +-
src/block_service/test/main.cpp | 3 +-
src/client/partition_resolver.cpp | 16 +-
src/client/partition_resolver.h | 4 +-
src/client/partition_resolver_manager.cpp | 2 +-
src/client/partition_resolver_manager.h | 2 +-
src/client/partition_resolver_simple.cpp | 56 +-
src/client/partition_resolver_simple.h | 1 -
src/client/replication_ddl_client.cpp | 54 +-
src/client/replication_ddl_client.h | 9 +-
src/client_lib/pegasus_client_factory_impl.cpp | 6 +-
src/client_lib/pegasus_client_impl.cpp | 101 +-
src/common/CMakeLists.txt | 21 +-
src/common/api_common.h | 92 -
src/common/common.cpp | 9 +-
src/common/consensus.thrift | 2 +-
src/common/duplication_common.cpp | 32 +-
src/common/duplication_internal.thrift | 52 +
src/common/fs_manager.cpp | 60 +-
src/common/fs_manager.h | 3 +-
src/common/gpid.h | 5 +-
src/common/json_helper.h | 26 +-
src/common/replication.codes.h | 1 +
src/common/replication_common.cpp | 36 +-
src/common/replication_common.h | 4 +-
src/common/serialization_helper/thrift_helper.h | 8 +-
src/common/storage_serverlet.h | 27 +-
src/common/test/main.cpp | 3 +-
src/failure_detector/failure_detector.cpp | 131 +-
src/failure_detector/failure_detector.h | 4 +-
.../failure_detector_multimaster.cpp | 29 +-
src/failure_detector/fd.code.definition.h | 3 +-
src/failure_detector/test/failure_detector.cpp | 29 +-
src/failure_detector/test/main.cpp | 3 +-
src/geo/bench/config.ini | 2 +-
src/geo/lib/geo_client.cpp | 8 +-
src/geo/lib/latlng_codec.cpp | 3 +-
src/geo/test/main.cpp | 1 -
src/http/builtin_http_calls.cpp | 5 -
src/http/builtin_http_calls.h | 2 -
src/http/config_http_service.cpp | 18 -
src/http/http_call_registry.h | 18 +-
src/http/http_message_parser.cpp | 26 +-
src/http/http_server.cpp | 53 +-
src/http/http_server.h | 27 +-
src/http/pprof_http_service.cpp | 45 +-
src/http/test/http_server_test.cpp | 4 +-
src/include/rrdb/rrdb.client.h | 9 +-
src/meta/app_balance_policy.cpp | 76 +-
src/meta/app_balance_policy.h | 11 +-
src/meta/cluster_balance_policy.cpp | 2 +-
src/meta/cluster_balance_policy.h | 2 +-
src/meta/dump_file.h | 16 +-
src/meta/duplication/duplication_info.cpp | 2 +-
src/meta/duplication/duplication_info.h | 4 -
src/meta/duplication/meta_duplication_service.cpp | 4 +-
src/meta/greedy_load_balancer.cpp | 25 +-
src/meta/greedy_load_balancer.h | 5 +-
src/meta/load_balance_policy.cpp | 102 +-
src/meta/load_balance_policy.h | 7 +-
src/meta/meta_backup_service.cpp | 365 +-
src/meta/meta_backup_service.h | 4 +
src/meta/meta_bulk_load_ingestion_context.cpp | 9 +-
src/meta/meta_bulk_load_service.cpp | 13 +-
src/meta/meta_data.cpp | 133 +-
src/meta/meta_http_service.cpp | 32 +-
src/meta/meta_http_service.h | 2 +-
src/meta/meta_options.cpp | 7 +-
src/meta/meta_options.h | 3 +-
src/meta/meta_rpc_types.h | 5 +-
src/meta/meta_server_failure_detector.cpp | 116 +-
src/meta/meta_service.cpp | 102 +-
src/meta/meta_service.h | 16 +-
src/meta/meta_service_app.cpp | 3 +-
src/meta/meta_split_service.cpp | 23 +-
src/meta/meta_state_service.h | 3 +-
src/meta/meta_state_service_simple.cpp | 23 +-
src/meta/meta_state_service_utils.cpp | 3 +-
src/meta/meta_state_service_zookeeper.cpp | 22 +-
src/meta/partition_guardian.cpp | 226 +-
src/meta/partition_guardian.h | 4 +-
src/meta/server_load_balancer.cpp | 12 +-
src/meta/server_load_balancer.h | 8 +-
src/meta/server_state.cpp | 1256 +-
src/meta/server_state.h | 9 +-
src/meta/server_state_restore.cpp | 21 +-
src/meta/test/backup_test.cpp | 11 +-
.../test/balancer_simulator/balancer_simulator.cpp | 29 +-
src/meta/test/balancer_validator.cpp | 132 +-
src/meta/test/dump_file.cpp | 4 +-
src/meta/test/json_compacity.cpp | 10 +-
src/meta/test/main.cpp | 5 +-
src/meta/test/meta_app_operation_test.cpp | 55 +-
src/meta/test/meta_partition_guardian_test.cpp | 22 +-
src/meta/test/meta_service_test_app.h | 3 +-
src/meta/test/meta_split_service_test.cpp | 1 -
src/meta/test/meta_state/main.cpp | 3 +-
src/meta/test/meta_state/meta_state_service.cpp | 6 +-
src/meta/test/meta_state_service_utils_test.cpp | 3 +-
src/meta/test/meta_test_base.cpp | 9 +-
src/meta/test/misc/misc.cpp | 148 +-
src/meta/test/misc/misc.h | 8 +-
src/meta/test/server_state_test.cpp | 1 -
src/meta/test/state_sync_test.cpp | 38 +-
src/meta/test/update_configuration_test.cpp | 10 +-
src/nfs/nfs_client_impl.cpp | 89 +-
src/nfs/nfs_client_impl.h | 4 +-
src/nfs/nfs_server_impl.cpp | 62 +-
src/nfs/nfs_server_impl.h | 17 +-
src/nfs/test/main.cpp | 1 -
src/perf_counter/builtin_counters.cpp | 9 +-
src/perf_counter/perf_counter.cpp | 7 +-
src/perf_counter/perf_counter.h | 1 -
src/perf_counter/perf_counter_atomic.h | 2 +-
src/perf_counter/perf_counters.cpp | 125 +-
src/perf_counter/perf_counters.h | 14 +-
src/perf_counter/test/main.cpp | 3 +-
src/perf_counter/test/perf_counter_test.cpp | 8 +-
src/redis_protocol/proxy/config.ini | 2 +-
src/redis_protocol/proxy/main.cpp | 9 +-
src/redis_protocol/proxy_lib/proxy_layer.cpp | 16 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 5 +-
src/redis_protocol/proxy_lib/redis_parser.cpp | 197 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 21 +-
src/remote_cmd/CMakeLists.txt | 2 +-
src/replica/backup/cold_backup_context.cpp | 445 +-
src/replica/backup/cold_backup_context.h | 12 +-
src/replica/backup/replica_backup_server.cpp | 25 +-
src/replica/backup/test/main.cpp | 3 +-
src/replica/bulk_load/test/main.cpp | 3 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 4 +-
src/replica/disk_cleaner.cpp | 8 +-
src/replica/duplication/duplication_sync_timer.cpp | 2 +-
src/replica/duplication/load_from_private_log.cpp | 10 +-
src/replica/duplication/mutation_batch.cpp | 6 +-
src/replica/duplication/replica_duplicator.cpp | 15 +-
src/replica/duplication/replica_duplicator.h | 3 +-
src/replica/duplication/replica_follower.cpp | 30 +-
src/replica/duplication/replica_follower.h | 3 +-
..._test.cpp => dup_replica_http_service_test.cpp} | 11 +-
src/replica/duplication/test/main.cpp | 3 +-
.../duplication/test/replica_follower_test.cpp | 5 +-
src/replica/log_block.h | 2 +-
src/replica/log_file.cpp | 63 +-
src/replica/log_file_stream.h | 4 +-
src/replica/mutation.cpp | 22 +-
src/replica/mutation.h | 10 +-
src/replica/mutation_cache.cpp | 7 +-
src/replica/mutation_log.cpp | 631 +-
src/replica/mutation_log_replay.cpp | 38 +-
src/replica/prepare_list.cpp | 27 +-
src/replica/replica.cpp | 123 +-
src/replica/replica.h | 1 +
src/replica/replica_2pc.cpp | 241 +-
src/replica/replica_backup.cpp | 268 +-
src/replica/replica_check.cpp | 34 +-
src/replica/replica_chkpt.cpp | 91 +-
src/replica/replica_config.cpp | 458 +-
src/replica/replica_context.cpp | 2 +-
src/replica/replica_context.h | 4 +-
src/replica/replica_disk_migrator.cpp | 11 +-
src/replica/replica_failover.cpp | 37 +-
src/replica/replica_http_service.cpp | 12 +-
src/replica/replica_http_service.h | 8 +-
src/replica/replica_init.cpp | 188 +-
src/replica/replica_learn.cpp | 966 +-
src/replica/replica_restore.cpp | 84 +-
src/replica/replica_stub.cpp | 666 +-
src/replica/replica_stub.h | 22 +-
src/replica/replication_app_base.cpp | 5 +-
src/replica/split/replica_split_manager.cpp | 40 +-
src/replica/split/test/main.cpp | 3 +-
.../storage/simple_kv/simple_kv.server.impl.cpp | 29 +-
src/replica/storage/simple_kv/test/case.cpp | 61 +-
src/replica/storage/simple_kv/test/case.h | 5 +
src/replica/storage/simple_kv/test/checker.cpp | 23 +-
src/replica/storage/simple_kv/test/client.cpp | 8 +-
src/replica/storage/simple_kv/test/common.cpp | 13 +-
src/replica/storage/simple_kv/test/common.h | 17 +-
src/replica/storage/simple_kv/test/injector.cpp | 3 -
.../storage/simple_kv/test/simple_kv.main.cpp | 2 +-
.../simple_kv/test/simple_kv.server.impl.cpp | 61 +-
src/replica/test/mock_utils.h | 6 +-
src/replica/test/mutation_log_learn_test.cpp | 16 +-
src/replica/test/replica_http_service_test.cpp | 115 +
src/replica/test/replica_test.cpp | 6 +-
src/reporter/pegasus_counter_reporter.cpp | 66 +-
src/runtime/api_layer1.h | 31 +-
src/runtime/api_task.h | 4 +-
src/runtime/app_model.h | 10 +-
src/runtime/env.sim.cpp | 2 +-
src/runtime/env_provider.h | 1 -
src/runtime/fault_injector.cpp | 68 +-
src/runtime/global_config.cpp | 4 +-
src/runtime/global_config.h | 25 +-
src/runtime/nativerun.cpp | 31 +-
src/runtime/pipeline.h | 4 +-
src/runtime/profiler.cpp | 55 +-
src/runtime/providers.common.cpp | 7 +-
src/runtime/rpc/asio_net_provider.cpp | 85 +-
src/runtime/rpc/asio_rpc_session.cpp | 46 +-
src/runtime/rpc/dsn_message_parser.cpp | 26 +-
src/runtime/rpc/group_address.h | 116 +-
src/runtime/rpc/message_parser.cpp | 23 +-
src/runtime/rpc/message_parser.h | 7 +-
src/runtime/rpc/network.cpp | 130 +-
src/runtime/rpc/network.h | 36 +-
src/runtime/rpc/network.sim.cpp | 33 +-
src/runtime/rpc/raw_message_parser.cpp | 5 +-
src/runtime/rpc/request_meta.thrift | 1 +
src/{utils => runtime/rpc}/rpc_address.cpp | 83 +-
src/{utils => runtime/rpc}/rpc_address.h | 57 +-
src/runtime/rpc/rpc_engine.cpp | 261 +-
src/runtime/rpc/rpc_engine.h | 2 +-
src/runtime/rpc/rpc_holder.h | 25 +-
src/runtime/rpc/rpc_message.cpp | 49 +-
src/runtime/rpc/rpc_message.h | 64 +-
src/runtime/rpc/rpc_stream.h | 25 +-
src/runtime/rpc/rpc_task.cpp | 18 +-
src/runtime/rpc/serialization.h | 6 +-
src/runtime/rpc/thrift_message_parser.cpp | 42 +-
src/runtime/scheduler.cpp | 3 +-
src/runtime/security/CMakeLists.txt | 2 +-
src/runtime/security/access_controller.cpp | 4 +-
src/runtime/security/client_negotiation.cpp | 4 +-
src/runtime/security/init.cpp | 8 +-
src/runtime/security/kinit_context.cpp | 21 +-
src/runtime/security/meta_access_controller.cpp | 14 +-
src/runtime/security/negotiation.cpp | 6 +-
src/runtime/security/sasl_init.cpp | 2 +-
src/runtime/security/server_negotiation.cpp | 4 +-
src/runtime/service_api_c.cpp | 160 +-
src/runtime/service_app.h | 5 +-
src/runtime/service_engine.cpp | 26 +-
src/runtime/service_engine.h | 4 +-
src/runtime/simulator.cpp | 4 +-
src/runtime/task/async_calls.h | 25 +-
src/runtime/task/simple_task_queue.cpp | 9 +-
src/runtime/task/task.cpp | 136 +-
src/runtime/task/task.h | 24 +-
src/runtime/task/task_code.cpp | 31 +
src/runtime/task/task_code.h | 4 +-
src/runtime/task/task_engine.cpp | 30 +-
src/runtime/task/task_engine.h | 8 +-
src/runtime/task/task_engine.sim.cpp | 33 +-
src/runtime/task/task_queue.cpp | 2 +-
src/runtime/task/task_queue.h | 5 +-
src/runtime/task/task_spec.cpp | 91 +-
src/runtime/task/task_spec.h | 37 +-
src/runtime/task/task_tracker.h | 20 +-
src/runtime/task/task_worker.cpp | 30 +-
src/runtime/task/task_worker.h | 24 +-
.../address.cpp => runtime/test/address_test.cpp} | 77 +-
src/runtime/test/async_call.cpp | 15 +-
src/runtime/test/corrupt_message.cpp | 3 +-
src/runtime/test/lpc.cpp | 3 +-
src/runtime/test/main.cpp | 5 +-
src/runtime/test/message_utils_test.cpp | 7 +-
src/runtime/test/meta_access_controller_test.cpp | 3 +-
src/runtime/test/netprovider.cpp | 19 +-
src/runtime/test/pipeline_test.cpp | 3 +-
.../test/replica_access_controller_test.cpp | 3 +-
src/runtime/test/rpc.cpp | 11 +-
src/runtime/test/rpc_holder_test.cpp | 19 +-
src/runtime/test/rpc_message.cpp | 6 +-
src/runtime/test/service_api_c.cpp | 1 -
src/runtime/test/sim_lock.cpp | 1 -
src/runtime/test/test_utils.h | 13 +-
src/runtime/tool_api.cpp | 4 +-
src/runtime/tool_api.h | 61 +-
src/runtime/tracer.cpp | 199 +-
src/runtime/tracer.h | 23 +-
src/runtime/zlocks.cpp | 18 +-
src/server/available_detector.cpp | 139 +-
src/server/brief_stat.cpp | 87 -
src/server/brief_stat.h | 24 -
src/server/compaction_filter_rule.cpp | 15 +-
src/server/compaction_operation.cpp | 4 +-
src/server/config.ini | 2 +-
src/server/config.min.ini | 2 +-
src/server/hashkey_transform.h | 4 +-
src/server/hotkey_collector.cpp | 8 +-
src/server/hotspot_partition_calculator.cpp | 20 +-
src/server/info_collector.cpp | 36 +-
src/server/info_collector.h | 3 +-
src/server/info_collector_app.cpp | 8 +-
src/server/main.cpp | 67 +-
src/server/meta_store.cpp | 11 +-
src/server/pegasus_mutation_duplicator.cpp | 18 +-
src/server/pegasus_server_impl.cpp | 452 +-
src/server/pegasus_server_impl_init.cpp | 24 +-
src/server/pegasus_server_write.cpp | 8 +-
src/server/pegasus_write_service.cpp | 12 +-
src/server/pegasus_write_service.h | 1 +
src/server/pegasus_write_service_impl.h | 25 +-
src/server/result_writer.cpp | 38 +-
src/server/rocksdb_wrapper.cpp | 2 +-
src/server/test/main.cpp | 3 +-
src/shell/args.h | 5 +-
src/shell/command_helper.h | 99 +-
src/shell/command_utils.h | 23 +-
src/shell/commands.h | 2 +
src/shell/commands/data_operations.cpp | 4 +-
src/shell/commands/detect_hotkey.cpp | 23 +-
src/shell/commands/duplication.cpp | 2 +-
src/shell/commands/global_properties.cpp | 5 +-
src/shell/commands/table_management.cpp | 47 +-
src/shell/config.ini | 2 +-
src/shell/main.cpp | 19 +-
src/test/bench_test/config.ini | 2 +-
.../test_backup_and_restore.cpp | 1 -
.../function_test/base_api_test/test_basic.cpp | 1 -
.../function_test/base_api_test/test_batch_get.cpp | 1 -
.../base_api_test/test_check_and_mutate.cpp | 1 -
.../base_api_test/test_check_and_set.cpp | 1 -
src/test/function_test/base_api_test/test_copy.cpp | 1 -
src/test/function_test/base_api_test/test_incr.cpp | 1 -
.../base_api_test/test_range_read.cpp | 1 -
.../function_test/base_api_test/test_recall.cpp | 1 -
src/test/function_test/base_api_test/test_scan.cpp | 1 -
.../bulk_load_test/test_bulk_load.cpp | 1 -
src/test/function_test/config.ini | 3 +-
.../detect_hotspot_test/test_detect_hotspot.cpp | 1 -
.../function_test/recovery_test/test_recovery.cpp | 1 -
.../function_test/restore_test/test_restore.cpp | 2 +-
.../function_test/throttle_test/test_throttle.cpp | 3 +-
src/test/function_test/utils/global_env.cpp | 2 +-
src/test/function_test/utils/test_util.cpp | 4 +-
src/test/kill_test/config.ini | 2 +-
src/test/kill_test/data_verifier.cpp | 257 +-
src/test/kill_test/kill_testor.cpp | 27 +-
src/test/kill_test/killer_handler_shell.cpp | 19 +-
src/test/kill_test/main.cpp | 7 +-
src/test/kill_test/partition_kill_testor.cpp | 10 +-
src/test/kill_test/process_kill_testor.cpp | 52 +-
src/test/pressure_test/config-pressure.ini | 2 +-
src/test/pressure_test/main.cpp | 20 +-
src/utils/CMakeLists.txt | 2 +-
src/utils/alloc.cpp | 2 +-
src/utils/alloc.h | 21 +-
src/utils/api_utilities.h | 68 +-
src/utils/clock.cpp | 3 +-
src/utils/command_manager.cpp | 99 +-
src/utils/command_manager.h | 57 +-
src/utils/customizable_id.h | 21 +-
src/utils/distributed_lock_service.h | 3 +-
src/utils/dlib.h | 52 -
src/utils/enum_helper.h | 1 +
src/utils/error_code.h | 4 +-
src/utils/errors.h | 11 +-
src/utils/fail_point.cpp | 20 +-
src/utils/filesystem.cpp | 53 +-
src/utils/flags.cpp | 12 +-
src/utils/flags.h | 9 +-
src/utils/fmt_logging.h | 250 +-
src/utils/latency_tracer.cpp | 7 +-
src/utils/logging.cpp | 97 +-
src/utils/logging_provider.h | 30 +-
src/utils/long_adder.cpp | 12 +-
src/utils/long_adder_bench/long_adder_bench.cpp | 9 +-
src/utils/math.cpp | 9 +-
src/utils/metrics.cpp | 271 +-
src/utils/metrics.h | 433 +-
src/utils/nth_element.h | 2 +-
src/utils/output_utils.cpp | 16 +-
src/utils/ports.h | 9 +
src/utils/shared_io_service.cpp | 4 +-
src/utils/simple_logger.cpp | 72 +-
src/utils/simple_logger.h | 37 +-
src/utils/string_view.cpp | 10 +-
src/utils/string_view.h | 4 +-
src/utils/strings.cpp | 307 +-
src/utils/strings.h | 54 +-
src/utils/sys_exit_hook.h | 2 +-
src/utils/test/CMakeLists.txt | 3 +-
src/utils/test/command_manager.cpp | 80 -
src/utils/test/command_manager_test.cpp | 69 +
src/utils/test/file_utils.cpp | 3 +-
src/utils/test/flag_test.cpp | 56 +-
src/utils/test/hostname_test.cpp | 7 +-
src/utils/test/logger.cpp | 77 +-
src/utils/test/main.cpp | 7 +-
src/utils/test/metrics_test.cpp | 1902 +-
src/utils/test/utils.cpp | 415 +-
src/utils/thread_access_checker.cpp | 9 +-
src/utils/threadpool_code.h | 7 +
src/utils/token_bucket_throttling_controller.cpp | 6 +-
src/utils/utils.cpp | 13 +-
src/utils/utils.h | 4 +-
src/utils/zlocks.h | 2 +
.../distributed_lock_service_zookeeper.cpp | 15 +-
src/zookeeper/lock_struct.cpp | 223 +-
src/zookeeper/test/distributed_lock_zookeeper.cpp | 21 +-
src/zookeeper/test/main.cpp | 3 +-
src/zookeeper/zookeeper_session.cpp | 28 +-
src/zookeeper/zookeeper_session_mgr.h | 3 +-
thirdparty/CMakeLists.txt | 8 +-
thirdparty/rocksdb_fix_atomic_flush_0879c240.patch | 213 +
527 files changed, 11952 insertions(+), 53781 deletions(-)
copy .github/workflows/{test_java-client.yml => test_python-client.yml} (65%)
delete mode 100644 go-client/idl/admin.thrift
delete mode 100644 go-client/idl/admin/GoUnusedProtection__.go
delete mode 100644 go-client/idl/admin/admin-consts.go
delete mode 100644 go-client/idl/admin/admin.go
delete mode 100644 go-client/idl/base.thrift
delete mode 100644 go-client/idl/cmd.thrift
delete mode 100644 go-client/idl/cmd/GoUnusedProtection__.go
delete mode 100644 go-client/idl/cmd/cmd-consts.go
delete mode 100644 go-client/idl/cmd/cmd.go
delete mode 100644 go-client/idl/radmin.thrift
delete mode 100644 go-client/idl/radmin/GoUnusedProtection__.go
delete mode 100644 go-client/idl/radmin/radmin-consts.go
delete mode 100644 go-client/idl/radmin/radmin.go
delete mode 100644 go-client/idl/replication.thrift
delete mode 100644 go-client/idl/replication/GoUnusedProtection__.go
delete mode 100644 go-client/idl/replication/replication-consts.go
delete mode 100644 go-client/idl/replication/replication.go
delete mode 100644 go-client/idl/rrdb.thrift
delete mode 100644 go-client/idl/rrdb/GoUnusedProtection__.go
delete mode 100644 go-client/idl/rrdb/rrdb-consts.go
delete mode 100644 go-client/idl/rrdb/rrdb.go
rename {src/common => idl}/backup.thrift (98%)
rename {src/common => idl}/bulk_load.thrift (98%)
rename {src/remote_cmd => idl}/command.thrift (92%)
rename {src/common => idl}/duplication.thrift (97%)
rename {src/common => idl}/meta_admin.thrift (77%)
rename {src/common => idl}/metadata.thrift (96%)
rename {src/common => idl}/partition_split.thrift (98%)
rename {src/common => idl}/replica_admin.thrift (91%)
rename {src/runtime/security => idl}/security.thrift (94%)
delete mode 100644 java-client/configuration/log4j.properties
delete mode 100644 java-client/idl/apache-licence-template
delete mode 100644 java-client/idl/base.thrift
delete mode 100644 java-client/idl/meta_admin.thrift
delete mode 100644 java-client/idl/replication.thrift
delete mode 100644 java-client/idl/rrdb.thrift
delete mode 100644 java-client/idl/security.thrift
rename java-client/{idl => scripts}/recompile_thrift.sh (79%)
delete mode 100644 java-client/src/assembly/dep.xml
create mode 100644 java-client/src/main/java/org/apache/pegasus/util/PropertyUtils.java
delete mode 100644 java-client/src/test/resource/pegasus.properties
rename java-client/{configuration => src/test/resources}/pegasus.properties (100%)
copy scala-client/scripts/format-all.sh => java-client/src/test/resources/simplelogger.properties (84%)
mode change 100755 => 100644
delete mode 100644 python-client/idl/base.thrift
delete mode 100644 python-client/idl/replication.thrift
delete mode 100644 python-client/idl/rrdb.thrift
delete mode 100644 python-client/pypegasus/replication/__init__.py
delete mode 100644 python-client/pypegasus/replication/constants.py
delete mode 100644 python-client/pypegasus/replication/replication.py
delete mode 100644 python-client/pypegasus/replication/ttypes.py
delete mode 100644 python-client/pypegasus/rrdb/__init__.py
delete mode 100644 python-client/pypegasus/rrdb/constants.py
delete mode 100644 python-client/pypegasus/rrdb/meta.py
delete mode 100644 python-client/pypegasus/rrdb/rrdb.py
delete mode 100644 python-client/pypegasus/rrdb/ttypes.py
create mode 100644 python-client/requirement.txt
copy {go-client => python-client}/test.sh (67%)
delete mode 100644 src/common/api_common.h
create mode 100644 src/common/duplication_internal.thrift
rename src/replica/duplication/test/{replica_http_service_test.cpp => dup_replica_http_service_test.cpp} (86%)
create mode 100644 src/replica/test/replica_http_service_test.cpp
rename src/{utils => runtime/rpc}/rpc_address.cpp (74%)
rename src/{utils => runtime/rpc}/rpc_address.h (85%)
rename src/{utils/test/address.cpp => runtime/test/address_test.cpp} (82%)
delete mode 100644 src/server/brief_stat.cpp
delete mode 100644 src/server/brief_stat.h
delete mode 100644 src/utils/dlib.h
delete mode 100644 src/utils/test/command_manager.cpp
create mode 100644 src/utils/test/command_manager_test.cpp
create mode 100644 thirdparty/rocksdb_fix_atomic_flush_0879c240.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org