This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/pip/python-client/twisted-24.7.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard cfbbb6670 build(deps): bump twisted from 21.2.0 to 24.7.0 in
/python-client
add 01b875450 refactor(scripts): Separate admin and build scripts to
independent directories (#2096)
add 9efe8d6b5 fix(duplication): fix unexpected ERR_NOT_ENOUGH_MEMBER while
checking if the remote table with only one replica is ready for duplication
(#2093)
add e68c2b9b9 fix(duplication): fix the dangling pointer after `blob`
object is moved (#2088)
add 2f843db2a fix(duplication): `min_checkpoint_decree` was reset to the
invalid decree after replica server was restarted (#2097)
add a8d99fd53 feat(duplication): add a new option to configure the
duration of the delay until the next execution if there is no mutation to be
loaded (#2099)
add 5b9f46a2e fix(github): add write permission to module labeler (#2106)
add c99cfd642 feat(new_metrics): support `server_stat` command showing
some important server-level metrics (part 1) (#2085)
add d0e926010 fix(blob): allow `blob` object to be initialized with
null-pointer char array whose length must be zero (#2110)
add adb886d3e fix(asio): fix the crash caused by early invalidated socket
(#2111)
add c90aa4854 refactor(tests): Simplify the runtime module unit tests
(#2115)
add b1fa5dc7b refactor(rpc): move rpc out of runtime (#1844)
add 88a29a461 chore(CI): Bump actions/labeler to v5 (#2116)
add ebb74e038 chore(CI): Sort disabled clang-tidy checks option (#2117)
add 8f21d7ae2 refator(tests): Use GTEST_SKIP macro to skip useless tests
(#2118)
add ecbfc8a4b chore(CI): Update actions/labeler configuration file (#2120)
add 8da31e487 build(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 in
/collector (#1982)
add 8a7681aa9 build(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 in
/admin-cli (#1981)
add 3ba32b371 build(deps): bump golang.org/x/net from 0.17.0 to 0.23.0 in
/pegic (#1979)
add 13f9e3310 build(deps): bump k8s.io/apimachinery in /admin-cli (#2003)
add 42dad5784 build(deps): bump k8s.io/apimachinery in /collector (#2002)
add 25a32ff5a build(deps): bump k8s.io/apimachinery in /pegic (#2001)
add 7236ebb0c build(deps): bump twisted from 21.2.0 to 24.7.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 (cfbbb6670)
\
N -- N -- N
refs/heads/dependabot/pip/python-client/twisted-24.7.0 (7236ebb0c)
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:
.clang-tidy | 4 +-
.../rebuild_thirdparty_if_needed/action.yaml | 4 +-
.github/workflows/labeler.yml | 7 +-
.github/workflows/lint_and_test_cpp.yaml | 18 +-
.github/workflows/module_labeler_conf.yml | 74 ++++--
.github/workflows/regular-build.yml | 2 +-
.licenserc.yaml | 79 +++---
LICENSE | 2 +-
admin-cli/go.mod | 8 +-
admin-cli/go.sum | 20 +-
{scripts => admin_tools}/config_hdfs.sh | 0
{scripts => admin_tools}/downgrade_node.sh | 0
{scripts => admin_tools}/learn_stat.py | 0
{scripts => admin_tools}/migrate_node.sh | 0
{scripts => admin_tools}/minos_common.sh | 0
{scripts => admin_tools}/pegasus_add_node_list.sh | 4 +-
{scripts => admin_tools}/pegasus_bench_run.sh | 0
.../pegasus_check_arguments.sh | 2 +-
{scripts => admin_tools}/pegasus_kill_test.sh | 0
{scripts => admin_tools}/pegasus_manual_compact.sh | 0
.../pegasus_migrate_zookeeper.sh | 2 +-
{scripts => admin_tools}/pegasus_offline_node.sh | 2 +-
.../pegasus_offline_node_list.sh | 4 +-
.../pegasus_rebalance_cluster.sh | 0
{scripts => admin_tools}/pegasus_replica_thread.sh | 0
{scripts => admin_tools}/pegasus_restart_node.sh | 2 +-
{scripts => admin_tools}/pegasus_rolling_update.sh | 4 +-
.../pegasus_set_usage_scenario.sh | 0
{scripts => admin_tools}/pegasus_stat_available.sh | 0
.../pegasus_update_ingest_behind.sh | 2 +-
{scripts => admin_tools}/sendmail.sh | 0
{scripts => build_tools}/bump_version.sh | 0
{scripts => build_tools}/check_license.py | 0
{scripts => build_tools}/clang_tidy.py | 36 ++-
{scripts => build_tools}/clear_zk.sh | 0
.../collector_table_counter_gen.py | 2 +-
{scripts => build_tools}/compile_thrift.py | 2 +-
{scripts => build_tools}/download_hadoop.sh | 0
{scripts => build_tools}/download_package.sh | 0
{scripts => build_tools}/download_zk.sh | 0
{scripts => build_tools}/format_files.sh | 0
{scripts => build_tools}/pack_client.sh | 0
{scripts => build_tools}/pack_common.sh | 0
{scripts => build_tools}/pack_server.sh | 4 +-
{scripts => build_tools}/pack_tools.sh | 11 +-
{scripts => build_tools}/recompile_thrift.sh | 2 +-
{scripts => build_tools}/redis_proto_check.py | 0
{scripts => build_tools}/run-clang-format.py | 0
{scripts => build_tools}/start_zk.sh | 0
{scripts => build_tools}/stop_zk.sh | 0
collector/go.mod | 8 +-
collector/go.sum | 21 +-
docker/thirdparties-bin/Dockerfile | 4 +-
java-client/README.md | 2 +-
pegic/go.mod | 6 +-
pegic/go.sum | 17 +-
run.sh | 30 +--
src/CMakeLists.txt | 1 +
src/base/pegasus_rpc_types.h | 2 +-
src/block_service/block_service.h | 6 +-
src/client/partition_resolver.cpp | 2 +-
src/client/partition_resolver.h | 6 +-
src/client/partition_resolver_manager.cpp | 4 +-
src/client/partition_resolver_simple.cpp | 6 +-
src/client/partition_resolver_simple.h | 2 +-
src/client/replication_ddl_client.cpp | 4 +-
src/client/replication_ddl_client.h | 12 +-
src/client/test/ddl_client_test.cpp | 2 +-
src/client_lib/pegasus_client_impl.cpp | 8 +-
src/client_lib/pegasus_client_impl.h | 2 +-
src/client_lib/pegasus_scanner_impl.cpp | 2 +-
src/common/backup_common.cpp | 2 +-
src/common/backup_common.h | 2 +-
src/common/bulk_load_common.h | 2 +-
src/common/duplication_common.h | 2 +-
src/common/manual_compact.h | 2 +-
src/common/partition_split_common.h | 2 +-
src/common/replication_common.cpp | 4 +-
src/common/replication_common.h | 7 +-
src/common/replication_other_types.h | 4 +-
src/common/serialization_helper/dsn_types.h | 2 +-
src/common/serialization_helper/thrift_helper.h | 4 +-
src/common/storage_serverlet.h | 6 +-
src/failure_detector/failure_detector.cpp | 4 +-
src/failure_detector/failure_detector.h | 3 +-
.../failure_detector_multimaster.cpp | 4 +-
.../failure_detector_multimaster.h | 5 +-
src/failure_detector/fd.code.definition.h | 6 +-
src/failure_detector/test/failure_detector.cpp | 10 +-
src/geo/test/geo_test.cpp | 2 +-
src/http/http_message_parser.cpp | 2 +-
src/http/http_message_parser.h | 4 +-
src/http/http_server.cpp | 4 +-
src/http/http_server_impl.h | 2 +-
src/http/test/http_server_test.cpp | 4 +-
src/include/rrdb/rrdb.client.h | 2 +-
src/meta/backup_engine.cpp | 6 +-
src/meta/cluster_balance_policy.cpp | 6 +-
src/meta/cluster_balance_policy.h | 3 +-
src/meta/dump_file.h | 6 +-
src/meta/duplication/duplication_info.cpp | 1 +
src/meta/duplication/duplication_info.h | 3 +-
src/meta/duplication/meta_duplication_service.cpp | 279 +++++++++++++--------
src/meta/greedy_load_balancer.cpp | 2 +-
src/meta/load_balance_policy.cpp | 4 +-
src/meta/load_balance_policy.h | 3 +-
src/meta/meta_backup_service.cpp | 8 +-
src/meta/meta_bulk_load_ingestion_context.h | 2 +-
src/meta/meta_bulk_load_service.cpp | 12 +-
src/meta/meta_bulk_load_service.h | 3 +-
src/meta/meta_data.cpp | 6 +-
src/meta/meta_data.h | 2 +-
src/meta/meta_http_service.cpp | 2 +-
src/meta/meta_rpc_types.h | 2 +-
src/meta/meta_server_failure_detector.cpp | 2 +-
src/meta/meta_server_failure_detector.h | 6 +-
src/meta/meta_service.cpp | 6 +-
src/meta/meta_service.h | 17 +-
src/meta/meta_split_service.cpp | 6 +-
src/meta/meta_state_service_simple.h | 2 +-
src/meta/partition_guardian.cpp | 2 +-
src/meta/partition_guardian.h | 2 +-
src/meta/server_load_balancer.cpp | 4 +-
src/meta/server_load_balancer.h | 3 +-
src/meta/server_state.cpp | 11 +-
src/meta/server_state_restore.cpp | 6 +-
src/meta/test/backup_test.cpp | 10 +-
.../test/balancer_simulator/balancer_simulator.cpp | 6 +-
src/meta/test/balancer_validator.cpp | 4 +-
src/meta/test/cluster_balance_policy_test.cpp | 4 +-
src/meta/test/copy_replica_operation_test.cpp | 2 +-
src/meta/test/ford_fulkerson_test.cpp | 6 +-
src/meta/test/json_compacity.cpp | 4 +-
src/meta/test/meta_app_operation_test.cpp | 4 +-
src/meta/test/meta_backup_test.cpp | 2 +-
src/meta/test/meta_bulk_load_ingestion_test.cpp | 6 +-
src/meta/test/meta_bulk_load_service_test.cpp | 6 +-
src/meta/test/meta_data.cpp | 6 +-
src/meta/test/meta_duplication_service_test.cpp | 95 +++++--
src/meta/test/meta_http_service_test.cpp | 4 +-
src/meta/test/meta_partition_guardian_test.cpp | 10 +-
src/meta/test/meta_service_test.cpp | 12 +-
src/meta/test/meta_service_test_app.h | 6 +-
src/meta/test/meta_split_service_test.cpp | 4 +-
src/meta/test/meta_test_base.cpp | 10 +-
src/meta/test/meta_test_base.h | 9 +-
src/meta/test/misc/misc.cpp | 6 +-
src/meta/test/misc/misc.h | 2 +-
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 | 10 +-
src/nfs/nfs_client_impl.cpp | 4 +-
src/nfs/nfs_client_impl.h | 2 +-
src/nfs/nfs_node.h | 4 +-
src/nfs/test/main.cpp | 2 +-
src/redis_protocol/proxy_lib/proxy_layer.cpp | 6 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 4 +-
src/redis_protocol/proxy_lib/redis_parser.cpp | 6 +-
src/redis_protocol/proxy_lib/redis_parser.h | 4 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 6 +-
src/remote_cmd/remote_command.cpp | 4 +-
src/replica/backup/replica_backup_server.cpp | 2 +-
src/replica/bulk_load/replica_bulk_loader.cpp | 10 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 4 +-
src/replica/duplication/duplication_pipeline.cpp | 18 +-
src/replica/duplication/duplication_sync_timer.cpp | 4 +-
src/replica/duplication/mutation_batch.cpp | 18 +-
src/replica/duplication/replica_duplicator.cpp | 106 +++++---
src/replica/duplication/replica_duplicator.h | 4 +-
src/replica/duplication/replica_follower.cpp | 12 +-
src/replica/duplication/replica_follower.h | 3 +-
.../test/dup_replica_http_service_test.cpp | 3 +-
.../test/duplication_sync_timer_test.cpp | 42 ++--
.../duplication/test/duplication_test_base.h | 7 +-
.../test/load_from_private_log_test.cpp | 15 +-
.../duplication/test/mutation_batch_test.cpp | 168 ++++++++-----
.../test/replica_duplicator_manager_test.cpp | 64 ++---
.../duplication/test/replica_duplicator_test.cpp | 31 ++-
.../duplication/test/replica_follower_test.cpp | 4 +-
src/replica/mutation.h | 2 +-
src/replica/mutation_log_replay.cpp | 70 +++---
src/replica/replica.cpp | 2 +-
src/replica/replica.h | 9 +-
src/replica/replica_2pc.cpp | 10 +-
src/replica/replica_check.cpp | 8 +-
src/replica/replica_chkpt.cpp | 6 +-
src/replica/replica_config.cpp | 14 +-
src/replica/replica_context.cpp | 2 +-
src/replica/replica_context.h | 2 +-
src/replica/replica_failover.cpp | 4 +-
src/replica/replica_learn.cpp | 10 +-
src/replica/replica_restore.cpp | 6 +-
src/replica/replica_stub.cpp | 6 +-
src/replica/replica_stub.h | 16 +-
src/replica/replica_throttle.cpp | 2 +-
src/replica/replication_app_base.cpp | 4 +-
src/replica/split/replica_split_manager.cpp | 10 +-
src/replica/split/test/replica_split_test.cpp | 4 +-
src/replica/storage/simple_kv/simple_kv.client.h | 2 +-
src/replica/storage/simple_kv/test/case.cpp | 2 +-
src/replica/storage/simple_kv/test/case.h | 3 +-
src/replica/storage/simple_kv/test/checker.cpp | 4 +-
src/replica/storage/simple_kv/test/checker.h | 4 +-
src/replica/storage/simple_kv/test/client.cpp | 10 +-
src/replica/storage/simple_kv/test/client.h | 2 +-
src/replica/storage/simple_kv/test/common.h | 2 +-
src/replica/test/log_block_test.cpp | 6 +-
src/replica/test/log_file_test.cpp | 3 +-
src/replica/test/mock_utils.h | 2 +-
src/replica/test/mutation_log_test.cpp | 10 +-
src/replica/test/open_replica_test.cpp | 4 +-
src/replica/test/replica_disk_migrate_test.cpp | 2 +-
src/replica/test/replica_disk_test.cpp | 2 +-
src/replica/test/replica_test.cpp | 6 +-
src/replica/test/replica_test_base.h | 8 +-
src/{ranger => rpc}/CMakeLists.txt | 9 +-
src/{runtime => }/rpc/asio_net_provider.cpp | 3 +-
src/{runtime => }/rpc/asio_net_provider.h | 10 +-
src/{runtime => }/rpc/asio_rpc_session.cpp | 25 +-
src/{runtime => }/rpc/asio_rpc_session.h | 13 +-
src/{runtime => }/rpc/dns_resolver.cpp | 8 +-
src/{runtime => }/rpc/dns_resolver.h | 4 +-
src/{runtime => }/rpc/dsn_message_parser.cpp | 2 +-
src/{runtime => }/rpc/dsn_message_parser.h | 2 +-
src/{runtime => }/rpc/group_address.h | 2 +-
src/{runtime => }/rpc/group_host_port.h | 7 +-
src/{runtime => }/rpc/message_parser.cpp | 2 +-
src/{runtime => }/rpc/message_parser.h | 2 +-
src/{runtime => }/rpc/message_parser_manager.h | 2 +-
src/{runtime => }/rpc/network.cpp | 12 +-
src/{runtime => }/rpc/network.h | 13 +-
src/{runtime => }/rpc/network.sim.cpp | 2 +-
src/{runtime => }/rpc/network.sim.h | 30 +--
src/{runtime => }/rpc/raw_message_parser.cpp | 4 +-
src/{runtime => }/rpc/raw_message_parser.h | 2 +-
src/{runtime => }/rpc/request_meta.thrift | 0
src/{runtime => }/rpc/rpc_address.cpp | 6 +-
src/{runtime => }/rpc/rpc_address.h | 0
src/{runtime => }/rpc/rpc_engine.cpp | 8 +-
src/{runtime => }/rpc/rpc_engine.h | 10 +-
src/{runtime => }/rpc/rpc_holder.h | 4 +-
src/{runtime => }/rpc/rpc_host_port.cpp | 4 +-
src/{runtime => }/rpc/rpc_host_port.h | 2 +-
src/{runtime => }/rpc/rpc_message.cpp | 6 +-
src/{runtime => }/rpc/rpc_message.h | 0
src/{runtime => }/rpc/rpc_stream.h | 2 +-
src/{runtime => }/rpc/rpc_task.cpp | 2 +-
src/{runtime => }/rpc/serialization.h | 6 +-
src/{ranger => rpc}/test/CMakeLists.txt | 6 +-
src/{runtime => rpc}/test/address_test.cpp | 4 +-
.../test/config-test.ini => rpc/test/config.ini} | 80 ++++--
.../test/corrupt_message_test.cpp} | 31 +--
src/{runtime => rpc}/test/host_port_test.cpp | 14 +-
src/{security => rpc}/test/main.cpp | 0
src/{runtime => rpc}/test/message_reader_test.cpp | 2 +-
src/{runtime => rpc}/test/message_utils_test.cpp | 10 +-
.../test/net_provider_test.cpp} | 46 ++--
src/{runtime => rpc}/test/rpc_holder_test.cpp | 14 +-
.../test/rpc_message_test.cpp} | 14 +-
.../test/rpc.cpp => rpc/test/rpc_test.cpp} | 20 +-
src/{ranger => rpc}/test/run.sh | 6 +-
.../test/thrift_message_parser_test.cpp | 8 +-
src/{runtime => }/rpc/thrift_message_parser.cpp | 4 +-
src/{runtime => }/rpc/thrift_message_parser.h | 2 +-
src/runtime/CMakeLists.txt | 4 +-
src/runtime/api_layer1.h | 4 +-
src/runtime/fault_injector.cpp | 2 +-
src/runtime/message_utils.cpp | 2 +-
src/runtime/message_utils.h | 2 +-
src/runtime/profiler.cpp | 2 +-
src/runtime/providers.common.cpp | 10 +-
src/runtime/rpc/CMakeLists.txt | 45 ----
src/runtime/serverlet.h | 4 +-
src/runtime/service_api_c.cpp | 8 +-
src/runtime/service_app.h | 3 +-
src/runtime/service_engine.cpp | 4 +-
src/runtime/task/async_calls.h | 2 +-
src/runtime/task/task.h | 2 +-
src/runtime/task/task_queue.cpp | 6 +-
src/runtime/task/task_spec.cpp | 2 +-
src/runtime/test/CMakeLists.txt | 4 +-
src/runtime/test/async_call.cpp | 4 +-
src/runtime/test/config-test-corrupt-message.ini | 141 -----------
src/runtime/test/dns_resolver_test.cpp | 10 +-
src/runtime/test/gtest.filter | 3 -
src/runtime/test/run.sh | 13 +-
src/runtime/test/service_api_c.cpp | 7 +-
src/runtime/test/sim_lock.cpp | 12 +-
src/runtime/test/task_engine.cpp | 7 +-
src/runtime/test_utils.h | 14 +-
src/runtime/tool_api.cpp | 2 +-
src/runtime/tool_api.h | 4 +-
src/runtime/tracer.cpp | 2 +-
src/security/client_negotiation.cpp | 4 +-
src/security/client_negotiation.h | 2 +-
src/security/meta_access_controller.cpp | 4 +-
src/security/negotiation.h | 6 +-
src/security/negotiation_manager.cpp | 4 +-
src/security/replica_access_controller.cpp | 4 +-
src/security/server_negotiation.cpp | 4 +-
src/security/server_negotiation.h | 2 +-
src/security/test/client_negotiation_test.cpp | 8 +-
src/security/test/meta_access_controller_test.cpp | 8 +-
src/security/test/negotiation_manager_test.cpp | 10 +-
.../test/replica_access_controller_test.cpp | 8 +-
src/security/test/server_negotiation_test.cpp | 6 +-
src/server/available_detector.h | 2 +-
src/server/capacity_unit_calculator.cpp | 2 +-
src/server/hotspot_partition_calculator.cpp | 4 +-
src/server/hotspot_partition_calculator.h | 2 +-
src/server/info_collector.cpp | 2 +-
src/server/info_collector.h | 3 +-
src/server/pegasus_mutation_duplicator.cpp | 4 +-
src/server/pegasus_server_impl.cpp | 4 +-
src/server/pegasus_server_impl_init.cpp | 2 +-
src/server/pegasus_server_write.cpp | 6 +-
src/server/test/capacity_unit_calculator_test.cpp | 2 +-
src/server/test/hotkey_collector_test.cpp | 2 +-
.../test/pegasus_mutation_duplicator_test.cpp | 4 +-
src/server/test/pegasus_server_write_test.cpp | 2 +-
src/server/test/pegasus_write_service_test.cpp | 2 +-
src/shell/command_helper.h | 102 ++++++--
src/shell/command_utils.cpp | 2 +-
src/shell/commands/bulk_load.cpp | 2 +-
src/shell/commands/data_operations.cpp | 5 +-
src/shell/commands/debugger.cpp | 4 +-
src/shell/commands/detect_hotkey.cpp | 2 +-
src/shell/commands/node_management.cpp | 209 +++++++++++++--
src/shell/commands/rebalance.cpp | 2 +-
src/shell/commands/recovery.cpp | 2 +-
src/shell/commands/table_management.cpp | 24 +-
src/shell/main.cpp | 11 +-
src/test/function_test/recovery/test_recovery.cpp | 2 +-
src/test/function_test/utils/global_env.cpp | 2 +-
src/test/function_test/utils/test_util.h | 2 +-
src/test/kill_test/kill_testor.h | 2 +-
src/tools/mutation_log_tool.cpp | 2 +-
src/utils/binary_reader.cpp | 4 +-
src/utils/binary_reader.h | 8 +-
src/utils/blob.h | 122 ++++++---
src/utils/distributed_lock_service.h | 6 +-
src/utils/error_code.h | 2 +
src/utils/metrics.cpp | 6 +-
src/utils/metrics.h | 90 +++++--
src/utils/test/blob_test.cpp | 145 +++++++++++
src/utils/test/json_helper_test.cpp | 2 +-
src/utils/test/metrics_test.cpp | 4 +-
src/zookeeper/zookeeper_session.cpp | 2 +-
349 files changed, 2222 insertions(+), 1457 deletions(-)
rename {scripts => admin_tools}/config_hdfs.sh (100%)
rename {scripts => admin_tools}/downgrade_node.sh (100%)
rename {scripts => admin_tools}/learn_stat.py (100%)
rename {scripts => admin_tools}/migrate_node.sh (100%)
rename {scripts => admin_tools}/minos_common.sh (100%)
rename {scripts => admin_tools}/pegasus_add_node_list.sh (92%)
rename {scripts => admin_tools}/pegasus_bench_run.sh (100%)
rename {scripts => admin_tools}/pegasus_check_arguments.sh (98%)
rename {scripts => admin_tools}/pegasus_kill_test.sh (100%)
rename {scripts => admin_tools}/pegasus_manual_compact.sh (100%)
rename {scripts => admin_tools}/pegasus_migrate_zookeeper.sh (99%)
rename {scripts => admin_tools}/pegasus_offline_node.sh (99%)
rename {scripts => admin_tools}/pegasus_offline_node_list.sh (96%)
rename {scripts => admin_tools}/pegasus_rebalance_cluster.sh (100%)
rename {scripts => admin_tools}/pegasus_replica_thread.sh (100%)
rename {scripts => admin_tools}/pegasus_restart_node.sh (99%)
rename {scripts => admin_tools}/pegasus_rolling_update.sh (98%)
rename {scripts => admin_tools}/pegasus_set_usage_scenario.sh (100%)
rename {scripts => admin_tools}/pegasus_stat_available.sh (100%)
rename {scripts => admin_tools}/pegasus_update_ingest_behind.sh (99%)
rename {scripts => admin_tools}/sendmail.sh (100%)
rename {scripts => build_tools}/bump_version.sh (100%)
rename {scripts => build_tools}/check_license.py (100%)
rename {scripts => build_tools}/clang_tidy.py (58%)
rename {scripts => build_tools}/clear_zk.sh (100%)
rename {scripts => build_tools}/collector_table_counter_gen.py (98%)
rename {scripts => build_tools}/compile_thrift.py (99%)
rename {scripts => build_tools}/download_hadoop.sh (100%)
rename {scripts => build_tools}/download_package.sh (100%)
rename {scripts => build_tools}/download_zk.sh (100%)
rename {scripts => build_tools}/format_files.sh (100%)
rename {scripts => build_tools}/pack_client.sh (100%)
rename {scripts => build_tools}/pack_common.sh (100%)
rename {scripts => build_tools}/pack_server.sh (98%)
rename {scripts => build_tools}/pack_tools.sh (94%)
rename {scripts => build_tools}/recompile_thrift.sh (83%)
rename {scripts => build_tools}/redis_proto_check.py (100%)
rename {scripts => build_tools}/run-clang-format.py (100%)
rename {scripts => build_tools}/start_zk.sh (100%)
rename {scripts => build_tools}/stop_zk.sh (100%)
copy src/{ranger => rpc}/CMakeLists.txt (81%)
rename src/{runtime => }/rpc/asio_net_provider.cpp (99%)
rename src/{runtime => }/rpc/asio_net_provider.h (96%)
rename src/{runtime => }/rpc/asio_rpc_session.cpp (93%)
rename src/{runtime => }/rpc/asio_rpc_session.h (88%)
rename src/{runtime => }/rpc/dns_resolver.cpp (97%)
rename src/{runtime => }/rpc/dns_resolver.h (97%)
rename src/{runtime => }/rpc/dsn_message_parser.cpp (99%)
rename src/{runtime => }/rpc/dsn_message_parser.h (98%)
rename src/{runtime => }/rpc/group_address.h (99%)
rename src/{runtime => }/rpc/group_host_port.h (98%)
rename src/{runtime => }/rpc/message_parser.cpp (99%)
rename src/{runtime => }/rpc/message_parser.h (99%)
rename src/{runtime => }/rpc/message_parser_manager.h (98%)
rename src/{runtime => }/rpc/network.cpp (98%)
rename src/{runtime => }/rpc/network.h (97%)
rename src/{runtime => }/rpc/network.sim.cpp (98%)
rename src/{runtime => }/rpc/network.sim.h (83%)
rename src/{runtime => }/rpc/raw_message_parser.cpp (98%)
rename src/{runtime => }/rpc/raw_message_parser.h (98%)
rename src/{runtime => }/rpc/request_meta.thrift (100%)
rename src/{runtime => }/rpc/rpc_address.cpp (99%)
rename src/{runtime => }/rpc/rpc_address.h (100%)
rename src/{runtime => }/rpc/rpc_engine.cpp (99%)
rename src/{runtime => }/rpc/rpc_engine.h (98%)
rename src/{runtime => }/rpc/rpc_holder.h (99%)
rename src/{runtime => }/rpc/rpc_host_port.cpp (98%)
rename src/{runtime => }/rpc/rpc_host_port.h (99%)
rename src/{runtime => }/rpc/rpc_message.cpp (99%)
rename src/{runtime => }/rpc/rpc_message.h (100%)
rename src/{runtime => }/rpc/rpc_stream.h (99%)
rename src/{runtime => }/rpc/rpc_task.cpp (99%)
rename src/{runtime => }/rpc/serialization.h (97%)
copy src/{ranger => rpc}/test/CMakeLists.txt (94%)
rename src/{runtime => rpc}/test/address_test.cpp (99%)
copy src/{http/test/config-test.ini => rpc/test/config.ini} (50%)
rename src/{runtime/test/corrupt_message.cpp =>
rpc/test/corrupt_message_test.cpp} (68%)
rename src/{runtime => rpc}/test/host_port_test.cpp (98%)
copy src/{security => rpc}/test/main.cpp (100%)
rename src/{runtime => rpc}/test/message_reader_test.cpp (98%)
rename src/{runtime => rpc}/test/message_utils_test.cpp (92%)
rename src/{runtime/test/netprovider.cpp => rpc/test/net_provider_test.cpp}
(89%)
rename src/{runtime => rpc}/test/rpc_holder_test.cpp (95%)
rename src/{runtime/test/rpc_message.cpp => rpc/test/rpc_message_test.cpp}
(96%)
rename src/{runtime/test/rpc.cpp => rpc/test/rpc_test.cpp} (96%)
copy src/{ranger => rpc}/test/run.sh (86%)
rename src/{runtime => rpc}/test/thrift_message_parser_test.cpp (99%)
rename src/{runtime => }/rpc/thrift_message_parser.cpp (99%)
rename src/{runtime => }/rpc/thrift_message_parser.h (99%)
delete mode 100644 src/runtime/rpc/CMakeLists.txt
delete mode 100644 src/runtime/test/config-test-corrupt-message.ini
delete mode 100644 src/runtime/test/gtest.filter
create mode 100644 src/utils/test/blob_test.cpp
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
