Path	Lines of Code
admin-cli/client/fake_cluster_test.go	117
admin-cli/client/fake_meta_test.go	194
admin-cli/client/migrate_node_test.go	61
admin-cli/client/replica_health_test.go	90
go-client/admin/client_test.go	96
go-client/admin/remote_cmd_client_test.go	13
go-client/idl/base/gpid_test.go	44
go-client/idl/base/rpc_address_test.go	20
go-client/pegasus/client_test.go	110
go-client/pegasus/error_test.go	44
go-client/pegasus/main_test.go	11
go-client/pegasus/retry_failover_test.go	56
go-client/pegasus/scan_test.go	304
go-client/pegasus/table_connector_leak_test.go	19
go-client/pegasus/table_connector_test.go	656
go-client/rpc/main_test.go	11
go-client/rpc/rpc_conn_test.go	107
go-client/rpc/stream_test.go	41
go-client/session/addr_test.go	27
go-client/session/codec_test.go	48
go-client/session/main_test.go	11
go-client/session/meta_session_test.go	78
go-client/session/replica_session_test.go	36
go-client/session/session_test.go	269
go-client/session/session_timeout_test.go	54
java-client/src/test/java/org/apache/pegasus/base/TestRpcAddress.java	33
java-client/src/test/java/org/apache/pegasus/client/PegasusScannerTest.java	540
java-client/src/test/java/org/apache/pegasus/client/TestAdminClient.java	126
java-client/src/test/java/org/apache/pegasus/client/TestBasic.java	2391
java-client/src/test/java/org/apache/pegasus/client/TestBatch.java	145
java-client/src/test/java/org/apache/pegasus/client/TestBatchGetByPartitions.java	88
java-client/src/test/java/org/apache/pegasus/client/TestBench.java	174
java-client/src/test/java/org/apache/pegasus/client/TestCheckAndMutate.java	1637
java-client/src/test/java/org/apache/pegasus/client/TestCheckAndSet.java	1542
java-client/src/test/java/org/apache/pegasus/client/TestFutureGroup.java	67
java-client/src/test/java/org/apache/pegasus/client/TestIncr.java	80
java-client/src/test/java/org/apache/pegasus/client/TestMultiThread.java	98
java-client/src/test/java/org/apache/pegasus/client/TestNoOperate.java	23
java-client/src/test/java/org/apache/pegasus/client/TestPException.java	102
java-client/src/test/java/org/apache/pegasus/client/TestPing.java	96
java-client/src/test/java/org/apache/pegasus/client/TestPingZK.java	62
java-client/src/test/java/org/apache/pegasus/client/TestTimeout.java	43
java-client/src/test/java/org/apache/pegasus/metrics/MetricsPoolTest.java	118
java-client/src/test/java/org/apache/pegasus/operator/ClientOperatorTest.java	26
java-client/src/test/java/org/apache/pegasus/rpc/async/ClusterManagerTest.java	58
java-client/src/test/java/org/apache/pegasus/rpc/async/InterceptorTest.java	34
java-client/src/test/java/org/apache/pegasus/rpc/async/MetaSessionTest.java	251
java-client/src/test/java/org/apache/pegasus/rpc/async/ReplicaSessionTest.java	248
java-client/src/test/java/org/apache/pegasus/rpc/async/TableHandlerTest.java	157
java-client/src/test/java/org/apache/pegasus/rpc/async/TimeoutBenchmark.java	70
java-client/src/test/java/org/apache/pegasus/security/NegotiationTest.java	129
java-client/src/test/java/org/apache/pegasus/tools/TestZstdWrapper.java	46
java-client/src/test/java/org/apache/pegasus/tools/Toollet.java	146
nodejs-client/test/client.test.js	291
python-client/tests/__init__.py	1
python-client/tests/test_basics.py	541
python-client/tests/test_benchmark.py	45
python-client/tests/test_integration.py	214
scala-client/src/test/scala/org/apache/pegasus/scalaclient/TableSpec.scala	232
scripts/pegasus_kill_test.sh	140
src/aio/test/aio.cpp	225
src/aio/test/clear.sh	1
src/aio/test/main.cpp	12
src/aio/test/run.sh	6
src/base/test/main.cpp	8
src/base/test/run.sh	8
src/base/test/utils_test.cpp	48
src/base/test/value_manager_test.cpp	63
src/base/test/value_schema_test.cpp	100
src/block_service/test/block_service_manager_test.cpp	95
src/block_service/test/block_service_mock.h	176
src/block_service/test/clear.sh	1
src/block_service/test/fds_service_test.cpp	662
src/block_service/test/hdfs_service_test.cpp	326
src/block_service/test/local_service_test.cpp	58
src/block_service/test/main.cpp	32
src/block_service/test/run.sh	6
src/client/test/ddl_client_test.cpp	87
src/client/test/main.cpp	8
src/client/test/run.sh	5
src/common/test/common_test.cpp	8
src/common/test/duplication_common_test.cpp	19
src/common/test/fs_manager_test.cpp	154
src/common/test/main.cpp	32
src/common/test/replication_common_test.cpp	82
src/common/test/run.sh	25
src/failure_detector/test/clear.sh	1
src/failure_detector/test/failure_detector.cpp	579
src/failure_detector/test/main.cpp	47
src/failure_detector/test/run.sh	26
src/geo/test/geo_test.cpp	534
src/geo/test/latlng_codec_test.cpp	118
src/geo/test/main.cpp	9
src/geo/test/run.sh	8
src/http/test/http_server_test.cpp	278
src/http/test/perf_counter_http_service_test.cpp	48
src/http/test/run.sh	5
src/http/test/uri_decoder_test.cpp	69
src/meta/test/backup_test.cpp	687
src/meta/test/balancer_simulator/balancer_simulator.cpp	148
src/meta/test/balancer_validator.cpp	186
src/meta/test/clear.sh	1
src/meta/test/cluster_balance_policy_test.cpp	451
src/meta/test/copy_replica_operation_test.cpp	202
src/meta/test/dummy_balancer.h	20
src/meta/test/dump_file.cpp	103
src/meta/test/duplication_info_test.cpp	239
src/meta/test/ford_fulkerson_test.cpp	222
src/meta/test/json_compacity.cpp	123
src/meta/test/main.cpp	70
src/meta/test/meta_app_envs_test.cpp	161
src/meta/test/meta_app_operation_test.cpp	602
src/meta/test/meta_backup_test.cpp	286
src/meta/test/meta_bulk_load_ingestion_test.cpp	330
src/meta/test/meta_bulk_load_service_test.cpp	1410
src/meta/test/meta_data.cpp	354
src/meta/test/meta_duplication_service_test.cpp	674
src/meta/test/meta_http_service_test.cpp	358
src/meta/test/meta_mauanl_compaction_test.cpp	178
src/meta/test/meta_partition_guardian_test.cpp	769
src/meta/test/meta_service_test.cpp	99
src/meta/test/meta_service_test_app.h	151
src/meta/test/meta_split_service_test.cpp	685
src/meta/test/meta_state/clear.sh	1
src/meta/test/meta_state/main.cpp	45
src/meta/test/meta_state/meta_state_service.cpp	237
src/meta/test/meta_state/run.sh	26
src/meta/test/meta_state_service_utils_test.cpp	133
src/meta/test/meta_test_base.cpp	194
src/meta/test/meta_test_base.h	47
src/meta/test/misc/misc.cpp	362
src/meta/test/misc/misc.h	77
src/meta/test/run.sh	37
src/meta/test/server_state_restore_test.cpp	139
src/meta/test/server_state_test.cpp	167
src/meta/test/state_sync_test.cpp	317
src/meta/test/update_configuration_test.cpp	413
src/nfs/test/clear.sh	1
src/nfs/test/main.cpp	150
src/nfs/test/run.sh	6
src/perf_counter/test/clear.sh	1
src/perf_counter/test/main.cpp	6
src/perf_counter/test/perf_counter_test.cpp	127
src/perf_counter/test/perf_counters_test.cpp	272
src/perf_counter/test/run.sh	6
src/redis_protocol/proxy_ut/redis_proxy_test.cpp	536
src/replica/backup/test/main.cpp	32
src/replica/backup/test/replica_backup_manager_test.cpp	28
src/replica/backup/test/run.sh	25
src/replica/bulk_load/test/main.cpp	32
src/replica/bulk_load/test/replica_bulk_loader_test.cpp	782
src/replica/bulk_load/test/run.sh	25
src/replica/duplication/test/dup_replica_http_service_test.cpp	49
src/replica/duplication/test/duplication_sync_timer_test.cpp	293
src/replica/duplication/test/duplication_test_base.h	65
src/replica/duplication/test/load_from_private_log_test.cpp	349
src/replica/duplication/test/main.cpp	32
src/replica/duplication/test/mutation_batch_test.cpp	77
src/replica/duplication/test/replica_duplicator_manager_test.cpp	161
src/replica/duplication/test/replica_duplicator_test.cpp	129
src/replica/duplication/test/replica_follower_test.cpp	204
src/replica/duplication/test/run.sh	25
src/replica/duplication/test/ship_mutation_test.cpp	92
src/replica/split/test/main.cpp	32
src/replica/split/test/replica_split_test.cpp	827
src/replica/split/test/run.sh	25
src/replica/storage/simple_kv/test/addcase.sh	13
src/replica/storage/simple_kv/test/case.cpp	1252
src/replica/storage/simple_kv/test/case.h	386
src/replica/storage/simple_kv/test/checker.cpp	318
src/replica/storage/simple_kv/test/checker.h	70
src/replica/storage/simple_kv/test/clear.sh	1
src/replica/storage/simple_kv/test/client.cpp	138
src/replica/storage/simple_kv/test/client.h	37
src/replica/storage/simple_kv/test/common.cpp	278
src/replica/storage/simple_kv/test/common.h	161
src/replica/storage/simple_kv/test/injector.cpp	136
src/replica/storage/simple_kv/test/injector.h	15
src/replica/storage/simple_kv/test/run.sh	81
src/replica/storage/simple_kv/test/simple_kv.main.cpp	52
src/replica/storage/simple_kv/test/simple_kv.server.impl.cpp	233
src/replica/storage/simple_kv/test/simple_kv.server.impl.h	79
src/replica/test/backup_block_service_mock.h	54
src/replica/test/clear.sh	1
src/replica/test/cold_backup_context_test.cpp	367
src/replica/test/log_block_test.cpp	137
src/replica/test/log_file_test.cpp	71
src/replica/test/main.cpp	40
src/replica/test/mock_utils.h	371
src/replica/test/mutation_log_learn_test.cpp	146
src/replica/test/mutation_log_test.cpp	467
src/replica/test/open_replica_test.cpp	69
src/replica/test/replica_disk_migrate_test.cpp	301
src/replica/test/replica_disk_test.cpp	248
src/replica/test/replica_disk_test_base.h	117
src/replica/test/replica_http_service_test.cpp	87
src/replica/test/replica_learn_test.cpp	106
src/replica/test/replica_test.cpp	475
src/replica/test/replica_test_base.h	48
src/replica/test/replication_service_test_app.h	21
src/replica/test/run.sh	23
src/replica/test/throttling_controller_test.cpp	95
src/runtime/test/address_test.cpp	181
src/runtime/test/async_call.cpp	204
src/runtime/test/clear.sh	1
src/runtime/test/client_negotiation_test.cpp	162
src/runtime/test/corrupt_message.cpp	25
src/runtime/test/host_port_test.cpp	186
src/runtime/test/lpc.cpp	23
src/runtime/test/main.cpp	47
src/runtime/test/message_reader_test.cpp	75
src/runtime/test/message_utils_test.cpp	42
src/runtime/test/meta_access_controller_test.cpp	78
src/runtime/test/negotiation_manager_test.cpp	144
src/runtime/test/netprovider.cpp	224
src/runtime/test/pipeline_test.cpp	91
src/runtime/test/ranger_resource_policy_manager_test.cpp	464
src/runtime/test/ranger_resource_policy_test.cpp	122
src/runtime/test/replica_access_controller_test.cpp	60
src/runtime/test/rpc.cpp	200
src/runtime/test/rpc_holder_test.cpp	126
src/runtime/test/rpc_message.cpp	167
src/runtime/test/run.sh	27
src/runtime/test/server_negotiation_test.cpp	214
src/runtime/test/service_api_c.cpp	188
src/runtime/test/sim_lock.cpp	74
src/runtime/test/task_engine.cpp	59
src/runtime/test/task_test.cpp	48
src/runtime/test/test_utils.h	113
src/runtime/test/thrift_message_parser_test.cpp	362
src/server/test/capacity_unit_calculator_test.cpp	423
src/server/test/compaction_filter_rule_test.cpp	139
src/server/test/compaction_operation_test.cpp	246
src/server/test/hashkey_transform_test.cpp	45
src/server/test/hotkey_collector_test.cpp	325
src/server/test/hotspot_partition_test.cpp	149
src/server/test/main.cpp	40
src/server/test/manual_compact_service_test.cpp	218
src/server/test/message_utils.h	28
src/server/test/pegasus_compression_options_test.cpp	119
src/server/test/pegasus_mutation_duplicator_test.cpp	310
src/server/test/pegasus_server_impl_test.cpp	140
src/server/test/pegasus_server_test_base.h	64
src/server/test/pegasus_server_write_test.cpp	102
src/server/test/pegasus_value_schema_test.cpp	38
src/server/test/pegasus_write_service_impl_test.cpp	128
src/server/test/pegasus_write_service_test.cpp	260
src/server/test/rocksdb_wrapper_test.cpp	172
src/server/test/run.sh	25
src/test/bench_test/benchmark.cpp	322
src/test/bench_test/benchmark.h	54
src/test/bench_test/config.cpp	7
src/test/bench_test/config.h	19
src/test/bench_test/main.cpp	29
src/test/bench_test/rand.cpp	24
src/test/bench_test/rand.h	8
src/test/bench_test/statistics.cpp	121
src/test/bench_test/statistics.h	34
src/test/bench_test/utils.h	14
src/test/function_test/backup_restore_test/main.cpp	9
src/test/function_test/backup_restore_test/test_backup_and_restore.cpp	188
src/test/function_test/base_api_test/integration_test.cpp	136
src/test/function_test/base_api_test/main.cpp	9
src/test/function_test/base_api_test/test_basic.cpp	1485
src/test/function_test/base_api_test/test_batch_get.cpp	85
src/test/function_test/base_api_test/test_check_and_mutate.cpp	1506
src/test/function_test/base_api_test/test_check_and_set.cpp	1391
src/test/function_test/base_api_test/test_copy.cpp	177
src/test/function_test/base_api_test/test_incr.cpp	165
src/test/function_test/base_api_test/test_range_read.cpp	152
src/test/function_test/base_api_test/test_recall.cpp	70
src/test/function_test/base_api_test/test_scan.cpp	379
src/test/function_test/base_api_test/test_ttl.cpp	140
src/test/function_test/bulk_load_test/main.cpp	9
src/test/function_test/bulk_load_test/test_bulk_load.cpp	213
src/test/function_test/detect_hotspot_test/main.cpp	9
src/test/function_test/detect_hotspot_test/test_detect_hotspot.cpp	173
src/test/function_test/partition_split_test/main.cpp	9
src/test/function_test/partition_split_test/test_split.cpp	275
src/test/function_test/recovery_test/main.cpp	9
src/test/function_test/recovery_test/test_recovery.cpp	198
src/test/function_test/restore_test/main.cpp	8
src/test/function_test/restore_test/test_restore.cpp	233
src/test/function_test/run.sh	42
src/test/function_test/throttle_test/main.cpp	9
src/test/function_test/throttle_test/test_throttle.cpp	676
src/test/function_test/utils/global_env.cpp	42
src/test/function_test/utils/global_env.h	18
src/test/function_test/utils/test_util.cpp	114
src/test/function_test/utils/test_util.h	43
src/test/function_test/utils/utils.h	193
src/test/kill_test/data_verifier.cpp	385
src/test/kill_test/data_verifier.h	7
src/test/kill_test/job.cpp	18
src/test/kill_test/job.h	39
src/test/kill_test/kill_testor.cpp	144
src/test/kill_test/kill_testor.h	38
src/test/kill_test/killer_handler.h	45
src/test/kill_test/killer_handler_shell.cpp	138
src/test/kill_test/killer_handler_shell.h	31
src/test/kill_test/killer_registry.cpp	5
src/test/kill_test/killer_registry.h	2
src/test/kill_test/main.cpp	27
src/test/kill_test/partition_kill_testor.cpp	80
src/test/kill_test/partition_kill_testor.h	14
src/test/kill_test/process_kill_testor.cpp	209
src/test/kill_test/process_kill_testor.h	30
src/test/pressure_test/main.cpp	214
src/test_util/test_util.cpp	78
src/test_util/test_util.h	36
src/utils/test/TokenBucketTest.cpp	76
src/utils/test/TokenBucketTest.h	8
src/utils/test/autoref_ptr_test.cpp	420
src/utils/test/binary_reader_test.cpp	45
src/utils/test/clear.sh	1
src/utils/test/command_manager_test.cpp	42
src/utils/test/configuration.cpp	230
src/utils/test/endian_test.cpp	49
src/utils/test/env.cpp	15
src/utils/test/fail_point_test.cpp	111
src/utils/test/file_system_test.cpp	23
src/utils/test/file_utils.cpp	755
src/utils/test/flag_test.cpp	256
src/utils/test/fmt_logging_test.cpp	24
src/utils/test/hostname_test.cpp	80
src/utils/test/je_ctl_test.cpp	61
src/utils/test/join_point_test.cpp	49
src/utils/test/json_helper_test.cpp	400
src/utils/test/latency_tracer_test.cpp	113
src/utils/test/lock.std.cpp	31
src/utils/test/logger.cpp	92
src/utils/test/logging.cpp	47
src/utils/test/long_adder_test.cpp	202
src/utils/test/main.cpp	10
src/utils/test/memutil_test.cpp	13
src/utils/test/metrics_test.cpp	2405
src/utils/test/nth_element_bench/nth_element_bench.cpp	177
src/utils/test/nth_element_test.cpp	181
src/utils/test/nth_element_utils.h	125
src/utils/test/output_utils_test.cpp	162
src/utils/test/percentile_utils.h	52
src/utils/test/priority_queue.cpp	102
src/utils/test/rand_test.cpp	57
src/utils/test/run.sh	20
src/utils/test/sema.cpp	56
src/utils/test/smart_pointers_test.cpp	83
src/utils/test/string_conv_test.cpp	207
src/utils/test/string_view_test.cpp	356
src/utils/test/time_utils_test.cpp	63
src/utils/test/token_bucket_throttling_controller_test.cpp	131
src/utils/test/token_buckets_test.cpp	34
src/utils/test/utils.cpp	420
src/utils/test_macros.h	13
src/zookeeper/test/clear.sh	1
src/zookeeper/test/distributed_lock_zookeeper.cpp	177
src/zookeeper/test/main.cpp	47
src/zookeeper/test/run.sh	20