This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/go-client/k8s.io/apimachinery-0.16.13
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard bc76855f6 build(deps): bump k8s.io/apimachinery in /go-client
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 9daece425 refactor(task): move task out of runtime (#1845)
add d1f6d618a build(deps): bump cryptography from 3.2 to 43.0.1 in
/python-client (#2121)
add a6965acd5 refactor(java-client): optimize the code style for checking
if the list is empty (#2122)
add dc2714a51 refactor(java-client): introduce validateHashKey() to
simplify code (#2123)
add 2bd86c1d6 fix(build): Fix a linkage error for thrift (#2125)
add 40e79df23 build(deps): bump k8s.io/apimachinery in /go-client
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (bc76855f6)
\
N -- N -- N
refs/heads/dependabot/go_modules/go-client/k8s.io/apimachinery-0.16.13
(40e79df23)
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 +-
.github/workflows/labeler.yml | 7 +-
.github/workflows/lint_and_test_cpp.yaml | 13 +-
.github/workflows/module_labeler_conf.yml | 77 ++++--
.licenserc.yaml | 291 +++++++++++----------
admin-cli/go.mod | 8 +-
admin-cli/go.sum | 20 +-
build_tools/clang_tidy.py | 35 ++-
build_tools/compile_thrift.py | 2 +-
build_tools/recompile_thrift.sh | 2 +-
collector/go.mod | 8 +-
collector/go.sum | 21 +-
.../org/apache/pegasus/client/PegasusTable.java | 147 +++++------
pegic/go.mod | 6 +-
pegic/go.sum | 17 +-
python-client/requirement.txt | 4 +-
python-client/setup.py | 2 +-
src/CMakeLists.txt | 2 +
src/aio/aio_task.cpp | 8 +-
src/aio/aio_task.h | 4 +-
src/aio/disk_engine.cpp | 6 +-
src/aio/file_io.h | 6 +-
src/aio/native_linux_aio_provider.cpp | 2 +-
src/aio/test/aio.cpp | 2 +-
src/base/pegasus_rpc_types.h | 2 +-
src/block_service/block_service.h | 12 +-
src/block_service/block_service_manager.cpp | 4 +-
src/block_service/hdfs/hdfs_service.cpp | 4 +-
src/block_service/hdfs/hdfs_service.h | 4 +-
src/block_service/local/local_service.cpp | 2 +-
src/block_service/local/local_service.h | 4 +-
src/block_service/test/hdfs_service_test.cpp | 8 +-
src/client/partition_resolver.cpp | 4 +-
src/client/partition_resolver.h | 12 +-
src/client/partition_resolver_manager.cpp | 4 +-
src/client/partition_resolver_simple.cpp | 12 +-
src/client/partition_resolver_simple.h | 6 +-
src/client/replication_ddl_client.cpp | 4 +-
src/client/replication_ddl_client.h | 20 +-
src/client/test/ddl_client_test.cpp | 4 +-
src/client_lib/pegasus_client_impl.cpp | 12 +-
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/json_helper.h | 2 +-
src/common/manual_compact.h | 2 +-
src/common/partition_split_common.h | 2 +-
src/common/replication.codes.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 | 8 +-
src/failure_detector/failure_detector.cpp | 8 +-
src/failure_detector/failure_detector.h | 8 +-
.../failure_detector_multimaster.cpp | 4 +-
.../failure_detector_multimaster.h | 5 +-
src/failure_detector/fd.client.h | 2 +-
src/failure_detector/fd.code.definition.h | 10 +-
src/failure_detector/test/failure_detector.cpp | 16 +-
src/geo/lib/geo_client.h | 2 +-
src/geo/test/geo_test.cpp | 2 +-
src/http/http_message_parser.cpp | 2 +-
src/http/http_message_parser.h | 6 +-
src/http/http_server.cpp | 4 +-
src/http/http_server.h | 2 +-
src/http/http_server_impl.h | 2 +-
src/http/test/http_server_test.cpp | 4 +-
src/include/rrdb/rrdb.client.h | 7 +-
src/meta/backup_engine.cpp | 14 +-
src/meta/backup_engine.h | 2 +-
src/meta/cluster_balance_policy.cpp | 6 +-
src/meta/cluster_balance_policy.h | 3 +-
src/meta/distributed_lock_service_simple.cpp | 2 +-
src/meta/distributed_lock_service_simple.h | 8 +-
src/meta/dump_file.h | 8 +-
src/meta/duplication/duplication_info.h | 3 +-
src/meta/duplication/meta_duplication_service.cpp | 14 +-
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 | 12 +-
src/meta/meta_backup_service.h | 4 +-
src/meta/meta_bulk_load_ingestion_context.h | 2 +-
src/meta/meta_bulk_load_service.cpp | 18 +-
src/meta/meta_bulk_load_service.h | 4 +-
src/meta/meta_data.cpp | 6 +-
src/meta/meta_data.h | 4 +-
src/meta/meta_http_service.cpp | 2 +-
src/meta/meta_rpc_types.h | 2 +-
src/meta/meta_server_failure_detector.cpp | 4 +-
src/meta/meta_server_failure_detector.h | 7 +-
src/meta/meta_service.cpp | 8 +-
src/meta/meta_service.h | 20 +-
src/meta/meta_split_service.cpp | 8 +-
src/meta/meta_split_service.h | 2 +-
src/meta/meta_state_service.h | 6 +-
src/meta/meta_state_service_simple.cpp | 4 +-
src/meta/meta_state_service_simple.h | 12 +-
src/meta/meta_state_service_zookeeper.h | 8 +-
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 | 18 +-
src/meta/server_state.h | 4 +-
src/meta/server_state_restore.cpp | 10 +-
src/meta/test/backup_test.cpp | 16 +-
.../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/main.cpp | 2 +-
src/meta/test/meta_app_operation_test.cpp | 6 +-
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 | 4 +-
src/meta/test/meta_http_service_test.cpp | 8 +-
src/meta/test/meta_partition_guardian_test.cpp | 14 +-
src/meta/test/meta_service_test.cpp | 12 +-
src/meta/test/meta_service_test_app.h | 12 +-
src/meta/test/meta_split_service_test.cpp | 4 +-
src/meta/test/meta_state/meta_state_service.cpp | 2 +-
src/meta/test/meta_state_service_utils_test.cpp | 2 +-
src/meta/test/meta_test_base.cpp | 6 +-
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 | 8 +-
src/meta/test/update_configuration_test.cpp | 14 +-
src/nfs/nfs_client_impl.cpp | 4 +-
src/nfs/nfs_client_impl.h | 9 +-
src/nfs/nfs_node.h | 6 +-
src/nfs/nfs_server_impl.cpp | 2 +-
src/nfs/nfs_server_impl.h | 4 +-
src/nfs/test/main.cpp | 4 +-
src/perf_counter/perf_counters.cpp | 2 +-
src/ranger/ranger_resource_policy_manager.cpp | 6 +-
src/ranger/ranger_resource_policy_manager.h | 2 +-
.../test/ranger_resource_policy_manager_test.cpp | 2 +-
src/redis_protocol/proxy_lib/proxy_layer.cpp | 8 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 6 +-
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 | 8 +-
src/remote_cmd/remote_command.cpp | 6 +-
src/remote_cmd/remote_command.h | 2 +-
src/replica/backup/cold_backup_context.cpp | 2 +-
src/replica/backup/replica_backup_manager.cpp | 2 +-
src/replica/backup/replica_backup_manager.h | 2 +-
src/replica/backup/replica_backup_server.cpp | 2 +-
src/replica/bulk_load/replica_bulk_loader.cpp | 12 +-
src/replica/bulk_load/replica_bulk_loader.h | 2 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 6 +-
src/replica/duplication/duplication_sync_timer.cpp | 8 +-
src/replica/duplication/duplication_sync_timer.h | 2 +-
src/replica/duplication/mutation_batch.cpp | 4 +-
src/replica/duplication/replica_duplicator.cpp | 2 +-
src/replica/duplication/replica_duplicator.h | 2 +-
src/replica/duplication/replica_follower.cpp | 14 +-
src/replica/duplication/replica_follower.h | 4 +-
.../test/duplication_sync_timer_test.cpp | 6 +-
.../test/load_from_private_log_test.cpp | 6 +-
.../duplication/test/mutation_batch_test.cpp | 2 +-
.../duplication/test/replica_duplicator_test.cpp | 2 +-
.../duplication/test/replica_follower_test.cpp | 6 +-
src/replica/log_file.h | 2 +-
src/replica/mutation.cpp | 2 +-
src/replica/mutation.h | 7 +-
src/replica/mutation_log.h | 6 +-
src/replica/replica.cpp | 2 +-
src/replica/replica.h | 9 +-
src/replica/replica_2pc.cpp | 18 +-
src/replica/replica_backup.cpp | 2 +-
src/replica/replica_check.cpp | 12 +-
src/replica/replica_chkpt.cpp | 10 +-
src/replica/replica_config.cpp | 18 +-
src/replica/replica_context.cpp | 2 +-
src/replica/replica_context.h | 4 +-
src/replica/replica_disk_migrator.cpp | 2 +-
src/replica/replica_disk_migrator.h | 2 +-
src/replica/replica_failover.cpp | 4 +-
src/replica/replica_init.cpp | 4 +-
src/replica/replica_learn.cpp | 14 +-
src/replica/replica_restore.cpp | 14 +-
src/replica/replica_stub.cpp | 8 +-
src/replica/replica_stub.h | 22 +-
src/replica/replica_throttle.cpp | 4 +-
src/replica/replication_app_base.cpp | 10 +-
src/replica/split/replica_split_manager.cpp | 14 +-
src/replica/split/test/replica_split_test.cpp | 8 +-
src/replica/storage/simple_kv/simple_kv.client.h | 8 +-
src/replica/storage/simple_kv/test/case.cpp | 6 +-
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 | 14 +-
src/replica/storage/simple_kv/test/client.h | 4 +-
src/replica/storage/simple_kv/test/common.h | 2 +-
src/replica/storage/simple_kv/test/injector.cpp | 4 +-
src/replica/test/backup_block_service_mock.h | 4 +-
src/replica/test/mock_utils.h | 2 +-
src/replica/test/mutation_log_learn_test.cpp | 2 +-
src/replica/test/open_replica_test.cpp | 6 +-
src/replica/test/replica_disk_migrate_test.cpp | 6 +-
src/replica/test/replica_disk_test.cpp | 2 +-
src/replica/test/replica_test.cpp | 10 +-
src/{ranger => rpc}/CMakeLists.txt | 9 +-
src/{runtime => }/rpc/asio_net_provider.cpp | 7 +-
src/{runtime => }/rpc/asio_net_provider.h | 12 +-
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 | 6 +-
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 | 4 +-
src/{runtime => }/rpc/message_parser.h | 4 +-
src/{runtime => }/rpc/message_parser_manager.h | 2 +-
src/{runtime => }/rpc/network.cpp | 18 +-
src/{runtime => }/rpc/network.h | 15 +-
src/{runtime => }/rpc/network.sim.cpp | 2 +-
src/{runtime => }/rpc/network.sim.h | 32 +--
src/{runtime => }/rpc/raw_message_parser.cpp | 8 +-
src/{runtime => }/rpc/raw_message_parser.h | 4 +-
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 | 16 +-
src/{runtime => }/rpc/rpc_holder.h | 10 +-
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 | 4 +-
src/{runtime => }/rpc/rpc_stream.h | 4 +-
src/{runtime => }/rpc/rpc_task.cpp | 12 +-
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} | 33 +--
src/{runtime => rpc}/test/host_port_test.cpp | 22 +-
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} | 52 ++--
src/{runtime => rpc}/test/rpc_holder_test.cpp | 14 +-
.../test/rpc_message_test.cpp} | 19 +-
.../test/rpc.cpp => rpc/test/rpc_test.cpp} | 24 +-
src/{ranger => rpc}/test/run.sh | 6 +-
.../test/thrift_message_parser_test.cpp | 12 +-
src/{runtime => }/rpc/thrift_message_parser.cpp | 4 +-
src/{runtime => }/rpc/thrift_message_parser.h | 4 +-
src/runtime/CMakeLists.txt | 6 +-
src/runtime/api_layer1.h | 8 +-
src/runtime/api_task.h | 2 +-
src/runtime/env.sim.cpp | 2 +-
src/runtime/fault_injector.cpp | 8 +-
src/runtime/global_config.cpp | 2 +-
src/runtime/global_config.h | 2 +-
src/runtime/message_utils.cpp | 2 +-
src/runtime/message_utils.h | 6 +-
src/runtime/nativerun.cpp | 2 +-
src/runtime/pipeline.h | 6 +-
src/runtime/profiler.cpp | 11 +-
src/runtime/providers.common.cpp | 18 +-
src/runtime/rpc/CMakeLists.txt | 45 ----
src/runtime/scheduler.cpp | 6 +-
src/runtime/scheduler.h | 4 +-
src/runtime/serverlet.h | 4 +-
src/runtime/service_api_c.cpp | 18 +-
src/runtime/service_app.h | 5 +-
src/runtime/service_engine.cpp | 10 +-
src/runtime/service_engine.h | 2 +-
src/runtime/simulator.cpp | 4 +-
src/runtime/task/CMakeLists.txt | 37 ---
src/runtime/test/CMakeLists.txt | 4 +-
src/runtime/test/config-test-corrupt-message.ini | 141 ----------
src/runtime/test/config-test-sim.ini | 10 +-
src/runtime/test/config-test.ini | 16 +-
src/runtime/test/dns_resolver_test.cpp | 10 +-
src/runtime/test/gtest.filter | 3 -
src/runtime/test/pipeline_test.cpp | 2 +-
src/runtime/test/run.sh | 13 +-
src/runtime/test/service_api_c.cpp | 12 +-
src/runtime/test/sim_lock.cpp | 16 +-
src/runtime/test_utils.h | 25 +-
src/runtime/tool_api.cpp | 7 +-
src/runtime/tool_api.h | 13 +-
src/runtime/tracer.cpp | 8 +-
src/security/client_negotiation.cpp | 4 +-
src/security/client_negotiation.h | 2 +-
src/security/meta_access_controller.cpp | 8 +-
src/security/negotiation.h | 6 +-
src/security/negotiation_manager.cpp | 6 +-
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 | 10 +-
src/security/test/negotiation_manager_test.cpp | 12 +-
.../test/replica_access_controller_test.cpp | 8 +-
src/security/test/server_negotiation_test.cpp | 6 +-
src/server/available_detector.cpp | 4 +-
src/server/available_detector.h | 6 +-
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 | 6 +-
src/server/info_collector.h | 6 +-
src/server/pegasus_manual_compact_service.cpp | 4 +-
src/server/pegasus_mutation_duplicator.cpp | 4 +-
src/server/pegasus_mutation_duplicator.h | 4 +-
src/server/pegasus_server_impl.cpp | 8 +-
src/server/pegasus_server_impl.h | 4 +-
src/server/pegasus_server_impl_init.cpp | 2 +-
src/server/pegasus_server_write.cpp | 6 +-
src/server/pegasus_server_write.h | 2 +-
src/server/pegasus_write_service.cpp | 4 +-
src/server/result_writer.cpp | 4 +-
src/server/result_writer.h | 2 +-
src/server/test/capacity_unit_calculator_test.cpp | 2 +-
src/server/test/hotkey_collector_test.cpp | 8 +-
.../test/pegasus_mutation_duplicator_test.cpp | 4 +-
src/server/test/pegasus_server_write_test.cpp | 2 +-
src/server/test/pegasus_write_service_test.cpp | 4 +-
src/shell/command_helper.h | 2 +-
src/shell/command_utils.cpp | 2 +-
src/shell/commands/bulk_load.cpp | 4 +-
src/shell/commands/data_operations.cpp | 4 +-
src/shell/commands/debugger.cpp | 6 +-
src/shell/commands/detect_hotkey.cpp | 2 +-
src/shell/commands/node_management.cpp | 2 +-
src/shell/commands/rebalance.cpp | 2 +-
src/shell/commands/recovery.cpp | 2 +-
src/shell/commands/table_management.cpp | 2 +-
src/{replica/storage => task}/CMakeLists.txt | 9 +-
src/{runtime => }/task/async_calls.h | 6 +-
src/{runtime => }/task/future_types.h | 0
src/{runtime => }/task/hpc_task_queue.cpp | 8 +-
src/{runtime => }/task/hpc_task_queue.h | 4 +-
src/{runtime => }/task/simple_task_queue.cpp | 10 +-
src/{runtime => }/task/simple_task_queue.h | 6 +-
src/{runtime => }/task/task.cpp | 7 +-
src/{runtime => }/task/task.h | 6 +-
src/{runtime => }/task/task_code.cpp | 0
src/{runtime => }/task/task_code.h | 0
src/{runtime => }/task/task_engine.cpp | 13 +-
src/{runtime => }/task/task_engine.h | 2 +-
src/{runtime => }/task/task_engine.sim.cpp | 4 +-
src/{runtime => }/task/task_engine.sim.h | 0
src/{runtime => }/task/task_queue.cpp | 11 +-
src/{runtime => }/task/task_queue.h | 0
src/{runtime => }/task/task_spec.cpp | 3 +-
src/{runtime => }/task/task_spec.h | 2 +-
src/{runtime => }/task/task_tracker.cpp | 0
src/{runtime => }/task/task_tracker.h | 0
src/{runtime => }/task/task_worker.cpp | 8 +-
src/{runtime => }/task/task_worker.h | 0
src/{ranger/test => task/tests}/CMakeLists.txt | 6 +-
.../tests/async_call_test.cpp} | 19 +-
.../config.ini => task/tests/config-test-sim.ini} | 20 +-
.../test/config.ini => task/tests/config-test.ini} | 32 ++-
.../test/lpc.cpp => task/tests/lpc_test.cpp} | 8 +-
src/{runtime/test => task/tests}/main.cpp | 41 ++-
src/task/tests/run.sh | 47 ++++
.../tests/task_engine_test.cpp} | 13 +-
src/{runtime/test => task/tests}/task_test.cpp | 6 +-
src/{runtime => }/task/timer_service.h | 0
src/test/function_test/base_api/test_copy.cpp | 2 +-
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/test/kill_test/partition_kill_testor.cpp | 2 +-
src/test/pressure_test/main.cpp | 6 +-
src/tools/mutation_log_tool.cpp | 4 +-
src/utils/distributed_lock_service.h | 26 +-
src/utils/latency_tracer.h | 2 +-
src/utils/metrics.cpp | 8 +-
src/utils/test/env.cpp | 2 +-
src/utils/test/fmt_logging_test.cpp | 2 +-
src/utils/test/json_helper_test.cpp | 2 +-
src/utils/test/metrics_test.cpp | 4 +-
.../distributed_lock_service_zookeeper.cpp | 2 +-
src/zookeeper/distributed_lock_service_zookeeper.h | 6 +-
src/zookeeper/lock_struct.cpp | 4 +-
src/zookeeper/lock_struct.h | 2 +-
src/zookeeper/lock_types.h | 2 +-
src/zookeeper/test/distributed_lock_zookeeper.cpp | 4 +-
src/zookeeper/zookeeper_session.cpp | 2 +-
thirdparty/CMakeLists.txt | 2 +-
...atch => fix_thrift_build_and_link_errors.patch} | 13 +
405 files changed, 1751 insertions(+), 1701 deletions(-)
copy src/{ranger => rpc}/CMakeLists.txt (81%)
rename src/{runtime => }/rpc/asio_net_provider.cpp (99%)
rename src/{runtime => }/rpc/asio_net_provider.h (95%)
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 (98%)
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 (98%)
rename src/{runtime => }/rpc/message_parser.h (98%)
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 (99%)
rename src/{runtime => }/rpc/network.sim.h (82%)
rename src/{runtime => }/rpc/raw_message_parser.cpp (97%)
rename src/{runtime => }/rpc/raw_message_parser.h (96%)
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 (97%)
rename src/{runtime => }/rpc/rpc_holder.h (98%)
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 (99%)
rename src/{runtime => }/rpc/rpc_stream.h (98%)
rename src/{runtime => }/rpc/rpc_task.cpp (95%)
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} (67%)
rename src/{runtime => rpc}/test/host_port_test.cpp (97%)
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}
(88%)
rename src/{runtime => rpc}/test/rpc_holder_test.cpp (95%)
rename src/{runtime/test/rpc_message.cpp => rpc/test/rpc_message_test.cpp}
(95%)
rename src/{runtime/test/rpc.cpp => rpc/test/rpc_test.cpp} (95%)
copy src/{ranger => rpc}/test/run.sh (86%)
rename src/{runtime => rpc}/test/thrift_message_parser_test.cpp (98%)
rename src/{runtime => }/rpc/thrift_message_parser.cpp (99%)
rename src/{runtime => }/rpc/thrift_message_parser.h (98%)
delete mode 100644 src/runtime/rpc/CMakeLists.txt
delete mode 100644 src/runtime/task/CMakeLists.txt
delete mode 100644 src/runtime/test/config-test-corrupt-message.ini
delete mode 100644 src/runtime/test/gtest.filter
copy src/{replica/storage => task}/CMakeLists.txt (87%)
rename src/{runtime => }/task/async_calls.h (99%)
rename src/{runtime => }/task/future_types.h (100%)
rename src/{runtime => }/task/hpc_task_queue.cpp (94%)
rename src/{runtime => }/task/hpc_task_queue.h (95%)
rename src/{runtime => }/task/simple_task_queue.cpp (96%)
rename src/{runtime => }/task/simple_task_queue.h (95%)
rename src/{runtime => }/task/task.cpp (99%)
rename src/{runtime => }/task/task.h (99%)
rename src/{runtime => }/task/task_code.cpp (100%)
rename src/{runtime => }/task/task_code.h (100%)
rename src/{runtime => }/task/task_engine.cpp (98%)
rename src/{runtime => }/task/task_engine.h (99%)
rename src/{runtime => }/task/task_engine.sim.cpp (99%)
rename src/{runtime => }/task/task_engine.sim.h (100%)
rename src/{runtime => }/task/task_queue.cpp (96%)
rename src/{runtime => }/task/task_queue.h (100%)
rename src/{runtime => }/task/task_spec.cpp (99%)
rename src/{runtime => }/task/task_spec.h (99%)
rename src/{runtime => }/task/task_tracker.cpp (100%)
rename src/{runtime => }/task/task_tracker.h (100%)
rename src/{runtime => }/task/task_worker.cpp (98%)
rename src/{runtime => }/task/task_worker.h (100%)
copy src/{ranger/test => task/tests}/CMakeLists.txt (90%)
rename src/{runtime/test/async_call.cpp => task/tests/async_call_test.cpp}
(96%)
copy src/{security/test/config.ini => task/tests/config-test-sim.ini} (73%)
copy src/{security/test/config.ini => task/tests/config-test.ini} (56%)
rename src/{runtime/test/lpc.cpp => task/tests/lpc_test.cpp} (93%)
copy src/{runtime/test => task/tests}/main.cpp (57%)
create mode 100755 src/task/tests/run.sh
rename src/{runtime/test/task_engine.cpp => task/tests/task_engine_test.cpp}
(91%)
rename src/{runtime/test => task/tests}/task_test.cpp (96%)
rename src/{runtime => }/task/timer_service.h (100%)
rename thirdparty/{fix_thrift_for_cpp11.patch =>
fix_thrift_build_and_link_errors.patch} (80%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
