This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a change to branch
dependabot/pip/python-client/twisted-24.7.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
from dacc00b6e Update test_python-client.yml
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 a75994dd4 Merge branch 'master' into
dependabot/pip/python-client/twisted-24.7.0
No new revisions were added by this update.
Summary of changes:
.github/workflows/lint_and_test_cpp.yaml | 3 +
.licenserc.yaml | 274 +++++++++++----------
build_tools/recompile_thrift.sh | 2 +-
.../org/apache/pegasus/client/PegasusTable.java | 147 ++++++-----
python-client/requirement.txt | 4 +-
python-client/setup.py | 2 +-
src/CMakeLists.txt | 1 +
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/block_service/block_service.h | 6 +-
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 | 2 +-
src/client/partition_resolver.h | 6 +-
src/client/partition_resolver_simple.cpp | 6 +-
src/client/partition_resolver_simple.h | 4 +-
src/client/replication_ddl_client.h | 8 +-
src/client/test/ddl_client_test.cpp | 2 +-
src/client_lib/pegasus_client_impl.cpp | 4 +-
src/common/json_helper.h | 2 +-
src/common/replication.codes.h | 2 +-
src/common/replication_common.h | 4 +-
src/common/storage_serverlet.h | 2 +-
src/failure_detector/failure_detector.cpp | 4 +-
src/failure_detector/failure_detector.h | 7 +-
src/failure_detector/fd.client.h | 2 +-
src/failure_detector/fd.code.definition.h | 4 +-
src/failure_detector/test/failure_detector.cpp | 6 +-
src/geo/lib/geo_client.h | 2 +-
src/http/http_message_parser.h | 2 +-
src/http/http_server.h | 2 +-
src/include/rrdb/rrdb.client.h | 5 +-
src/meta/backup_engine.cpp | 8 +-
src/meta/backup_engine.h | 2 +-
src/meta/distributed_lock_service_simple.cpp | 2 +-
src/meta/distributed_lock_service_simple.h | 8 +-
src/meta/dump_file.h | 2 +-
src/meta/duplication/meta_duplication_service.cpp | 2 +-
src/meta/meta_backup_service.cpp | 4 +-
src/meta/meta_backup_service.h | 4 +-
src/meta/meta_bulk_load_service.cpp | 6 +-
src/meta/meta_bulk_load_service.h | 3 +-
src/meta/meta_data.h | 2 +-
src/meta/meta_server_failure_detector.cpp | 2 +-
src/meta/meta_server_failure_detector.h | 3 +-
src/meta/meta_service.cpp | 2 +-
src/meta/meta_service.h | 9 +-
src/meta/meta_split_service.cpp | 2 +-
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 | 10 +-
src/meta/meta_state_service_zookeeper.h | 8 +-
src/meta/server_state.cpp | 7 +-
src/meta/server_state.h | 4 +-
src/meta/server_state_restore.cpp | 4 +-
src/meta/test/backup_test.cpp | 6 +-
src/meta/test/main.cpp | 2 +-
src/meta/test/meta_app_operation_test.cpp | 2 +-
src/meta/test/meta_http_service_test.cpp | 4 +-
src/meta/test/meta_partition_guardian_test.cpp | 4 +-
src/meta/test/meta_service_test_app.h | 6 +-
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 | 2 +-
src/meta/test/state_sync_test.cpp | 2 +-
src/meta/test/update_configuration_test.cpp | 4 +-
src/nfs/nfs_client_impl.h | 7 +-
src/nfs/nfs_node.h | 2 +-
src/nfs/nfs_server_impl.cpp | 2 +-
src/nfs/nfs_server_impl.h | 4 +-
src/nfs/test/main.cpp | 2 +-
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 | 2 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 2 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 2 +-
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/bulk_load/replica_bulk_loader.cpp | 2 +-
src/replica/bulk_load/replica_bulk_loader.h | 2 +-
.../bulk_load/test/replica_bulk_loader_test.cpp | 2 +-
src/replica/duplication/duplication_sync_timer.cpp | 4 +-
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 | 2 +-
src/replica/duplication/replica_follower.h | 3 +-
.../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 | 2 +-
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.h | 4 +-
src/replica/replica_2pc.cpp | 8 +-
src/replica/replica_backup.cpp | 2 +-
src/replica/replica_check.cpp | 4 +-
src/replica/replica_chkpt.cpp | 4 +-
src/replica/replica_config.cpp | 4 +-
src/replica/replica_context.h | 2 +-
src/replica/replica_disk_migrator.cpp | 2 +-
src/replica/replica_disk_migrator.h | 2 +-
src/replica/replica_init.cpp | 4 +-
src/replica/replica_learn.cpp | 4 +-
src/replica/replica_restore.cpp | 8 +-
src/replica/replica_stub.cpp | 2 +-
src/replica/replica_stub.h | 6 +-
src/replica/replica_throttle.cpp | 2 +-
src/replica/replication_app_base.cpp | 6 +-
src/replica/split/replica_split_manager.cpp | 4 +-
src/replica/split/test/replica_split_test.cpp | 4 +-
src/replica/storage/simple_kv/simple_kv.client.h | 8 +-
src/replica/storage/simple_kv/test/case.cpp | 4 +-
src/replica/storage/simple_kv/test/client.cpp | 4 +-
src/replica/storage/simple_kv/test/client.h | 2 +-
src/replica/storage/simple_kv/test/injector.cpp | 4 +-
src/replica/test/backup_block_service_mock.h | 4 +-
src/replica/test/mutation_log_learn_test.cpp | 2 +-
src/replica/test/open_replica_test.cpp | 2 +-
src/replica/test/replica_disk_migrate_test.cpp | 4 +-
src/replica/test/replica_test.cpp | 6 +-
src/rpc/asio_net_provider.cpp | 4 +-
src/rpc/asio_net_provider.h | 2 +-
src/rpc/dsn_message_parser.cpp | 4 +-
src/rpc/message_parser.cpp | 2 +-
src/rpc/message_parser.h | 2 +-
src/rpc/network.cpp | 8 +-
src/rpc/network.h | 2 +-
src/rpc/network.sim.cpp | 2 +-
src/rpc/network.sim.h | 2 +-
src/rpc/raw_message_parser.cpp | 4 +-
src/rpc/raw_message_parser.h | 2 +-
src/rpc/rpc_engine.h | 6 +-
src/rpc/rpc_holder.h | 10 +-
src/rpc/rpc_message.h | 4 +-
src/rpc/rpc_stream.h | 2 +-
src/rpc/rpc_task.cpp | 10 +-
src/rpc/test/corrupt_message_test.cpp | 4 +-
src/rpc/test/host_port_test.cpp | 8 +-
src/rpc/test/net_provider_test.cpp | 6 +-
src/rpc/test/rpc_message_test.cpp | 7 +-
src/rpc/test/rpc_test.cpp | 4 +-
src/rpc/test/thrift_message_parser_test.cpp | 4 +-
src/rpc/thrift_message_parser.h | 2 +-
src/runtime/CMakeLists.txt | 4 +-
src/runtime/api_layer1.h | 4 +-
src/runtime/api_task.h | 2 +-
src/runtime/env.sim.cpp | 2 +-
src/runtime/fault_injector.cpp | 6 +-
src/runtime/global_config.cpp | 2 +-
src/runtime/global_config.h | 2 +-
src/runtime/message_utils.h | 4 +-
src/runtime/nativerun.cpp | 2 +-
src/runtime/pipeline.h | 6 +-
src/runtime/profiler.cpp | 11 +-
src/runtime/providers.common.cpp | 12 +-
src/runtime/scheduler.cpp | 6 +-
src/runtime/scheduler.h | 4 +-
src/runtime/service_api_c.cpp | 10 +-
src/runtime/service_app.h | 2 +-
src/runtime/service_engine.cpp | 8 +-
src/runtime/service_engine.h | 2 +-
src/runtime/simulator.cpp | 4 +-
src/runtime/task/CMakeLists.txt | 37 ---
src/runtime/test/config-test-sim.ini | 10 +-
src/runtime/test/config-test.ini | 16 +-
src/runtime/test/pipeline_test.cpp | 2 +-
src/runtime/test/service_api_c.cpp | 5 +-
src/runtime/test/sim_lock.cpp | 4 +-
src/runtime/test_utils.h | 31 +--
src/runtime/tool_api.cpp | 7 +-
src/runtime/tool_api.h | 11 +-
src/runtime/tracer.cpp | 8 +-
src/security/meta_access_controller.cpp | 4 +-
src/security/negotiation_manager.cpp | 2 +-
src/security/test/meta_access_controller_test.cpp | 2 +-
src/security/test/negotiation_manager_test.cpp | 2 +-
src/server/available_detector.cpp | 4 +-
src/server/available_detector.h | 4 +-
src/server/info_collector.cpp | 4 +-
src/server/info_collector.h | 5 +-
src/server/pegasus_manual_compact_service.cpp | 4 +-
src/server/pegasus_mutation_duplicator.h | 4 +-
src/server/pegasus_server_impl.cpp | 4 +-
src/server/pegasus_server_impl.h | 4 +-
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/hotkey_collector_test.cpp | 8 +-
src/server/test/pegasus_write_service_test.cpp | 4 +-
src/shell/command_helper.h | 2 +-
src/shell/commands/bulk_load.cpp | 2 +-
src/shell/commands/data_operations.cpp | 2 +-
src/shell/commands/debugger.cpp | 6 +-
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 | 5 +-
src/{runtime => }/task/task_queue.h | 0
src/{runtime => }/task/task_spec.cpp | 1 +
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/{rpc/test => task/tests}/CMakeLists.txt | 8 +-
.../tests/async_call_test.cpp} | 17 +-
.../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} | 6 +-
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/kill_test/partition_kill_testor.cpp | 2 +-
src/test/pressure_test/main.cpp | 6 +-
src/tools/mutation_log_tool.cpp | 2 +-
src/utils/distributed_lock_service.h | 20 +-
src/utils/latency_tracer.h | 2 +-
src/utils/metrics.cpp | 2 +-
src/utils/test/env.cpp | 2 +-
src/utils/test/fmt_logging_test.cpp | 2 +-
.../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 +-
260 files changed, 848 insertions(+), 818 deletions(-)
delete mode 100644 src/runtime/task/CMakeLists.txt
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 (98%)
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/{rpc/test => task/tests}/CMakeLists.txt (90%)
rename src/{runtime/test/async_call.cpp => task/tests/async_call_test.cpp}
(97%)
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}
(97%)
rename src/{runtime/test => task/tests}/task_test.cpp (96%)
rename src/{runtime => }/task/timer_service.h (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
