This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
from c7638fc14 update commons-configuration2 version to 2.8.0 (#1222)
add e2a0088f8 refactor(macro): use CHECK_* to replace dassert_* (part 3)
(#1226)
No new revisions were added by this update.
Summary of changes:
src/block_service/block_service_manager.cpp | 23 ++--
src/block_service/fds/fds_service.cpp | 16 +--
src/block_service/local/local_service.cpp | 7 +-
src/client/partition_resolver.cpp | 8 +-
src/client/replication_ddl_client.cpp | 2 +-
src/client_lib/pegasus_client_impl.cpp | 3 +-
src/common/common.cpp | 6 +-
src/common/duplication_common.cpp | 12 +--
src/common/fs_manager.cpp | 6 +-
src/common/json_helper.h | 2 +-
src/common/storage_serverlet.h | 8 +-
src/meta/duplication/duplication_info.h | 2 +-
src/meta/load_balance_policy.cpp | 15 +--
src/meta/meta_data.cpp | 7 +-
src/meta/meta_options.cpp | 7 +-
src/replica/backup/cold_backup_context.cpp | 21 ++--
src/replica/duplication/mutation_batch.cpp | 2 +-
src/replica/log_block.h | 2 +-
src/replica/log_file.cpp | 12 +--
src/replica/log_file_stream.h | 2 +-
src/replica/mutation.cpp | 11 +-
src/replica/mutation.h | 10 +-
src/replica/mutation_cache.cpp | 2 +-
src/replica/mutation_log_replay.cpp | 5 +-
src/replica/prepare_list.cpp | 6 +-
src/replica/replica.cpp | 34 +++---
src/replica/replica_2pc.cpp | 26 +++--
src/replica/replica_backup.cpp | 22 ++--
src/replica/replica_check.cpp | 7 +-
src/replica/replica_chkpt.cpp | 6 +-
src/replica/replica_context.cpp | 2 +-
src/replica/replica_context.h | 4 +-
src/replica/replica_failover.cpp | 13 ++-
src/replica/replica_http_service.h | 2 +-
src/replica/replica_init.cpp | 21 ++--
src/replica/replica_learn.cpp | 47 ++++-----
src/replica/replica_restore.cpp | 42 ++++----
src/replica/replication_app_base.cpp | 2 +-
src/replica/split/replica_split_manager.cpp | 2 +-
src/replica/storage/simple_kv/test/case.cpp | 21 ++--
src/replica/storage/simple_kv/test/checker.cpp | 2 +-
src/replica/storage/simple_kv/test/common.cpp | 8 +-
.../simple_kv/test/simple_kv.server.impl.cpp | 12 +--
src/replica/test/replica_test.cpp | 6 +-
src/runtime/fault_injector.cpp | 2 +-
src/runtime/pipeline.h | 4 +-
src/runtime/profiler.cpp | 13 +--
src/runtime/rpc/asio_net_provider.cpp | 8 +-
src/runtime/rpc/message_parser.cpp | 11 +-
src/runtime/rpc/network.cpp | 19 ++--
src/runtime/rpc/network.sim.cpp | 24 ++---
src/runtime/rpc/rpc_engine.cpp | 117 ++++++++++-----------
src/runtime/rpc/rpc_engine.h | 2 +-
src/runtime/rpc/rpc_holder.h | 16 +--
src/runtime/rpc/rpc_message.cpp | 39 ++++---
src/runtime/rpc/rpc_stream.h | 5 +-
src/runtime/rpc/serialization.h | 4 +-
src/runtime/rpc/thrift_message_parser.cpp | 6 +-
src/runtime/scheduler.cpp | 2 +-
src/runtime/security/meta_access_controller.cpp | 7 +-
src/runtime/service_api_c.cpp | 18 ++--
src/runtime/service_app.h | 2 +-
src/runtime/service_engine.cpp | 8 +-
src/runtime/task/simple_task_queue.cpp | 7 +-
src/runtime/task/task.cpp | 89 ++++++++--------
src/runtime/task/task_engine.sim.cpp | 13 +--
src/runtime/task/task_spec.cpp | 18 ++--
src/runtime/tracer.cpp | 2 +-
src/server/pegasus_server_impl.cpp | 3 +-
src/server/pegasus_server_impl_init.cpp | 6 +-
src/server/pegasus_write_service.cpp | 8 +-
src/server/rocksdb_wrapper.cpp | 2 +-
src/shell/commands/data_operations.cpp | 2 +-
src/utils/api_utilities.h | 15 ---
src/utils/command_manager.cpp | 4 +-
src/utils/errors.h | 11 +-
src/utils/filesystem.cpp | 2 +-
src/utils/flags.cpp | 10 +-
src/utils/fmt_logging.h | 11 +-
src/utils/logging.cpp | 5 +-
src/utils/long_adder.cpp | 10 +-
src/utils/output_utils.cpp | 8 +-
src/utils/simple_logger.cpp | 6 +-
src/zookeeper/lock_struct.cpp | 4 +-
src/zookeeper/test/distributed_lock_zookeeper.cpp | 2 +-
src/zookeeper/zookeeper_session.cpp | 2 +-
86 files changed, 476 insertions(+), 547 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
