You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by gi...@apache.org on 2024/01/12 10:30:54 UTC
(incubator-pegasus) branch dependabot/maven/java-client/org.apache.thrift-libthrift-0.14.0 updated (5385a8e76 -> 0bda98e29)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/java-client/org.apache.thrift-libthrift-0.14.0
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
discard 5385a8e76 build(deps): bump libthrift from 0.11.0 to 0.14.0 in /java-client
add 874eb4502 refactor(CI): enable and parallelize function test (#1149)
add 854e79c20 feat(jemalloc): support to dump stats (#1133)
add ccde4bf5b chore(CI): Lint and build all projects regularlly (#1142)
add 5e12eb17c fix: fix bad links and bad image names (#1154)
add 67063247a feat: make java client interface closable (#1152)
add d9df46695 fix(workflow): drop --on_travis option for unit tests of jemalloc (#1161)
add eccab4991 fix(config): create stat table as required by cpp collector on bootstrap (#1155)
add bb04f78b0 build(images): parallelize images building for all binary third-parties and only build ubuntu1804 for test images (#1163)
add bddbb5eee build(images): download hadoop-2.8.4.tar.gz during third-parties image building for unit tests (#1167)
add b83e53b98 refacor(function_test): use test_util to reduce duplicate code (#1169)
add d18ad6705 refactor(test): remove useless upgrade_test (#1171)
add 760c049ec ci: download hadoop-2.8.4.tar.gz during release building for unit tests once third-parties have changed (#1168)
add 56339c00b chore(license): check and fix *.txt files license (#1172)
add a81a7c8b0 chore(license): add ignore file/path configs to .rat-excludes (#1175)
add b5410fcdf fix: fix workflow labeler not work (#1182)
add 2621dc17e docs: update nodejs-client/README.md (#1180)
add d5f0e5c3b build(images): download apache-zookeeper-3.7.0-bin.tar.gz during third-parties image building for unit tests (#1178)
add 48f7412f0 chore(CI): disable some flaky tests (#1187)
add d3e9cb817 refactor(rdsn): remove 'include' directory in rdsn (#1189)
add 359500ee5 ci: download apache-zookeeper-3.7.0-bin.tar.gz during release building for unit tests once third-parties have change (#1186)
add e4bca55d1 fix: fix wrong comments for down_cast (#1194)
add 0b17b67af refactor(metrics): drop template specialization for gauge (#1192)
add f9c85bf9e feat(new_metrics): use rwlock instead of mutex to protect read/write of metric an entity or registry for lots of queries over them in the future (#1196)
add e52e8794d refactor(rdsn): flatten source code directory by moving files from 'src/rdsn/src/*' to 'src/*' (#1190)
add fc4668859 refactor(log): adjust log level and macro names (#1200)
add 88fa55ce5 refactor(log): adjust log level and rename for d*_f macros (#1201)
add db1761ec6 refactor(log): adjust log level and rename for d*_replica/dup/rocksdb macros (#1202)
add c20a88d0e refactor(macro): use CHECK to replace dassert_f/dassert (#1205)
add 20b344cc6 fix: move zookeeper-bin under (#1210)
add cea109969 refactor(macro): use CHECK to replace dassert_f/dassert (part2) (#1211)
add 1dacb92ad refactor(macro): use CHECK_EQ to replace dassert_eq* (#1212)
add 68a1a01e0 refactor(macro): use CHECK_* to replace dassert_* (#1214)
add b6548e7b2 fix: fix rollback by mistake for mutation_log::reset_from (#1208)
add 20aa6e842 feat(new_metrics): take snapshot of each metric as json format (#1219)
add 0f4bd1501 refactor(macro): use CHECK_* to replace dassert_* (part 2) (#1217)
add c7638fc14 update commons-configuration2 version to 2.8.0 (#1222)
add e2a0088f8 refactor(macro): use CHECK_* to replace dassert_* (part 3) (#1226)
add ba723a991 feat: overload stream insertion operator(<<) to support formatting by {fmt} (#1225)
add 0ffc3c9dd refactor(macro): use DCHECK* to replace dbg_dassert and self defined ASSERT_* (#1228)
add afca62fc1 refactor(macro): use the more general CHECK_PREFIX* to replace dassert_replica (#1230)
add de1d02b5c feat: improve checking if C string is empty (#1229)
add 01ca71c3e feat(thirdparty): use official rocksdb (#1048)
add e7c0589c4 refactor: use linux_fd_t instead of dsn_handle_t for file descriptor (#1238)
add 405ce5fef refactor: use command_deregister to auto deregister from command_manager (#1241)
add 162f39986 refactor: use state machine to improve split_args for strings (#1240)
add 14995745b refactor: remove api_common.h and dlib.h header files (#1235)
add e9537a64e fix: fix log header not corresponding to level (#1246)
add b26a1130c feat(new_metrics): support filters for selected metric fields in response (#1237)
add a24bb90e9 feat: support showing true expression in message for CHECK* macro (#1253)
add 478b07e09 refactor(log): adjust default log level from DEBUG to INFO (#1250)
add d54e05fb7 refactor: enable build warning on unused result (#1248)
add 9cb11f90b build(pom): use --release when building java client with java11+ (#1256)
add 2938389c3 build(pom): inherit apache pom (#1260)
add 1e9fe8e5f refactor: Remove assembly and output debug output to console when running UTs for java client (#1266)
add 607884b40 refactor: remove zkclient dependency (#1264)
add 6f90ccabe refactor: Use spotless plugin to format pom file (#1271)
add 5229a614c chore(action): support checking issue number prefixed with '#' in github actions for PRs (#1270)
add 25dd45a4e refactor: Remove usage of commons-configuration (#1273)
add 2e0574218 build: bump netty's version and shade it (#1274)
add 3f957893e build: use maven flatten plugin to generate resolved pom (#1277)
add 06a0ad9bb refactor(rpc_address): simple refactor on rpc_address (#1251)
add d4b2ce986 feat(config): Make the configs take effect for the FLAGS_* only used once (#1198)
add 450944dbe build: support publish artifacts to repository.a.o (#1278)
add 8205f245a feat(new_metrics): take snapshot of each entity as json format (#1258)
add caf5c1ebf fix: fix some bad links of docs (#1282)
add 06b2033ea feat(new_metrics): traverse the whole registry to choose entities and metrics according to the filters (#1285)
add c1435758d refactor(idl): unify the *.thrift files used by cpp and go-client (#1284)
add 6804b3bbd refactor: let cmds deregister automatically (#1287)
add 1bb62a2d2 fix: fix judgment to disk for partition split (#1289)
add 2fe716b5e feat: add rename_app interface (#1272)
add 67b35b190 chore(ci): use ubuntu-20.04 and install thrift-0.13 specially (#1292)
add 2aaf021ff refactor(idl): unify the *.thrift files used by cpp and java-client (#1290)
add 608847829 fix: fix ubuntu-16.04 build (#1295)
add 17bd73310 feat(new_metrics): provide http service to process client query for metrics (#1298)
add 9a6702ae2 feat(server): disable UDP service by default (#1132)
add cb99a6b70 feat: expose parameter success_if_exist for interface create_app (#1148)
add 86f7e02ab feat: decide whether two C strings are equal and support CHECK_STREQ* and CHECK_STRNE* (#1300)
add ad0299570 feat(new_metrics): support frequently-used combinations of metric fields in the query string (#1302)
add 180277a28 refactor(log): use LOG_DEBUG_F instead of LOG_DEBUG (#1306)
add 966e9002a refactor(FLAG): remove the quotes of section field of FLAG (#1308)
add 948682211 refactor(log): use LOG_INFO_F instead of LOG_INFO (1/3) (#1307)
add 8d3b42c43 refactor(log): use LOG_INFO_F instead of LOG_INFO (2/3) (#1310)
add 9df5bdaab refactor(log): use LOG_INFO_F instead of LOG_INFO (3/3) (#1311)
add 0dcb32ffa refactor(log): use LOG_FATAL_F instead of LOG_FATAL (#1312)
add 5ed43a1f1 chore(CI): Add unit test workflow for python client (#1314)
add f781f6c08 refactor(log): use LOG_WARNING_F instead of LOG_WARNING (1/3) (#1315)
add 16d9e3253 refactor(log): use LOG_WARNING_F instead of LOG_WARNING (2/3) (#1316)
add b81cb43e6 refactor(log): use LOG_ERROR_F instead of LOG_ERROR (1/2) (#1318)
add 3a4e1cbac refactor(log): use LOG_WARNING_F instead of LOG_WARNING (3/3) (#1319)
add d17f1ff40 refactor(log): use LOG_ERROR_F instead of LOG_ERROR (2/2) (#1320)
add 831fb5c43 refactor(idl): unify the *.thrift files used by cpp and python-client (#1317)
add 79e58f2fe refactor(log): use LOG_* instead of LOG_*_F (#1322)
add d83ce3d12 refactor(conf): use DSN_DEFINE_int32 to load int32 type of configs (#1324)
add a0be562f9 chore(CI): Add unit test workflow for node.js client (#1332)
add 4f25086f0 refactor(idl): unify the *.thrift files used by cpp and nodejs-client (#1335)
add 390ccf8ff feat(utils): add an utility function to find string prefix by separator (#1338)
add 624cae5ac feat(new_metrics): retire stale metric entities that are not used by any other object (#1304)
add 447621904 fix: fix rocksdb build type (#1340)
add d6c15b835 refactor(conf): use DSN_DEFINE_int32 to load int32 type of configs (part 2) (#1346)
add c37bacd9f build: support Ubuntu 22.04 and clang 14 (#1350)
add 4c76112a5 refactor(conf): use DSN_DEFINE_uint32 to load uint32 type of configs (#1352)
add ec905d991 refactor(conf): use DSN_DEFINE_int64 to load int64 type of configs (#1357)
add 3598aa6cc refactor(conf): use DSN_DEFINE_uint64 to load uint64 type of configs (#1359)
add 51b57615c refactor(conf): use DSN_DEFINE_double to load double type of configs (#1362)
add 9b160a935 refactor(conf): use DSN_DEFINE_bool to load bool type of configs (#1363)
add cd01040d8 feat(security): Use Apache Ranger for access control(1/n) (#1360)
add 2c6911779 feat(security): Use Apache Ranger for access control(2/n) (#1375)
add 98e359888 refactor(conf): use DSN_DEFINE_string to load string type of configs (#1371)
add 0922a9ac8 chore(cmake): fix project load failure by CLion (#1376)
add 5088b2929 feat(test): add bench type multi set/get (#1373)
add f628e87a5 fix: fix centos image build (#1356)
add 6ee7a953f chore(CI): Use Ubuntu 22.04 as the default test platform (#1381)
add 37434d28d refactor: Move some functions from 'replica' to 'replica_stub' (#1384)
add 84ce5fb97 feat(Ranger): Compatible with the old ACL and the new ACL (#1379)
add ca6ee39de feat(Ranger): Support encode and decode Ranger policies (#1378)
add 7b40abcdd chore(script): support specifying config file while downgrading node by shell (#1369)
add c27590bf3 chore(script): support specifying config file while migrating node by shell (#1370)
add e55cd3681 refactor(IWYU): introduce IWYU and fix related issues (#1354)
add 1d2e0c6ff fix: resolve undeclared names that are reported while building alloc.h in debug mode (#1392)
add fd5a4350c chore(CI): include cmath to fix ambiguous std::abs on ubuntu1604 (#1395)
add fc50c1c1d fix: fix kerberos authentication based on keytab for java client (#1393)
add e4fee118c chore(build): make build dir standalone and speedup re-build (#1401)
add 034cb9d10 feat(Ranger): Pull policies from the Ranger Service and update using resources policies (#1388)
add ad80389cb chore(github): try to add some contributors into apache collaborators to allow them to use github actions (#1409)
add 169333005 check leader status (#1406)
add 576189319 batchGetByPartitions (#1411)
add 58bad7471 refactor: return Status::code instead of meanless integer (#1417)
add 254f6d4a7 chore(CI): fix regularly build failure (#1420)
add 039e2fd3f refactor: minor refactor on replica module (#1423)
add 87f169a80 feat(Ranger): Use Apache Ranger for meta access controller (#1402)
add f630ce148 feat: add new macro definitions (#1429)
add 0199edee8 fix: log error but not crash if found an imcomplete replica path (#1428)
add ababcc08a fix(java-client): Fix java spotbug (#1416)
add 9303c3aba fix: Fix the corruption RocksDB instance will be reused bug (#1422)
add fe0e0284d feat(FQDN): Implement of struct rpc_host_port (#1430)
add a2e87bcdc refactor: retry function test when run failed (#1179)
add cf997de7f fix(IWYU): fix include errors for rpc_host_port reported by IWYU (#1434)
add d16e65cd8 feat(Ranger): Use Apache Ranger for replica access controller (#1433)
add 1beb24a76 fix(ut): fix a flaky test integration_test.write_corrupt_db (#1442)
add 0dc3e4b31 doc(go-client): add deprecated marker to TableConnector.Close() (#1448)
add b4937faa6 fix(go-client): loopForRequest not return and retry forever (#1444)
add ce0af37c1 feat(Ranger): Use Apache Ranger for ACL when replica master-slave learn (#1445)
add b676991a6 refactor: remove useless function 'last_flushed_decree()' (#1456)
add 079de23e2 feat(util): add cancel() for class defer (#1458)
add 5ab400dea refactor(log): make macros LOG_AND_RETURN_NOT_* more general (#1457)
add 7a6c28e4a fix: fix a crash bug when open an incomplete created RocksDB instance (#1451)
add 64414e601 feat(Ranger): Use Apache Ranger for ACL when replica performs nfs copy (#1452)
add 12c8b56e2 fix: Fault-tolerant storage engine errors for read operations (#1447)
add b11b45d64 fix(ddl_client): sleep for a while before retry once meta server is busy (#1453)
add e655400af feat(FQDN): Implemention of struct host_port_group (#1436)
add d37fca91f fix(log): fix using of macro LOG_AND_RETURN_NOT_* print duplicate prefixes (#1465)
add 5d1ce0b42 fix: fix garble words of time filed in logs (#1468)
add ee03ffee8 feat(FQDN): Implemention of struct dns_resolver (#1464)
add 48fd4e87f feat(java-client): add listApps interface (#1471)
add 6b9fba392 refactor: minor refactor on class fs_manager (#1476)
add ccd01c593 refactor: remove some useless code (#1480)
add d5f225967 refactor: improve the single-responsibility of class fs_manager (#1477)
add 5404c4047 refactor: update replica's dir_node status (part1) (#1487)
add 86181aac9 chore(github): remove directories and tarballs after packing server and tools for github actions in case of running out of disk space (#1486)
add 766e64baa fix: fix start_onebox failed because of libjvm.so not found (#1494)
add 8706026ad chore(github): remove CMakeFiles during Tar files in case of running out of disk space (#1498)
add e4350d4c7 refactor: update replica's dir_node status (part2) (#1489)
add bbdb7041d feat(Ranger): remove ACL of RPC_CM_LIST_APPS from global resource (#1500)
add 99477dac0 refactor: remove counter_info and counter_info_ptr (#1509)
add 09c962d01 chore: update rocksdb install url on thirdparty (#1516)
add a0881816f chore(build): separate the build directory of IWYU version (#1519)
add 4dcbb1e28 feat: skip IO_ERROR dir_node when assign replicas (#1512)
add d216696e5 refactor: improve the single-responsibility of class fs_manager (2/n) (#1522)
add f3d13881a feat(Ranger): add a default database policy name for legacy table (#1507)
add 4ae39997b feat(FQDN): serialization format rpc_host_port (#1496)
add 6972752a5 fix: fix invaild build type (#1521)
add a509e8a92 fix(shell): fix the additional options not applied bug of command "./run.sh test" (#1526)
add 96116f6dd fix(github): throttle_test failed frequently due to insufficient disk space (#1530)
add 992cae4e4 feat(replica): close the replica and mark the dir_node as IO_ERROR when encounter read/write IO error (#1473)
add 78136dd0a feat(Ranger): refactor the logic when ranger performs ACL (#1518)
add df658a7a1 build: add a devcontainer.json (#1544)
add 93ccdc370 fix: fix build failure on older Ubuntu&GCC versions (#1555)
add 2c9dc39cd chore: remove the supporting of EOL OS ubuntu 16.04 (#1553)
add 5f83f7492 chore: remove the supporting of EOL OS CentOS 6 (#1557)
add 614623301 fix(docker): fix pegasus-build-env of ubuntu:18.04 Dockerfile (#1558)
add 99456f491 fix(rocksdb): turn off write_global_seqno by default (#1563)
add e3ffcbcaa chore(github): add some contributors into apache collaborators to allow them to use github actions (#1566)
add 117f604f3 fix(logs): fix logs in FATAL level not take effect (#1573)
add 4b0ea2650 fix(slog): add an option to exit the process when find slog error (#1574)
add 8cad63e1d chore(github): free disk space for github workflows (#1577)
add 10a54350d fix: support core dump for fatal logging in simple_logger::dsn_logv and call fatal logging exactly once for the assertion (#1580)
add fc616286b Feature:Online Query and Dynamic Modification of Table-level RocksDB Options (#1511)
add 7fe41d4bf chore(github): free disk space after packaging with jemalloc in github workflows (#1581)
add 72c8f2f75 feat(security): Support to use the principal of Unix account for authentication (#1569)
add c5a01c1f4 chore(github): free disk space for daily building on github (#1586)
add be9119e75 fix: fix errors in format string for logging and macro (#1588)
add 26b99e1e8 Revert "build(thirdparty): add thirdparty for centos6 build env (#1017)" (#1600)
add 5489b43a8 build(thirdparty): bump fmtlib to 10.1.1 (#1605)
add 7cb159994 feat(build): make C++17 as required (#1603)
add e978e4c78 feat(thirdparty): upgrade rocksdb to 8.5.3 (#1601)
add b15d57714 fix(docker): fix build failure of rocksdb when PORTABLE=0 (#1607)
add fef5b16c3 chore(CI): unify to use Ubuntu 22.04 for CI (#1609)
add 31ce32858 fix(ASAN): avoid reporting false 'odr-violation' issues (#1611)
add 9f3201755 build(thirdparty): use v8.5.3-pegasus-encrypt branch of pegasus-kv/rocksdb (#1610)
add edd1e17c8 feat(build): build RocksDB with encryption enabled (#1612)
add 22c91816c fix(rocksdb): update rocksdb to fix build failure on lower OpenSSL version (#1614)
add 7b2bd09b9 fix(build): fix a link error on macOS (#1615)
add 625cebcc9 feat(encryption): introduce PegasusEnv (#1606)
add 42136fa4b refactor(test): refactor bulk load function test (#1616)
add c8793d22d feat(slog): flush and remove all shared logs for garbage collection (#1594)
add f1fee10dd refactor(aio_test): refactor aio unit test (#1617)
add 73d53dbbb refactor(hdfs): use rocksdb API to read/write file (#1618)
add 64abf9055 refactor(local service): use rocksdb API to read/write file (#1619)
add a2f2ebd3d refactor(simple_meta_state): use rocksdb API to read/write file (#1620)
add c4470fa4b refactor(nfs_test): use rocksdb API to read/write file (#1621)
add 916c77414 refactor(simple_kv): use rocksdb API to read/write file (#1622)
add a1c463d48 refactor(replica): use rocksdb API to read/write file (#1623)
add c65c39af3 refactor(misc): use rocksdb API to read/write file (#1625)
add c2d9affe8 refactor(configuration): use rocksdb API to read/write file (#1626)
add 4a605825d fix(http_server): add deregister_http_call back (#1627)
add 58ac76575 refactor(file_system): use rocksdb API to read/write file (#1624)
add 0db1ff90d feat(http): implement http client based on libcurl (#1583)
add 70d246739 refactor(file_system): remove useless read/write_file() (#1628)
add b551e2627 refactor: some minor refactors without functional changes (#1629)
add 4cb68284c fix(ut): fix flaky unit test test_rename_path_while_writing (#1630)
add 0ccf1108f fix(jemalloc): enlarge the buffer size to dump jemalloc stats (#1636)
add 6064d7085 build(thirdparty): bump libcurl from 7.47.0 to 8.4.0 (#1633)
add ed3d31ef7 refactor(filesystem): refactor file_utils unit tests (#1634)
add 0f92716dd feat(aio): use rocksdb APIs to re-implement the aio module (#1637)
add 13a45ab73 feat(log): Redacted user key-values printed in logs (#1598)
add 8d7c91b04 feat(dup): parameterize the period seconds of duplication sync (#1639)
add 36d8be42a feat(encryption): support data encrypt at rest (#1599)
add cacd0a8d8 chore(CI): remove the "Check issue" from Standardization Lint (#1652)
add 21e25cad3 fix(CI): Fix the "Lint Dockerfile" action failure (#1656)
add 383ef0f1e fix: generate thrift sources for scala client (#1662)
add 1bdbfd3e5 fix(hotkey): never redact hot key for encryption (#1668)
add 565beab52 chore(version): update the version of pegasus server and client of each language to 2.5.0 (#1660)
add 724ec0bb2 chore: update NOTICE year to 2023 (#1671)
add ee369d380 fix: parse timestamp from the name of data dir for gc instead of the last update time (#1667)
add 85f3e74f2 chore(license): add license checker for copyright and fix license files (#1674)
add aa9d31a89 feat(thirdparty): Introduce abseil (#1675)
add 5e9a2a9dc feat(thirdparty): Use facebook/rocksdb and pegasus-kv/encfs as rocksdb thirdparty (#1678)
add dbd5f202e chore(thirdparty): find and use OpenSSL by CMake functions (#1679)
add 97bde421d refactor: use fmt:join to simplify code (#1680)
add 3238686bf chore(thirdparty): Bump gperftools to 2.13 (#1682)
add a276661bd feat(pprof): Supports both heap profiling and heap sampling (#1684)
add 64129e85c feat(thirdparty): compile curl with gssapi (#1683)
add b01a88417 refactor(build): Improve the project CMake (#1687)
add b580ccce2 fix: use libgcc instead of generic_fp as default stacktrace (#1690)
add 1409d090e refactor(thirdparty): Bump googletest to 1.14.0 (#1689)
add 75744cb7d refactor(thirdparty): Bump s2geometry to 0.10.0 (#1688)
add 79cd226d9 refactor(absl): Use the abseil in thirdparty instead of the internal copied one (#1694)
add da54c5881 chore: remove personal comments in file header (#1696)
add 6cb3f5e0a refactor(regex): use std::regex instead of boost::regex (#1697)
add 16caf01f5 fix(bulk_load): rocksDB parameter allow_ingest_behind was lost after replica migration (#1651)
add 432499f0b fix(admin-cli): fix the command reports incorrect ERR_INVALID_PARAMETERS error (#1699)
add 2ff8c027c feat(ddl_client): add failure logs when backup or restore command failed (#1701)
add 41ff58d83 refactor(FDS): Terminate the FDS supporting (#1695)
add 19876094e feat(HDFS): Add hdfs_service related configs in server.ini and run.sh (#1705)
add 50563ea33 chore: add change log for version 2.5 (#1700)
add 3ffe54275 refactor(backup&restore): add more logs when backup or restore failed (#1702)
add 05a90883c chore: switch to the standard Incubator DISCLAIMER instead of current work-in-progress version (#1707)
add 63583da3e feat: source config_hdfs.sh automatically before starting onebox (#1708)
add e15f9b275 feat(replica): add FileDataType as the parameter (#1703)
add 4b8b49a09 chore(CI): Use actions/labeler@v4 to keep compatiblity (#1711)
add 18e378dc8 refactor(function_test): make [backup_]restore_test derive from test_util (#1710)
add 50493b1fc chore(asf.yml): update collaborators (#1757)
add 4028c12f8 feat(new_metrics): add replica-level metric entity (#1345)
add 2d7cb40b8 feat(new_metrics): migrate replica-level metrics for write service (#1351)
add c3f524002 feat(new_metrics): migrate replica-level metrics for pegasus_server_impl (part 1) (#1374)
add e6ce28b87 feat(new_metrics): migrate replica-level metrics for pegasus_server_impl (part 2) (#1386)
add f5eafcbf3 feat(new_metrics): migrate replica-level metrics for capacity_unit_calculator (#1387)
add 522626048 feat(new_metrics): migrate replica-level metrics for replica class (#1397)
add c263b8b51 feat(new_metrics): migrate replica-level metrics for pegasus_event_listener (#1407)
add 688b43630 feat(new_metrics): migrate replica-level metrics for pegasus_mutation_duplicator (#1413)
add b1730fba5 feat(new_metrics): add server-level metric entity (#1415)
add 2d362f1e1 feat(new_metrics): migrate built-in server-level metrics (#1418)
add 14c8a102d feat(new_metrics): migrate server-level metrics for nfs (#1421)
add 659743d6d feat(new_metrics): add disk-level metric entity and migrate disk-level metrics for fs_manager (#1427)
add dbaa01abd feat(new_metrics): add table-level metric entity and migrate table-level metrics for server_state of meta (#1431)
add e2243751a feat(new_metrics): add partition-level metric entity and migrate partition-level metrics for greedy_load_balancer of meta (#1435)
add fb5b5b017 feat(new_metrics): migrate server-level metrics for meta_service (#1437)
add 3e88153a1 feat(new_metrics): add backup-policy-level metric entity and migrate backup-policy-level metrics for meta_backup_service (#1438)
add 6bd8b9568 feat(new_metrics): migrate partition-level metrics for partition_guardian (#1440)
add 23debd2d2 feat(new_metrics): migrate replica-level metrics for pegasus_manual_compact_service (#1443)
add a5c841e2b feat(new_metrics): migrate metrics for replica_stub (part 1) (#1455)
add 30221094d feat(new_metrics): migrate metrics for replica_stub (part 2) (#1459)
add 15ab7a1d0 feat(collector): migrate the collector from pegasus-kv/collector (#1461)
add f959ba4b4 feat(new_metrics): migrate metrics for replica_stub (part 3) (#1462)
add 43a0b0e8a feat(new_metrics): migrate metrics for replica_stub (part 4) (#1463)
add a5ae84682 feat(new_metrics): migrate metrics for replica_stub (part 5) (#1469)
add ec9a1ae62 feat(new_metrics): migrate metrics for replica_stub (part 6) (#1474)
add 5249fdc9e feat(new_metrics): migrate metrics for replica_stub (part 7) (#1475)
add c4c835149 feat(new_metrics): migrate metrics for some duplication class (#1482)
add cbfc0e842 feat(new_metrics): migrate metrics for task queue (#1484)
add ade5adfde refactor(new_metrics): refactor enum definition for metric types and units (#1491)
add 8abadfc4d feat(new_metrics): migrate metrics for failure detector (#1502)
add 556c6ac62 feat(new_metrics): migrate metrics for network (#1504)
add 79b4e6aa3 feat(new_metrics): migrate server-level metrics of rocksdb (#1506)
add 93391cb2f feat: Aggregate table/server level metrics (#1517)
add 568227956 feat(new_metrics): migrate metrics for profiler (#1524)
add 71e516251 fix(new_metrics): profiled tasks are measured by the wrong metrics (#1528)
add 8e3b1f036 feat(new_metrics): remove all table-level perf-counters for each replica (#1531)
add 2169d9c43 refactor(new_metrics): remove perf-counters that are still used in shared log (#1533)
add 50cf91606 feat(new_metrics): migrate metrics for latency tracer (#1537)
add 641e97bfa fix(new_metrics): total_capacity_mb/total_available_mb are not atomic (#1542)
add e724b62c6 feat(new_metrics): remove http service for perf counters (#1540)
add dfb50dcc0 feat(new_metrics): remove pegasus_counter_reporter (#1548)
add 83eeb8c4a feat(new_metrics): remove perf counter since shared log has been deprecated
add 6be5e286f feat(new_metrics): remove deleted header files introduced in source files for new metrics
add db8e780bc fix(new_metrics): fix unit tests in verifying values of backup_requests and write_size_exceed_threshold_requests
add fa82854a3 fix(IWYU): fix the suggestions reported by IWYU while rebase merging branch migrate-metrics-dev into master such as including absl/strings/string_view.h
add 4dd2b7ab8 refactor(function_test): abstract some functions to reduce duplicate code (#1756)
add d85837c2e fix(collector): fix lint and build errors for go collector (#1762)
add 5ea2a8d4d feat(snappy/lz4/zstd): Build snappy/lz4/zstd as a thirdparty libraries (#1709)
add 224cb818e feat(cpp-shell): make mlog_dump dump plog (#1760)
add 867174591 build(images): append branch name to the tag of each build-env-* image to support building image for each branch (#1763)
add 5eb33cc75 refactor(local_service): minor refactor on file_metadata (#1769)
add 2b7d6582f feat(slog): Remove slog related code (#1759)
add df61744fb refactor(function_test): generate bulk load files internally (#1770)
add 89ee42cfe fix: use boost::filesystem::path instead of std::filesystem::path to be compatible with lower gcc/clang versions (#1771)
add e5770a89a build(images): remove ci-env docker image (#1773)
add edb2ec422 fix(java-client): use junit5 as the only testing framework (#1755)
add 223b5c708 chore(java-client-ci): build the server instead of downloading it from external site (#1778)
add aacfd56f9 build(deps): bump github.com/valyala/fasthttp in /collector (#1787)
add 025687262 build(deps): bump github.com/kataras/iris/v12 from 12.1.8 to 12.2.0 in /collector (#1786)
add b174ede24 build(deps): bump github.com/prometheus/client_golang in /collector (#1785)
add 78256d0f0 build(deps): bump golang.org/x/net from 0.0.0-20210415231046-e915ea6b2b7d to 0.17.0 in /pegic (#1783)
add e1fce3488 fix(rocksdb): specify the HINTS for zstd/lz4/snappy in third-party CMakeLists allowing rocksdb to find them (#1777)
add f6a7e3553 build(deps): bump gopkg.in/yaml.v3 in /admin-cli (#1592)
add b5d520431 build(deps): bump gopkg.in/yaml.v3 in /pegic (#1591)
add 2a6cc71ee build(deps): bump golang.org/x/text from 0.3.5 to 0.3.8 in /admin-cli (#1361)
add 211bbf313 chore(admin-cli&pegic): add go fmt in Makefile and fotmat files (#1793)
add 63c3e67f0 fix(scripts): drop unnecessary dependencies for pack_server.sh (#1794)
add 96cd89d31 fix(scripts): fix that librocksdb.so.8 was not found for the executable binary generated by pack_server.sh (#1796)
add b48a6c8e3 feat(go): Unify and bump go version to 1.18 (#1797)
add 0b96bd769 build(deps): bump golang.org/x/net from 0.8.0 to 0.17.0 in /collector (#1802)
add 1473a95de build(deps): bump golang.org/x/net in /admin-cli (#1801)
add a6edc7acc build(deps): bump google.golang.org/protobuf in /collector (#1800)
add cde63a2c2 build(deps): bump golang.org/x/crypto from 0.7.0 to 0.17.0 in /collector (#1799)
add 8f3881257 build(deps): bump golang.org/x/net from 0.0.0-20191105084925-a882066a44e0 to 0.17.0 in /go-client (#1782)
add dec19d4b8 fix(rocksdb): force librocksdb.so* to be output into the directory `lib` (#1804)
add 0504f777a fix(logger): logs fail to be printed to stdout and the process is not terminated for fatal errors before logging is initialized (#1803)
add 908313d8e feat(run.sh): make it possible to build partial objects (#1798)
add 05466d3e2 chore(CI): Improve github actions (#1791)
add 2f551c7ed refactor(logging): drop the unnecessary interface, use `log` instead of `dsn_log` and improve the tests (#1809)
add a397c07ed fix: standby meta server exits abnormally with core dump after receiving the http request `/meta/cluster` (#1816)
add 28df30ed0 chore(go-client-ci): build the server instead of downloading it from external site (#1790)
add 6298bdec6 chore(nodejs-client-ci): build the server instead of downloading it from external site (#1814)
add cbc160463 chore(scala-client-ci): build the server instead of downloading it from external site (#1813)
add 1b44329a9 chore(python-client-ci): build the server instead of downloading it from external site (#1815)
add 4e66ebe3f feat(fqdn): json decode & encode for rpc_host_port (#1811)
add 43aa01646 refactor(ranger): move ranger out of runtime (#1808)
add 394617b77 chore(CI): Improve github actions (2nd) (#1812)
add a2ccb9c7b feat(http): use scoped enum http_status_code instead of magic numbers (#1776)
add e7a1d0b2b chore(github): add contributor limowang into apache collaborators to use github actions (#1828)
add 746318392 chore: Update .gitignore (#1823)
add 82d981f51 fix(logging): remove too verbose log when key not found (#1829)
add 9300a2926 fix(build): Fix Cpp build errors in recent github actions (#1834)
add 14ca78e7e refactor(json_file): Refactor the load and dump functions of JSON objects (#1818)
add 4093b4f27 chore(collector): add fmt job for collector CI (#1833)
add 43f2e3ba7 chore(version): update the version of pegasus server and client of each language to 2.6.0-SNAPSHOT (#1831)
add 363d78988 feat(new_metrics): add some basic fields to the response to metrics query (#1827)
add 71711592b refactor(security): Move security out of runtime (#1821)
add b75bd0388 feat(json_file): load and dump functions of JSON objects support encryption (#1842)
add 655fc0913 fix(java-client): fix the failed java-client test (#1836)
add 4a98e96f1 fix: specify the 'single_master_cluster' cluster for recovery_test (#1839)
add a461fa511 feat(fqdn): add operator< and use shared_ptr for group_host_port() instead of raw pointer for host_port (#1825)
add 026c49e76 chore(.gitignore): update .gitignore for go-client (#1837)
add c097a154f fix(build): fix undefined reference to thrift-generated objects while linking libdsn_client.a (#1847)
add 49a742b5e feat(marco): Add RETURN_ERRS_NOT_TRUE marco to simplify code (#1849)
add 0bda98e29 build(deps): bump libthrift from 0.11.0 to 0.14.0 in /java-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 (5385a8e76)
\
N -- N -- N refs/heads/dependabot/maven/java-client/org.apache.thrift-libthrift-0.14.0 (0bda98e29)
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:
.asf.yaml | 7 +
.devcontainer/devcontainer.json | 11 +
.github/actions/build_pegasus/action.yaml | 52 +
.github/actions/download_artifact/action.yaml | 33 +
.../rebuild_thirdparty_if_needed/action.yaml | 49 +
.github/actions/run_server_tests/action.yaml | 27 +
.../unpack_prebuilt_thirdparties/action.yaml | 30 +
.github/actions/upload_artifact/action.yaml | 38 +
.github/workflows/build-push-env-docker.yml | 8 +-
.github/workflows/free_disk_space.sh | 70 +
.github/workflows/labeler.yml | 2 +-
.github/workflows/lint_and_test_admin-cli.yml | 15 +-
.../lint_and_test_admin-cli_always_pass.yml | 1 +
.github/workflows/lint_and_test_collector.yml | 92 +
.github/workflows/lint_and_test_cpp.yaml | 479 +-
.github/workflows/lint_and_test_go-client.yml | 108 +-
.github/workflows/lint_and_test_java-client.yml | 106 +
.github/workflows/lint_and_test_pegic.yml | 13 +-
.../workflows/lint_and_test_pegic_always_pass.yml | 1 +
.github/workflows/lint_and_test_scala-client.yml | 111 +
.github/workflows/module_labeler_conf.yml | 2 +
.github/workflows/pegasus-regular-build.yml | 75 -
.github/workflows/regular-build.yml | 142 +
.github/workflows/standardization_lint.yaml | 21 +-
.github/workflows/test_java-client.yml | 57 -
.github/workflows/test_nodejs-client.yml | 78 +
.github/workflows/test_python-client.yml | 95 +
.github/workflows/test_scala-client.yml | 55 -
.github/workflows/thirdparty-regular-push.yml | 86 +-
.gitignore | 232 +-
.licenserc.yaml | 1200 +-
.rat-excludes | 37 +-
CMakeLists.txt | 13 +-
DISCLAIMER | 10 +
DISCLAIMER-WIP | 19 -
HISTORY.md | 40 +
LICENSE | 90 +-
NOTICE | 2 +-
README.md | 8 +-
admin-cli/Makefile | 3 +
admin-cli/README.md | 2 -
admin-cli/client/meta.go | 4 +-
admin-cli/cmd/remote_command.go | 2 +-
admin-cli/executor/partition_split.go | 2 +-
admin-cli/executor/server_config.go | 2 +-
admin-cli/go.mod | 48 +-
admin-cli/go.sum | 16 +-
admin-cli/tabular/printer.go | 17 +-
admin-cli/util/pegasus_node.go | 4 +-
cmake_modules/BaseFunctions.cmake | 53 +-
cmake_modules/CompilerInfo.cmake | 2 +-
collector/Makefile | 24 +
collector/README.md | 44 +
collector/aggregate/aggregatable.go | 92 +
collector/aggregate/aggregator.go | 173 +
collector/aggregate/aggregator_test.go | 97 +
collector/aggregate/history.go | 111 +
collector/aggregate/history_test.go | 40 +
collector/aggregate/hook.go | 69 +
collector/aggregate/hook_test.go | 51 +
collector/aggregate/perf_client.go | 237 +
collector/aggregate/perf_client_test.go | 49 +
collector/aggregate/perf_counter_decoder.go | 62 +
collector/aggregate/perf_counter_decoder_test.go | 61 +
collector/aggregate/perf_session.go | 91 +
collector/aggregate/table_stats.go | 134 +
collector/avail/detector.go | 152 +
collector/config.yml | 46 +
collector/go.mod | 101 +
collector/go.sum | 590 +
collector/hotspot/algo.go | 18 +
collector/main.go | 101 +
collector/metrics/meta_server_metrics.go | 23 +
collector/metrics/metric_collector.go | 514 +
collector/metrics/replica_server_metrics.go | 23 +
collector/sink/falcon_sink.go | 144 +
collector/sink/prometheus_sink.go | 110 +
collector/sink/sink.go | 53 +
collector/templates/index.html | 80 +
collector/usage/usage_recorder.go | 115 +
collector/webui/index.go | 84 +
collector/webui/tables.go | 47 +
collector/webui/webserver.go | 61 +
docker/README.md | 18 +-
docker/ci-env/Dockerfile | 33 -
docker/pegasus-build-env/centos6/Dockerfile | 87 -
docker/pegasus-build-env/centos7/Dockerfile | 11 +-
docker/pegasus-build-env/ubuntu1604/Dockerfile | 69 -
docker/pegasus-build-env/ubuntu1804/Dockerfile | 11 +-
docker/pegasus-build-env/ubuntu2004/Dockerfile | 6 +-
docker/pegasus-build-env/ubuntu2204/Dockerfile | 70 +
docker/pegasus-docker-compose/README.md | 2 +-
docker/pegasus-docker-compose/build_docker.sh | 26 +-
docker/pegasus-docker-compose/config.min.ini | 6 +-
.../image_for_prebuilt_bin/Dockerfile | 3 +-
docker/thirdparties-bin/Dockerfile | 12 +-
docker/thirdparties-src/Dockerfile | 8 +-
go-client/Makefile | 15 +-
go-client/README.md | 24 +-
go-client/admin/client.go | 18 +-
go-client/admin/client_test.go | 6 +-
go-client/docs/how_to_add_new_interface.md | 11 +-
go-client/example/main.go | 2 +-
go-client/generator/admin.csv | 22 +-
go-client/generator/main.go | 70 +-
go-client/go.mod | 15 +-
go-client/go.sum | 12 +-
go-client/idl/admin.thrift | 767 -
go-client/idl/admin/GoUnusedProtection__.go | 6 -
go-client/idl/admin/admin-consts.go | 25 -
go-client/idl/admin/admin.go | 20627 -------------------
go-client/idl/base.thrift | 33 -
go-client/idl/base/dsn_err_string.go | 1 -
go-client/idl/base/error_code.go | 2 +-
go-client/idl/base/gpid_test.go | 19 +
go-client/idl/cmd.thrift | 30 -
go-client/idl/cmd/GoUnusedProtection__.go | 6 -
go-client/idl/cmd/cmd-consts.go | 23 -
go-client/idl/cmd/cmd.go | 536 -
go-client/idl/radmin.thrift | 99 -
go-client/idl/radmin/GoUnusedProtection__.go | 6 -
go-client/idl/radmin/radmin-consts.go | 25 -
go-client/idl/radmin/radmin.go | 2353 ---
go-client/idl/replication.thrift | 58 -
go-client/idl/replication/GoUnusedProtection__.go | 6 -
go-client/idl/replication/replication-consts.go | 25 -
go-client/idl/replication/replication.go | 1135 -
go-client/idl/rrdb.thrift | 293 -
go-client/idl/rrdb/GoUnusedProtection__.go | 6 -
go-client/idl/rrdb/rrdb-consts.go | 27 -
go-client/idl/rrdb/rrdb.go | 10824 ----------
go-client/pegalog/logger.go | 3 +-
go-client/pegasus/op/multidel.go | 4 +-
go-client/pegasus/op/multiget.go | 4 +-
go-client/pegasus/scanner.go | 2 +-
go-client/pegasus/table_connector.go | 3 +
go-client/pegasus/table_connector_test.go | 2 +-
go-client/session/admin_rpc_types.go | 123 +-
go-client/session/codec.go | 32 +-
go-client/session/meta_session.go | 1 -
go-client/session/radmin_rpc_types.go | 35 +-
go-client/session/session.go | 12 +-
go-client/test.sh | 46 -
idl/backup.thrift | 208 +
idl/bulk_load.thrift | 236 +
idl/command.thrift | 39 +
idl/dsn.layer2.thrift | 17 +-
idl/dsn.thrift | 8 +
idl/duplication.thrift | 164 +
idl/meta_admin.thrift | 479 +
idl/metadata.thrift | 114 +
idl/partition_split.thrift | 182 +
idl/replica_admin.thrift | 170 +
idl/rrdb.thrift | 60 +-
idl/security.thrift | 76 +
java-client/README.md | 51 +-
java-client/configuration/log4j.properties | 42 -
java-client/dev-support/findbugs-exclude.xml | 2 +
java-client/idl/apache-licence-template | 18 -
java-client/idl/base.thrift | 42 -
java-client/idl/meta_admin.thrift | 63 -
java-client/idl/recompile_thrift.sh | 68 -
java-client/idl/replication.thrift | 59 -
java-client/idl/rrdb.thrift | 322 -
java-client/idl/security.thrift | 79 -
java-client/pom.xml | 330 +-
java-client/scripts/ci-test.sh | 72 -
java-client/scripts/recompile_thrift.sh | 68 +
java-client/src/assembly/dep.xml | 57 -
.../org/apache/pegasus/client/ClientOptions.java | 79 +-
.../org/apache/pegasus/client/ListAppInfoType.java | 34 +
.../org/apache/pegasus/client/PConfigUtil.java | 23 +-
.../apache/pegasus/client/PegasusAdminClient.java | 47 +-
.../client/PegasusAdminClientInterface.java | 26 +-
.../pegasus/client/PegasusClientInterface.java | 4 +-
.../org/apache/pegasus/client/PegasusScanner.java | 2 +-
.../pegasus/client/PegasusScannerInterface.java | 4 +-
.../org/apache/pegasus/client/PegasusTable.java | 2 +
.../pegasus/operator/create_app_operator.java | 7 +-
.../apache/pegasus/operator/drop_app_operator.java | 7 +-
.../pegasus/operator/list_apps_operator.java | 68 +
.../org/apache/pegasus/rpc/async/MetaSession.java | 3 +
.../org/apache/pegasus/security/Credential.java | 5 +-
.../pegasus/security/KerberosCredential.java | 12 +-
.../apache/pegasus/security/KerberosProtocol.java | 40 +-
.../org/apache/pegasus/util/PropertyUtils.java | 51 +
.../org/apache/pegasus/base/TestRpcAddress.java | 30 +-
.../apache/pegasus/client/PegasusScannerTest.java | 156 +-
.../org/apache/pegasus/client/TestAdminClient.java | 58 +-
.../java/org/apache/pegasus/client/TestBasic.java | 1730 +-
.../java/org/apache/pegasus/client/TestBatch.java | 41 +-
.../pegasus/client/TestBatchGetByPartitions.java | 21 +-
.../java/org/apache/pegasus/client/TestBench.java | 30 +-
.../apache/pegasus/client/TestCheckAndMutate.java | 787 +-
.../org/apache/pegasus/client/TestCheckAndSet.java | 761 +-
.../org/apache/pegasus/client/TestFutureGroup.java | 23 +-
.../java/org/apache/pegasus/client/TestIncr.java | 46 +-
.../org/apache/pegasus/client/TestMultiThread.java | 12 +-
.../org/apache/pegasus/client/TestNoOperate.java | 2 +-
.../org/apache/pegasus/client/TestPException.java | 22 +-
.../java/org/apache/pegasus/client/TestPing.java | 58 +-
.../java/org/apache/pegasus/client/TestPingZK.java | 52 +-
.../org/apache/pegasus/client/TestTimeout.java | 2 +-
.../apache/pegasus/metrics/MetricsPoolTest.java | 73 +-
.../pegasus/operator/ClientOperatorTest.java | 16 +-
.../pegasus/rpc/async/ClusterManagerTest.java | 32 +-
.../apache/pegasus/rpc/async/InterceptorTest.java | 19 +-
.../apache/pegasus/rpc/async/MetaSessionTest.java | 51 +-
.../pegasus/rpc/async/ReplicaSessionTest.java | 110 +-
.../apache/pegasus/rpc/async/TableHandlerTest.java | 59 +-
.../apache/pegasus/rpc/async/TimeoutBenchmark.java | 12 +-
.../apache/pegasus/security/NegotiationTest.java | 47 +-
.../org/apache/pegasus/tools/TestZstdWrapper.java | 21 +-
.../java/org/apache/pegasus/tools/Toollet.java | 2 +-
java-client/src/test/resource/pegasus.properties | 25 -
.../test/resources}/pegasus.properties | 0
.../src/test/resources/simplelogger.properties | 22 +
nodejs-client/README.md | 22 +-
nodejs-client/idl/base.thrift | 42 -
nodejs-client/idl/recompile_thrift.sh | 40 -
nodejs-client/idl/replication.thrift | 226 -
nodejs-client/idl/rrdb.thrift | 170 -
nodejs-client/package.json | 2 +-
nodejs-client/recompile_thrift.sh | 61 +
nodejs-client/src/connection.js | 4 +-
nodejs-client/src/dsn/base_types.js | 291 -
nodejs-client/src/dsn/dsn_types.js | 303 +
nodejs-client/src/dsn/meta.js | 1956 --
nodejs-client/src/dsn/replication_types.js | 2767 ---
nodejs-client/src/dsn/rrdb.js | 2072 --
nodejs-client/src/dsn/rrdb_types.js | 1564 --
nodejs-client/src/errors.js | 2 +-
nodejs-client/src/operator.js | 2 +-
nodejs-client/src/session.js | 4 +-
nodejs-client/src/table_handler.js | 8 +-
nodejs-client/test/client.test.js | 2 +-
pegic/Makefile | 3 +
pegic/go.mod | 29 +-
pegic/go.sum | 21 +-
python-client/README.md | 80 +-
python-client/idl/base.thrift | 43 -
python-client/idl/replication.thrift | 60 -
python-client/idl/rrdb.thrift | 294 -
python-client/pypegasus/__init__.py | 2 +-
python-client/pypegasus/base/constants.py | 15 +-
python-client/pypegasus/base/ttypes.py | 10 +-
python-client/pypegasus/replication/__init__.py | 18 -
python-client/pypegasus/replication/constants.py | 28 -
python-client/pypegasus/replication/replication.py | 23 -
python-client/pypegasus/replication/ttypes.py | 533 -
python-client/pypegasus/rrdb/__init__.py | 18 -
python-client/pypegasus/rrdb/constants.py | 28 -
python-client/pypegasus/rrdb/meta.py | 258 -
python-client/pypegasus/rrdb/rrdb.py | 2625 ---
python-client/pypegasus/rrdb/ttypes.py | 2824 ---
python-client/requirement.txt | 5 +
python-client/sample.py | 2 +-
python-client/setup.py | 4 +-
python-client/tests/test_basics.py | 11 +-
run.sh | 648 +-
scala-client/README.md | 27 +-
scala-client/build.sbt | 4 +-
scala-client/scripts/ci-test.sh | 69 -
scala-client/scripts/format-all.sh | 23 -
.../apache/pegasus/scalaclient/PegasusUtil.scala | 2 +-
.../scalaclient/ScalaPegasusAsyncTable.scala | 5 +-
scripts/check_license.py | 213 +
scripts/clear_zk.sh | 17 +-
scripts/compile_thrift.py | 12 +-
scripts/config_hdfs.sh | 36 +-
scripts/downgrade_node.sh | 50 +-
scripts/download_hadoop.sh | 31 +
scripts/download_package.sh | 79 +
scripts/download_zk.sh | 31 +
scripts/migrate_node.sh | 49 +-
scripts/pack_client.sh | 20 +-
scripts/pack_common.sh | 10 +-
scripts/pack_server.sh | 27 +-
scripts/pack_tools.sh | 45 +-
scripts/recompile_thrift.sh | 2 +-
scripts/start_zk.sh | 30 +-
scripts/stop_zk.sh | 11 +-
src/CMakeLists.txt | 47 +-
src/aio/CMakeLists.txt | 48 +
src/aio/aio_provider.cpp | 51 +
src/aio/aio_provider.h | 99 +
src/aio/aio_task.cpp | 90 +
src/aio/aio_task.h | 132 +
src/aio/disk_engine.cpp | 287 +
src/aio/disk_engine.h | 100 +
src/aio/file_io.cpp | 171 +
src/aio/file_io.h | 113 +
src/aio/native_linux_aio_provider.cpp | 181 +
src/aio/native_linux_aio_provider.h | 66 +
src/aio/test/CMakeLists.txt | 46 +
src/aio/test/aio.cpp | 461 +
src/{rdsn/src => }/aio/test/clear.sh | 0
src/aio/test/config.ini | 50 +
src/{rdsn/src => }/aio/test/copy_source.txt | 0
src/aio/test/main.cpp | 31 +
src/{rdsn/src => }/aio/test/run.sh | 0
src/base/CMakeLists.txt | 2 +-
src/base/idl_utils.h | 18 +-
src/base/pegasus_const.cpp | 49 +
src/base/pegasus_const.h | 22 +
src/base/pegasus_key_schema.h | 33 +-
src/base/pegasus_rpc_types.h | 10 +-
src/base/pegasus_utils.cpp | 15 +-
src/base/pegasus_utils.h | 45 +-
src/base/pegasus_value_schema.h | 52 +-
src/base/test/CMakeLists.txt | 10 +-
src/base/test/main.cpp | 3 +-
src/base/test/redact_sensitive_string_test.cpp | 67 +
src/base/test/utils_test.cpp | 5 +-
src/base/test/value_manager_test.cpp | 12 +-
src/base/test/value_schema_test.cpp | 25 +-
src/base/value_field.h | 7 +-
src/base/value_schema_manager.cpp | 19 +-
src/base/value_schema_manager.h | 9 +-
src/base/value_schema_v0.cpp | 29 +-
src/base/value_schema_v0.h | 11 +-
src/base/value_schema_v1.cpp | 35 +-
src/base/value_schema_v1.h | 13 +-
src/base/value_schema_v2.cpp | 38 +-
src/base/value_schema_v2.h | 13 +-
src/block_service/CMakeLists.txt | 42 +
src/block_service/block_service.h | 427 +
src/block_service/block_service_manager.cpp | 193 +
src/block_service/block_service_manager.h | 89 +
src/block_service/hdfs/CMakeLists.txt | 41 +
src/block_service/hdfs/hdfs_service.cpp | 595 +
src/block_service/hdfs/hdfs_service.h | 125 +
src/block_service/local/CMakeLists.txt | 38 +
src/block_service/local/local_service.cpp | 559 +
src/block_service/local/local_service.h | 118 +
src/block_service/test/CMakeLists.txt | 48 +
.../test/block_service_manager_test.cpp | 123 +
src/block_service/test/block_service_mock.h | 216 +
src/{rdsn/src => }/block_service/test/clear.sh | 0
src/block_service/test/config-test.ini | 54 +
src/block_service/test/hdfs_service_test.cpp | 454 +
src/block_service/test/local_service_test.cpp | 104 +
src/block_service/test/main.cpp | 58 +
src/{rdsn/src => }/block_service/test/run.sh | 0
src/client/CMakeLists.txt | 45 +
src/client/partition_resolver.cpp | 132 +
src/client/partition_resolver.h | 153 +
src/client/partition_resolver_manager.cpp | 81 +
src/client/partition_resolver_manager.h | 56 +
src/client/partition_resolver_simple.cpp | 456 +
src/client/partition_resolver_simple.h | 135 +
src/client/replication_ddl_client.cpp | 1770 ++
src/client/replication_ddl_client.h | 447 +
src/client/test/CMakeLists.txt | 42 +
src/client/test/config.ini | 83 +
src/client/test/ddl_client_test.cpp | 150 +
src/client/test/main.cpp | 27 +
src/client/test/run.sh | 24 +
src/client_lib/CMakeLists.txt | 51 +-
src/client_lib/mutation.cpp | 6 +
src/client_lib/pegasus_client_factory_impl.cpp | 19 +-
src/client_lib/pegasus_client_factory_impl.h | 12 +-
src/client_lib/pegasus_client_impl.cpp | 144 +-
src/client_lib/pegasus_client_impl.h | 24 +-
src/client_lib/pegasus_scanner_impl.cpp | 40 +-
src/common/CMakeLists.txt | 105 +
src/common/backup_common.cpp | 129 +
src/common/backup_common.h | 192 +
src/{rdsn/src => }/common/bulk_load_common.cpp | 0
src/common/bulk_load_common.h | 55 +
src/common/common.cpp | 32 +
src/{rdsn/include/dsn/dist => common}/common.h | 0
src/common/consensus.thrift | 199 +
src/common/duplication_common.cpp | 184 +
src/common/duplication_common.h | 94 +
src/common/duplication_internal.thrift | 52 +
src/common/fs_manager.cpp | 623 +
src/common/fs_manager.h | 195 +
src/common/gpid.h | 108 +
src/common/json_helper.h | 737 +
src/common/manual_compact.h | 30 +
src/common/partition_split_common.h | 32 +
src/common/replica_envs.h | 76 +
src/common/replication.codes.h | 218 +
src/common/replication_common.cpp | 411 +
src/common/replication_common.h | 87 +
src/common/replication_enums.h | 181 +
src/common/replication_other_types.h | 95 +
src/common/serialization_helper/dsn_types.h | 29 +
src/common/serialization_helper/thrift_helper.h | 764 +
src/common/storage_serverlet.h | 174 +
src/common/test/CMakeLists.txt | 46 +
src/common/test/common_test.cpp | 31 +
src/common/test/config-test.ini | 100 +
src/common/test/duplication_common_test.cpp | 52 +
src/common/test/fs_manager_test.cpp | 213 +
src/common/test/main.cpp | 67 +
src/common/test/replication_common_test.cpp | 126 +
src/common/test/run.sh | 55 +
src/failure_detector/CMakeLists.txt | 49 +
src/failure_detector/failure_detector.cpp | 599 +
src/failure_detector/failure_detector.h | 241 +
.../failure_detector_multimaster.cpp | 140 +
.../failure_detector_multimaster.h | 88 +
src/failure_detector/fd.client.h | 87 +
src/failure_detector/fd.code.definition.h | 60 +
src/failure_detector/fd.server.h | 59 +
src/failure_detector/fd.thrift | 52 +
src/failure_detector/test/CMakeLists.txt | 49 +
src/{rdsn/src => }/failure_detector/test/clear.sh | 0
src/failure_detector/test/config-test.ini | 126 +
.../test/config-whitelist-test-failed.ini | 127 +
.../test/config-whitelist-test.ini | 127 +
src/failure_detector/test/failure_detector.cpp | 759 +
.../src => }/failure_detector/test/gtest.filter | 0
src/failure_detector/test/main.cpp | 86 +
src/{rdsn/src => }/failure_detector/test/run.sh | 0
src/geo/bench/CMakeLists.txt | 12 +-
src/geo/bench/bench.cpp | 40 +-
src/geo/bench/config.ini | 2 +-
src/geo/lib/geo_client.cpp | 253 +-
src/geo/lib/geo_client.h | 30 +-
src/geo/lib/latlng_codec.cpp | 19 +-
src/geo/lib/latlng_codec.h | 5 +-
src/geo/test/CMakeLists.txt | 4 +-
src/geo/test/geo_test.cpp | 50 +-
src/geo/test/latlng_codec_test.cpp | 11 +-
src/geo/test/main.cpp | 3 +-
src/http/CMakeLists.txt | 28 +
src/http/builtin_http_calls.cpp | 106 +
src/http/builtin_http_calls.h | 42 +
src/http/config_http_service.cpp | 59 +
src/http/http_call_registry.h | 97 +
src/http/http_client.cpp | 348 +
src/http/http_client.h | 158 +
src/http/http_message_parser.cpp | 260 +
src/http/http_message_parser.h | 108 +
src/http/http_method.h | 44 +
src/http/http_server.cpp | 277 +
src/http/http_server.h | 151 +
src/http/http_server_impl.h | 38 +
src/http/http_status_code.cpp | 46 +
src/http/http_status_code.h | 52 +
src/http/pprof_http_service.cpp | 557 +
src/http/pprof_http_service.h | 85 +
src/{rdsn/src => }/http/service_version.cpp | 0
src/{rdsn/src => }/http/service_version.h | 0
src/http/test/CMakeLists.txt | 41 +
src/http/test/config-test.ini | 75 +
src/http/test/http_client_test.cpp | 223 +
src/http/test/http_server_test.cpp | 356 +
src/http/test/http_status_code_test.cpp | 68 +
src/http/test/main.cpp | 121 +
src/{rdsn/src => }/http/test/run.sh | 0
src/http/test/uri_decoder_test.cpp | 94 +
src/http/uri_decoder.cpp | 87 +
src/http/uri_decoder.h | 33 +
src/include/pegasus/client.h | 5 +
src/include/pegasus/version.h | 2 +-
src/include/rrdb/rrdb.client.h | 12 +-
src/include/rrdb/rrdb.code.definition.h | 3 +-
src/meta/CMakeLists.txt | 52 +
src/meta/app_balance_policy.cpp | 200 +
src/meta/app_balance_policy.h | 79 +
src/meta/app_env_validator.cpp | 277 +
src/meta/app_env_validator.h | 54 +
src/meta/backup_engine.cpp | 399 +
src/meta/backup_engine.h | 125 +
src/meta/cluster_balance_policy.cpp | 562 +
src/meta/cluster_balance_policy.h | 196 +
src/meta/distributed_lock_service_simple.cpp | 304 +
src/meta/distributed_lock_service_simple.h | 111 +
src/meta/dump_file.h | 163 +
src/meta/duplication/duplication_info.cpp | 248 +
src/meta/duplication/duplication_info.h | 258 +
src/meta/duplication/meta_duplication_service.cpp | 664 +
src/meta/duplication/meta_duplication_service.h | 154 +
src/meta/greedy_load_balancer.cpp | 245 +
src/meta/greedy_load_balancer.h | 97 +
src/meta/load_balance_policy.cpp | 784 +
src/meta/load_balance_policy.h | 309 +
src/meta/meta_backup_service.cpp | 1797 ++
src/meta/meta_backup_service.h | 449 +
src/meta/meta_bulk_load_ingestion_context.cpp | 204 +
src/meta/meta_bulk_load_ingestion_context.h | 100 +
src/meta/meta_bulk_load_service.cpp | 2114 ++
src/meta/meta_bulk_load_service.h | 535 +
src/meta/meta_data.cpp | 702 +
src/meta/meta_data.h | 593 +
src/meta/meta_http_service.cpp | 897 +
src/meta/meta_http_service.h | 163 +
src/meta/meta_options.cpp | 79 +
src/meta/meta_options.h | 59 +
src/meta/meta_rpc_types.h | 74 +
src/meta/meta_server_failure_detector.cpp | 327 +
src/meta/meta_server_failure_detector.h | 158 +
src/meta/meta_service.cpp | 1338 ++
src/meta/meta_service.h | 503 +
src/meta/meta_service_app.cpp | 110 +
src/meta/meta_service_app.h | 69 +
src/meta/meta_split_service.cpp | 611 +
src/meta/meta_split_service.h | 94 +
src/meta/meta_state_service.h | 181 +
src/meta/meta_state_service_simple.cpp | 544 +
src/meta/meta_state_service_simple.h | 286 +
src/meta/meta_state_service_utils.cpp | 114 +
src/meta/meta_state_service_utils.h | 88 +
src/meta/meta_state_service_utils_impl.h | 314 +
src/meta/meta_state_service_zookeeper.cpp | 433 +
src/meta/meta_state_service_zookeeper.h | 123 +
src/meta/partition_guardian.cpp | 789 +
src/meta/partition_guardian.h | 112 +
src/meta/server_load_balancer.cpp | 209 +
src/meta/server_load_balancer.h | 195 +
src/meta/server_state.cpp | 3968 ++++
src/meta/server_state.h | 437 +
src/meta/server_state_restore.cpp | 265 +
src/meta/table_metrics.cpp | 389 +
src/meta/table_metrics.h | 257 +
src/meta/test/CMakeLists.txt | 58 +
src/meta/test/backup_test.cpp | 881 +
src/meta/test/balancer_simulator/CMakeLists.txt | 36 +
.../test/balancer_simulator/balancer_simulator.cpp | 198 +
src/meta/test/balancer_validator.cpp | 250 +
src/{rdsn/src => }/meta/test/clear.sh | 0
src/meta/test/cluster_balance_policy_test.cpp | 556 +
src/meta/test/config-test.ini | 139 +
src/meta/test/copy_replica_operation_test.cpp | 287 +
src/{rdsn/src => }/meta/test/dummy_balancer.h | 0
src/meta/test/dump_file.cpp | 149 +
src/meta/test/duplication_info_test.cpp | 310 +
src/meta/test/ford_fulkerson_test.cpp | 292 +
src/meta/test/json_compacity.cpp | 172 +
src/meta/test/main.cpp | 123 +
src/meta/test/meta_app_envs_test.cpp | 220 +
src/meta/test/meta_app_operation_test.cpp | 976 +
src/meta/test/meta_backup_test.cpp | 372 +
src/meta/test/meta_bulk_load_ingestion_test.cpp | 396 +
src/meta/test/meta_bulk_load_service_test.cpp | 1672 ++
src/meta/test/meta_data.cpp | 464 +
src/meta/test/meta_duplication_service_test.cpp | 892 +
src/meta/test/meta_http_service_test.cpp | 422 +
src/meta/test/meta_mauanl_compaction_test.cpp | 209 +
src/meta/test/meta_partition_guardian_test.cpp | 945 +
src/meta/test/meta_service_test.cpp | 135 +
src/meta/test/meta_service_test_app.h | 212 +
src/meta/test/meta_split_service_test.cpp | 852 +
src/meta/test/meta_state/CMakeLists.txt | 42 +
src/{rdsn/src => }/meta/test/meta_state/clear.sh | 0
src/meta/test/meta_state/config-test.ini | 110 +
.../src => }/meta/test/meta_state/gtest.filter | 0
src/meta/test/meta_state/main.cpp | 91 +
src/meta/test/meta_state/meta_state_service.cpp | 326 +
src/{rdsn/src => }/meta/test/meta_state/run.sh | 0
src/meta/test/meta_state_service_utils_test.cpp | 190 +
src/meta/test/meta_test_base.cpp | 257 +
src/meta/test/meta_test_base.h | 91 +
src/meta/test/misc/misc.cpp | 436 +
src/meta/test/misc/misc.h | 135 +
src/meta/test/run.sh | 66 +
src/meta/test/server_state_restore_test.cpp | 179 +
src/meta/test/server_state_test.cpp | 222 +
src/meta/test/state_sync_test.cpp | 414 +
src/{rdsn/src => }/meta/test/suite1 | 0
src/{rdsn/src => }/meta/test/suite2 | 0
src/meta/test/update_configuration_test.cpp | 544 +
src/nfs/CMakeLists.txt | 47 +
src/nfs/nfs.thrift | 70 +
src/nfs/nfs_client_impl.cpp | 615 +
src/nfs/nfs_client_impl.h | 324 +
src/nfs/nfs_code_definition.h | 44 +
src/nfs/nfs_node.cpp | 112 +
src/nfs/nfs_node.h | 116 +
src/nfs/nfs_node_simple.cpp | 101 +
src/nfs/nfs_node_simple.h | 75 +
src/nfs/nfs_server_impl.cpp | 288 +
src/nfs/nfs_server_impl.h | 142 +
src/nfs/test/CMakeLists.txt | 59 +
src/{rdsn/src => }/nfs/test/clear.sh | 0
src/{rdsn/src => }/nfs/test/config.ini | 0
src/nfs/test/main.cpp | 258 +
src/{rdsn/src => }/nfs/test/nfs_test_file1 | 0
src/{rdsn/src => }/nfs/test/nfs_test_file2 | 0
src/{rdsn/src => }/nfs/test/run.sh | 0
src/perf_counter/CMakeLists.txt | 41 +
src/perf_counter/perf_counter.cpp | 64 +
src/perf_counter/perf_counter.h | 130 +
src/perf_counter/perf_counter_atomic.cpp | 84 +
src/perf_counter/perf_counter_atomic.h | 435 +
src/perf_counter/perf_counter_utils.h | 50 +
src/perf_counter/perf_counter_wrapper.h | 111 +
src/perf_counter/perf_counters.cpp | 430 +
src/perf_counter/perf_counters.h | 173 +
src/perf_counter/test/CMakeLists.txt | 42 +
src/{rdsn/src => }/perf_counter/test/clear.sh | 0
src/perf_counter/test/main.cpp | 24 +
src/perf_counter/test/perf_counter_test.cpp | 171 +
src/perf_counter/test/perf_counters_test.cpp | 319 +
src/{rdsn/src => }/perf_counter/test/run.sh | 0
src/ranger/CMakeLists.txt | 26 +
src/ranger/access_type.h | 70 +
src/ranger/ranger_resource_policy.cpp | 268 +
src/ranger/ranger_resource_policy.h | 277 +
src/ranger/ranger_resource_policy_manager.cpp | 658 +
src/ranger/ranger_resource_policy_manager.h | 153 +
src/ranger/test/CMakeLists.txt | 30 +
src/ranger/test/main.cpp | 28 +
.../test/ranger_resource_policy_manager_test.cpp | 523 +
src/ranger/test/ranger_resource_policy_test.cpp | 182 +
src/ranger/test/run.sh | 25 +
src/rdsn/include/dsn/c/api_common.h | 61 -
src/rdsn/include/dsn/c/api_layer1.h | 274 -
src/rdsn/include/dsn/c/api_task.h | 87 -
src/rdsn/include/dsn/c/api_utilities.h | 161 -
src/rdsn/include/dsn/c/app_model.h | 102 -
src/rdsn/include/dsn/cpp/json_helper.h | 659 -
src/rdsn/include/dsn/cpp/message_utils.h | 77 -
src/rdsn/include/dsn/cpp/pipeline.h | 302 -
src/rdsn/include/dsn/cpp/rpc_holder.h | 381 -
src/rdsn/include/dsn/cpp/rpc_stream.h | 131 -
src/rdsn/include/dsn/cpp/serialization.h | 104 -
.../dsn/cpp/serialization_helper/dsn_types.h | 29 -
.../dsn/cpp/serialization_helper/thrift_helper.h | 715 -
src/rdsn/include/dsn/cpp/serverlet.h | 249 -
src/rdsn/include/dsn/cpp/service_app.h | 105 -
src/rdsn/include/dsn/dist/block_service.h | 411 -
.../include/dsn/dist/distributed_lock_service.h | 179 -
src/rdsn/include/dsn/dist/failure_detector.h | 38 -
.../dsn/dist/failure_detector/failure_detector.h | 234 -
.../include/dsn/dist/failure_detector/fd.client.h | 96 -
.../dsn/dist/failure_detector/fd.code.definition.h | 57 -
.../include/dsn/dist/failure_detector/fd.server.h | 68 -
.../dsn/dist/failure_detector_multimaster.h | 88 -
src/rdsn/include/dsn/dist/fmt_logging.h | 84 -
src/rdsn/include/dsn/dist/meta_state_service.h | 188 -
src/rdsn/include/dsn/dist/nfs_node.h | 94 -
src/rdsn/include/dsn/dist/remote_command.h | 39 -
src/rdsn/include/dsn/dist/replication.h | 40 -
.../dsn/dist/replication/duplication_common.h | 86 -
.../dsn/dist/replication/meta_service_app.h | 64 -
.../dsn/dist/replication/mutation_duplicator.h | 87 -
.../dsn/dist/replication/mutation_log_tool.h | 56 -
.../dsn/dist/replication/partition_resolver.h | 139 -
.../include/dsn/dist/replication/replica_base.h | 61 -
.../include/dsn/dist/replication/replica_envs.h | 69 -
.../dsn/dist/replication/replica_test_utils.h | 52 -
.../dsn/dist/replication/replication.codes.h | 218 -
.../dsn/dist/replication/replication_app_base.h | 300 -
.../dsn/dist/replication/replication_ddl_client.h | 335 -
.../dsn/dist/replication/replication_enums.h | 160 -
.../dsn/dist/replication/replication_other_types.h | 97 -
.../dsn/dist/replication/replication_service_app.h | 75 -
.../dsn/dist/replication/replication_types.h | 28 -
.../dsn/dist/replication/storage_serverlet.h | 137 -
src/rdsn/include/dsn/http/http_server.h | 130 -
src/rdsn/include/dsn/perf_counter/perf_counter.h | 127 -
.../include/dsn/perf_counter/perf_counter_utils.h | 50 -
.../dsn/perf_counter/perf_counter_wrapper.h | 111 -
src/rdsn/include/dsn/perf_counter/perf_counters.h | 175 -
src/rdsn/include/dsn/service_api_c.h | 94 -
src/rdsn/include/dsn/service_api_cpp.h | 44 -
src/rdsn/include/dsn/tool-api/aio_task.h | 121 -
src/rdsn/include/dsn/tool-api/async_calls.h | 227 -
src/rdsn/include/dsn/tool-api/auto_codes.h | 41 -
src/rdsn/include/dsn/tool-api/command_manager.h | 102 -
src/rdsn/include/dsn/tool-api/env_provider.h | 62 -
src/rdsn/include/dsn/tool-api/file_io.h | 95 -
src/rdsn/include/dsn/tool-api/future_types.h | 36 -
src/rdsn/include/dsn/tool-api/global_config.h | 200 -
src/rdsn/include/dsn/tool-api/gpid.h | 102 -
src/rdsn/include/dsn/tool-api/group_address.h | 215 -
src/rdsn/include/dsn/tool-api/logging_provider.h | 103 -
src/rdsn/include/dsn/tool-api/message_parser.h | 136 -
src/rdsn/include/dsn/tool-api/network.h | 356 -
src/rdsn/include/dsn/tool-api/rpc_address.h | 228 -
src/rdsn/include/dsn/tool-api/rpc_message.h | 237 -
src/rdsn/include/dsn/tool-api/task.h | 603 -
src/rdsn/include/dsn/tool-api/task_code.h | 192 -
src/rdsn/include/dsn/tool-api/task_queue.h | 108 -
src/rdsn/include/dsn/tool-api/task_spec.h | 327 -
src/rdsn/include/dsn/tool-api/task_tracker.h | 237 -
src/rdsn/include/dsn/tool-api/task_worker.h | 115 -
.../include/dsn/tool-api/thread_access_checker.h | 47 -
src/rdsn/include/dsn/tool-api/threadpool_code.h | 61 -
src/rdsn/include/dsn/tool-api/threadpool_spec.h | 123 -
src/rdsn/include/dsn/tool-api/timer_service.h | 79 -
src/rdsn/include/dsn/tool-api/uniq_timestamp_us.h | 61 -
src/rdsn/include/dsn/tool-api/zlocks.h | 198 -
src/rdsn/include/dsn/tool/nativerun.h | 53 -
src/rdsn/include/dsn/tool/node_scoper.h | 60 -
src/rdsn/include/dsn/tool/providers.common.h | 44 -
src/rdsn/include/dsn/tool/simulator.h | 79 -
src/rdsn/include/dsn/tool_api.h | 218 -
src/rdsn/include/dsn/toollet/fault_injector.h | 103 -
src/rdsn/include/dsn/toollet/profiler.h | 66 -
src/rdsn/include/dsn/toollet/tracer.h | 113 -
src/rdsn/include/dsn/utility/TokenBucket.h | 507 -
.../dsn/utility/absl/base/internal/invoke.h | 218 -
.../include/dsn/utility/absl/utility/utility.h | 207 -
src/rdsn/include/dsn/utility/alloc.h | 84 -
src/rdsn/include/dsn/utility/apply.h | 35 -
src/rdsn/include/dsn/utility/autoref_ptr.h | 181 -
src/rdsn/include/dsn/utility/binary_reader.h | 106 -
src/rdsn/include/dsn/utility/binary_writer.h | 126 -
src/rdsn/include/dsn/utility/blob.h | 167 -
src/rdsn/include/dsn/utility/casts.h | 47 -
src/rdsn/include/dsn/utility/clock.h | 45 -
src/rdsn/include/dsn/utility/config_api.h | 132 -
src/rdsn/include/dsn/utility/config_helper.h | 142 -
src/rdsn/include/dsn/utility/configuration.h | 234 -
src/rdsn/include/dsn/utility/customizable_id.h | 212 -
src/rdsn/include/dsn/utility/defer.h | 64 -
src/rdsn/include/dsn/utility/dlib.h | 52 -
src/rdsn/include/dsn/utility/endians.h | 158 -
src/rdsn/include/dsn/utility/enum_helper.h | 127 -
src/rdsn/include/dsn/utility/error_code.h | 160 -
src/rdsn/include/dsn/utility/errors.h | 227 -
src/rdsn/include/dsn/utility/exp_delay.h | 130 -
src/rdsn/include/dsn/utility/extensible_object.h | 242 -
src/rdsn/include/dsn/utility/factory_store.h | 169 -
src/rdsn/include/dsn/utility/fail_point.h | 84 -
src/rdsn/include/dsn/utility/filesystem.h | 155 -
.../include/dsn/utility/fixed_size_buffer_pool.h | 56 -
src/rdsn/include/dsn/utility/flags.h | 175 -
.../include/dsn/utility/hpc_locks/autoresetevent.h | 68 -
src/rdsn/include/dsn/utility/hpc_locks/benaphore.h | 117 -
src/rdsn/include/dsn/utility/hpc_locks/rwlock.h | 172 -
src/rdsn/include/dsn/utility/hpc_locks/sema.h | 237 -
src/rdsn/include/dsn/utility/join_point.h | 129 -
src/rdsn/include/dsn/utility/link.h | 206 -
src/rdsn/include/dsn/utility/long_adder.h | 237 -
src/rdsn/include/dsn/utility/metrics.h | 840 -
src/rdsn/include/dsn/utility/nth_element.h | 128 -
src/rdsn/include/dsn/utility/output_utils.h | 228 -
src/rdsn/include/dsn/utility/ports.h | 111 -
src/rdsn/include/dsn/utility/preloadable.h | 39 -
src/rdsn/include/dsn/utility/priority_queue.h | 148 -
src/rdsn/include/dsn/utility/process_utils.h | 77 -
src/rdsn/include/dsn/utility/rand.h | 66 -
src/rdsn/include/dsn/utility/safe_strerror_posix.h | 35 -
src/rdsn/include/dsn/utility/singleton_store.h | 133 -
src/rdsn/include/dsn/utility/smart_pointers.h | 130 -
src/rdsn/include/dsn/utility/string_conv.h | 164 -
src/rdsn/include/dsn/utility/string_view.h | 428 -
src/rdsn/include/dsn/utility/strings.h | 85 -
src/rdsn/include/dsn/utility/synchronize.h | 182 -
src/rdsn/include/dsn/utility/sys_exit_hook.h | 43 -
src/rdsn/include/dsn/utility/timer.h | 62 -
src/rdsn/include/dsn/utility/utils.h | 135 -
src/rdsn/include/dsn/utility/work_queue.h | 109 -
src/rdsn/include/dsn/utils/latency_tracer.h | 191 -
src/rdsn/include/dsn/utils/time_utils.h | 129 -
.../dsn/utils/token_bucket_throttling_controller.h | 97 -
src/rdsn/include/dsn/utils/token_buckets.h | 41 -
src/rdsn/src/CMakeLists.txt | 47 -
src/rdsn/src/aio/CMakeLists.txt | 19 -
src/rdsn/src/aio/aio_provider.cpp | 47 -
src/rdsn/src/aio/aio_provider.h | 85 -
src/rdsn/src/aio/aio_task.cpp | 70 -
src/rdsn/src/aio/disk_engine.cpp | 277 -
src/rdsn/src/aio/disk_engine.h | 92 -
src/rdsn/src/aio/file_io.cpp | 141 -
src/rdsn/src/aio/native_linux_aio_provider.cpp | 169 -
src/rdsn/src/aio/native_linux_aio_provider.h | 52 -
src/rdsn/src/aio/test/CMakeLists.txt | 24 -
src/rdsn/src/aio/test/aio.cpp | 284 -
src/rdsn/src/aio/test/config.ini | 45 -
src/rdsn/src/aio/test/main.cpp | 30 -
src/rdsn/src/block_service/CMakeLists.txt | 43 -
.../src/block_service/block_service_manager.cpp | 189 -
src/rdsn/src/block_service/block_service_manager.h | 83 -
.../src/block_service/directio_writable_file.cpp | 135 -
.../src/block_service/directio_writable_file.h | 53 -
src/rdsn/src/block_service/fds/CMakeLists.txt | 18 -
src/rdsn/src/block_service/fds/fds_service.cpp | 716 -
src/rdsn/src/block_service/fds/fds_service.h | 143 -
src/rdsn/src/block_service/hdfs/CMakeLists.txt | 23 -
src/rdsn/src/block_service/hdfs/hdfs_service.cpp | 550 -
src/rdsn/src/block_service/hdfs/hdfs_service.h | 112 -
src/rdsn/src/block_service/local/CMakeLists.txt | 17 -
src/rdsn/src/block_service/local/local_service.cpp | 565 -
src/rdsn/src/block_service/local/local_service.h | 100 -
src/rdsn/src/block_service/test/CMakeLists.txt | 49 -
.../test/block_service_manager_test.cpp | 124 -
.../src/block_service/test/block_service_mock.h | 216 -
src/rdsn/src/block_service/test/config-test.ini | 59 -
.../src/block_service/test/fds_service_test.cpp | 801 -
.../src/block_service/test/hdfs_service_test.cpp | 378 -
.../src/block_service/test/local_service_test.cpp | 86 -
src/rdsn/src/block_service/test/main.cpp | 52 -
src/rdsn/src/client/CMakeLists.txt | 17 -
src/rdsn/src/client/partition_resolver.cpp | 127 -
src/rdsn/src/client/partition_resolver_manager.cpp | 77 -
src/rdsn/src/client/partition_resolver_manager.h | 53 -
src/rdsn/src/client/partition_resolver_simple.cpp | 455 -
src/rdsn/src/client/partition_resolver_simple.h | 124 -
src/rdsn/src/client/replication_ddl_client.cpp | 1742 --
src/rdsn/src/common/CMakeLists.txt | 74 -
src/rdsn/src/common/backup.thrift | 206 -
src/rdsn/src/common/backup_common.cpp | 126 -
src/rdsn/src/common/backup_common.h | 188 -
src/rdsn/src/common/bulk_load.thrift | 234 -
src/rdsn/src/common/bulk_load_common.h | 43 -
src/rdsn/src/common/common.cpp | 29 -
src/rdsn/src/common/consensus.thrift | 199 -
src/rdsn/src/common/duplication.thrift | 162 -
src/rdsn/src/common/duplication_common.cpp | 173 -
src/rdsn/src/common/fs_manager.cpp | 366 -
src/rdsn/src/common/fs_manager.h | 143 -
src/rdsn/src/common/manual_compact.h | 30 -
src/rdsn/src/common/meta_admin.thrift | 404 -
src/rdsn/src/common/metadata.thrift | 107 -
src/rdsn/src/common/partition_split.thrift | 180 -
src/rdsn/src/common/partition_split_common.h | 32 -
src/rdsn/src/common/replica_admin.thrift | 158 -
src/rdsn/src/common/replication_common.cpp | 666 -
src/rdsn/src/common/replication_common.h | 138 -
src/rdsn/src/common/test/CMakeLists.txt | 18 -
src/rdsn/src/common/test/common_test.cpp | 28 -
src/rdsn/src/common/test/config-test.ini | 102 -
.../src/common/test/duplication_common_test.cpp | 48 -
src/rdsn/src/common/test/fs_manager_test.cpp | 60 -
src/rdsn/src/common/test/main.cpp | 61 -
.../src/common/test/replication_common_test.cpp | 124 -
src/rdsn/src/common/test/run.sh | 36 -
src/rdsn/src/failure_detector/CMakeLists.txt | 27 -
src/rdsn/src/failure_detector/failure_detector.cpp | 610 -
.../failure_detector_multimaster.cpp | 146 -
src/rdsn/src/failure_detector/fd.thrift | 52 -
src/rdsn/src/failure_detector/test/CMakeLists.txt | 34 -
src/rdsn/src/failure_detector/test/config-test.ini | 135 -
.../test/config-whitelist-test-failed.ini | 136 -
.../test/config-whitelist-test.ini | 136 -
.../src/failure_detector/test/failure_detector.cpp | 723 -
src/rdsn/src/failure_detector/test/main.cpp | 85 -
src/rdsn/src/http/CMakeLists.txt | 30 -
src/rdsn/src/http/builtin_http_calls.cpp | 110 -
src/rdsn/src/http/builtin_http_calls.h | 48 -
src/rdsn/src/http/config_http_service.cpp | 72 -
src/rdsn/src/http/http_call_registry.h | 75 -
src/rdsn/src/http/http_message_parser.cpp | 253 -
src/rdsn/src/http/http_message_parser.h | 105 -
src/rdsn/src/http/http_server.cpp | 252 -
src/rdsn/src/http/http_server_impl.h | 38 -
src/rdsn/src/http/perf_counter_http_service.cpp | 57 -
src/rdsn/src/http/pprof_http_service.cpp | 504 -
src/rdsn/src/http/pprof_http_service.h | 81 -
src/rdsn/src/http/test/CMakeLists.txt | 20 -
src/rdsn/src/http/test/http_server_test.cpp | 330 -
.../http/test/perf_counter_http_service_test.cpp | 73 -
src/rdsn/src/http/test/uri_decoder_test.cpp | 91 -
src/rdsn/src/http/uri_decoder.cpp | 85 -
src/rdsn/src/http/uri_decoder.h | 31 -
src/rdsn/src/meta/CMakeLists.txt | 44 -
src/rdsn/src/meta/app_balance_policy.cpp | 206 -
src/rdsn/src/meta/app_balance_policy.h | 72 -
src/rdsn/src/meta/app_env_validator.cpp | 214 -
src/rdsn/src/meta/app_env_validator.h | 52 -
src/rdsn/src/meta/backup_engine.cpp | 369 -
src/rdsn/src/meta/backup_engine.h | 110 -
src/rdsn/src/meta/cluster_balance_policy.cpp | 550 -
src/rdsn/src/meta/cluster_balance_policy.h | 178 -
.../src/meta/distributed_lock_service_simple.cpp | 311 -
.../src/meta/distributed_lock_service_simple.h | 104 -
src/rdsn/src/meta/dump_file.h | 154 -
src/rdsn/src/meta/duplication/duplication_info.cpp | 248 -
src/rdsn/src/meta/duplication/duplication_info.h | 257 -
.../meta/duplication/meta_duplication_service.cpp | 637 -
.../meta/duplication/meta_duplication_service.h | 137 -
src/rdsn/src/meta/greedy_load_balancer.cpp | 257 -
src/rdsn/src/meta/greedy_load_balancer.h | 101 -
src/rdsn/src/meta/load_balance_policy.cpp | 789 -
src/rdsn/src/meta/load_balance_policy.h | 288 -
src/rdsn/src/meta/meta_backup_service.cpp | 1709 --
src/rdsn/src/meta/meta_backup_service.h | 397 -
.../src/meta/meta_bulk_load_ingestion_context.cpp | 195 -
.../src/meta/meta_bulk_load_ingestion_context.h | 92 -
src/rdsn/src/meta/meta_bulk_load_service.cpp | 2076 --
src/rdsn/src/meta/meta_bulk_load_service.h | 505 -
src/rdsn/src/meta/meta_data.cpp | 729 -
src/rdsn/src/meta/meta_data.h | 586 -
src/rdsn/src/meta/meta_http_service.cpp | 868 -
src/rdsn/src/meta/meta_http_service.h | 158 -
src/rdsn/src/meta/meta_options.cpp | 179 -
src/rdsn/src/meta/meta_options.h | 97 -
src/rdsn/src/meta/meta_rpc_types.h | 67 -
src/rdsn/src/meta/meta_server_failure_detector.cpp | 317 -
src/rdsn/src/meta/meta_server_failure_detector.h | 148 -
src/rdsn/src/meta/meta_service.cpp | 1227 --
src/rdsn/src/meta/meta_service.h | 426 -
src/rdsn/src/meta/meta_service_app.cpp | 110 -
src/rdsn/src/meta/meta_split_service.cpp | 580 -
src/rdsn/src/meta/meta_split_service.h | 84 -
src/rdsn/src/meta/meta_state_service_simple.cpp | 510 -
src/rdsn/src/meta/meta_state_service_simple.h | 270 -
src/rdsn/src/meta/meta_state_service_utils.cpp | 108 -
src/rdsn/src/meta/meta_state_service_utils.h | 79 -
src/rdsn/src/meta/meta_state_service_utils_impl.h | 311 -
src/rdsn/src/meta/meta_state_service_zookeeper.cpp | 430 -
src/rdsn/src/meta/meta_state_service_zookeeper.h | 121 -
src/rdsn/src/meta/partition_guardian.cpp | 781 -
src/rdsn/src/meta/partition_guardian.h | 101 -
src/rdsn/src/meta/server_load_balancer.cpp | 202 -
src/rdsn/src/meta/server_load_balancer.h | 204 -
src/rdsn/src/meta/server_state.cpp | 3949 ----
src/rdsn/src/meta/server_state.h | 424 -
src/rdsn/src/meta/server_state_restore.cpp | 245 -
src/rdsn/src/meta/test/CMakeLists.txt | 49 -
src/rdsn/src/meta/test/backup_test.cpp | 841 -
.../meta/test/balancer_simulator/CMakeLists.txt | 24 -
.../test/balancer_simulator/balancer_simulator.cpp | 200 -
src/rdsn/src/meta/test/balancer_validator.cpp | 357 -
.../src/meta/test/cluster_balance_policy_test.cpp | 537 -
src/rdsn/src/meta/test/config-test.ini | 145 -
.../src/meta/test/copy_replica_operation_test.cpp | 273 -
src/rdsn/src/meta/test/dump_file.cpp | 139 -
src/rdsn/src/meta/test/duplication_info_test.cpp | 308 -
src/rdsn/src/meta/test/ford_fulkerson_test.cpp | 282 -
src/rdsn/src/meta/test/json_compacity.cpp | 165 -
src/rdsn/src/meta/test/main.cpp | 108 -
src/rdsn/src/meta/test/meta_app_envs_test.cpp | 190 -
src/rdsn/src/meta/test/meta_app_operation_test.cpp | 802 -
src/rdsn/src/meta/test/meta_backup_test.cpp | 354 -
.../meta/test/meta_bulk_load_ingestion_test.cpp | 390 -
.../src/meta/test/meta_bulk_load_service_test.cpp | 1642 --
src/rdsn/src/meta/test/meta_data.cpp | 455 -
.../meta/test/meta_duplication_service_test.cpp | 868 -
src/rdsn/src/meta/test/meta_http_service_test.cpp | 400 -
.../src/meta/test/meta_mauanl_compaction_test.cpp | 195 -
.../src/meta/test/meta_partition_guardian_test.cpp | 922 -
src/rdsn/src/meta/test/meta_service_test.cpp | 124 -
src/rdsn/src/meta/test/meta_service_test_app.h | 191 -
src/rdsn/src/meta/test/meta_split_service_test.cpp | 819 -
src/rdsn/src/meta/test/meta_state/CMakeLists.txt | 32 -
src/rdsn/src/meta/test/meta_state/clear.cmd | 29 -
src/rdsn/src/meta/test/meta_state/config-test.ini | 113 -
src/rdsn/src/meta/test/meta_state/main.cpp | 99 -
.../meta/test/meta_state/meta_state_service.cpp | 303 -
.../meta/test/meta_state_service_utils_test.cpp | 182 -
src/rdsn/src/meta/test/meta_test_base.cpp | 233 -
src/rdsn/src/meta/test/meta_test_base.h | 85 -
src/rdsn/src/meta/test/misc/misc.cpp | 421 -
src/rdsn/src/meta/test/misc/misc.h | 121 -
src/rdsn/src/meta/test/run.sh | 47 -
.../src/meta/test/server_state_restore_test.cpp | 164 -
src/rdsn/src/meta/test/server_state_test.cpp | 206 -
src/rdsn/src/meta/test/state_sync_test.cpp | 393 -
.../src/meta/test/update_configuration_test.cpp | 511 -
src/rdsn/src/nfs/CMakeLists.txt | 23 -
src/rdsn/src/nfs/nfs.thrift | 68 -
src/rdsn/src/nfs/nfs_client_impl.cpp | 605 -
src/rdsn/src/nfs/nfs_client_impl.h | 307 -
src/rdsn/src/nfs/nfs_code_definition.h | 52 -
src/rdsn/src/nfs/nfs_node.cpp | 105 -
src/rdsn/src/nfs/nfs_node_impl.cpp | 76 -
src/rdsn/src/nfs/nfs_node_simple.h | 64 -
src/rdsn/src/nfs/nfs_server_impl.cpp | 288 -
src/rdsn/src/nfs/nfs_server_impl.h | 142 -
src/rdsn/src/nfs/test/CMakeLists.txt | 25 -
src/rdsn/src/nfs/test/main.cpp | 186 -
src/rdsn/src/perf_counter/CMakeLists.txt | 17 -
src/rdsn/src/perf_counter/builtin_counters.cpp | 51 -
src/rdsn/src/perf_counter/builtin_counters.h | 32 -
src/rdsn/src/perf_counter/perf_counter.cpp | 63 -
src/rdsn/src/perf_counter/perf_counter_atomic.h | 465 -
src/rdsn/src/perf_counter/perf_counters.cpp | 374 -
src/rdsn/src/perf_counter/test/CMakeLists.txt | 22 -
src/rdsn/src/perf_counter/test/main.cpp | 25 -
.../src/perf_counter/test/perf_counter_test.cpp | 169 -
.../src/perf_counter/test/perf_counters_test.cpp | 349 -
src/rdsn/src/remote_cmd/CMakeLists.txt | 13 -
src/rdsn/src/remote_cmd/command.thrift | 33 -
src/rdsn/src/remote_cmd/remote_command.cpp | 62 -
src/rdsn/src/replica/CMakeLists.txt | 67 -
.../src/replica/backup/cold_backup_context.cpp | 1075 -
src/rdsn/src/replica/backup/cold_backup_context.h | 373 -
.../src/replica/backup/replica_backup_manager.cpp | 198 -
.../src/replica/backup/replica_backup_manager.h | 50 -
.../src/replica/backup/replica_backup_server.cpp | 86 -
.../src/replica/backup/replica_backup_server.h | 46 -
src/rdsn/src/replica/backup/test/CMakeLists.txt | 25 -
src/rdsn/src/replica/backup/test/config-test.ini | 58 -
src/rdsn/src/replica/backup/test/main.cpp | 52 -
.../backup/test/replica_backup_manager_test.cpp | 47 -
src/rdsn/src/replica/backup/test/run.sh | 35 -
.../src/replica/bulk_load/replica_bulk_loader.cpp | 1051 -
.../src/replica/bulk_load/replica_bulk_loader.h | 182 -
src/rdsn/src/replica/bulk_load/test/CMakeLists.txt | 22 -
.../src/replica/bulk_load/test/config-test.ini | 99 -
src/rdsn/src/replica/bulk_load/test/main.cpp | 52 -
.../bulk_load/test/replica_bulk_loader_test.cpp | 915 -
src/rdsn/src/replica/bulk_load/test/run.sh | 35 -
src/rdsn/src/replica/disk_cleaner.cpp | 129 -
src/rdsn/src/replica/disk_cleaner.h | 73 -
.../replica/duplication/duplication_pipeline.cpp | 118 -
.../src/replica/duplication/duplication_pipeline.h | 91 -
.../replica/duplication/duplication_sync_timer.cpp | 196 -
.../replica/duplication/duplication_sync_timer.h | 84 -
.../replica/duplication/load_from_private_log.cpp | 283 -
.../replica/duplication/load_from_private_log.h | 106 -
.../src/replica/duplication/mutation_batch.cpp | 179 -
src/rdsn/src/replica/duplication/mutation_batch.h | 85 -
.../src/replica/duplication/replica_duplicator.cpp | 242 -
.../src/replica/duplication/replica_duplicator.h | 169 -
.../duplication/replica_duplicator_manager.cpp | 176 -
.../duplication/replica_duplicator_manager.h | 119 -
.../src/replica/duplication/replica_follower.cpp | 258 -
.../src/replica/duplication/replica_follower.h | 82 -
.../src/replica/duplication/test/CMakeLists.txt | 28 -
.../src/replica/duplication/test/config-test.ini | 55 -
.../test/duplication_sync_timer_test.cpp | 381 -
.../duplication/test/duplication_test_base.h | 94 -
.../test/load_from_private_log_test.cpp | 423 -
src/rdsn/src/replica/duplication/test/main.cpp | 52 -
.../duplication/test/mutation_batch_test.cpp | 96 -
.../test/replica_duplicator_manager_test.cpp | 206 -
.../duplication/test/replica_duplicator_test.cpp | 165 -
.../duplication/test/replica_follower_test.cpp | 250 -
.../duplication/test/replica_http_service_test.cpp | 69 -
src/rdsn/src/replica/duplication/test/run.sh | 35 -
.../duplication/test/ship_mutation_test.cpp | 121 -
src/rdsn/src/replica/log_block.cpp | 55 -
src/rdsn/src/replica/log_block.h | 130 -
src/rdsn/src/replica/log_file.cpp | 415 -
src/rdsn/src/replica/log_file.h | 216 -
src/rdsn/src/replica/log_file_stream.h | 196 -
src/rdsn/src/replica/mutation.cpp | 462 -
src/rdsn/src/replica/mutation.h | 242 -
src/rdsn/src/replica/mutation_cache.cpp | 149 -
src/rdsn/src/replica/mutation_cache.h | 73 -
src/rdsn/src/replica/mutation_log.cpp | 1738 --
src/rdsn/src/replica/mutation_log.h | 502 -
src/rdsn/src/replica/mutation_log_replay.cpp | 209 -
src/rdsn/src/replica/mutation_log_utils.cpp | 98 -
src/rdsn/src/replica/mutation_log_utils.h | 82 -
src/rdsn/src/replica/prepare_list.cpp | 205 -
src/rdsn/src/replica/prepare_list.h | 85 -
src/rdsn/src/replica/replica.cpp | 585 -
src/rdsn/src/replica/replica.h | 644 -
src/rdsn/src/replica/replica_2pc.cpp | 833 -
src/rdsn/src/replica/replica_backup.cpp | 720 -
src/rdsn/src/replica/replica_check.cpp | 253 -
src/rdsn/src/replica/replica_chkpt.cpp | 425 -
src/rdsn/src/replica/replica_config.cpp | 1206 --
src/rdsn/src/replica/replica_context.cpp | 286 -
src/rdsn/src/replica/replica_context.h | 289 -
src/rdsn/src/replica/replica_disk_migrator.cpp | 361 -
src/rdsn/src/replica/replica_disk_migrator.h | 69 -
src/rdsn/src/replica/replica_failover.cpp | 120 -
src/rdsn/src/replica/replica_http_service.cpp | 156 -
src/rdsn/src/replica/replica_http_service.h | 78 -
src/rdsn/src/replica/replica_init.cpp | 478 -
src/rdsn/src/replica/replica_learn.cpp | 1678 --
src/rdsn/src/replica/replica_restore.cpp | 494 -
src/rdsn/src/replica/replica_stub.cpp | 3003 ---
src/rdsn/src/replica/replica_stub.h | 516 -
src/rdsn/src/replica/replica_test_utils.cpp | 66 -
src/rdsn/src/replica/replica_throttle.cpp | 140 -
src/rdsn/src/replica/replication_app_base.cpp | 488 -
src/rdsn/src/replica/replication_service_app.cpp | 91 -
.../src/replica/split/replica_split_manager.cpp | 1518 --
src/rdsn/src/replica/split/replica_split_manager.h | 227 -
src/rdsn/src/replica/split/test/CMakeLists.txt | 22 -
src/rdsn/src/replica/split/test/config-test.ini | 91 -
src/rdsn/src/replica/split/test/main.cpp | 52 -
.../src/replica/split/test/replica_split_test.cpp | 1010 -
src/rdsn/src/replica/split/test/run.sh | 35 -
src/rdsn/src/replica/storage/CMakeLists.txt | 1 -
.../src/replica/storage/simple_kv/CMakeLists.txt | 32 -
src/rdsn/src/replica/storage/simple_kv/config.ini | 184 -
src/rdsn/src/replica/storage/simple_kv/run.sh | 58 -
.../storage/simple_kv/simple_kv.app.example.h | 130 -
.../replica/storage/simple_kv/simple_kv.client.h | 158 -
.../storage/simple_kv/simple_kv.code.definition.h | 51 -
.../replica/storage/simple_kv/simple_kv.main.cpp | 63 -
.../replica/storage/simple_kv/simple_kv.server.h | 105 -
.../storage/simple_kv/simple_kv.server.impl.cpp | 290 -
.../storage/simple_kv/simple_kv.server.impl.h | 117 -
.../replica/storage/simple_kv/test/CMakeLists.txt | 31 -
.../replica/storage/simple_kv/test/case-000.ini | 199 -
.../replica/storage/simple_kv/test/case-001.ini | 203 -
.../replica/storage/simple_kv/test/case-002.ini | 203 -
.../replica/storage/simple_kv/test/case-003.ini | 203 -
.../replica/storage/simple_kv/test/case-004.ini | 203 -
.../replica/storage/simple_kv/test/case-005.ini | 199 -
.../replica/storage/simple_kv/test/case-006.ini | 204 -
.../replica/storage/simple_kv/test/case-100.ini | 200 -
.../replica/storage/simple_kv/test/case-101.ini | 200 -
.../replica/storage/simple_kv/test/case-102.ini | 200 -
.../replica/storage/simple_kv/test/case-103.ini | 202 -
.../replica/storage/simple_kv/test/case-104.ini | 200 -
.../replica/storage/simple_kv/test/case-105.ini | 200 -
.../replica/storage/simple_kv/test/case-106.ini | 200 -
.../replica/storage/simple_kv/test/case-107.ini | 200 -
.../replica/storage/simple_kv/test/case-108.ini | 200 -
.../replica/storage/simple_kv/test/case-109.ini | 200 -
.../replica/storage/simple_kv/test/case-200.ini | 200 -
.../replica/storage/simple_kv/test/case-201.ini | 200 -
.../replica/storage/simple_kv/test/case-202-0.ini | 205 -
.../replica/storage/simple_kv/test/case-202-1.ini | 205 -
.../replica/storage/simple_kv/test/case-203-0.ini | 205 -
.../replica/storage/simple_kv/test/case-204.ini | 198 -
.../replica/storage/simple_kv/test/case-205.ini | 198 -
.../replica/storage/simple_kv/test/case-206.ini | 198 -
.../replica/storage/simple_kv/test/case-207.ini | 198 -
.../replica/storage/simple_kv/test/case-208.ini | 198 -
.../replica/storage/simple_kv/test/case-209.ini | 198 -
.../replica/storage/simple_kv/test/case-210.ini | 198 -
.../replica/storage/simple_kv/test/case-211.ini | 198 -
.../replica/storage/simple_kv/test/case-212.ini | 197 -
.../replica/storage/simple_kv/test/case-213.ini | 198 -
.../replica/storage/simple_kv/test/case-214.ini | 198 -
.../replica/storage/simple_kv/test/case-215.ini | 198 -
.../replica/storage/simple_kv/test/case-216.ini | 198 -
.../replica/storage/simple_kv/test/case-300-0.ini | 200 -
.../replica/storage/simple_kv/test/case-300-1.ini | 200 -
.../replica/storage/simple_kv/test/case-300-2.ini | 200 -
.../replica/storage/simple_kv/test/case-301.ini | 200 -
.../replica/storage/simple_kv/test/case-302.ini | 202 -
.../replica/storage/simple_kv/test/case-303.ini | 200 -
.../replica/storage/simple_kv/test/case-304.ini | 200 -
.../replica/storage/simple_kv/test/case-305.ini | 200 -
.../replica/storage/simple_kv/test/case-306.ini | 200 -
.../replica/storage/simple_kv/test/case-307.ini | 200 -
.../replica/storage/simple_kv/test/case-400.ini | 200 -
.../replica/storage/simple_kv/test/case-401.ini | 200 -
.../replica/storage/simple_kv/test/case-402.ini | 200 -
.../replica/storage/simple_kv/test/case-600.ini | 204 -
.../replica/storage/simple_kv/test/case-601.ini | 204 -
.../replica/storage/simple_kv/test/case-602.ini | 204 -
.../replica/storage/simple_kv/test/case-603.ini | 206 -
.../src/replica/storage/simple_kv/test/case.cpp | 1403 --
src/rdsn/src/replica/storage/simple_kv/test/case.h | 489 -
.../src/replica/storage/simple_kv/test/checker.cpp | 391 -
.../src/replica/storage/simple_kv/test/checker.h | 120 -
.../src/replica/storage/simple_kv/test/client.cpp | 184 -
.../src/replica/storage/simple_kv/test/client.h | 71 -
.../src/replica/storage/simple_kv/test/common.cpp | 342 -
.../src/replica/storage/simple_kv/test/common.h | 189 -
.../src/replica/storage/simple_kv/test/config.ini | 212 -
.../replica/storage/simple_kv/test/injector.cpp | 207 -
.../src/replica/storage/simple_kv/test/injector.h | 52 -
src/rdsn/src/replica/storage/simple_kv/test/run.sh | 100 -
.../storage/simple_kv/test/simple_kv.main.cpp | 90 -
.../simple_kv/test/simple_kv.server.impl.cpp | 316 -
.../storage/simple_kv/test/simple_kv.server.impl.h | 118 -
src/rdsn/src/replica/test/CMakeLists.txt | 31 -
.../src/replica/test/backup_block_service_mock.h | 73 -
src/rdsn/src/replica/test/clear.sh | 20 -
.../src/replica/test/cold_backup_context_test.cpp | 434 -
src/rdsn/src/replica/test/config-test.ini | 95 -
src/rdsn/src/replica/test/log_block_test.cpp | 170 -
src/rdsn/src/replica/test/log_file_test.cpp | 87 -
src/rdsn/src/replica/test/main.cpp | 71 -
src/rdsn/src/replica/test/mock_utils.h | 454 -
.../src/replica/test/mutation_log_learn_test.cpp | 185 -
src/rdsn/src/replica/test/mutation_log_test.cpp | 588 -
src/rdsn/src/replica/test/open_replica_test.cpp | 97 -
.../src/replica/test/replica_disk_migrate_test.cpp | 369 -
src/rdsn/src/replica/test/replica_disk_test.cpp | 291 -
src/rdsn/src/replica/test/replica_disk_test_base.h | 257 -
src/rdsn/src/replica/test/replica_learn_test.cpp | 172 -
src/rdsn/src/replica/test/replica_test.cpp | 479 -
src/rdsn/src/replica/test/replica_test_base.h | 87 -
.../replica/test/replication_service_test_app.h | 52 -
src/rdsn/src/replica/test/run.sh | 33 -
.../replica/test/throttling_controller_test.cpp | 131 -
src/rdsn/src/runtime/CMakeLists.txt | 32 -
src/rdsn/src/runtime/core_main.cpp | 46 -
src/rdsn/src/runtime/env.sim.cpp | 70 -
src/rdsn/src/runtime/env.sim.h | 54 -
src/rdsn/src/runtime/fault_injector.cpp | 347 -
src/rdsn/src/runtime/global_config.cpp | 387 -
src/rdsn/src/runtime/message_utils.cpp | 49 -
src/rdsn/src/runtime/nativerun.cpp | 105 -
src/rdsn/src/runtime/profiler.cpp | 557 -
src/rdsn/src/runtime/profiler_header.h | 92 -
src/rdsn/src/runtime/providers.common.cpp | 79 -
src/rdsn/src/runtime/rpc/CMakeLists.txt | 21 -
src/rdsn/src/runtime/rpc/asio_net_provider.cpp | 415 -
src/rdsn/src/runtime/rpc/asio_net_provider.h | 123 -
src/rdsn/src/runtime/rpc/asio_rpc_session.cpp | 204 -
src/rdsn/src/runtime/rpc/asio_rpc_session.h | 74 -
src/rdsn/src/runtime/rpc/dsn_message_parser.cpp | 213 -
src/rdsn/src/runtime/rpc/dsn_message_parser.h | 66 -
src/rdsn/src/runtime/rpc/message_parser.cpp | 200 -
src/rdsn/src/runtime/rpc/message_parser_manager.h | 70 -
src/rdsn/src/runtime/rpc/network.cpp | 827 -
src/rdsn/src/runtime/rpc/network.sim.cpp | 199 -
src/rdsn/src/runtime/rpc/network.sim.h | 117 -
src/rdsn/src/runtime/rpc/raw_message_parser.cpp | 128 -
src/rdsn/src/runtime/rpc/raw_message_parser.h | 60 -
src/rdsn/src/runtime/rpc/request_meta.thrift | 37 -
src/rdsn/src/runtime/rpc/rpc_engine.cpp | 851 -
src/rdsn/src/runtime/rpc/rpc_engine.h | 214 -
src/rdsn/src/runtime/rpc/rpc_message.cpp | 512 -
src/rdsn/src/runtime/rpc/rpc_task.cpp | 135 -
src/rdsn/src/runtime/rpc/thrift_message_parser.cpp | 417 -
src/rdsn/src/runtime/rpc/thrift_message_parser.h | 135 -
src/rdsn/src/runtime/scheduler.cpp | 300 -
src/rdsn/src/runtime/scheduler.h | 153 -
src/rdsn/src/runtime/security/CMakeLists.txt | 25 -
.../src/runtime/security/access_controller.cpp | 55 -
src/rdsn/src/runtime/security/access_controller.h | 57 -
.../src/runtime/security/client_negotiation.cpp | 202 -
src/rdsn/src/runtime/security/client_negotiation.h | 48 -
src/rdsn/src/runtime/security/init.cpp | 89 -
src/rdsn/src/runtime/security/init.h | 30 -
src/rdsn/src/runtime/security/kinit_context.cpp | 325 -
src/rdsn/src/runtime/security/kinit_context.h | 27 -
.../runtime/security/meta_access_controller.cpp | 69 -
.../src/runtime/security/meta_access_controller.h | 40 -
src/rdsn/src/runtime/security/negotiation.cpp | 72 -
src/rdsn/src/runtime/security/negotiation.h | 62 -
.../src/runtime/security/negotiation_manager.cpp | 154 -
.../src/runtime/security/negotiation_manager.h | 57 -
.../runtime/security/replica_access_controller.cpp | 69 -
.../runtime/security/replica_access_controller.h | 42 -
.../src/runtime/security/sasl_client_wrapper.cpp | 73 -
.../src/runtime/security/sasl_client_wrapper.h | 38 -
src/rdsn/src/runtime/security/sasl_init.cpp | 152 -
src/rdsn/src/runtime/security/sasl_init.h | 27 -
.../src/runtime/security/sasl_server_wrapper.cpp | 72 -
.../src/runtime/security/sasl_server_wrapper.h | 35 -
src/rdsn/src/runtime/security/sasl_wrapper.cpp | 97 -
src/rdsn/src/runtime/security/sasl_wrapper.h | 52 -
src/rdsn/src/runtime/security/security.thrift | 69 -
.../src/runtime/security/server_negotiation.cpp | 170 -
src/rdsn/src/runtime/security/server_negotiation.h | 52 -
src/rdsn/src/runtime/service_api_c.cpp | 588 -
src/rdsn/src/runtime/service_engine.cpp | 295 -
src/rdsn/src/runtime/service_engine.h | 145 -
src/rdsn/src/runtime/sim_clock.h | 37 -
src/rdsn/src/runtime/simulator.cpp | 134 -
src/rdsn/src/runtime/task/CMakeLists.txt | 13 -
src/rdsn/src/runtime/task/hpc_task_queue.cpp | 84 -
src/rdsn/src/runtime/task/hpc_task_queue.h | 61 -
src/rdsn/src/runtime/task/simple_task_queue.cpp | 110 -
src/rdsn/src/runtime/task/simple_task_queue.h | 71 -
src/rdsn/src/runtime/task/task.cpp | 487 -
src/rdsn/src/runtime/task/task_code.cpp | 89 -
src/rdsn/src/runtime/task/task_engine.cpp | 343 -
src/rdsn/src/runtime/task/task_engine.h | 142 -
src/rdsn/src/runtime/task/task_engine.sim.cpp | 251 -
src/rdsn/src/runtime/task/task_engine.sim.h | 147 -
src/rdsn/src/runtime/task/task_queue.cpp | 106 -
src/rdsn/src/runtime/task/task_spec.cpp | 313 -
src/rdsn/src/runtime/task/task_tracker.cpp | 174 -
src/rdsn/src/runtime/task/task_worker.cpp | 244 -
src/rdsn/src/runtime/test/CMakeLists.txt | 25 -
src/rdsn/src/runtime/test/async_call.cpp | 251 -
.../src/runtime/test/client_negotiation_test.cpp | 195 -
.../runtime/test/config-test-corrupt-message.ini | 141 -
src/rdsn/src/runtime/test/config-test-sim.ini | 133 -
src/rdsn/src/runtime/test/config-test.ini | 156 -
src/rdsn/src/runtime/test/corrupt_message.cpp | 59 -
src/rdsn/src/runtime/test/lpc.cpp | 55 -
src/rdsn/src/runtime/test/main.cpp | 88 -
src/rdsn/src/runtime/test/message_reader_test.cpp | 112 -
src/rdsn/src/runtime/test/message_utils_test.cpp | 76 -
.../runtime/test/meta_access_controller_test.cpp | 99 -
.../src/runtime/test/negotiation_manager_test.cpp | 169 -
src/rdsn/src/runtime/test/netprovider.cpp | 308 -
src/rdsn/src/runtime/test/pipeline_test.cpp | 134 -
.../test/replica_access_controller_test.cpp | 76 -
src/rdsn/src/runtime/test/rpc.cpp | 247 -
src/rdsn/src/runtime/test/rpc_holder_test.cpp | 182 -
src/rdsn/src/runtime/test/rpc_message.cpp | 224 -
.../src/runtime/test/server_negotiation_test.cpp | 249 -
src/rdsn/src/runtime/test/service_api_c.cpp | 237 -
src/rdsn/src/runtime/test/sim_lock.cpp | 117 -
src/rdsn/src/runtime/test/task_engine.cpp | 95 -
src/rdsn/src/runtime/test/task_test.cpp | 83 -
src/rdsn/src/runtime/test/test_utils.h | 143 -
.../runtime/test/thrift_message_parser_test.cpp | 432 -
src/rdsn/src/runtime/threadpool_code.cpp | 53 -
src/rdsn/src/runtime/tool_api.cpp | 174 -
src/rdsn/src/runtime/tracer.cpp | 408 -
src/rdsn/src/runtime/zlocks.cpp | 231 -
src/rdsn/src/tools/CMakeLists.txt | 16 -
src/rdsn/src/tools/mutation_log_tool.cpp | 91 -
src/rdsn/src/utils/CMakeLists.txt | 22 -
src/rdsn/src/utils/alloc.cpp | 54 -
src/rdsn/src/utils/binary_reader.cpp | 126 -
src/rdsn/src/utils/binary_writer.cpp | 199 -
src/rdsn/src/utils/clock.cpp | 37 -
src/rdsn/src/utils/command_manager.cpp | 176 -
src/rdsn/src/utils/config_api.cpp | 106 -
src/rdsn/src/utils/configuration.cpp | 464 -
src/rdsn/src/utils/coredump.h | 50 -
src/rdsn/src/utils/coredump.posix.cpp | 75 -
src/rdsn/src/utils/crc.cpp | 481 -
src/rdsn/src/utils/error_code.cpp | 65 -
src/rdsn/src/utils/fail_point.cpp | 171 -
src/rdsn/src/utils/fail_point_impl.h | 134 -
src/rdsn/src/utils/filesystem.cpp | 954 -
src/rdsn/src/utils/flags.cpp | 395 -
src/rdsn/src/utils/gpid.cpp | 44 -
src/rdsn/src/utils/latency_tracer.cpp | 289 -
src/rdsn/src/utils/lockp.std.h | 106 -
src/rdsn/src/utils/logging.cpp | 184 -
src/rdsn/src/utils/long_adder.cpp | 280 -
src/rdsn/src/utils/long_adder_bench/CMakeLists.txt | 39 -
.../utils/long_adder_bench/long_adder_bench.cpp | 198 -
src/rdsn/src/utils/math.cpp | 50 -
src/rdsn/src/utils/memutil.h | 25 -
src/rdsn/src/utils/metrics.cpp | 280 -
src/rdsn/src/utils/output_utils.cpp | 188 -
src/rdsn/src/utils/process_utils.cpp | 111 -
src/rdsn/src/utils/rand.cpp | 34 -
src/rdsn/src/utils/rpc_address.cpp | 218 -
src/rdsn/src/utils/safe_strerror_posix.cpp | 116 -
src/rdsn/src/utils/shared_io_service.cpp | 60 -
src/rdsn/src/utils/shared_io_service.h | 66 -
src/rdsn/src/utils/simple_logger.cpp | 257 -
src/rdsn/src/utils/simple_logger.h | 105 -
src/rdsn/src/utils/string_view.cpp | 100 -
src/rdsn/src/utils/strings.cpp | 223 -
src/rdsn/src/utils/test/CMakeLists.txt | 30 -
src/rdsn/src/utils/test/TokenBucketTest.cpp | 127 -
src/rdsn/src/utils/test/TokenBucketTest.h | 28 -
src/rdsn/src/utils/test/address.cpp | 223 -
src/rdsn/src/utils/test/autoref_ptr_test.cpp | 575 -
src/rdsn/src/utils/test/binary_reader_test.cpp | 73 -
src/rdsn/src/utils/test/command_manager.cpp | 80 -
src/rdsn/src/utils/test/configuration.cpp | 312 -
src/rdsn/src/utils/test/endian_test.cpp | 70 -
src/rdsn/src/utils/test/env.cpp | 52 -
src/rdsn/src/utils/test/fail_point_test.cpp | 168 -
src/rdsn/src/utils/test/file_system_test.cpp | 43 -
src/rdsn/src/utils/test/file_utils.cpp | 906 -
src/rdsn/src/utils/test/flag_test.cpp | 351 -
src/rdsn/src/utils/test/fmt_logging_test.cpp | 48 -
src/rdsn/src/utils/test/hostname_test.cpp | 127 -
src/rdsn/src/utils/test/join_point_test.cpp | 87 -
src/rdsn/src/utils/test/json_helper_test.cpp | 497 -
src/rdsn/src/utils/test/latency_tracer_test.cpp | 142 -
src/rdsn/src/utils/test/lock.std.cpp | 61 -
src/rdsn/src/utils/test/logger.cpp | 127 -
src/rdsn/src/utils/test/logging.cpp | 80 -
src/rdsn/src/utils/test/long_adder_test.cpp | 265 -
src/rdsn/src/utils/test/main.cpp | 36 -
src/rdsn/src/utils/test/memutil_test.cpp | 31 -
src/rdsn/src/utils/test/metrics_test.cpp | 906 -
.../utils/test/nth_element_bench/CMakeLists.txt | 39 -
.../test/nth_element_bench/nth_element_bench.cpp | 230 -
src/rdsn/src/utils/test/nth_element_test.cpp | 288 -
src/rdsn/src/utils/test/nth_element_utils.h | 180 -
src/rdsn/src/utils/test/output_utils_test.cpp | 204 -
src/rdsn/src/utils/test/percentile_utils.h | 88 -
src/rdsn/src/utils/test/priority_queue.cpp | 151 -
src/rdsn/src/utils/test/rand_test.cpp | 82 -
src/rdsn/src/utils/test/sema.cpp | 112 -
src/rdsn/src/utils/test/smart_pointers_test.cpp | 112 -
src/rdsn/src/utils/test/string_conv_test.cpp | 311 -
src/rdsn/src/utils/test/string_view_test.cpp | 436 -
src/rdsn/src/utils/test/time_utils_test.cpp | 102 -
.../token_bucket_throttling_controller_test.cpp | 164 -
src/rdsn/src/utils/test/token_buckets_test.cpp | 54 -
src/rdsn/src/utils/test/utils.cpp | 319 -
src/rdsn/src/utils/thread_access_checker.cpp | 46 -
src/rdsn/src/utils/throttling_controller.cpp | 178 -
src/rdsn/src/utils/time_utils.cpp | 49 -
.../utils/token_bucket_throttling_controller.cpp | 171 -
src/rdsn/src/utils/token_buckets.cpp | 44 -
src/rdsn/src/utils/utils.cpp | 194 -
src/rdsn/src/utils/zlock_provider.h | 182 -
src/rdsn/src/zookeeper/CMakeLists.txt | 22 -
.../distributed_lock_service_zookeeper.cpp | 289 -
.../zookeeper/distributed_lock_service_zookeeper.h | 122 -
src/rdsn/src/zookeeper/lock_struct.cpp | 801 -
src/rdsn/src/zookeeper/lock_struct.h | 126 -
src/rdsn/src/zookeeper/lock_types.h | 51 -
src/rdsn/src/zookeeper/test/CMakeLists.txt | 31 -
src/rdsn/src/zookeeper/test/config-test.ini | 121 -
.../zookeeper/test/distributed_lock_zookeeper.cpp | 235 -
src/rdsn/src/zookeeper/test/main.cpp | 85 -
src/rdsn/src/zookeeper/zookeeper_error.cpp | 60 -
src/rdsn/src/zookeeper/zookeeper_error.h | 43 -
src/rdsn/src/zookeeper/zookeeper_session.cpp | 394 -
src/rdsn/src/zookeeper/zookeeper_session.h | 199 -
src/rdsn/src/zookeeper/zookeeper_session_mgr.cpp | 69 -
src/rdsn/src/zookeeper/zookeeper_session_mgr.h | 66 -
src/redis_protocol/proxy/CMakeLists.txt | 5 +-
src/redis_protocol/proxy/config.ini | 2 +-
src/redis_protocol/proxy/main.cpp | 27 +-
src/redis_protocol/proxy_lib/proxy_layer.cpp | 27 +-
src/redis_protocol/proxy_lib/proxy_layer.h | 20 +-
src/redis_protocol/proxy_lib/redis_parser.cpp | 347 +-
src/redis_protocol/proxy_lib/redis_parser.h | 19 +-
src/redis_protocol/proxy_ut/CMakeLists.txt | 4 +-
src/redis_protocol/proxy_ut/config.ini | 2 +-
src/redis_protocol/proxy_ut/redis_proxy_test.cpp | 53 +-
src/remote_cmd/CMakeLists.txt | 37 +
src/remote_cmd/remote_command.cpp | 73 +
src/remote_cmd/remote_command.h | 46 +
src/replica/CMakeLists.txt | 89 +
src/replica/backup/cold_backup_context.cpp | 1082 +
src/replica/backup/cold_backup_context.h | 390 +
src/replica/backup/replica_backup_manager.cpp | 243 +
src/replica/backup/replica_backup_manager.h | 61 +
src/replica/backup/replica_backup_server.cpp | 108 +
src/replica/backup/replica_backup_server.h | 45 +
src/replica/backup/test/CMakeLists.txt | 39 +
src/replica/backup/test/config-test.ini | 59 +
src/replica/backup/test/main.cpp | 58 +
.../backup/test/replica_backup_manager_test.cpp | 56 +
src/replica/backup/test/run.sh | 53 +
src/replica/bulk_load/replica_bulk_loader.cpp | 1122 +
src/replica/bulk_load/replica_bulk_loader.h | 210 +
src/replica/bulk_load/test/CMakeLists.txt | 38 +
src/replica/bulk_load/test/config-test.ini | 99 +
src/replica/bulk_load/test/main.cpp | 58 +
.../bulk_load/test/replica_bulk_loader_test.cpp | 896 +
src/replica/bulk_load/test/run.sh | 53 +
src/replica/disk_cleaner.cpp | 288 +
src/replica/disk_cleaner.h | 68 +
src/replica/duplication/duplication_pipeline.cpp | 130 +
src/replica/duplication/duplication_pipeline.h | 97 +
src/replica/duplication/duplication_sync_timer.cpp | 215 +
src/replica/duplication/duplication_sync_timer.h | 87 +
src/replica/duplication/load_from_private_log.cpp | 305 +
src/replica/duplication/load_from_private_log.h | 118 +
src/replica/duplication/mutation_batch.cpp | 193 +
src/replica/duplication/mutation_batch.h | 91 +
src/replica/duplication/mutation_duplicator.h | 93 +
src/replica/duplication/replica_duplicator.cpp | 266 +
src/replica/duplication/replica_duplicator.h | 183 +
.../duplication/replica_duplicator_manager.cpp | 194 +
.../duplication/replica_duplicator_manager.h | 132 +
src/replica/duplication/replica_follower.cpp | 269 +
src/replica/duplication/replica_follower.h | 94 +
src/replica/duplication/test/CMakeLists.txt | 44 +
src/replica/duplication/test/config-test.ini | 58 +
.../test/dup_replica_http_service_test.cpp | 81 +
.../test/duplication_sync_timer_test.cpp | 396 +
.../duplication/test/duplication_test_base.h | 94 +
.../test/load_from_private_log_test.cpp | 501 +
.../test/log.1.0.all_loaded_are_write_empties | Bin
.../test/log.1.0.handle_real_private_log | Bin
.../test/log.1.0.handle_real_private_log2 | Bin
src/replica/duplication/test/main.cpp | 58 +
.../duplication/test/mutation_batch_test.cpp | 114 +
.../test/replica_duplicator_manager_test.cpp | 223 +
.../duplication/test/replica_duplicator_test.cpp | 184 +
.../duplication/test/replica_follower_test.cpp | 261 +
src/replica/duplication/test/run.sh | 53 +
.../duplication/test/ship_mutation_test.cpp | 137 +
src/replica/log_block.cpp | 59 +
src/replica/log_block.h | 139 +
src/replica/log_file.cpp | 431 +
src/replica/log_file.h | 241 +
src/replica/log_file_stream.h | 198 +
src/replica/mutation.cpp | 467 +
src/replica/mutation.h | 254 +
src/replica/mutation_cache.cpp | 151 +
src/replica/mutation_cache.h | 75 +
src/replica/mutation_log.cpp | 1204 ++
src/replica/mutation_log.h | 444 +
src/replica/mutation_log_replay.cpp | 222 +
src/replica/mutation_log_utils.cpp | 102 +
src/replica/mutation_log_utils.h | 86 +
src/replica/prepare_list.cpp | 209 +
src/replica/prepare_list.h | 93 +
src/replica/replica.cpp | 716 +
src/replica/replica.h | 704 +
src/replica/replica_2pc.cpp | 845 +
src/replica/replica_backup.cpp | 753 +
src/replica/replica_base.cpp | 53 +
src/replica/replica_base.h | 76 +
src/replica/replica_check.cpp | 272 +
src/replica/replica_chkpt.cpp | 453 +
src/replica/replica_config.cpp | 1157 ++
src/replica/replica_context.cpp | 280 +
src/replica/replica_context.h | 304 +
src/replica/replica_disk_migrator.cpp | 335 +
src/replica/replica_disk_migrator.h | 76 +
src/replica/replica_failover.cpp | 123 +
src/replica/replica_http_service.cpp | 171 +
src/replica/replica_http_service.h | 93 +
src/replica/replica_init.cpp | 333 +
src/replica/replica_learn.cpp | 1611 ++
src/replica/replica_restore.cpp | 473 +
src/replica/replica_stub.cpp | 2764 +++
src/replica/replica_stub.h | 538 +
src/replica/replica_throttle.cpp | 150 +
src/replica/replication_app_base.cpp | 407 +
src/replica/replication_app_base.h | 313 +
src/replica/replication_service_app.cpp | 94 +
src/replica/replication_service_app.h | 70 +
src/replica/split/replica_split_manager.cpp | 1587 ++
src/replica/split/replica_split_manager.h | 265 +
src/replica/split/test/CMakeLists.txt | 33 +
src/replica/split/test/config-test.ini | 91 +
src/replica/split/test/main.cpp | 58 +
src/replica/split/test/replica_split_test.cpp | 1030 +
src/replica/split/test/run.sh | 53 +
src/replica/storage/CMakeLists.txt | 25 +
src/replica/storage/simple_kv/CMakeLists.txt | 51 +
.../src => }/replica/storage/simple_kv/clear.sh | 0
src/replica/storage/simple_kv/config.ini | 185 +
src/replica/storage/simple_kv/run.sh | 77 +
.../storage/simple_kv/simple_kv.app.example.h | 121 +
src/replica/storage/simple_kv/simple_kv.client.h | 158 +
.../storage/simple_kv/simple_kv.code.definition.h | 42 +
src/replica/storage/simple_kv/simple_kv.main.cpp | 55 +
src/replica/storage/simple_kv/simple_kv.server.h | 100 +
.../storage/simple_kv/simple_kv.server.impl.cpp | 334 +
.../storage/simple_kv/simple_kv.server.impl.h | 123 +
.../replica/storage/simple_kv/simple_kv.thrift | 0
src/replica/storage/simple_kv/test/CMakeLists.txt | 51 +
.../replica/storage/simple_kv/test/README.md | 0
.../replica/storage/simple_kv/test/addcase.sh | 0
.../replica/storage/simple_kv/test/case-000.act | 0
src/replica/storage/simple_kv/test/case-000.ini | 203 +
.../replica/storage/simple_kv/test/case-001.act | 0
src/replica/storage/simple_kv/test/case-001.ini | 207 +
.../replica/storage/simple_kv/test/case-002.act | 0
src/replica/storage/simple_kv/test/case-002.ini | 207 +
.../replica/storage/simple_kv/test/case-003.act | 0
src/replica/storage/simple_kv/test/case-003.ini | 207 +
.../replica/storage/simple_kv/test/case-004.act | 0
src/replica/storage/simple_kv/test/case-004.ini | 207 +
.../replica/storage/simple_kv/test/case-005.act | 0
src/replica/storage/simple_kv/test/case-005.ini | 203 +
.../replica/storage/simple_kv/test/case-006.act | 0
src/replica/storage/simple_kv/test/case-006.ini | 208 +
.../replica/storage/simple_kv/test/case-100.act | 0
src/replica/storage/simple_kv/test/case-100.ini | 204 +
.../replica/storage/simple_kv/test/case-101.act | 0
src/replica/storage/simple_kv/test/case-101.ini | 204 +
.../replica/storage/simple_kv/test/case-102.act | 0
src/replica/storage/simple_kv/test/case-102.ini | 204 +
.../replica/storage/simple_kv/test/case-103.act | 0
src/replica/storage/simple_kv/test/case-103.ini | 206 +
.../replica/storage/simple_kv/test/case-104.act | 0
src/replica/storage/simple_kv/test/case-104.ini | 204 +
.../replica/storage/simple_kv/test/case-105.act | 0
src/replica/storage/simple_kv/test/case-105.ini | 204 +
.../replica/storage/simple_kv/test/case-106.act | 0
src/replica/storage/simple_kv/test/case-106.ini | 204 +
.../replica/storage/simple_kv/test/case-107.act | 0
src/replica/storage/simple_kv/test/case-107.ini | 204 +
.../replica/storage/simple_kv/test/case-108.act | 0
src/replica/storage/simple_kv/test/case-108.ini | 204 +
.../replica/storage/simple_kv/test/case-109.act | 0
src/replica/storage/simple_kv/test/case-109.ini | 204 +
.../replica/storage/simple_kv/test/case-200.act | 0
src/replica/storage/simple_kv/test/case-200.ini | 204 +
.../replica/storage/simple_kv/test/case-201.act | 0
src/replica/storage/simple_kv/test/case-201.ini | 204 +
.../replica/storage/simple_kv/test/case-202-0.act | 0
src/replica/storage/simple_kv/test/case-202-0.ini | 209 +
.../replica/storage/simple_kv/test/case-202-1.act | 0
src/replica/storage/simple_kv/test/case-202-1.ini | 209 +
.../replica/storage/simple_kv/test/case-203-0.act | 0
src/replica/storage/simple_kv/test/case-203-0.ini | 209 +
.../replica/storage/simple_kv/test/case-204.act | 0
src/replica/storage/simple_kv/test/case-204.ini | 202 +
.../replica/storage/simple_kv/test/case-205.act | 0
src/replica/storage/simple_kv/test/case-205.ini | 202 +
.../replica/storage/simple_kv/test/case-206.act | 0
src/replica/storage/simple_kv/test/case-206.ini | 202 +
.../replica/storage/simple_kv/test/case-207.act | 0
src/replica/storage/simple_kv/test/case-207.ini | 202 +
.../replica/storage/simple_kv/test/case-208.act | 0
src/replica/storage/simple_kv/test/case-208.ini | 202 +
.../replica/storage/simple_kv/test/case-209.act | 0
src/replica/storage/simple_kv/test/case-209.ini | 202 +
.../replica/storage/simple_kv/test/case-210.act | 0
src/replica/storage/simple_kv/test/case-210.ini | 202 +
.../replica/storage/simple_kv/test/case-211.act | 0
src/replica/storage/simple_kv/test/case-211.ini | 202 +
.../replica/storage/simple_kv/test/case-212.act | 0
src/replica/storage/simple_kv/test/case-212.ini | 201 +
.../replica/storage/simple_kv/test/case-213.act | 0
src/replica/storage/simple_kv/test/case-213.ini | 202 +
.../replica/storage/simple_kv/test/case-214.act | 0
src/replica/storage/simple_kv/test/case-214.ini | 202 +
.../replica/storage/simple_kv/test/case-215.act | 0
src/replica/storage/simple_kv/test/case-215.ini | 202 +
.../replica/storage/simple_kv/test/case-216.act | 0
src/replica/storage/simple_kv/test/case-216.ini | 202 +
.../replica/storage/simple_kv/test/case-300-0.act | 0
src/replica/storage/simple_kv/test/case-300-0.ini | 204 +
.../replica/storage/simple_kv/test/case-300-1.act | 0
src/replica/storage/simple_kv/test/case-300-1.ini | 204 +
.../replica/storage/simple_kv/test/case-300-2.act | 0
src/replica/storage/simple_kv/test/case-300-2.ini | 204 +
.../replica/storage/simple_kv/test/case-301.act | 0
src/replica/storage/simple_kv/test/case-301.ini | 204 +
.../replica/storage/simple_kv/test/case-302.act | 0
src/replica/storage/simple_kv/test/case-302.ini | 206 +
.../replica/storage/simple_kv/test/case-303.act | 0
src/replica/storage/simple_kv/test/case-303.ini | 204 +
.../replica/storage/simple_kv/test/case-304.act | 0
src/replica/storage/simple_kv/test/case-304.ini | 204 +
.../replica/storage/simple_kv/test/case-305.act | 0
src/replica/storage/simple_kv/test/case-305.ini | 204 +
.../replica/storage/simple_kv/test/case-306.act | 0
src/replica/storage/simple_kv/test/case-306.ini | 204 +
.../replica/storage/simple_kv/test/case-307.act | 0
src/replica/storage/simple_kv/test/case-307.ini | 204 +
.../replica/storage/simple_kv/test/case-400.act | 0
src/replica/storage/simple_kv/test/case-400.ini | 204 +
.../replica/storage/simple_kv/test/case-401.act | 0
src/replica/storage/simple_kv/test/case-401.ini | 204 +
.../replica/storage/simple_kv/test/case-402.act | 0
src/replica/storage/simple_kv/test/case-402.ini | 204 +
.../replica/storage/simple_kv/test/case-600.act | 0
src/replica/storage/simple_kv/test/case-600.ini | 208 +
.../replica/storage/simple_kv/test/case-601.act | 0
src/replica/storage/simple_kv/test/case-601.ini | 208 +
.../replica/storage/simple_kv/test/case-602.act | 0
src/replica/storage/simple_kv/test/case-602.ini | 208 +
.../replica/storage/simple_kv/test/case-603.act | 0
src/replica/storage/simple_kv/test/case-603.ini | 210 +
src/replica/storage/simple_kv/test/case.cpp | 1406 ++
src/replica/storage/simple_kv/test/case.h | 502 +
src/replica/storage/simple_kv/test/checker.cpp | 400 +
src/replica/storage/simple_kv/test/checker.h | 121 +
.../replica/storage/simple_kv/test/clear.sh | 0
src/replica/storage/simple_kv/test/client.cpp | 187 +
src/replica/storage/simple_kv/test/client.h | 72 +
src/replica/storage/simple_kv/test/common.cpp | 336 +
src/replica/storage/simple_kv/test/common.h | 211 +
src/replica/storage/simple_kv/test/config.ini | 213 +
src/replica/storage/simple_kv/test/injector.cpp | 203 +
src/replica/storage/simple_kv/test/injector.h | 45 +
.../replica/storage/simple_kv/test/rep_tests.pdf | Bin
src/replica/storage/simple_kv/test/run.sh | 127 +
.../storage/simple_kv/test/simple_kv.main.cpp | 92 +
.../simple_kv/test/simple_kv.server.impl.cpp | 367 +
.../storage/simple_kv/test/simple_kv.server.impl.h | 136 +
src/replica/test/CMakeLists.txt | 53 +
src/replica/test/backup_block_service_mock.h | 76 +
src/replica/test/clear.sh | 20 +
src/replica/test/cold_backup_context_test.cpp | 456 +
src/replica/test/config-test.ini | 95 +
src/replica/test/log_block_test.cpp | 185 +
src/replica/test/log_file_test.cpp | 100 +
src/replica/test/main.cpp | 82 +
src/replica/test/mock_utils.h | 448 +
src/replica/test/mutation_log_learn_test.cpp | 205 +
src/replica/test/mutation_log_test.cpp | 602 +
src/replica/test/open_replica_test.cpp | 95 +
src/replica/test/replica_disk_migrate_test.cpp | 406 +
src/replica/test/replica_disk_test.cpp | 363 +
src/replica/test/replica_disk_test_base.h | 185 +
src/replica/test/replica_http_service_test.cpp | 138 +
src/replica/test/replica_learn_test.cpp | 187 +
src/replica/test/replica_test.cpp | 585 +
src/replica/test/replica_test_base.h | 91 +
src/replica/test/replication_service_test_app.h | 52 +
src/replica/test/run.sh | 52 +
src/replica/test/throttling_controller_test.cpp | 131 +
src/reporter/CMakeLists.txt | 44 -
src/reporter/pegasus_counter_reporter.cpp | 362 -
src/reporter/pegasus_counter_reporter.h | 105 -
src/reporter/pegasus_io_service.h | 65 -
src/runtime/CMakeLists.txt | 53 +
src/runtime/api_layer1.h | 275 +
src/runtime/api_task.h | 81 +
src/runtime/app_model.h | 93 +
src/{rdsn/src => }/runtime/build_config.h | 0
src/runtime/core_main.cpp | 46 +
src/runtime/env.sim.cpp | 66 +
src/runtime/env.sim.h | 45 +
src/runtime/env_provider.h | 52 +
src/runtime/fault_injector.cpp | 358 +
src/runtime/fault_injector.h | 96 +
src/runtime/global_config.cpp | 380 +
src/runtime/global_config.h | 198 +
src/runtime/message_utils.cpp | 53 +
src/runtime/message_utils.h | 80 +
src/runtime/nativerun.cpp | 109 +
src/runtime/nativerun.h | 47 +
src/runtime/node_scoper.h | 51 +
src/runtime/pipeline.h | 302 +
src/runtime/profiler.cpp | 544 +
src/runtime/profiler.h | 68 +
src/runtime/profiler_header.h | 80 +
src/runtime/providers.common.cpp | 81 +
src/runtime/providers.common.h | 33 +
src/runtime/rpc/CMakeLists.txt | 45 +
src/runtime/rpc/asio_net_provider.cpp | 454 +
src/runtime/rpc/asio_net_provider.h | 138 +
src/runtime/rpc/asio_rpc_session.cpp | 237 +
src/runtime/rpc/asio_rpc_session.h | 79 +
src/runtime/rpc/dns_resolver.cpp | 111 +
src/runtime/rpc/dns_resolver.h | 54 +
src/runtime/rpc/dsn_message_parser.cpp | 214 +
src/runtime/rpc/dsn_message_parser.h | 58 +
src/runtime/rpc/group_address.h | 223 +
src/runtime/rpc/group_host_port.h | 257 +
src/runtime/rpc/message_parser.cpp | 203 +
src/runtime/rpc/message_parser.h | 134 +
src/runtime/rpc/message_parser_manager.h | 61 +
src/runtime/rpc/network.cpp | 836 +
src/runtime/rpc/network.h | 359 +
src/runtime/rpc/network.sim.cpp | 195 +
src/runtime/rpc/network.sim.h | 116 +
src/runtime/rpc/raw_message_parser.cpp | 133 +
src/runtime/rpc/raw_message_parser.h | 55 +
src/runtime/rpc/request_meta.thrift | 38 +
src/runtime/rpc/rpc_address.cpp | 252 +
src/runtime/rpc/rpc_address.h | 235 +
src/runtime/rpc/rpc_engine.cpp | 860 +
src/runtime/rpc/rpc_engine.h | 230 +
src/runtime/rpc/rpc_holder.h | 396 +
src/runtime/rpc/rpc_host_port.cpp | 224 +
src/runtime/rpc/rpc_host_port.h | 157 +
src/runtime/rpc/rpc_message.cpp | 525 +
src/runtime/rpc/rpc_message.h | 234 +
src/runtime/rpc/rpc_stream.h | 136 +
src/runtime/rpc/rpc_task.cpp | 152 +
src/runtime/rpc/serialization.h | 104 +
src/runtime/rpc/thrift_message_parser.cpp | 432 +
src/runtime/rpc/thrift_message_parser.h | 136 +
src/runtime/scheduler.cpp | 301 +
src/runtime/scheduler.h | 156 +
src/runtime/serverlet.h | 250 +
src/runtime/service_api_c.cpp | 610 +
src/runtime/service_app.h | 103 +
src/runtime/service_engine.cpp | 285 +
src/runtime/service_engine.h | 138 +
src/runtime/sim_clock.h | 37 +
src/runtime/simulator.cpp | 136 +
src/runtime/simulator.h | 76 +
src/runtime/task/CMakeLists.txt | 37 +
src/runtime/task/async_calls.h | 230 +
src/runtime/task/future_types.h | 37 +
src/runtime/task/hpc_task_queue.cpp | 84 +
src/runtime/task/hpc_task_queue.h | 56 +
src/runtime/task/simple_task_queue.cpp | 131 +
src/runtime/task/simple_task_queue.h | 80 +
src/runtime/task/task.cpp | 495 +
src/runtime/task/task.h | 609 +
src/runtime/task/task_code.cpp | 126 +
src/runtime/task/task_code.h | 211 +
src/runtime/task/task_engine.cpp | 359 +
src/runtime/task/task_engine.h | 137 +
src/runtime/task/task_engine.sim.cpp | 251 +
src/runtime/task/task_engine.sim.h | 146 +
src/runtime/task/task_queue.cpp | 141 +
src/runtime/task/task_queue.h | 106 +
src/runtime/task/task_spec.cpp | 292 +
src/runtime/task/task_spec.h | 318 +
src/runtime/task/task_tracker.cpp | 169 +
src/runtime/task/task_tracker.h | 229 +
src/runtime/task/task_worker.cpp | 262 +
src/runtime/task/task_worker.h | 111 +
src/runtime/task/timer_service.h | 70 +
src/runtime/test/CMakeLists.txt | 46 +
src/runtime/test/address_test.cpp | 250 +
src/runtime/test/async_call.cpp | 259 +
src/{rdsn/src => }/runtime/test/clear.sh | 0
src/{rdsn/src => }/runtime/test/command.txt | 0
src/runtime/test/config-test-corrupt-message.ini | 141 +
src/runtime/test/config-test-sim.ini | 133 +
src/runtime/test/config-test.ini | 156 +
src/runtime/test/corrupt_message.cpp | 59 +
src/{rdsn/src => }/runtime/test/gtest.filter | 0
src/runtime/test/host_port_test.cpp | 289 +
src/runtime/test/lpc.cpp | 53 +
src/runtime/test/main.cpp | 88 +
src/runtime/test/message_reader_test.cpp | 115 +
src/runtime/test/message_utils_test.cpp | 83 +
src/runtime/test/netprovider.cpp | 307 +
src/runtime/test/pipeline_test.cpp | 139 +
src/runtime/test/rpc.cpp | 255 +
src/runtime/test/rpc_holder_test.cpp | 187 +
src/runtime/test/rpc_message.cpp | 231 +
src/{rdsn/src => }/runtime/test/run.sh | 0
src/runtime/test/service_api_c.cpp | 241 +
src/runtime/test/sim_lock.cpp | 108 +
src/runtime/test/task_engine.cpp | 96 +
src/runtime/test/task_test.cpp | 97 +
src/runtime/test/thrift_message_parser_test.cpp | 450 +
src/runtime/test_utils.h | 160 +
src/runtime/threadpool_code.cpp | 53 +
src/runtime/tool_api.cpp | 180 +
src/runtime/tool_api.h | 221 +
src/runtime/tracer.cpp | 421 +
src/runtime/tracer.h | 112 +
src/runtime/zlocks.cpp | 229 +
src/sample/CMakeLists.txt | 31 +
src/sample/Makefile | 38 -
src/sample/README.md | 5 -
src/sample/main.cpp | 2 +
src/sample/run.sh | 4 +-
src/security/CMakeLists.txt | 31 +
src/security/access_controller.cpp | 67 +
src/security/access_controller.h | 76 +
src/security/client_negotiation.cpp | 212 +
src/security/client_negotiation.h | 55 +
src/security/init.cpp | 101 +
src/security/init.h | 30 +
src/security/kinit_context.cpp | 366 +
src/security/kinit_context.h | 30 +
src/security/meta_access_controller.cpp | 133 +
src/security/meta_access_controller.h | 52 +
src/security/negotiation.cpp | 73 +
src/security/negotiation.h | 71 +
src/security/negotiation_manager.cpp | 165 +
src/security/negotiation_manager.h | 67 +
.../src/runtime => }/security/negotiation_utils.h | 0
src/security/replica_access_controller.cpp | 125 +
src/security/replica_access_controller.h | 81 +
src/security/sasl_client_wrapper.cpp | 77 +
src/security/sasl_client_wrapper.h | 43 +
src/security/sasl_init.cpp | 151 +
src/security/sasl_init.h | 27 +
src/security/sasl_server_wrapper.cpp | 76 +
src/security/sasl_server_wrapper.h | 40 +
src/security/sasl_wrapper.cpp | 100 +
src/security/sasl_wrapper.h | 59 +
src/security/server_negotiation.cpp | 180 +
src/security/server_negotiation.h | 55 +
src/security/test/CMakeLists.txt | 31 +
src/security/test/client_negotiation_test.cpp | 203 +
src/security/test/config.ini | 24 +
src/security/test/main.cpp | 43 +
src/security/test/meta_access_controller_test.cpp | 111 +
src/security/test/negotiation_manager_test.cpp | 176 +
.../test/replica_access_controller_test.cpp | 89 +
src/security/test/run.sh | 25 +
src/security/test/server_negotiation_test.cpp | 257 +
src/server/CMakeLists.txt | 60 +-
src/server/available_detector.cpp | 293 +-
src/server/available_detector.h | 29 +-
src/server/brief_stat.cpp | 87 -
src/server/brief_stat.h | 24 -
src/server/capacity_unit_calculator.cpp | 207 +-
src/server/capacity_unit_calculator.h | 46 +-
src/server/compaction_filter_rule.cpp | 40 +-
src/server/compaction_filter_rule.h | 39 +-
src/server/compaction_operation.cpp | 27 +-
src/server/compaction_operation.h | 35 +-
src/server/config.ini | 33 +-
src/server/config.min.ini | 15 +-
src/server/hashkey_transform.h | 12 +-
src/server/hotkey_collector.cpp | 69 +-
src/server/hotkey_collector.h | 19 +-
src/server/hotkey_collector_state.h | 2 +-
src/server/hotspot_partition_calculator.cpp | 82 +-
src/server/hotspot_partition_calculator.h | 15 +-
src/server/info_collector.cpp | 127 +-
src/server/info_collector.h | 40 +-
src/server/info_collector_app.cpp | 27 +-
src/server/info_collector_app.h | 10 +-
src/server/key_ttl_compaction_filter.h | 4 +-
src/server/logging_utils.h | 16 +-
src/server/main.cpp | 77 +-
src/server/meta_store.cpp | 72 +-
src/server/meta_store.h | 19 +-
src/server/pegasus_event_listener.cpp | 132 +-
src/server/pegasus_event_listener.h | 34 +-
src/server/pegasus_manual_compact_service.cpp | 121 +-
src/server/pegasus_manual_compact_service.h | 22 +-
src/server/pegasus_mutation_duplicator.cpp | 118 +-
src/server/pegasus_mutation_duplicator.h | 42 +-
src/server/pegasus_read_service.h | 11 +-
src/server/pegasus_scan_context.h | 6 +-
src/server/pegasus_server_impl.cpp | 1659 +-
src/server/pegasus_server_impl.h | 202 +-
src/server/pegasus_server_impl_init.cpp | 1172 +-
src/server/pegasus_server_write.cpp | 104 +-
src/server/pegasus_server_write.h | 24 +-
src/server/pegasus_service_app.h | 51 +-
src/server/pegasus_write_service.cpp | 342 +-
src/server/pegasus_write_service.h | 102 +-
src/server/pegasus_write_service_impl.h | 225 +-
src/server/range_read_limiter.h | 3 +-
src/server/result_writer.cpp | 50 +-
src/server/result_writer.h | 10 +-
src/server/rocksdb_wrapper.cpp | 140 +-
src/server/rocksdb_wrapper.h | 45 +-
src/server/test/CMakeLists.txt | 58 +-
src/server/test/capacity_unit_calculator_test.cpp | 67 +-
src/server/test/compaction_filter_rule_test.cpp | 8 +-
src/server/test/compaction_operation_test.cpp | 26 +-
src/server/test/config.ini | 14 +-
src/server/test/hashkey_transform_test.cpp | 5 +-
src/server/test/hotkey_collector_test.cpp | 51 +-
src/server/test/hotspot_partition_test.cpp | 25 +-
src/server/test/main.cpp | 12 +-
src/server/test/manual_compact_service_test.cpp | 42 +-
src/server/test/message_utils.h | 2 +-
.../test/pegasus_compression_options_test.cpp | 21 +-
.../test/pegasus_mutation_duplicator_test.cpp | 49 +-
src/server/test/pegasus_server_impl_test.cpp | 120 +-
src/server/test/pegasus_server_test_base.h | 46 +-
src/server/test/pegasus_server_write_test.cpp | 36 +-
src/server/test/pegasus_value_schema_test.cpp | 4 +-
.../test/pegasus_write_service_impl_test.cpp | 45 +-
src/server/test/pegasus_write_service_test.cpp | 40 +-
src/server/test/rocksdb_wrapper_test.cpp | 82 +-
src/server/test/run.sh | 21 +-
src/shell/CMakeLists.txt | 72 +-
src/shell/args.h | 5 +-
src/shell/command_executor.h | 2 +-
src/shell/command_helper.h | 115 +-
src/shell/command_output.h | 3 +-
src/shell/command_utils.cpp | 6 +
src/shell/command_utils.h | 27 +-
src/shell/commands.h | 14 +-
src/shell/commands/bulk_load.cpp | 26 +
src/shell/commands/cold_backup.cpp | 19 +
src/shell/commands/data_operations.cpp | 64 +-
src/shell/commands/debugger.cpp | 107 +-
src/shell/commands/detect_hotkey.cpp | 28 +-
src/shell/commands/duplication.cpp | 32 +-
src/shell/commands/global_properties.cpp | 11 +-
src/shell/commands/misc.cpp | 8 +
src/shell/commands/node_management.cpp | 31 +-
src/shell/commands/rebalance.cpp | 21 +
src/shell/commands/recovery.cpp | 24 +-
src/shell/commands/table_management.cpp | 88 +-
src/shell/config.ini | 4 +-
src/shell/main.cpp | 41 +-
src/test/bench_test/CMakeLists.txt | 10 +-
src/test/bench_test/benchmark.cpp | 237 +-
src/test/bench_test/benchmark.h | 15 +-
src/test/bench_test/config.cpp | 41 +-
src/test/bench_test/config.h | 24 +-
src/test/bench_test/config.ini | 7 +-
src/test/bench_test/main.cpp | 7 +-
src/test/bench_test/rand.cpp | 3 +
src/test/bench_test/statistics.cpp | 16 +-
src/test/bench_test/statistics.h | 8 +-
src/test/bench_test/utils.h | 4 +-
src/test/function_test/CMakeLists.txt | 37 +-
.../function_test/backup_restore/CMakeLists.txt | 39 +
src/test/function_test/backup_restore/main.cpp | 30 +
.../backup_restore/test_backup_and_restore.cpp | 99 +
src/test/function_test/base_api/CMakeLists.txt | 47 +
.../function_test/base_api/integration_test.cpp | 201 +
src/test/function_test/base_api/main.cpp | 30 +
src/test/function_test/base_api/test_basic.cpp | 1803 ++
src/test/function_test/base_api/test_batch_get.cpp | 116 +
.../base_api/test_check_and_mutate.cpp | 1705 ++
.../function_test/base_api/test_check_and_set.cpp | 1576 ++
src/test/function_test/base_api/test_copy.cpp | 220 +
src/test/function_test/base_api/test_incr.cpp | 249 +
.../function_test/base_api/test_range_read.cpp | 195 +
src/test/function_test/base_api/test_recall.cpp | 108 +
src/test/function_test/base_api/test_scan.cpp | 446 +
src/test/function_test/base_api/test_ttl.cpp | 206 +
src/test/function_test/bulk_load/CMakeLists.txt | 52 +
src/test/function_test/bulk_load/main.cpp | 30 +
.../function_test/bulk_load/test_bulk_load.cpp | 358 +
src/test/function_test/config.ini | 11 +-
.../function_test/detect_hotspot/CMakeLists.txt | 46 +
src/test/function_test/detect_hotspot/main.cpp | 30 +
.../detect_hotspot/test_detect_hotspot.cpp | 217 +
src/test/function_test/global_env.cpp | 77 -
src/test/function_test/global_env.h | 44 -
src/test/function_test/main.cpp | 63 -
.../function_test/partition_split/CMakeLists.txt | 47 +
src/test/function_test/partition_split/main.cpp | 30 +
.../function_test/partition_split/test_split.cpp | 342 +
src/test/function_test/recovery/CMakeLists.txt | 46 +
src/test/function_test/recovery/main.cpp | 30 +
src/test/function_test/recovery/test_recovery.cpp | 289 +
src/test/function_test/restore/CMakeLists.txt | 46 +
src/test/function_test/restore/main.cpp | 29 +
src/test/function_test/restore/test_restore.cpp | 150 +
src/test/function_test/run.sh | 101 +-
src/test/function_test/test_backup_and_restore.cpp | 249 -
src/test/function_test/test_basic.cpp | 1854 --
src/test/function_test/test_batch_get.cpp | 109 -
src/test/function_test/test_bulk_load.cpp | 327 -
src/test/function_test/test_check_and_mutate.cpp | 1849 --
src/test/function_test/test_check_and_set.cpp | 1705 --
src/test/function_test/test_copy.cpp | 231 -
src/test/function_test/test_detect_hotspot.cpp | 239 -
src/test/function_test/test_incr.cpp | 300 -
src/test/function_test/test_range_read.cpp | 203 -
src/test/function_test/test_recall.cpp | 136 -
src/test/function_test/test_recovery.cpp | 383 -
src/test/function_test/test_restore.cpp | 366 -
src/test/function_test/test_scan.cpp | 494 -
src/test/function_test/test_split.cpp | 360 -
src/test/function_test/test_throttle.cpp | 785 -
src/test/function_test/test_ttl.cpp | 241 -
src/test/function_test/throttle/CMakeLists.txt | 47 +
src/test/function_test/throttle/main.cpp | 30 +
src/test/function_test/throttle/test_throttle.cpp | 668 +
src/test/function_test/utils.h | 206 -
src/test/function_test/utils/CMakeLists.txt | 29 +
src/test/function_test/utils/global_env.cpp | 72 +
src/test/function_test/utils/global_env.h | 43 +
src/test/function_test/utils/test_util.cpp | 288 +
src/test/function_test/utils/test_util.h | 123 +
src/test/function_test/utils/utils.h | 229 +
src/test/kill_test/CMakeLists.txt | 2 +-
src/test/kill_test/config.ini | 3 +-
src/test/kill_test/data_verifier.cpp | 347 +-
src/test/kill_test/data_verifier.h | 4 +
src/test/kill_test/job.cpp | 2 +
src/test/kill_test/kill_testor.cpp | 80 +-
src/test/kill_test/kill_testor.h | 20 +-
src/test/kill_test/killer_handler.h | 2 +-
src/test/kill_test/killer_handler_shell.cpp | 56 +-
src/test/kill_test/killer_handler_shell.h | 9 +-
src/test/kill_test/main.cpp | 15 +-
src/test/kill_test/partition_kill_testor.cpp | 37 +-
src/test/kill_test/partition_kill_testor.h | 4 -
src/test/kill_test/process_kill_testor.cpp | 168 +-
src/test/kill_test/process_kill_testor.h | 17 +-
src/test/pressure_test/CMakeLists.txt | 2 +-
src/test/pressure_test/config-pressure.ini | 2 +-
src/test/pressure_test/main.cpp | 158 +-
src/test/upgrade_test/CMakeLists.txt | 51 -
src/test/upgrade_test/config.ini | 118 -
src/test/upgrade_test/data_verifier.cpp | 435 -
src/test/upgrade_test/data_verifier.h | 23 -
src/test/upgrade_test/job.cpp | 40 -
src/test/upgrade_test/job.h | 65 -
src/test/upgrade_test/main.cpp | 44 -
src/test/upgrade_test/process_upgrader.cpp | 206 -
src/test/upgrade_test/process_upgrader.h | 23 -
src/test/upgrade_test/upgrade_testor.cpp | 230 -
src/test/upgrade_test/upgrade_testor.h | 86 -
src/test/upgrade_test/upgrader_handler.h | 77 -
src/test/upgrade_test/upgrader_handler_shell.cpp | 240 -
src/test/upgrade_test/upgrader_handler_shell.h | 69 -
src/test/upgrade_test/upgrader_registry.cpp | 29 -
src/test/upgrade_test/upgrader_registry.h | 22 -
src/test_util/CMakeLists.txt | 32 +
src/test_util/test_util.cpp | 136 +
src/test_util/test_util.h | 147 +
src/tools/CMakeLists.txt | 40 +
src/tools/mutation_log_tool.cpp | 137 +
src/tools/mutation_log_tool.h | 51 +
src/utils/CMakeLists.txt | 53 +
src/utils/TokenBucket.h | 507 +
src/utils/alloc.cpp | 57 +
src/utils/alloc.h | 90 +
src/utils/api_utilities.h | 128 +
src/utils/autoref_ptr.h | 174 +
src/utils/binary_reader.cpp | 130 +
src/utils/binary_reader.h | 110 +
src/utils/binary_writer.cpp | 203 +
src/utils/binary_writer.h | 132 +
src/utils/blob.h | 216 +
src/utils/builtin_metrics.cpp | 92 +
src/utils/builtin_metrics.h | 48 +
src/utils/casts.h | 47 +
.../dsn/utility => utils}/chrono_literals.h | 0
src/utils/clock.cpp | 37 +
src/utils/clock.h | 46 +
src/utils/command_manager.cpp | 187 +
src/utils/command_manager.h | 125 +
src/utils/config_api.cpp | 108 +
src/utils/config_api.h | 134 +
src/utils/config_helper.h | 142 +
src/utils/configuration.cpp | 441 +
src/utils/configuration.h | 236 +
src/utils/coredump.h | 41 +
src/utils/coredump.posix.cpp | 78 +
src/utils/crc.cpp | 481 +
src/{rdsn/include/dsn/utility => utils}/crc.h | 0
src/utils/customizable_id.h | 211 +
src/utils/defer.h | 72 +
src/utils/distributed_lock_service.h | 177 +
src/utils/endians.h | 158 +
src/utils/enum_helper.h | 270 +
src/utils/env.cpp | 210 +
src/utils/env.h | 66 +
src/utils/error_code.cpp | 68 +
src/utils/error_code.h | 187 +
src/utils/errors.h | 247 +
src/utils/exp_delay.h | 122 +
src/utils/extensible_object.h | 234 +
src/utils/factory_store.h | 161 +
src/utils/fail_point.cpp | 175 +
src/utils/fail_point.h | 95 +
src/utils/fail_point_impl.h | 137 +
src/utils/filesystem.cpp | 906 +
src/utils/filesystem.h | 170 +
src/utils/fixed_size_buffer_pool.h | 57 +
src/utils/flags.cpp | 404 +
src/utils/flags.h | 184 +
src/utils/fmt_logging.h | 346 +
src/utils/fmt_utils.h | 29 +
.../dsn/utility => utils}/function_traits.h | 0
src/utils/gpid.cpp | 46 +
src/utils/hpc_locks/autoresetevent.h | 68 +
.../hpc_locks/autoreseteventcondvar.h | 0
src/utils/hpc_locks/benaphore.h | 117 +
.../dsn/utility => utils}/hpc_locks/bitfield.h | 0
.../dsn/utility => utils}/hpc_locks/readme.txt | 0
src/utils/hpc_locks/rwlock.h | 172 +
src/utils/hpc_locks/sema.h | 238 +
src/utils/je_ctl.cpp | 107 +
src/utils/je_ctl.h | 67 +
src/utils/join_point.h | 131 +
src/utils/latency_tracer.cpp | 381 +
src/utils/latency_tracer.h | 194 +
src/utils/link.h | 199 +
src/utils/load_dump_object.h | 175 +
src/utils/lockp.std.h | 97 +
src/utils/logging.cpp | 131 +
src/utils/logging_provider.h | 91 +
src/utils/long_adder.cpp | 280 +
src/utils/long_adder.h | 237 +
src/utils/long_adder_bench/CMakeLists.txt | 45 +
src/utils/long_adder_bench/long_adder_bench.cpp | 193 +
src/utils/macros.h | 28 +
src/utils/math.cpp | 53 +
src/{rdsn/include/dsn/utility => utils}/math.h | 0
src/utils/metrics.cpp | 727 +
src/utils/metrics.h | 1651 ++
src/utils/nth_element.h | 124 +
src/{rdsn/include/dsn/utility => utils}/optional.h | 0
src/utils/output_utils.cpp | 193 +
src/utils/output_utils.h | 230 +
src/utils/ports.h | 120 +
src/utils/preloadable.h | 39 +
src/utils/priority_queue.h | 142 +
src/utils/process_utils.cpp | 118 +
src/utils/process_utils.h | 78 +
src/utils/rand.cpp | 34 +
src/utils/rand.h | 65 +
src/utils/safe_strerror_posix.cpp | 117 +
src/utils/safe_strerror_posix.h | 36 +
src/utils/shared_io_service.cpp | 66 +
src/utils/shared_io_service.h | 56 +
src/utils/simple_logger.cpp | 289 +
src/utils/simple_logger.h | 93 +
.../include/dsn/utility => utils}/singleton.h | 0
src/utils/singleton_store.h | 124 +
src/utils/string_conv.h | 176 +
.../dsn/utility => utils}/string_splitter.h | 0
src/utils/strings.cpp | 428 +
src/utils/strings.h | 125 +
src/utils/synchronize.h | 183 +
src/utils/sys_exit_hook.h | 43 +
src/utils/test/CMakeLists.txt | 60 +
src/utils/test/TokenBucketTest.cpp | 134 +
src/utils/test/TokenBucketTest.h | 28 +
src/utils/test/autoref_ptr_test.cpp | 575 +
src/utils/test/binary_reader_test.cpp | 74 +
src/{rdsn/src => }/utils/test/clear.sh | 0
src/utils/test/command_manager_test.cpp | 70 +
.../src => }/utils/test/config-bad-section.ini | 0
src/{rdsn/src => }/utils/test/config-dup-key.ini | 0
.../src => }/utils/test/config-dup-section.ini | 0
src/{rdsn/src => }/utils/test/config-empty.ini | 0
src/{rdsn/src => }/utils/test/config-no-key.ini | 0
.../src => }/utils/test/config-no-section.ini | 0
.../src => }/utils/test/config-null-section.ini | 0
src/{rdsn/src => }/utils/test/config-sample.ini | 0
.../src => }/utils/test/config-unmatch-section.ini | 0
src/utils/test/configuration.cpp | 320 +
src/utils/test/endian_test.cpp | 74 +
src/utils/test/enum_helper_test.cpp | 278 +
src/utils/test/env.cpp | 316 +
src/utils/test/fail_point_test.cpp | 171 +
src/utils/test/file_system_test.cpp | 180 +
src/utils/test/file_utils.cpp | 359 +
src/utils/test/flag_test.cpp | 357 +
src/utils/test/fmt_logging_test.cpp | 53 +
src/utils/test/hostname_test.cpp | 129 +
src/utils/test/je_ctl_test.cpp | 109 +
src/utils/test/join_point_test.cpp | 90 +
src/utils/test/json_helper_test.cpp | 519 +
src/utils/test/latency_tracer_test.cpp | 155 +
src/utils/test/load_dump_object_test.cpp | 126 +
src/utils/test/lock.std.cpp | 65 +
src/utils/test/logger.cpp | 131 +
src/utils/test/logging.cpp | 69 +
src/utils/test/long_adder_test.cpp | 267 +
src/utils/test/main.cpp | 33 +
src/utils/test/metrics_test.cpp | 3260 +++
src/utils/test/nth_element_bench/CMakeLists.txt | 45 +
.../test/nth_element_bench/nth_element_bench.cpp | 230 +
src/utils/test/nth_element_test.cpp | 289 +
src/utils/test/nth_element_utils.h | 183 +
src/utils/test/output_utils_test.cpp | 205 +
src/utils/test/percentile_utils.h | 88 +
src/utils/test/priority_queue.cpp | 149 +
src/utils/test/rand_test.cpp | 86 +
src/{rdsn/src => }/utils/test/run.sh | 0
src/utils/test/sema.cpp | 107 +
src/utils/test/string_conv_test.cpp | 313 +
src/utils/test/time_utils_test.cpp | 102 +
.../token_bucket_throttling_controller_test.cpp | 167 +
src/utils/test/token_buckets_test.cpp | 59 +
src/utils/test/utils.cpp | 570 +
src/utils/test_macros.h | 41 +
src/utils/thread_access_checker.cpp | 48 +
src/utils/thread_access_checker.h | 48 +
src/utils/threadpool_code.h | 71 +
src/utils/threadpool_spec.h | 124 +
src/utils/throttling_controller.cpp | 183 +
src/{rdsn/src => }/utils/throttling_controller.h | 0
src/utils/time_utils.cpp | 54 +
src/utils/time_utils.h | 162 +
src/utils/timer.h | 62 +
src/utils/token_bucket_throttling_controller.cpp | 175 +
src/utils/token_bucket_throttling_controller.h | 100 +
src/utils/token_buckets.cpp | 46 +
src/utils/token_buckets.h | 43 +
src/utils/uniq_timestamp_us.h | 62 +
src/utils/utils.cpp | 180 +
src/utils/utils.h | 134 +
src/utils/work_queue.h | 101 +
src/utils/zlock_provider.h | 182 +
src/utils/zlocks.h | 201 +
src/zookeeper/CMakeLists.txt | 46 +
.../distributed_lock_service_zookeeper.cpp | 286 +
src/zookeeper/distributed_lock_service_zookeeper.h | 130 +
src/zookeeper/lock_struct.cpp | 802 +
src/zookeeper/lock_struct.h | 126 +
src/zookeeper/lock_types.h | 47 +
src/zookeeper/test/CMakeLists.txt | 56 +
src/{rdsn/src => }/zookeeper/test/clear.sh | 0
src/zookeeper/test/config-test.ini | 118 +
src/zookeeper/test/distributed_lock_zookeeper.cpp | 239 +
src/zookeeper/test/main.cpp | 86 +
src/{rdsn/src => }/zookeeper/test/run.sh | 0
src/zookeeper/zookeeper_error.cpp | 52 +
src/zookeeper/zookeeper_error.h | 36 +
src/zookeeper/zookeeper_session.cpp | 394 +
src/zookeeper/zookeeper_session.h | 203 +
src/zookeeper/zookeeper_session_mgr.cpp | 61 +
src/zookeeper/zookeeper_session_mgr.h | 52 +
thirdparty/CMakeLists.txt | 376 +-
thirdparty/fix_fds_for_macos.patch | 14 -
thirdparty/fix_prometheus-cpp_limits.patch | 10 +
thirdparty/fix_rocksdb-cmake-PORTABLE-option.patch | 75 +
thirdparty/fix_s2_build_with_absl_and_gtest.patch | 42 +
thirdparty/fix_s2_for_aarch64.patch | 10 -
thirdparty/fix_snappy-Wsign-compare-warning.patch | 26 +
2237 files changed, 206897 insertions(+), 241954 deletions(-)
create mode 100644 .devcontainer/devcontainer.json
create mode 100644 .github/actions/build_pegasus/action.yaml
create mode 100644 .github/actions/download_artifact/action.yaml
create mode 100644 .github/actions/rebuild_thirdparty_if_needed/action.yaml
create mode 100644 .github/actions/run_server_tests/action.yaml
create mode 100644 .github/actions/unpack_prebuilt_thirdparties/action.yaml
create mode 100644 .github/actions/upload_artifact/action.yaml
create mode 100755 .github/workflows/free_disk_space.sh
create mode 100644 .github/workflows/lint_and_test_collector.yml
create mode 100644 .github/workflows/lint_and_test_java-client.yml
create mode 100644 .github/workflows/lint_and_test_scala-client.yml
delete mode 100644 .github/workflows/pegasus-regular-build.yml
create mode 100644 .github/workflows/regular-build.yml
delete mode 100644 .github/workflows/test_java-client.yml
create mode 100644 .github/workflows/test_nodejs-client.yml
create mode 100644 .github/workflows/test_python-client.yml
delete mode 100644 .github/workflows/test_scala-client.yml
create mode 100644 DISCLAIMER
delete mode 100644 DISCLAIMER-WIP
create mode 100644 HISTORY.md
create mode 100644 collector/Makefile
create mode 100644 collector/README.md
create mode 100644 collector/aggregate/aggregatable.go
create mode 100644 collector/aggregate/aggregator.go
create mode 100644 collector/aggregate/aggregator_test.go
create mode 100644 collector/aggregate/history.go
create mode 100644 collector/aggregate/history_test.go
create mode 100644 collector/aggregate/hook.go
create mode 100644 collector/aggregate/hook_test.go
create mode 100644 collector/aggregate/perf_client.go
create mode 100644 collector/aggregate/perf_client_test.go
create mode 100644 collector/aggregate/perf_counter_decoder.go
create mode 100644 collector/aggregate/perf_counter_decoder_test.go
create mode 100644 collector/aggregate/perf_session.go
create mode 100644 collector/aggregate/table_stats.go
create mode 100644 collector/avail/detector.go
create mode 100644 collector/config.yml
create mode 100644 collector/go.mod
create mode 100644 collector/go.sum
create mode 100644 collector/hotspot/algo.go
create mode 100644 collector/main.go
create mode 100644 collector/metrics/meta_server_metrics.go
create mode 100644 collector/metrics/metric_collector.go
create mode 100644 collector/metrics/replica_server_metrics.go
create mode 100644 collector/sink/falcon_sink.go
create mode 100644 collector/sink/prometheus_sink.go
create mode 100644 collector/sink/sink.go
create mode 100644 collector/templates/index.html
create mode 100644 collector/usage/usage_recorder.go
create mode 100644 collector/webui/index.go
create mode 100644 collector/webui/tables.go
create mode 100644 collector/webui/webserver.go
delete mode 100644 docker/ci-env/Dockerfile
delete mode 100644 docker/pegasus-build-env/centos6/Dockerfile
delete mode 100644 docker/pegasus-build-env/ubuntu1604/Dockerfile
create mode 100644 docker/pegasus-build-env/ubuntu2204/Dockerfile
delete mode 100644 go-client/idl/admin.thrift
delete mode 100644 go-client/idl/admin/GoUnusedProtection__.go
delete mode 100644 go-client/idl/admin/admin-consts.go
delete mode 100644 go-client/idl/admin/admin.go
delete mode 100644 go-client/idl/base.thrift
delete mode 100644 go-client/idl/cmd.thrift
delete mode 100644 go-client/idl/cmd/GoUnusedProtection__.go
delete mode 100644 go-client/idl/cmd/cmd-consts.go
delete mode 100644 go-client/idl/cmd/cmd.go
delete mode 100644 go-client/idl/radmin.thrift
delete mode 100644 go-client/idl/radmin/GoUnusedProtection__.go
delete mode 100644 go-client/idl/radmin/radmin-consts.go
delete mode 100644 go-client/idl/radmin/radmin.go
delete mode 100644 go-client/idl/replication.thrift
delete mode 100644 go-client/idl/replication/GoUnusedProtection__.go
delete mode 100644 go-client/idl/replication/replication-consts.go
delete mode 100644 go-client/idl/replication/replication.go
delete mode 100644 go-client/idl/rrdb.thrift
delete mode 100644 go-client/idl/rrdb/GoUnusedProtection__.go
delete mode 100644 go-client/idl/rrdb/rrdb-consts.go
delete mode 100644 go-client/idl/rrdb/rrdb.go
delete mode 100755 go-client/test.sh
create mode 100644 idl/backup.thrift
create mode 100644 idl/bulk_load.thrift
create mode 100644 idl/command.thrift
create mode 100644 idl/duplication.thrift
create mode 100644 idl/meta_admin.thrift
create mode 100644 idl/metadata.thrift
create mode 100644 idl/partition_split.thrift
create mode 100644 idl/replica_admin.thrift
create mode 100644 idl/security.thrift
delete mode 100644 java-client/configuration/log4j.properties
delete mode 100644 java-client/idl/apache-licence-template
delete mode 100644 java-client/idl/base.thrift
delete mode 100644 java-client/idl/meta_admin.thrift
delete mode 100755 java-client/idl/recompile_thrift.sh
delete mode 100644 java-client/idl/replication.thrift
delete mode 100644 java-client/idl/rrdb.thrift
delete mode 100644 java-client/idl/security.thrift
delete mode 100755 java-client/scripts/ci-test.sh
create mode 100755 java-client/scripts/recompile_thrift.sh
delete mode 100644 java-client/src/assembly/dep.xml
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/ListAppInfoType.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/list_apps_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/util/PropertyUtils.java
delete mode 100644 java-client/src/test/resource/pegasus.properties
rename java-client/{configuration => src/test/resources}/pegasus.properties (100%)
create mode 100644 java-client/src/test/resources/simplelogger.properties
delete mode 100644 nodejs-client/idl/base.thrift
delete mode 100755 nodejs-client/idl/recompile_thrift.sh
delete mode 100644 nodejs-client/idl/replication.thrift
delete mode 100644 nodejs-client/idl/rrdb.thrift
create mode 100755 nodejs-client/recompile_thrift.sh
delete mode 100644 nodejs-client/src/dsn/base_types.js
create mode 100644 nodejs-client/src/dsn/dsn_types.js
delete mode 100644 nodejs-client/src/dsn/meta.js
delete mode 100644 nodejs-client/src/dsn/replication_types.js
delete mode 100644 nodejs-client/src/dsn/rrdb.js
delete mode 100644 nodejs-client/src/dsn/rrdb_types.js
delete mode 100644 python-client/idl/base.thrift
delete mode 100644 python-client/idl/replication.thrift
delete mode 100644 python-client/idl/rrdb.thrift
delete mode 100644 python-client/pypegasus/replication/__init__.py
delete mode 100644 python-client/pypegasus/replication/constants.py
delete mode 100644 python-client/pypegasus/replication/replication.py
delete mode 100644 python-client/pypegasus/replication/ttypes.py
delete mode 100644 python-client/pypegasus/rrdb/__init__.py
delete mode 100644 python-client/pypegasus/rrdb/constants.py
delete mode 100644 python-client/pypegasus/rrdb/meta.py
delete mode 100644 python-client/pypegasus/rrdb/rrdb.py
delete mode 100644 python-client/pypegasus/rrdb/ttypes.py
create mode 100644 python-client/requirement.txt
delete mode 100755 scala-client/scripts/ci-test.sh
delete mode 100755 scala-client/scripts/format-all.sh
create mode 100755 scripts/check_license.py
create mode 100755 scripts/download_hadoop.sh
create mode 100755 scripts/download_package.sh
create mode 100755 scripts/download_zk.sh
create mode 100644 src/aio/CMakeLists.txt
create mode 100644 src/aio/aio_provider.cpp
create mode 100644 src/aio/aio_provider.h
create mode 100644 src/aio/aio_task.cpp
create mode 100644 src/aio/aio_task.h
create mode 100644 src/aio/disk_engine.cpp
create mode 100644 src/aio/disk_engine.h
create mode 100644 src/aio/file_io.cpp
create mode 100644 src/aio/file_io.h
create mode 100644 src/aio/native_linux_aio_provider.cpp
create mode 100644 src/aio/native_linux_aio_provider.h
create mode 100644 src/aio/test/CMakeLists.txt
create mode 100644 src/aio/test/aio.cpp
rename src/{rdsn/src => }/aio/test/clear.sh (100%)
create mode 100644 src/aio/test/config.ini
rename src/{rdsn/src => }/aio/test/copy_source.txt (100%)
create mode 100644 src/aio/test/main.cpp
rename src/{rdsn/src => }/aio/test/run.sh (100%)
create mode 100644 src/base/test/redact_sensitive_string_test.cpp
create mode 100644 src/block_service/CMakeLists.txt
create mode 100644 src/block_service/block_service.h
create mode 100644 src/block_service/block_service_manager.cpp
create mode 100644 src/block_service/block_service_manager.h
create mode 100644 src/block_service/hdfs/CMakeLists.txt
create mode 100644 src/block_service/hdfs/hdfs_service.cpp
create mode 100644 src/block_service/hdfs/hdfs_service.h
create mode 100644 src/block_service/local/CMakeLists.txt
create mode 100644 src/block_service/local/local_service.cpp
create mode 100644 src/block_service/local/local_service.h
create mode 100644 src/block_service/test/CMakeLists.txt
create mode 100644 src/block_service/test/block_service_manager_test.cpp
create mode 100644 src/block_service/test/block_service_mock.h
rename src/{rdsn/src => }/block_service/test/clear.sh (100%)
create mode 100644 src/block_service/test/config-test.ini
create mode 100644 src/block_service/test/hdfs_service_test.cpp
create mode 100644 src/block_service/test/local_service_test.cpp
create mode 100644 src/block_service/test/main.cpp
rename src/{rdsn/src => }/block_service/test/run.sh (100%)
create mode 100644 src/client/CMakeLists.txt
create mode 100644 src/client/partition_resolver.cpp
create mode 100644 src/client/partition_resolver.h
create mode 100644 src/client/partition_resolver_manager.cpp
create mode 100644 src/client/partition_resolver_manager.h
create mode 100644 src/client/partition_resolver_simple.cpp
create mode 100644 src/client/partition_resolver_simple.h
create mode 100644 src/client/replication_ddl_client.cpp
create mode 100644 src/client/replication_ddl_client.h
create mode 100644 src/client/test/CMakeLists.txt
create mode 100644 src/client/test/config.ini
create mode 100644 src/client/test/ddl_client_test.cpp
create mode 100644 src/client/test/main.cpp
create mode 100755 src/client/test/run.sh
create mode 100644 src/common/CMakeLists.txt
create mode 100644 src/common/backup_common.cpp
create mode 100644 src/common/backup_common.h
rename src/{rdsn/src => }/common/bulk_load_common.cpp (100%)
create mode 100644 src/common/bulk_load_common.h
create mode 100644 src/common/common.cpp
rename src/{rdsn/include/dsn/dist => common}/common.h (100%)
create mode 100644 src/common/consensus.thrift
create mode 100644 src/common/duplication_common.cpp
create mode 100644 src/common/duplication_common.h
create mode 100644 src/common/duplication_internal.thrift
create mode 100644 src/common/fs_manager.cpp
create mode 100644 src/common/fs_manager.h
create mode 100644 src/common/gpid.h
create mode 100644 src/common/json_helper.h
create mode 100644 src/common/manual_compact.h
create mode 100644 src/common/partition_split_common.h
create mode 100644 src/common/replica_envs.h
create mode 100644 src/common/replication.codes.h
create mode 100644 src/common/replication_common.cpp
create mode 100644 src/common/replication_common.h
create mode 100644 src/common/replication_enums.h
create mode 100644 src/common/replication_other_types.h
create mode 100644 src/common/serialization_helper/dsn_types.h
create mode 100644 src/common/serialization_helper/thrift_helper.h
create mode 100644 src/common/storage_serverlet.h
create mode 100644 src/common/test/CMakeLists.txt
create mode 100644 src/common/test/common_test.cpp
create mode 100644 src/common/test/config-test.ini
create mode 100644 src/common/test/duplication_common_test.cpp
create mode 100644 src/common/test/fs_manager_test.cpp
create mode 100644 src/common/test/main.cpp
create mode 100644 src/common/test/replication_common_test.cpp
create mode 100755 src/common/test/run.sh
create mode 100644 src/failure_detector/CMakeLists.txt
create mode 100644 src/failure_detector/failure_detector.cpp
create mode 100644 src/failure_detector/failure_detector.h
create mode 100644 src/failure_detector/failure_detector_multimaster.cpp
create mode 100644 src/failure_detector/failure_detector_multimaster.h
create mode 100644 src/failure_detector/fd.client.h
create mode 100644 src/failure_detector/fd.code.definition.h
create mode 100644 src/failure_detector/fd.server.h
create mode 100644 src/failure_detector/fd.thrift
create mode 100644 src/failure_detector/test/CMakeLists.txt
rename src/{rdsn/src => }/failure_detector/test/clear.sh (100%)
create mode 100644 src/failure_detector/test/config-test.ini
create mode 100644 src/failure_detector/test/config-whitelist-test-failed.ini
create mode 100644 src/failure_detector/test/config-whitelist-test.ini
create mode 100644 src/failure_detector/test/failure_detector.cpp
rename src/{rdsn/src => }/failure_detector/test/gtest.filter (100%)
create mode 100644 src/failure_detector/test/main.cpp
rename src/{rdsn/src => }/failure_detector/test/run.sh (100%)
create mode 100644 src/http/CMakeLists.txt
create mode 100644 src/http/builtin_http_calls.cpp
create mode 100644 src/http/builtin_http_calls.h
create mode 100644 src/http/config_http_service.cpp
create mode 100644 src/http/http_call_registry.h
create mode 100644 src/http/http_client.cpp
create mode 100644 src/http/http_client.h
create mode 100644 src/http/http_message_parser.cpp
create mode 100644 src/http/http_message_parser.h
create mode 100644 src/http/http_method.h
create mode 100644 src/http/http_server.cpp
create mode 100644 src/http/http_server.h
create mode 100644 src/http/http_server_impl.h
create mode 100644 src/http/http_status_code.cpp
create mode 100644 src/http/http_status_code.h
create mode 100644 src/http/pprof_http_service.cpp
create mode 100644 src/http/pprof_http_service.h
rename src/{rdsn/src => }/http/service_version.cpp (100%)
rename src/{rdsn/src => }/http/service_version.h (100%)
create mode 100644 src/http/test/CMakeLists.txt
create mode 100644 src/http/test/config-test.ini
create mode 100644 src/http/test/http_client_test.cpp
create mode 100644 src/http/test/http_server_test.cpp
create mode 100644 src/http/test/http_status_code_test.cpp
create mode 100644 src/http/test/main.cpp
rename src/{rdsn/src => }/http/test/run.sh (100%)
create mode 100644 src/http/test/uri_decoder_test.cpp
create mode 100644 src/http/uri_decoder.cpp
create mode 100644 src/http/uri_decoder.h
create mode 100644 src/meta/CMakeLists.txt
create mode 100644 src/meta/app_balance_policy.cpp
create mode 100644 src/meta/app_balance_policy.h
create mode 100644 src/meta/app_env_validator.cpp
create mode 100644 src/meta/app_env_validator.h
create mode 100644 src/meta/backup_engine.cpp
create mode 100644 src/meta/backup_engine.h
create mode 100644 src/meta/cluster_balance_policy.cpp
create mode 100644 src/meta/cluster_balance_policy.h
create mode 100644 src/meta/distributed_lock_service_simple.cpp
create mode 100644 src/meta/distributed_lock_service_simple.h
create mode 100644 src/meta/dump_file.h
create mode 100644 src/meta/duplication/duplication_info.cpp
create mode 100644 src/meta/duplication/duplication_info.h
create mode 100644 src/meta/duplication/meta_duplication_service.cpp
create mode 100644 src/meta/duplication/meta_duplication_service.h
create mode 100644 src/meta/greedy_load_balancer.cpp
create mode 100644 src/meta/greedy_load_balancer.h
create mode 100644 src/meta/load_balance_policy.cpp
create mode 100644 src/meta/load_balance_policy.h
create mode 100644 src/meta/meta_backup_service.cpp
create mode 100644 src/meta/meta_backup_service.h
create mode 100644 src/meta/meta_bulk_load_ingestion_context.cpp
create mode 100644 src/meta/meta_bulk_load_ingestion_context.h
create mode 100644 src/meta/meta_bulk_load_service.cpp
create mode 100644 src/meta/meta_bulk_load_service.h
create mode 100644 src/meta/meta_data.cpp
create mode 100644 src/meta/meta_data.h
create mode 100644 src/meta/meta_http_service.cpp
create mode 100644 src/meta/meta_http_service.h
create mode 100644 src/meta/meta_options.cpp
create mode 100644 src/meta/meta_options.h
create mode 100644 src/meta/meta_rpc_types.h
create mode 100644 src/meta/meta_server_failure_detector.cpp
create mode 100644 src/meta/meta_server_failure_detector.h
create mode 100644 src/meta/meta_service.cpp
create mode 100644 src/meta/meta_service.h
create mode 100644 src/meta/meta_service_app.cpp
create mode 100644 src/meta/meta_service_app.h
create mode 100644 src/meta/meta_split_service.cpp
create mode 100644 src/meta/meta_split_service.h
create mode 100644 src/meta/meta_state_service.h
create mode 100644 src/meta/meta_state_service_simple.cpp
create mode 100644 src/meta/meta_state_service_simple.h
create mode 100644 src/meta/meta_state_service_utils.cpp
create mode 100644 src/meta/meta_state_service_utils.h
create mode 100644 src/meta/meta_state_service_utils_impl.h
create mode 100644 src/meta/meta_state_service_zookeeper.cpp
create mode 100644 src/meta/meta_state_service_zookeeper.h
create mode 100644 src/meta/partition_guardian.cpp
create mode 100644 src/meta/partition_guardian.h
create mode 100644 src/meta/server_load_balancer.cpp
create mode 100644 src/meta/server_load_balancer.h
create mode 100644 src/meta/server_state.cpp
create mode 100644 src/meta/server_state.h
create mode 100644 src/meta/server_state_restore.cpp
create mode 100644 src/meta/table_metrics.cpp
create mode 100644 src/meta/table_metrics.h
create mode 100644 src/meta/test/CMakeLists.txt
create mode 100644 src/meta/test/backup_test.cpp
create mode 100644 src/meta/test/balancer_simulator/CMakeLists.txt
create mode 100644 src/meta/test/balancer_simulator/balancer_simulator.cpp
create mode 100644 src/meta/test/balancer_validator.cpp
rename src/{rdsn/src => }/meta/test/clear.sh (100%)
create mode 100644 src/meta/test/cluster_balance_policy_test.cpp
create mode 100644 src/meta/test/config-test.ini
create mode 100644 src/meta/test/copy_replica_operation_test.cpp
rename src/{rdsn/src => }/meta/test/dummy_balancer.h (100%)
create mode 100644 src/meta/test/dump_file.cpp
create mode 100644 src/meta/test/duplication_info_test.cpp
create mode 100644 src/meta/test/ford_fulkerson_test.cpp
create mode 100644 src/meta/test/json_compacity.cpp
create mode 100644 src/meta/test/main.cpp
create mode 100644 src/meta/test/meta_app_envs_test.cpp
create mode 100644 src/meta/test/meta_app_operation_test.cpp
create mode 100644 src/meta/test/meta_backup_test.cpp
create mode 100644 src/meta/test/meta_bulk_load_ingestion_test.cpp
create mode 100644 src/meta/test/meta_bulk_load_service_test.cpp
create mode 100644 src/meta/test/meta_data.cpp
create mode 100644 src/meta/test/meta_duplication_service_test.cpp
create mode 100644 src/meta/test/meta_http_service_test.cpp
create mode 100644 src/meta/test/meta_mauanl_compaction_test.cpp
create mode 100644 src/meta/test/meta_partition_guardian_test.cpp
create mode 100644 src/meta/test/meta_service_test.cpp
create mode 100644 src/meta/test/meta_service_test_app.h
create mode 100644 src/meta/test/meta_split_service_test.cpp
create mode 100644 src/meta/test/meta_state/CMakeLists.txt
rename src/{rdsn/src => }/meta/test/meta_state/clear.sh (100%)
create mode 100644 src/meta/test/meta_state/config-test.ini
rename src/{rdsn/src => }/meta/test/meta_state/gtest.filter (100%)
create mode 100644 src/meta/test/meta_state/main.cpp
create mode 100644 src/meta/test/meta_state/meta_state_service.cpp
rename src/{rdsn/src => }/meta/test/meta_state/run.sh (100%)
create mode 100644 src/meta/test/meta_state_service_utils_test.cpp
create mode 100644 src/meta/test/meta_test_base.cpp
create mode 100644 src/meta/test/meta_test_base.h
create mode 100644 src/meta/test/misc/misc.cpp
create mode 100644 src/meta/test/misc/misc.h
create mode 100755 src/meta/test/run.sh
create mode 100644 src/meta/test/server_state_restore_test.cpp
create mode 100644 src/meta/test/server_state_test.cpp
create mode 100644 src/meta/test/state_sync_test.cpp
rename src/{rdsn/src => }/meta/test/suite1 (100%)
rename src/{rdsn/src => }/meta/test/suite2 (100%)
create mode 100644 src/meta/test/update_configuration_test.cpp
create mode 100644 src/nfs/CMakeLists.txt
create mode 100644 src/nfs/nfs.thrift
create mode 100644 src/nfs/nfs_client_impl.cpp
create mode 100644 src/nfs/nfs_client_impl.h
create mode 100644 src/nfs/nfs_code_definition.h
create mode 100644 src/nfs/nfs_node.cpp
create mode 100644 src/nfs/nfs_node.h
create mode 100644 src/nfs/nfs_node_simple.cpp
create mode 100644 src/nfs/nfs_node_simple.h
create mode 100644 src/nfs/nfs_server_impl.cpp
create mode 100644 src/nfs/nfs_server_impl.h
create mode 100644 src/nfs/test/CMakeLists.txt
rename src/{rdsn/src => }/nfs/test/clear.sh (100%)
rename src/{rdsn/src => }/nfs/test/config.ini (100%)
create mode 100644 src/nfs/test/main.cpp
rename src/{rdsn/src => }/nfs/test/nfs_test_file1 (100%)
rename src/{rdsn/src => }/nfs/test/nfs_test_file2 (100%)
rename src/{rdsn/src => }/nfs/test/run.sh (100%)
create mode 100644 src/perf_counter/CMakeLists.txt
create mode 100644 src/perf_counter/perf_counter.cpp
create mode 100644 src/perf_counter/perf_counter.h
create mode 100644 src/perf_counter/perf_counter_atomic.cpp
create mode 100644 src/perf_counter/perf_counter_atomic.h
create mode 100644 src/perf_counter/perf_counter_utils.h
create mode 100644 src/perf_counter/perf_counter_wrapper.h
create mode 100644 src/perf_counter/perf_counters.cpp
create mode 100644 src/perf_counter/perf_counters.h
create mode 100644 src/perf_counter/test/CMakeLists.txt
rename src/{rdsn/src => }/perf_counter/test/clear.sh (100%)
create mode 100644 src/perf_counter/test/main.cpp
create mode 100644 src/perf_counter/test/perf_counter_test.cpp
create mode 100644 src/perf_counter/test/perf_counters_test.cpp
rename src/{rdsn/src => }/perf_counter/test/run.sh (100%)
create mode 100644 src/ranger/CMakeLists.txt
create mode 100644 src/ranger/access_type.h
create mode 100644 src/ranger/ranger_resource_policy.cpp
create mode 100644 src/ranger/ranger_resource_policy.h
create mode 100644 src/ranger/ranger_resource_policy_manager.cpp
create mode 100644 src/ranger/ranger_resource_policy_manager.h
create mode 100644 src/ranger/test/CMakeLists.txt
create mode 100644 src/ranger/test/main.cpp
create mode 100644 src/ranger/test/ranger_resource_policy_manager_test.cpp
create mode 100644 src/ranger/test/ranger_resource_policy_test.cpp
create mode 100755 src/ranger/test/run.sh
delete mode 100644 src/rdsn/include/dsn/c/api_common.h
delete mode 100644 src/rdsn/include/dsn/c/api_layer1.h
delete mode 100644 src/rdsn/include/dsn/c/api_task.h
delete mode 100644 src/rdsn/include/dsn/c/api_utilities.h
delete mode 100644 src/rdsn/include/dsn/c/app_model.h
delete mode 100644 src/rdsn/include/dsn/cpp/json_helper.h
delete mode 100644 src/rdsn/include/dsn/cpp/message_utils.h
delete mode 100644 src/rdsn/include/dsn/cpp/pipeline.h
delete mode 100644 src/rdsn/include/dsn/cpp/rpc_holder.h
delete mode 100644 src/rdsn/include/dsn/cpp/rpc_stream.h
delete mode 100644 src/rdsn/include/dsn/cpp/serialization.h
delete mode 100644 src/rdsn/include/dsn/cpp/serialization_helper/dsn_types.h
delete mode 100644 src/rdsn/include/dsn/cpp/serialization_helper/thrift_helper.h
delete mode 100644 src/rdsn/include/dsn/cpp/serverlet.h
delete mode 100644 src/rdsn/include/dsn/cpp/service_app.h
delete mode 100644 src/rdsn/include/dsn/dist/block_service.h
delete mode 100644 src/rdsn/include/dsn/dist/distributed_lock_service.h
delete mode 100644 src/rdsn/include/dsn/dist/failure_detector.h
delete mode 100644 src/rdsn/include/dsn/dist/failure_detector/failure_detector.h
delete mode 100644 src/rdsn/include/dsn/dist/failure_detector/fd.client.h
delete mode 100644 src/rdsn/include/dsn/dist/failure_detector/fd.code.definition.h
delete mode 100644 src/rdsn/include/dsn/dist/failure_detector/fd.server.h
delete mode 100644 src/rdsn/include/dsn/dist/failure_detector_multimaster.h
delete mode 100644 src/rdsn/include/dsn/dist/fmt_logging.h
delete mode 100644 src/rdsn/include/dsn/dist/meta_state_service.h
delete mode 100644 src/rdsn/include/dsn/dist/nfs_node.h
delete mode 100644 src/rdsn/include/dsn/dist/remote_command.h
delete mode 100644 src/rdsn/include/dsn/dist/replication.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/duplication_common.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/meta_service_app.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/mutation_duplicator.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/mutation_log_tool.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/partition_resolver.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replica_base.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replica_envs.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replica_test_utils.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replication.codes.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replication_app_base.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replication_ddl_client.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replication_enums.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replication_other_types.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replication_service_app.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/replication_types.h
delete mode 100644 src/rdsn/include/dsn/dist/replication/storage_serverlet.h
delete mode 100644 src/rdsn/include/dsn/http/http_server.h
delete mode 100644 src/rdsn/include/dsn/perf_counter/perf_counter.h
delete mode 100644 src/rdsn/include/dsn/perf_counter/perf_counter_utils.h
delete mode 100644 src/rdsn/include/dsn/perf_counter/perf_counter_wrapper.h
delete mode 100644 src/rdsn/include/dsn/perf_counter/perf_counters.h
delete mode 100644 src/rdsn/include/dsn/service_api_c.h
delete mode 100644 src/rdsn/include/dsn/service_api_cpp.h
delete mode 100644 src/rdsn/include/dsn/tool-api/aio_task.h
delete mode 100644 src/rdsn/include/dsn/tool-api/async_calls.h
delete mode 100644 src/rdsn/include/dsn/tool-api/auto_codes.h
delete mode 100644 src/rdsn/include/dsn/tool-api/command_manager.h
delete mode 100644 src/rdsn/include/dsn/tool-api/env_provider.h
delete mode 100644 src/rdsn/include/dsn/tool-api/file_io.h
delete mode 100644 src/rdsn/include/dsn/tool-api/future_types.h
delete mode 100644 src/rdsn/include/dsn/tool-api/global_config.h
delete mode 100644 src/rdsn/include/dsn/tool-api/gpid.h
delete mode 100644 src/rdsn/include/dsn/tool-api/group_address.h
delete mode 100644 src/rdsn/include/dsn/tool-api/logging_provider.h
delete mode 100644 src/rdsn/include/dsn/tool-api/message_parser.h
delete mode 100644 src/rdsn/include/dsn/tool-api/network.h
delete mode 100644 src/rdsn/include/dsn/tool-api/rpc_address.h
delete mode 100644 src/rdsn/include/dsn/tool-api/rpc_message.h
delete mode 100644 src/rdsn/include/dsn/tool-api/task.h
delete mode 100644 src/rdsn/include/dsn/tool-api/task_code.h
delete mode 100644 src/rdsn/include/dsn/tool-api/task_queue.h
delete mode 100644 src/rdsn/include/dsn/tool-api/task_spec.h
delete mode 100644 src/rdsn/include/dsn/tool-api/task_tracker.h
delete mode 100644 src/rdsn/include/dsn/tool-api/task_worker.h
delete mode 100644 src/rdsn/include/dsn/tool-api/thread_access_checker.h
delete mode 100644 src/rdsn/include/dsn/tool-api/threadpool_code.h
delete mode 100644 src/rdsn/include/dsn/tool-api/threadpool_spec.h
delete mode 100644 src/rdsn/include/dsn/tool-api/timer_service.h
delete mode 100644 src/rdsn/include/dsn/tool-api/uniq_timestamp_us.h
delete mode 100644 src/rdsn/include/dsn/tool-api/zlocks.h
delete mode 100644 src/rdsn/include/dsn/tool/nativerun.h
delete mode 100644 src/rdsn/include/dsn/tool/node_scoper.h
delete mode 100644 src/rdsn/include/dsn/tool/providers.common.h
delete mode 100644 src/rdsn/include/dsn/tool/simulator.h
delete mode 100644 src/rdsn/include/dsn/tool_api.h
delete mode 100644 src/rdsn/include/dsn/toollet/fault_injector.h
delete mode 100644 src/rdsn/include/dsn/toollet/profiler.h
delete mode 100644 src/rdsn/include/dsn/toollet/tracer.h
delete mode 100644 src/rdsn/include/dsn/utility/TokenBucket.h
delete mode 100644 src/rdsn/include/dsn/utility/absl/base/internal/invoke.h
delete mode 100644 src/rdsn/include/dsn/utility/absl/utility/utility.h
delete mode 100644 src/rdsn/include/dsn/utility/alloc.h
delete mode 100644 src/rdsn/include/dsn/utility/apply.h
delete mode 100644 src/rdsn/include/dsn/utility/autoref_ptr.h
delete mode 100644 src/rdsn/include/dsn/utility/binary_reader.h
delete mode 100644 src/rdsn/include/dsn/utility/binary_writer.h
delete mode 100644 src/rdsn/include/dsn/utility/blob.h
delete mode 100644 src/rdsn/include/dsn/utility/casts.h
delete mode 100644 src/rdsn/include/dsn/utility/clock.h
delete mode 100644 src/rdsn/include/dsn/utility/config_api.h
delete mode 100644 src/rdsn/include/dsn/utility/config_helper.h
delete mode 100644 src/rdsn/include/dsn/utility/configuration.h
delete mode 100644 src/rdsn/include/dsn/utility/customizable_id.h
delete mode 100644 src/rdsn/include/dsn/utility/defer.h
delete mode 100644 src/rdsn/include/dsn/utility/dlib.h
delete mode 100644 src/rdsn/include/dsn/utility/endians.h
delete mode 100644 src/rdsn/include/dsn/utility/enum_helper.h
delete mode 100644 src/rdsn/include/dsn/utility/error_code.h
delete mode 100644 src/rdsn/include/dsn/utility/errors.h
delete mode 100644 src/rdsn/include/dsn/utility/exp_delay.h
delete mode 100644 src/rdsn/include/dsn/utility/extensible_object.h
delete mode 100644 src/rdsn/include/dsn/utility/factory_store.h
delete mode 100644 src/rdsn/include/dsn/utility/fail_point.h
delete mode 100644 src/rdsn/include/dsn/utility/filesystem.h
delete mode 100644 src/rdsn/include/dsn/utility/fixed_size_buffer_pool.h
delete mode 100644 src/rdsn/include/dsn/utility/flags.h
delete mode 100644 src/rdsn/include/dsn/utility/hpc_locks/autoresetevent.h
delete mode 100644 src/rdsn/include/dsn/utility/hpc_locks/benaphore.h
delete mode 100644 src/rdsn/include/dsn/utility/hpc_locks/rwlock.h
delete mode 100644 src/rdsn/include/dsn/utility/hpc_locks/sema.h
delete mode 100644 src/rdsn/include/dsn/utility/join_point.h
delete mode 100644 src/rdsn/include/dsn/utility/link.h
delete mode 100644 src/rdsn/include/dsn/utility/long_adder.h
delete mode 100644 src/rdsn/include/dsn/utility/metrics.h
delete mode 100644 src/rdsn/include/dsn/utility/nth_element.h
delete mode 100644 src/rdsn/include/dsn/utility/output_utils.h
delete mode 100644 src/rdsn/include/dsn/utility/ports.h
delete mode 100644 src/rdsn/include/dsn/utility/preloadable.h
delete mode 100644 src/rdsn/include/dsn/utility/priority_queue.h
delete mode 100644 src/rdsn/include/dsn/utility/process_utils.h
delete mode 100644 src/rdsn/include/dsn/utility/rand.h
delete mode 100644 src/rdsn/include/dsn/utility/safe_strerror_posix.h
delete mode 100644 src/rdsn/include/dsn/utility/singleton_store.h
delete mode 100644 src/rdsn/include/dsn/utility/smart_pointers.h
delete mode 100644 src/rdsn/include/dsn/utility/string_conv.h
delete mode 100644 src/rdsn/include/dsn/utility/string_view.h
delete mode 100644 src/rdsn/include/dsn/utility/strings.h
delete mode 100644 src/rdsn/include/dsn/utility/synchronize.h
delete mode 100644 src/rdsn/include/dsn/utility/sys_exit_hook.h
delete mode 100644 src/rdsn/include/dsn/utility/timer.h
delete mode 100644 src/rdsn/include/dsn/utility/utils.h
delete mode 100644 src/rdsn/include/dsn/utility/work_queue.h
delete mode 100644 src/rdsn/include/dsn/utils/latency_tracer.h
delete mode 100644 src/rdsn/include/dsn/utils/time_utils.h
delete mode 100644 src/rdsn/include/dsn/utils/token_bucket_throttling_controller.h
delete mode 100644 src/rdsn/include/dsn/utils/token_buckets.h
delete mode 100644 src/rdsn/src/CMakeLists.txt
delete mode 100644 src/rdsn/src/aio/CMakeLists.txt
delete mode 100644 src/rdsn/src/aio/aio_provider.cpp
delete mode 100644 src/rdsn/src/aio/aio_provider.h
delete mode 100644 src/rdsn/src/aio/aio_task.cpp
delete mode 100644 src/rdsn/src/aio/disk_engine.cpp
delete mode 100644 src/rdsn/src/aio/disk_engine.h
delete mode 100644 src/rdsn/src/aio/file_io.cpp
delete mode 100644 src/rdsn/src/aio/native_linux_aio_provider.cpp
delete mode 100644 src/rdsn/src/aio/native_linux_aio_provider.h
delete mode 100644 src/rdsn/src/aio/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/aio/test/aio.cpp
delete mode 100644 src/rdsn/src/aio/test/config.ini
delete mode 100644 src/rdsn/src/aio/test/main.cpp
delete mode 100644 src/rdsn/src/block_service/CMakeLists.txt
delete mode 100644 src/rdsn/src/block_service/block_service_manager.cpp
delete mode 100644 src/rdsn/src/block_service/block_service_manager.h
delete mode 100644 src/rdsn/src/block_service/directio_writable_file.cpp
delete mode 100644 src/rdsn/src/block_service/directio_writable_file.h
delete mode 100644 src/rdsn/src/block_service/fds/CMakeLists.txt
delete mode 100644 src/rdsn/src/block_service/fds/fds_service.cpp
delete mode 100644 src/rdsn/src/block_service/fds/fds_service.h
delete mode 100644 src/rdsn/src/block_service/hdfs/CMakeLists.txt
delete mode 100644 src/rdsn/src/block_service/hdfs/hdfs_service.cpp
delete mode 100644 src/rdsn/src/block_service/hdfs/hdfs_service.h
delete mode 100644 src/rdsn/src/block_service/local/CMakeLists.txt
delete mode 100644 src/rdsn/src/block_service/local/local_service.cpp
delete mode 100644 src/rdsn/src/block_service/local/local_service.h
delete mode 100644 src/rdsn/src/block_service/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/block_service/test/block_service_manager_test.cpp
delete mode 100644 src/rdsn/src/block_service/test/block_service_mock.h
delete mode 100644 src/rdsn/src/block_service/test/config-test.ini
delete mode 100644 src/rdsn/src/block_service/test/fds_service_test.cpp
delete mode 100644 src/rdsn/src/block_service/test/hdfs_service_test.cpp
delete mode 100644 src/rdsn/src/block_service/test/local_service_test.cpp
delete mode 100644 src/rdsn/src/block_service/test/main.cpp
delete mode 100644 src/rdsn/src/client/CMakeLists.txt
delete mode 100644 src/rdsn/src/client/partition_resolver.cpp
delete mode 100644 src/rdsn/src/client/partition_resolver_manager.cpp
delete mode 100644 src/rdsn/src/client/partition_resolver_manager.h
delete mode 100644 src/rdsn/src/client/partition_resolver_simple.cpp
delete mode 100644 src/rdsn/src/client/partition_resolver_simple.h
delete mode 100644 src/rdsn/src/client/replication_ddl_client.cpp
delete mode 100644 src/rdsn/src/common/CMakeLists.txt
delete mode 100644 src/rdsn/src/common/backup.thrift
delete mode 100644 src/rdsn/src/common/backup_common.cpp
delete mode 100644 src/rdsn/src/common/backup_common.h
delete mode 100644 src/rdsn/src/common/bulk_load.thrift
delete mode 100644 src/rdsn/src/common/bulk_load_common.h
delete mode 100644 src/rdsn/src/common/common.cpp
delete mode 100644 src/rdsn/src/common/consensus.thrift
delete mode 100644 src/rdsn/src/common/duplication.thrift
delete mode 100644 src/rdsn/src/common/duplication_common.cpp
delete mode 100644 src/rdsn/src/common/fs_manager.cpp
delete mode 100644 src/rdsn/src/common/fs_manager.h
delete mode 100644 src/rdsn/src/common/manual_compact.h
delete mode 100644 src/rdsn/src/common/meta_admin.thrift
delete mode 100644 src/rdsn/src/common/metadata.thrift
delete mode 100644 src/rdsn/src/common/partition_split.thrift
delete mode 100644 src/rdsn/src/common/partition_split_common.h
delete mode 100644 src/rdsn/src/common/replica_admin.thrift
delete mode 100644 src/rdsn/src/common/replication_common.cpp
delete mode 100644 src/rdsn/src/common/replication_common.h
delete mode 100644 src/rdsn/src/common/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/common/test/common_test.cpp
delete mode 100644 src/rdsn/src/common/test/config-test.ini
delete mode 100644 src/rdsn/src/common/test/duplication_common_test.cpp
delete mode 100644 src/rdsn/src/common/test/fs_manager_test.cpp
delete mode 100644 src/rdsn/src/common/test/main.cpp
delete mode 100644 src/rdsn/src/common/test/replication_common_test.cpp
delete mode 100755 src/rdsn/src/common/test/run.sh
delete mode 100644 src/rdsn/src/failure_detector/CMakeLists.txt
delete mode 100644 src/rdsn/src/failure_detector/failure_detector.cpp
delete mode 100644 src/rdsn/src/failure_detector/failure_detector_multimaster.cpp
delete mode 100644 src/rdsn/src/failure_detector/fd.thrift
delete mode 100644 src/rdsn/src/failure_detector/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/failure_detector/test/config-test.ini
delete mode 100644 src/rdsn/src/failure_detector/test/config-whitelist-test-failed.ini
delete mode 100644 src/rdsn/src/failure_detector/test/config-whitelist-test.ini
delete mode 100644 src/rdsn/src/failure_detector/test/failure_detector.cpp
delete mode 100644 src/rdsn/src/failure_detector/test/main.cpp
delete mode 100644 src/rdsn/src/http/CMakeLists.txt
delete mode 100644 src/rdsn/src/http/builtin_http_calls.cpp
delete mode 100644 src/rdsn/src/http/builtin_http_calls.h
delete mode 100644 src/rdsn/src/http/config_http_service.cpp
delete mode 100644 src/rdsn/src/http/http_call_registry.h
delete mode 100644 src/rdsn/src/http/http_message_parser.cpp
delete mode 100644 src/rdsn/src/http/http_message_parser.h
delete mode 100644 src/rdsn/src/http/http_server.cpp
delete mode 100644 src/rdsn/src/http/http_server_impl.h
delete mode 100644 src/rdsn/src/http/perf_counter_http_service.cpp
delete mode 100644 src/rdsn/src/http/pprof_http_service.cpp
delete mode 100644 src/rdsn/src/http/pprof_http_service.h
delete mode 100644 src/rdsn/src/http/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/http/test/http_server_test.cpp
delete mode 100644 src/rdsn/src/http/test/perf_counter_http_service_test.cpp
delete mode 100644 src/rdsn/src/http/test/uri_decoder_test.cpp
delete mode 100644 src/rdsn/src/http/uri_decoder.cpp
delete mode 100644 src/rdsn/src/http/uri_decoder.h
delete mode 100644 src/rdsn/src/meta/CMakeLists.txt
delete mode 100644 src/rdsn/src/meta/app_balance_policy.cpp
delete mode 100644 src/rdsn/src/meta/app_balance_policy.h
delete mode 100644 src/rdsn/src/meta/app_env_validator.cpp
delete mode 100644 src/rdsn/src/meta/app_env_validator.h
delete mode 100644 src/rdsn/src/meta/backup_engine.cpp
delete mode 100644 src/rdsn/src/meta/backup_engine.h
delete mode 100644 src/rdsn/src/meta/cluster_balance_policy.cpp
delete mode 100644 src/rdsn/src/meta/cluster_balance_policy.h
delete mode 100644 src/rdsn/src/meta/distributed_lock_service_simple.cpp
delete mode 100644 src/rdsn/src/meta/distributed_lock_service_simple.h
delete mode 100644 src/rdsn/src/meta/dump_file.h
delete mode 100644 src/rdsn/src/meta/duplication/duplication_info.cpp
delete mode 100644 src/rdsn/src/meta/duplication/duplication_info.h
delete mode 100644 src/rdsn/src/meta/duplication/meta_duplication_service.cpp
delete mode 100644 src/rdsn/src/meta/duplication/meta_duplication_service.h
delete mode 100644 src/rdsn/src/meta/greedy_load_balancer.cpp
delete mode 100644 src/rdsn/src/meta/greedy_load_balancer.h
delete mode 100644 src/rdsn/src/meta/load_balance_policy.cpp
delete mode 100644 src/rdsn/src/meta/load_balance_policy.h
delete mode 100644 src/rdsn/src/meta/meta_backup_service.cpp
delete mode 100644 src/rdsn/src/meta/meta_backup_service.h
delete mode 100644 src/rdsn/src/meta/meta_bulk_load_ingestion_context.cpp
delete mode 100644 src/rdsn/src/meta/meta_bulk_load_ingestion_context.h
delete mode 100644 src/rdsn/src/meta/meta_bulk_load_service.cpp
delete mode 100644 src/rdsn/src/meta/meta_bulk_load_service.h
delete mode 100644 src/rdsn/src/meta/meta_data.cpp
delete mode 100644 src/rdsn/src/meta/meta_data.h
delete mode 100644 src/rdsn/src/meta/meta_http_service.cpp
delete mode 100644 src/rdsn/src/meta/meta_http_service.h
delete mode 100644 src/rdsn/src/meta/meta_options.cpp
delete mode 100644 src/rdsn/src/meta/meta_options.h
delete mode 100644 src/rdsn/src/meta/meta_rpc_types.h
delete mode 100644 src/rdsn/src/meta/meta_server_failure_detector.cpp
delete mode 100644 src/rdsn/src/meta/meta_server_failure_detector.h
delete mode 100644 src/rdsn/src/meta/meta_service.cpp
delete mode 100644 src/rdsn/src/meta/meta_service.h
delete mode 100644 src/rdsn/src/meta/meta_service_app.cpp
delete mode 100644 src/rdsn/src/meta/meta_split_service.cpp
delete mode 100644 src/rdsn/src/meta/meta_split_service.h
delete mode 100644 src/rdsn/src/meta/meta_state_service_simple.cpp
delete mode 100644 src/rdsn/src/meta/meta_state_service_simple.h
delete mode 100644 src/rdsn/src/meta/meta_state_service_utils.cpp
delete mode 100644 src/rdsn/src/meta/meta_state_service_utils.h
delete mode 100644 src/rdsn/src/meta/meta_state_service_utils_impl.h
delete mode 100644 src/rdsn/src/meta/meta_state_service_zookeeper.cpp
delete mode 100644 src/rdsn/src/meta/meta_state_service_zookeeper.h
delete mode 100644 src/rdsn/src/meta/partition_guardian.cpp
delete mode 100644 src/rdsn/src/meta/partition_guardian.h
delete mode 100644 src/rdsn/src/meta/server_load_balancer.cpp
delete mode 100644 src/rdsn/src/meta/server_load_balancer.h
delete mode 100644 src/rdsn/src/meta/server_state.cpp
delete mode 100644 src/rdsn/src/meta/server_state.h
delete mode 100644 src/rdsn/src/meta/server_state_restore.cpp
delete mode 100644 src/rdsn/src/meta/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/meta/test/backup_test.cpp
delete mode 100644 src/rdsn/src/meta/test/balancer_simulator/CMakeLists.txt
delete mode 100644 src/rdsn/src/meta/test/balancer_simulator/balancer_simulator.cpp
delete mode 100644 src/rdsn/src/meta/test/balancer_validator.cpp
delete mode 100644 src/rdsn/src/meta/test/cluster_balance_policy_test.cpp
delete mode 100644 src/rdsn/src/meta/test/config-test.ini
delete mode 100644 src/rdsn/src/meta/test/copy_replica_operation_test.cpp
delete mode 100644 src/rdsn/src/meta/test/dump_file.cpp
delete mode 100644 src/rdsn/src/meta/test/duplication_info_test.cpp
delete mode 100644 src/rdsn/src/meta/test/ford_fulkerson_test.cpp
delete mode 100644 src/rdsn/src/meta/test/json_compacity.cpp
delete mode 100644 src/rdsn/src/meta/test/main.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_app_envs_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_app_operation_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_backup_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_bulk_load_ingestion_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_bulk_load_service_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_data.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_duplication_service_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_http_service_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_mauanl_compaction_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_partition_guardian_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_service_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_service_test_app.h
delete mode 100644 src/rdsn/src/meta/test/meta_split_service_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_state/CMakeLists.txt
delete mode 100644 src/rdsn/src/meta/test/meta_state/clear.cmd
delete mode 100644 src/rdsn/src/meta/test/meta_state/config-test.ini
delete mode 100644 src/rdsn/src/meta/test/meta_state/main.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_state/meta_state_service.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_state_service_utils_test.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_test_base.cpp
delete mode 100644 src/rdsn/src/meta/test/meta_test_base.h
delete mode 100644 src/rdsn/src/meta/test/misc/misc.cpp
delete mode 100644 src/rdsn/src/meta/test/misc/misc.h
delete mode 100755 src/rdsn/src/meta/test/run.sh
delete mode 100644 src/rdsn/src/meta/test/server_state_restore_test.cpp
delete mode 100644 src/rdsn/src/meta/test/server_state_test.cpp
delete mode 100644 src/rdsn/src/meta/test/state_sync_test.cpp
delete mode 100644 src/rdsn/src/meta/test/update_configuration_test.cpp
delete mode 100644 src/rdsn/src/nfs/CMakeLists.txt
delete mode 100644 src/rdsn/src/nfs/nfs.thrift
delete mode 100644 src/rdsn/src/nfs/nfs_client_impl.cpp
delete mode 100644 src/rdsn/src/nfs/nfs_client_impl.h
delete mode 100644 src/rdsn/src/nfs/nfs_code_definition.h
delete mode 100644 src/rdsn/src/nfs/nfs_node.cpp
delete mode 100644 src/rdsn/src/nfs/nfs_node_impl.cpp
delete mode 100644 src/rdsn/src/nfs/nfs_node_simple.h
delete mode 100644 src/rdsn/src/nfs/nfs_server_impl.cpp
delete mode 100644 src/rdsn/src/nfs/nfs_server_impl.h
delete mode 100644 src/rdsn/src/nfs/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/nfs/test/main.cpp
delete mode 100644 src/rdsn/src/perf_counter/CMakeLists.txt
delete mode 100644 src/rdsn/src/perf_counter/builtin_counters.cpp
delete mode 100644 src/rdsn/src/perf_counter/builtin_counters.h
delete mode 100644 src/rdsn/src/perf_counter/perf_counter.cpp
delete mode 100644 src/rdsn/src/perf_counter/perf_counter_atomic.h
delete mode 100644 src/rdsn/src/perf_counter/perf_counters.cpp
delete mode 100644 src/rdsn/src/perf_counter/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/perf_counter/test/main.cpp
delete mode 100644 src/rdsn/src/perf_counter/test/perf_counter_test.cpp
delete mode 100644 src/rdsn/src/perf_counter/test/perf_counters_test.cpp
delete mode 100644 src/rdsn/src/remote_cmd/CMakeLists.txt
delete mode 100644 src/rdsn/src/remote_cmd/command.thrift
delete mode 100644 src/rdsn/src/remote_cmd/remote_command.cpp
delete mode 100644 src/rdsn/src/replica/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/backup/cold_backup_context.cpp
delete mode 100644 src/rdsn/src/replica/backup/cold_backup_context.h
delete mode 100644 src/rdsn/src/replica/backup/replica_backup_manager.cpp
delete mode 100644 src/rdsn/src/replica/backup/replica_backup_manager.h
delete mode 100644 src/rdsn/src/replica/backup/replica_backup_server.cpp
delete mode 100644 src/rdsn/src/replica/backup/replica_backup_server.h
delete mode 100644 src/rdsn/src/replica/backup/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/backup/test/config-test.ini
delete mode 100644 src/rdsn/src/replica/backup/test/main.cpp
delete mode 100644 src/rdsn/src/replica/backup/test/replica_backup_manager_test.cpp
delete mode 100755 src/rdsn/src/replica/backup/test/run.sh
delete mode 100644 src/rdsn/src/replica/bulk_load/replica_bulk_loader.cpp
delete mode 100644 src/rdsn/src/replica/bulk_load/replica_bulk_loader.h
delete mode 100644 src/rdsn/src/replica/bulk_load/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/bulk_load/test/config-test.ini
delete mode 100644 src/rdsn/src/replica/bulk_load/test/main.cpp
delete mode 100644 src/rdsn/src/replica/bulk_load/test/replica_bulk_loader_test.cpp
delete mode 100755 src/rdsn/src/replica/bulk_load/test/run.sh
delete mode 100644 src/rdsn/src/replica/disk_cleaner.cpp
delete mode 100644 src/rdsn/src/replica/disk_cleaner.h
delete mode 100644 src/rdsn/src/replica/duplication/duplication_pipeline.cpp
delete mode 100644 src/rdsn/src/replica/duplication/duplication_pipeline.h
delete mode 100644 src/rdsn/src/replica/duplication/duplication_sync_timer.cpp
delete mode 100644 src/rdsn/src/replica/duplication/duplication_sync_timer.h
delete mode 100644 src/rdsn/src/replica/duplication/load_from_private_log.cpp
delete mode 100644 src/rdsn/src/replica/duplication/load_from_private_log.h
delete mode 100644 src/rdsn/src/replica/duplication/mutation_batch.cpp
delete mode 100644 src/rdsn/src/replica/duplication/mutation_batch.h
delete mode 100644 src/rdsn/src/replica/duplication/replica_duplicator.cpp
delete mode 100644 src/rdsn/src/replica/duplication/replica_duplicator.h
delete mode 100644 src/rdsn/src/replica/duplication/replica_duplicator_manager.cpp
delete mode 100644 src/rdsn/src/replica/duplication/replica_duplicator_manager.h
delete mode 100644 src/rdsn/src/replica/duplication/replica_follower.cpp
delete mode 100644 src/rdsn/src/replica/duplication/replica_follower.h
delete mode 100644 src/rdsn/src/replica/duplication/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/duplication/test/config-test.ini
delete mode 100644 src/rdsn/src/replica/duplication/test/duplication_sync_timer_test.cpp
delete mode 100644 src/rdsn/src/replica/duplication/test/duplication_test_base.h
delete mode 100644 src/rdsn/src/replica/duplication/test/load_from_private_log_test.cpp
delete mode 100644 src/rdsn/src/replica/duplication/test/main.cpp
delete mode 100644 src/rdsn/src/replica/duplication/test/mutation_batch_test.cpp
delete mode 100644 src/rdsn/src/replica/duplication/test/replica_duplicator_manager_test.cpp
delete mode 100644 src/rdsn/src/replica/duplication/test/replica_duplicator_test.cpp
delete mode 100644 src/rdsn/src/replica/duplication/test/replica_follower_test.cpp
delete mode 100644 src/rdsn/src/replica/duplication/test/replica_http_service_test.cpp
delete mode 100755 src/rdsn/src/replica/duplication/test/run.sh
delete mode 100644 src/rdsn/src/replica/duplication/test/ship_mutation_test.cpp
delete mode 100644 src/rdsn/src/replica/log_block.cpp
delete mode 100644 src/rdsn/src/replica/log_block.h
delete mode 100644 src/rdsn/src/replica/log_file.cpp
delete mode 100644 src/rdsn/src/replica/log_file.h
delete mode 100644 src/rdsn/src/replica/log_file_stream.h
delete mode 100644 src/rdsn/src/replica/mutation.cpp
delete mode 100644 src/rdsn/src/replica/mutation.h
delete mode 100644 src/rdsn/src/replica/mutation_cache.cpp
delete mode 100644 src/rdsn/src/replica/mutation_cache.h
delete mode 100644 src/rdsn/src/replica/mutation_log.cpp
delete mode 100644 src/rdsn/src/replica/mutation_log.h
delete mode 100644 src/rdsn/src/replica/mutation_log_replay.cpp
delete mode 100644 src/rdsn/src/replica/mutation_log_utils.cpp
delete mode 100644 src/rdsn/src/replica/mutation_log_utils.h
delete mode 100644 src/rdsn/src/replica/prepare_list.cpp
delete mode 100644 src/rdsn/src/replica/prepare_list.h
delete mode 100644 src/rdsn/src/replica/replica.cpp
delete mode 100644 src/rdsn/src/replica/replica.h
delete mode 100644 src/rdsn/src/replica/replica_2pc.cpp
delete mode 100644 src/rdsn/src/replica/replica_backup.cpp
delete mode 100644 src/rdsn/src/replica/replica_check.cpp
delete mode 100644 src/rdsn/src/replica/replica_chkpt.cpp
delete mode 100644 src/rdsn/src/replica/replica_config.cpp
delete mode 100644 src/rdsn/src/replica/replica_context.cpp
delete mode 100644 src/rdsn/src/replica/replica_context.h
delete mode 100644 src/rdsn/src/replica/replica_disk_migrator.cpp
delete mode 100644 src/rdsn/src/replica/replica_disk_migrator.h
delete mode 100644 src/rdsn/src/replica/replica_failover.cpp
delete mode 100644 src/rdsn/src/replica/replica_http_service.cpp
delete mode 100644 src/rdsn/src/replica/replica_http_service.h
delete mode 100644 src/rdsn/src/replica/replica_init.cpp
delete mode 100644 src/rdsn/src/replica/replica_learn.cpp
delete mode 100644 src/rdsn/src/replica/replica_restore.cpp
delete mode 100644 src/rdsn/src/replica/replica_stub.cpp
delete mode 100644 src/rdsn/src/replica/replica_stub.h
delete mode 100644 src/rdsn/src/replica/replica_test_utils.cpp
delete mode 100644 src/rdsn/src/replica/replica_throttle.cpp
delete mode 100644 src/rdsn/src/replica/replication_app_base.cpp
delete mode 100644 src/rdsn/src/replica/replication_service_app.cpp
delete mode 100644 src/rdsn/src/replica/split/replica_split_manager.cpp
delete mode 100644 src/rdsn/src/replica/split/replica_split_manager.h
delete mode 100644 src/rdsn/src/replica/split/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/split/test/config-test.ini
delete mode 100644 src/rdsn/src/replica/split/test/main.cpp
delete mode 100644 src/rdsn/src/replica/split/test/replica_split_test.cpp
delete mode 100755 src/rdsn/src/replica/split/test/run.sh
delete mode 100644 src/rdsn/src/replica/storage/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/config.ini
delete mode 100755 src/rdsn/src/replica/storage/simple_kv/run.sh
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/simple_kv.app.example.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/simple_kv.client.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/simple_kv.code.definition.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/simple_kv.main.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/simple_kv.server.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/simple_kv.server.impl.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/simple_kv.server.impl.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-000.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-001.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-002.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-003.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-004.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-005.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-006.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-100.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-101.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-102.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-103.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-104.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-105.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-106.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-107.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-108.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-109.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-200.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-201.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-202-0.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-202-1.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-203-0.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-204.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-205.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-206.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-207.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-208.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-209.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-210.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-211.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-212.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-213.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-214.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-215.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-216.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-300-0.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-300-1.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-300-2.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-301.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-302.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-303.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-304.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-305.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-306.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-307.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-400.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-401.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-402.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-600.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-601.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-602.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case-603.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/case.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/checker.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/checker.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/client.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/client.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/common.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/common.h
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/config.ini
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/injector.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/injector.h
delete mode 100755 src/rdsn/src/replica/storage/simple_kv/test/run.sh
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/simple_kv.main.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/simple_kv.server.impl.cpp
delete mode 100644 src/rdsn/src/replica/storage/simple_kv/test/simple_kv.server.impl.h
delete mode 100644 src/rdsn/src/replica/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/replica/test/backup_block_service_mock.h
delete mode 100755 src/rdsn/src/replica/test/clear.sh
delete mode 100644 src/rdsn/src/replica/test/cold_backup_context_test.cpp
delete mode 100644 src/rdsn/src/replica/test/config-test.ini
delete mode 100644 src/rdsn/src/replica/test/log_block_test.cpp
delete mode 100644 src/rdsn/src/replica/test/log_file_test.cpp
delete mode 100644 src/rdsn/src/replica/test/main.cpp
delete mode 100644 src/rdsn/src/replica/test/mock_utils.h
delete mode 100644 src/rdsn/src/replica/test/mutation_log_learn_test.cpp
delete mode 100644 src/rdsn/src/replica/test/mutation_log_test.cpp
delete mode 100644 src/rdsn/src/replica/test/open_replica_test.cpp
delete mode 100644 src/rdsn/src/replica/test/replica_disk_migrate_test.cpp
delete mode 100644 src/rdsn/src/replica/test/replica_disk_test.cpp
delete mode 100644 src/rdsn/src/replica/test/replica_disk_test_base.h
delete mode 100644 src/rdsn/src/replica/test/replica_learn_test.cpp
delete mode 100644 src/rdsn/src/replica/test/replica_test.cpp
delete mode 100644 src/rdsn/src/replica/test/replica_test_base.h
delete mode 100644 src/rdsn/src/replica/test/replication_service_test_app.h
delete mode 100755 src/rdsn/src/replica/test/run.sh
delete mode 100644 src/rdsn/src/replica/test/throttling_controller_test.cpp
delete mode 100644 src/rdsn/src/runtime/CMakeLists.txt
delete mode 100644 src/rdsn/src/runtime/core_main.cpp
delete mode 100644 src/rdsn/src/runtime/env.sim.cpp
delete mode 100644 src/rdsn/src/runtime/env.sim.h
delete mode 100644 src/rdsn/src/runtime/fault_injector.cpp
delete mode 100644 src/rdsn/src/runtime/global_config.cpp
delete mode 100644 src/rdsn/src/runtime/message_utils.cpp
delete mode 100644 src/rdsn/src/runtime/nativerun.cpp
delete mode 100644 src/rdsn/src/runtime/profiler.cpp
delete mode 100644 src/rdsn/src/runtime/profiler_header.h
delete mode 100644 src/rdsn/src/runtime/providers.common.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/CMakeLists.txt
delete mode 100644 src/rdsn/src/runtime/rpc/asio_net_provider.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/asio_net_provider.h
delete mode 100644 src/rdsn/src/runtime/rpc/asio_rpc_session.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/asio_rpc_session.h
delete mode 100644 src/rdsn/src/runtime/rpc/dsn_message_parser.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/dsn_message_parser.h
delete mode 100644 src/rdsn/src/runtime/rpc/message_parser.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/message_parser_manager.h
delete mode 100644 src/rdsn/src/runtime/rpc/network.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/network.sim.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/network.sim.h
delete mode 100644 src/rdsn/src/runtime/rpc/raw_message_parser.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/raw_message_parser.h
delete mode 100644 src/rdsn/src/runtime/rpc/request_meta.thrift
delete mode 100644 src/rdsn/src/runtime/rpc/rpc_engine.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/rpc_engine.h
delete mode 100644 src/rdsn/src/runtime/rpc/rpc_message.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/rpc_task.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/thrift_message_parser.cpp
delete mode 100644 src/rdsn/src/runtime/rpc/thrift_message_parser.h
delete mode 100644 src/rdsn/src/runtime/scheduler.cpp
delete mode 100644 src/rdsn/src/runtime/scheduler.h
delete mode 100644 src/rdsn/src/runtime/security/CMakeLists.txt
delete mode 100644 src/rdsn/src/runtime/security/access_controller.cpp
delete mode 100644 src/rdsn/src/runtime/security/access_controller.h
delete mode 100644 src/rdsn/src/runtime/security/client_negotiation.cpp
delete mode 100644 src/rdsn/src/runtime/security/client_negotiation.h
delete mode 100644 src/rdsn/src/runtime/security/init.cpp
delete mode 100644 src/rdsn/src/runtime/security/init.h
delete mode 100644 src/rdsn/src/runtime/security/kinit_context.cpp
delete mode 100644 src/rdsn/src/runtime/security/kinit_context.h
delete mode 100644 src/rdsn/src/runtime/security/meta_access_controller.cpp
delete mode 100644 src/rdsn/src/runtime/security/meta_access_controller.h
delete mode 100644 src/rdsn/src/runtime/security/negotiation.cpp
delete mode 100644 src/rdsn/src/runtime/security/negotiation.h
delete mode 100644 src/rdsn/src/runtime/security/negotiation_manager.cpp
delete mode 100644 src/rdsn/src/runtime/security/negotiation_manager.h
delete mode 100644 src/rdsn/src/runtime/security/replica_access_controller.cpp
delete mode 100644 src/rdsn/src/runtime/security/replica_access_controller.h
delete mode 100644 src/rdsn/src/runtime/security/sasl_client_wrapper.cpp
delete mode 100644 src/rdsn/src/runtime/security/sasl_client_wrapper.h
delete mode 100644 src/rdsn/src/runtime/security/sasl_init.cpp
delete mode 100644 src/rdsn/src/runtime/security/sasl_init.h
delete mode 100644 src/rdsn/src/runtime/security/sasl_server_wrapper.cpp
delete mode 100644 src/rdsn/src/runtime/security/sasl_server_wrapper.h
delete mode 100644 src/rdsn/src/runtime/security/sasl_wrapper.cpp
delete mode 100644 src/rdsn/src/runtime/security/sasl_wrapper.h
delete mode 100644 src/rdsn/src/runtime/security/security.thrift
delete mode 100644 src/rdsn/src/runtime/security/server_negotiation.cpp
delete mode 100644 src/rdsn/src/runtime/security/server_negotiation.h
delete mode 100644 src/rdsn/src/runtime/service_api_c.cpp
delete mode 100644 src/rdsn/src/runtime/service_engine.cpp
delete mode 100644 src/rdsn/src/runtime/service_engine.h
delete mode 100644 src/rdsn/src/runtime/sim_clock.h
delete mode 100644 src/rdsn/src/runtime/simulator.cpp
delete mode 100644 src/rdsn/src/runtime/task/CMakeLists.txt
delete mode 100644 src/rdsn/src/runtime/task/hpc_task_queue.cpp
delete mode 100644 src/rdsn/src/runtime/task/hpc_task_queue.h
delete mode 100644 src/rdsn/src/runtime/task/simple_task_queue.cpp
delete mode 100644 src/rdsn/src/runtime/task/simple_task_queue.h
delete mode 100644 src/rdsn/src/runtime/task/task.cpp
delete mode 100644 src/rdsn/src/runtime/task/task_code.cpp
delete mode 100644 src/rdsn/src/runtime/task/task_engine.cpp
delete mode 100644 src/rdsn/src/runtime/task/task_engine.h
delete mode 100644 src/rdsn/src/runtime/task/task_engine.sim.cpp
delete mode 100644 src/rdsn/src/runtime/task/task_engine.sim.h
delete mode 100644 src/rdsn/src/runtime/task/task_queue.cpp
delete mode 100644 src/rdsn/src/runtime/task/task_spec.cpp
delete mode 100644 src/rdsn/src/runtime/task/task_tracker.cpp
delete mode 100644 src/rdsn/src/runtime/task/task_worker.cpp
delete mode 100644 src/rdsn/src/runtime/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/runtime/test/async_call.cpp
delete mode 100644 src/rdsn/src/runtime/test/client_negotiation_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/config-test-corrupt-message.ini
delete mode 100644 src/rdsn/src/runtime/test/config-test-sim.ini
delete mode 100644 src/rdsn/src/runtime/test/config-test.ini
delete mode 100644 src/rdsn/src/runtime/test/corrupt_message.cpp
delete mode 100644 src/rdsn/src/runtime/test/lpc.cpp
delete mode 100644 src/rdsn/src/runtime/test/main.cpp
delete mode 100644 src/rdsn/src/runtime/test/message_reader_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/message_utils_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/meta_access_controller_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/negotiation_manager_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/netprovider.cpp
delete mode 100644 src/rdsn/src/runtime/test/pipeline_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/replica_access_controller_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/rpc.cpp
delete mode 100644 src/rdsn/src/runtime/test/rpc_holder_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/rpc_message.cpp
delete mode 100644 src/rdsn/src/runtime/test/server_negotiation_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/service_api_c.cpp
delete mode 100644 src/rdsn/src/runtime/test/sim_lock.cpp
delete mode 100644 src/rdsn/src/runtime/test/task_engine.cpp
delete mode 100644 src/rdsn/src/runtime/test/task_test.cpp
delete mode 100644 src/rdsn/src/runtime/test/test_utils.h
delete mode 100644 src/rdsn/src/runtime/test/thrift_message_parser_test.cpp
delete mode 100644 src/rdsn/src/runtime/threadpool_code.cpp
delete mode 100644 src/rdsn/src/runtime/tool_api.cpp
delete mode 100644 src/rdsn/src/runtime/tracer.cpp
delete mode 100644 src/rdsn/src/runtime/zlocks.cpp
delete mode 100644 src/rdsn/src/tools/CMakeLists.txt
delete mode 100644 src/rdsn/src/tools/mutation_log_tool.cpp
delete mode 100644 src/rdsn/src/utils/CMakeLists.txt
delete mode 100644 src/rdsn/src/utils/alloc.cpp
delete mode 100644 src/rdsn/src/utils/binary_reader.cpp
delete mode 100644 src/rdsn/src/utils/binary_writer.cpp
delete mode 100644 src/rdsn/src/utils/clock.cpp
delete mode 100644 src/rdsn/src/utils/command_manager.cpp
delete mode 100644 src/rdsn/src/utils/config_api.cpp
delete mode 100644 src/rdsn/src/utils/configuration.cpp
delete mode 100644 src/rdsn/src/utils/coredump.h
delete mode 100644 src/rdsn/src/utils/coredump.posix.cpp
delete mode 100644 src/rdsn/src/utils/crc.cpp
delete mode 100644 src/rdsn/src/utils/error_code.cpp
delete mode 100644 src/rdsn/src/utils/fail_point.cpp
delete mode 100644 src/rdsn/src/utils/fail_point_impl.h
delete mode 100644 src/rdsn/src/utils/filesystem.cpp
delete mode 100644 src/rdsn/src/utils/flags.cpp
delete mode 100644 src/rdsn/src/utils/gpid.cpp
delete mode 100644 src/rdsn/src/utils/latency_tracer.cpp
delete mode 100644 src/rdsn/src/utils/lockp.std.h
delete mode 100644 src/rdsn/src/utils/logging.cpp
delete mode 100644 src/rdsn/src/utils/long_adder.cpp
delete mode 100644 src/rdsn/src/utils/long_adder_bench/CMakeLists.txt
delete mode 100644 src/rdsn/src/utils/long_adder_bench/long_adder_bench.cpp
delete mode 100644 src/rdsn/src/utils/math.cpp
delete mode 100644 src/rdsn/src/utils/memutil.h
delete mode 100644 src/rdsn/src/utils/metrics.cpp
delete mode 100644 src/rdsn/src/utils/output_utils.cpp
delete mode 100644 src/rdsn/src/utils/process_utils.cpp
delete mode 100644 src/rdsn/src/utils/rand.cpp
delete mode 100644 src/rdsn/src/utils/rpc_address.cpp
delete mode 100644 src/rdsn/src/utils/safe_strerror_posix.cpp
delete mode 100644 src/rdsn/src/utils/shared_io_service.cpp
delete mode 100644 src/rdsn/src/utils/shared_io_service.h
delete mode 100644 src/rdsn/src/utils/simple_logger.cpp
delete mode 100644 src/rdsn/src/utils/simple_logger.h
delete mode 100644 src/rdsn/src/utils/string_view.cpp
delete mode 100644 src/rdsn/src/utils/strings.cpp
delete mode 100644 src/rdsn/src/utils/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/utils/test/TokenBucketTest.cpp
delete mode 100644 src/rdsn/src/utils/test/TokenBucketTest.h
delete mode 100644 src/rdsn/src/utils/test/address.cpp
delete mode 100644 src/rdsn/src/utils/test/autoref_ptr_test.cpp
delete mode 100644 src/rdsn/src/utils/test/binary_reader_test.cpp
delete mode 100644 src/rdsn/src/utils/test/command_manager.cpp
delete mode 100644 src/rdsn/src/utils/test/configuration.cpp
delete mode 100644 src/rdsn/src/utils/test/endian_test.cpp
delete mode 100644 src/rdsn/src/utils/test/env.cpp
delete mode 100644 src/rdsn/src/utils/test/fail_point_test.cpp
delete mode 100644 src/rdsn/src/utils/test/file_system_test.cpp
delete mode 100644 src/rdsn/src/utils/test/file_utils.cpp
delete mode 100644 src/rdsn/src/utils/test/flag_test.cpp
delete mode 100644 src/rdsn/src/utils/test/fmt_logging_test.cpp
delete mode 100644 src/rdsn/src/utils/test/hostname_test.cpp
delete mode 100644 src/rdsn/src/utils/test/join_point_test.cpp
delete mode 100644 src/rdsn/src/utils/test/json_helper_test.cpp
delete mode 100644 src/rdsn/src/utils/test/latency_tracer_test.cpp
delete mode 100644 src/rdsn/src/utils/test/lock.std.cpp
delete mode 100644 src/rdsn/src/utils/test/logger.cpp
delete mode 100644 src/rdsn/src/utils/test/logging.cpp
delete mode 100644 src/rdsn/src/utils/test/long_adder_test.cpp
delete mode 100644 src/rdsn/src/utils/test/main.cpp
delete mode 100644 src/rdsn/src/utils/test/memutil_test.cpp
delete mode 100644 src/rdsn/src/utils/test/metrics_test.cpp
delete mode 100644 src/rdsn/src/utils/test/nth_element_bench/CMakeLists.txt
delete mode 100644 src/rdsn/src/utils/test/nth_element_bench/nth_element_bench.cpp
delete mode 100644 src/rdsn/src/utils/test/nth_element_test.cpp
delete mode 100644 src/rdsn/src/utils/test/nth_element_utils.h
delete mode 100644 src/rdsn/src/utils/test/output_utils_test.cpp
delete mode 100644 src/rdsn/src/utils/test/percentile_utils.h
delete mode 100644 src/rdsn/src/utils/test/priority_queue.cpp
delete mode 100644 src/rdsn/src/utils/test/rand_test.cpp
delete mode 100644 src/rdsn/src/utils/test/sema.cpp
delete mode 100644 src/rdsn/src/utils/test/smart_pointers_test.cpp
delete mode 100644 src/rdsn/src/utils/test/string_conv_test.cpp
delete mode 100644 src/rdsn/src/utils/test/string_view_test.cpp
delete mode 100644 src/rdsn/src/utils/test/time_utils_test.cpp
delete mode 100644 src/rdsn/src/utils/test/token_bucket_throttling_controller_test.cpp
delete mode 100644 src/rdsn/src/utils/test/token_buckets_test.cpp
delete mode 100644 src/rdsn/src/utils/test/utils.cpp
delete mode 100644 src/rdsn/src/utils/thread_access_checker.cpp
delete mode 100644 src/rdsn/src/utils/throttling_controller.cpp
delete mode 100644 src/rdsn/src/utils/time_utils.cpp
delete mode 100644 src/rdsn/src/utils/token_bucket_throttling_controller.cpp
delete mode 100644 src/rdsn/src/utils/token_buckets.cpp
delete mode 100644 src/rdsn/src/utils/utils.cpp
delete mode 100644 src/rdsn/src/utils/zlock_provider.h
delete mode 100644 src/rdsn/src/zookeeper/CMakeLists.txt
delete mode 100644 src/rdsn/src/zookeeper/distributed_lock_service_zookeeper.cpp
delete mode 100644 src/rdsn/src/zookeeper/distributed_lock_service_zookeeper.h
delete mode 100644 src/rdsn/src/zookeeper/lock_struct.cpp
delete mode 100644 src/rdsn/src/zookeeper/lock_struct.h
delete mode 100644 src/rdsn/src/zookeeper/lock_types.h
delete mode 100644 src/rdsn/src/zookeeper/test/CMakeLists.txt
delete mode 100644 src/rdsn/src/zookeeper/test/config-test.ini
delete mode 100644 src/rdsn/src/zookeeper/test/distributed_lock_zookeeper.cpp
delete mode 100644 src/rdsn/src/zookeeper/test/main.cpp
delete mode 100644 src/rdsn/src/zookeeper/zookeeper_error.cpp
delete mode 100644 src/rdsn/src/zookeeper/zookeeper_error.h
delete mode 100644 src/rdsn/src/zookeeper/zookeeper_session.cpp
delete mode 100644 src/rdsn/src/zookeeper/zookeeper_session.h
delete mode 100644 src/rdsn/src/zookeeper/zookeeper_session_mgr.cpp
delete mode 100644 src/rdsn/src/zookeeper/zookeeper_session_mgr.h
create mode 100644 src/remote_cmd/CMakeLists.txt
create mode 100644 src/remote_cmd/remote_command.cpp
create mode 100644 src/remote_cmd/remote_command.h
create mode 100644 src/replica/CMakeLists.txt
create mode 100644 src/replica/backup/cold_backup_context.cpp
create mode 100644 src/replica/backup/cold_backup_context.h
create mode 100644 src/replica/backup/replica_backup_manager.cpp
create mode 100644 src/replica/backup/replica_backup_manager.h
create mode 100644 src/replica/backup/replica_backup_server.cpp
create mode 100644 src/replica/backup/replica_backup_server.h
create mode 100644 src/replica/backup/test/CMakeLists.txt
create mode 100644 src/replica/backup/test/config-test.ini
create mode 100644 src/replica/backup/test/main.cpp
create mode 100644 src/replica/backup/test/replica_backup_manager_test.cpp
create mode 100755 src/replica/backup/test/run.sh
create mode 100644 src/replica/bulk_load/replica_bulk_loader.cpp
create mode 100644 src/replica/bulk_load/replica_bulk_loader.h
create mode 100644 src/replica/bulk_load/test/CMakeLists.txt
create mode 100644 src/replica/bulk_load/test/config-test.ini
create mode 100644 src/replica/bulk_load/test/main.cpp
create mode 100644 src/replica/bulk_load/test/replica_bulk_loader_test.cpp
create mode 100755 src/replica/bulk_load/test/run.sh
create mode 100644 src/replica/disk_cleaner.cpp
create mode 100644 src/replica/disk_cleaner.h
create mode 100644 src/replica/duplication/duplication_pipeline.cpp
create mode 100644 src/replica/duplication/duplication_pipeline.h
create mode 100644 src/replica/duplication/duplication_sync_timer.cpp
create mode 100644 src/replica/duplication/duplication_sync_timer.h
create mode 100644 src/replica/duplication/load_from_private_log.cpp
create mode 100644 src/replica/duplication/load_from_private_log.h
create mode 100644 src/replica/duplication/mutation_batch.cpp
create mode 100644 src/replica/duplication/mutation_batch.h
create mode 100644 src/replica/duplication/mutation_duplicator.h
create mode 100644 src/replica/duplication/replica_duplicator.cpp
create mode 100644 src/replica/duplication/replica_duplicator.h
create mode 100644 src/replica/duplication/replica_duplicator_manager.cpp
create mode 100644 src/replica/duplication/replica_duplicator_manager.h
create mode 100644 src/replica/duplication/replica_follower.cpp
create mode 100644 src/replica/duplication/replica_follower.h
create mode 100644 src/replica/duplication/test/CMakeLists.txt
create mode 100644 src/replica/duplication/test/config-test.ini
create mode 100644 src/replica/duplication/test/dup_replica_http_service_test.cpp
create mode 100644 src/replica/duplication/test/duplication_sync_timer_test.cpp
create mode 100644 src/replica/duplication/test/duplication_test_base.h
create mode 100644 src/replica/duplication/test/load_from_private_log_test.cpp
rename src/{rdsn/src => }/replica/duplication/test/log.1.0.all_loaded_are_write_empties (100%)
rename src/{rdsn/src => }/replica/duplication/test/log.1.0.handle_real_private_log (100%)
rename src/{rdsn/src => }/replica/duplication/test/log.1.0.handle_real_private_log2 (100%)
create mode 100644 src/replica/duplication/test/main.cpp
create mode 100644 src/replica/duplication/test/mutation_batch_test.cpp
create mode 100644 src/replica/duplication/test/replica_duplicator_manager_test.cpp
create mode 100644 src/replica/duplication/test/replica_duplicator_test.cpp
create mode 100644 src/replica/duplication/test/replica_follower_test.cpp
create mode 100755 src/replica/duplication/test/run.sh
create mode 100644 src/replica/duplication/test/ship_mutation_test.cpp
create mode 100644 src/replica/log_block.cpp
create mode 100644 src/replica/log_block.h
create mode 100644 src/replica/log_file.cpp
create mode 100644 src/replica/log_file.h
create mode 100644 src/replica/log_file_stream.h
create mode 100644 src/replica/mutation.cpp
create mode 100644 src/replica/mutation.h
create mode 100644 src/replica/mutation_cache.cpp
create mode 100644 src/replica/mutation_cache.h
create mode 100644 src/replica/mutation_log.cpp
create mode 100644 src/replica/mutation_log.h
create mode 100644 src/replica/mutation_log_replay.cpp
create mode 100644 src/replica/mutation_log_utils.cpp
create mode 100644 src/replica/mutation_log_utils.h
create mode 100644 src/replica/prepare_list.cpp
create mode 100644 src/replica/prepare_list.h
create mode 100644 src/replica/replica.cpp
create mode 100644 src/replica/replica.h
create mode 100644 src/replica/replica_2pc.cpp
create mode 100644 src/replica/replica_backup.cpp
create mode 100644 src/replica/replica_base.cpp
create mode 100644 src/replica/replica_base.h
create mode 100644 src/replica/replica_check.cpp
create mode 100644 src/replica/replica_chkpt.cpp
create mode 100644 src/replica/replica_config.cpp
create mode 100644 src/replica/replica_context.cpp
create mode 100644 src/replica/replica_context.h
create mode 100644 src/replica/replica_disk_migrator.cpp
create mode 100644 src/replica/replica_disk_migrator.h
create mode 100644 src/replica/replica_failover.cpp
create mode 100644 src/replica/replica_http_service.cpp
create mode 100644 src/replica/replica_http_service.h
create mode 100644 src/replica/replica_init.cpp
create mode 100644 src/replica/replica_learn.cpp
create mode 100644 src/replica/replica_restore.cpp
create mode 100644 src/replica/replica_stub.cpp
create mode 100644 src/replica/replica_stub.h
create mode 100644 src/replica/replica_throttle.cpp
create mode 100644 src/replica/replication_app_base.cpp
create mode 100644 src/replica/replication_app_base.h
create mode 100644 src/replica/replication_service_app.cpp
create mode 100644 src/replica/replication_service_app.h
create mode 100644 src/replica/split/replica_split_manager.cpp
create mode 100644 src/replica/split/replica_split_manager.h
create mode 100644 src/replica/split/test/CMakeLists.txt
create mode 100644 src/replica/split/test/config-test.ini
create mode 100644 src/replica/split/test/main.cpp
create mode 100644 src/replica/split/test/replica_split_test.cpp
create mode 100755 src/replica/split/test/run.sh
create mode 100644 src/replica/storage/CMakeLists.txt
create mode 100644 src/replica/storage/simple_kv/CMakeLists.txt
rename src/{rdsn/src => }/replica/storage/simple_kv/clear.sh (100%)
create mode 100644 src/replica/storage/simple_kv/config.ini
create mode 100755 src/replica/storage/simple_kv/run.sh
create mode 100644 src/replica/storage/simple_kv/simple_kv.app.example.h
create mode 100644 src/replica/storage/simple_kv/simple_kv.client.h
create mode 100644 src/replica/storage/simple_kv/simple_kv.code.definition.h
create mode 100644 src/replica/storage/simple_kv/simple_kv.main.cpp
create mode 100644 src/replica/storage/simple_kv/simple_kv.server.h
create mode 100644 src/replica/storage/simple_kv/simple_kv.server.impl.cpp
create mode 100644 src/replica/storage/simple_kv/simple_kv.server.impl.h
rename src/{rdsn/src => }/replica/storage/simple_kv/simple_kv.thrift (100%)
create mode 100644 src/replica/storage/simple_kv/test/CMakeLists.txt
rename src/{rdsn/src => }/replica/storage/simple_kv/test/README.md (100%)
rename src/{rdsn/src => }/replica/storage/simple_kv/test/addcase.sh (100%)
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-000.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-000.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-001.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-001.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-002.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-002.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-003.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-003.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-004.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-004.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-005.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-005.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-006.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-006.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-100.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-100.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-101.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-101.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-102.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-102.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-103.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-103.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-104.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-104.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-105.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-105.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-106.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-106.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-107.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-107.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-108.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-108.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-109.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-109.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-200.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-200.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-201.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-201.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-202-0.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-202-0.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-202-1.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-202-1.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-203-0.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-203-0.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-204.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-204.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-205.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-205.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-206.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-206.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-207.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-207.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-208.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-208.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-209.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-209.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-210.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-210.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-211.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-211.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-212.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-212.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-213.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-213.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-214.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-214.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-215.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-215.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-216.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-216.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-300-0.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-300-0.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-300-1.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-300-1.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-300-2.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-300-2.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-301.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-301.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-302.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-302.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-303.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-303.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-304.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-304.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-305.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-305.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-306.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-306.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-307.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-307.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-400.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-400.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-401.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-401.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-402.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-402.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-600.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-600.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-601.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-601.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-602.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-602.ini
rename src/{rdsn/src => }/replica/storage/simple_kv/test/case-603.act (100%)
create mode 100644 src/replica/storage/simple_kv/test/case-603.ini
create mode 100644 src/replica/storage/simple_kv/test/case.cpp
create mode 100644 src/replica/storage/simple_kv/test/case.h
create mode 100644 src/replica/storage/simple_kv/test/checker.cpp
create mode 100644 src/replica/storage/simple_kv/test/checker.h
rename src/{rdsn/src => }/replica/storage/simple_kv/test/clear.sh (100%)
create mode 100644 src/replica/storage/simple_kv/test/client.cpp
create mode 100644 src/replica/storage/simple_kv/test/client.h
create mode 100644 src/replica/storage/simple_kv/test/common.cpp
create mode 100644 src/replica/storage/simple_kv/test/common.h
create mode 100644 src/replica/storage/simple_kv/test/config.ini
create mode 100644 src/replica/storage/simple_kv/test/injector.cpp
create mode 100644 src/replica/storage/simple_kv/test/injector.h
rename src/{rdsn/src => }/replica/storage/simple_kv/test/rep_tests.pdf (100%)
create mode 100755 src/replica/storage/simple_kv/test/run.sh
create mode 100644 src/replica/storage/simple_kv/test/simple_kv.main.cpp
create mode 100644 src/replica/storage/simple_kv/test/simple_kv.server.impl.cpp
create mode 100644 src/replica/storage/simple_kv/test/simple_kv.server.impl.h
create mode 100644 src/replica/test/CMakeLists.txt
create mode 100644 src/replica/test/backup_block_service_mock.h
create mode 100755 src/replica/test/clear.sh
create mode 100644 src/replica/test/cold_backup_context_test.cpp
create mode 100644 src/replica/test/config-test.ini
create mode 100644 src/replica/test/log_block_test.cpp
create mode 100644 src/replica/test/log_file_test.cpp
create mode 100644 src/replica/test/main.cpp
create mode 100644 src/replica/test/mock_utils.h
create mode 100644 src/replica/test/mutation_log_learn_test.cpp
create mode 100644 src/replica/test/mutation_log_test.cpp
create mode 100644 src/replica/test/open_replica_test.cpp
create mode 100644 src/replica/test/replica_disk_migrate_test.cpp
create mode 100644 src/replica/test/replica_disk_test.cpp
create mode 100644 src/replica/test/replica_disk_test_base.h
create mode 100644 src/replica/test/replica_http_service_test.cpp
create mode 100644 src/replica/test/replica_learn_test.cpp
create mode 100644 src/replica/test/replica_test.cpp
create mode 100644 src/replica/test/replica_test_base.h
create mode 100644 src/replica/test/replication_service_test_app.h
create mode 100755 src/replica/test/run.sh
create mode 100644 src/replica/test/throttling_controller_test.cpp
delete mode 100644 src/reporter/CMakeLists.txt
delete mode 100644 src/reporter/pegasus_counter_reporter.cpp
delete mode 100644 src/reporter/pegasus_counter_reporter.h
delete mode 100644 src/reporter/pegasus_io_service.h
create mode 100644 src/runtime/CMakeLists.txt
create mode 100644 src/runtime/api_layer1.h
create mode 100644 src/runtime/api_task.h
create mode 100644 src/runtime/app_model.h
rename src/{rdsn/src => }/runtime/build_config.h (100%)
create mode 100644 src/runtime/core_main.cpp
create mode 100644 src/runtime/env.sim.cpp
create mode 100644 src/runtime/env.sim.h
create mode 100644 src/runtime/env_provider.h
create mode 100644 src/runtime/fault_injector.cpp
create mode 100644 src/runtime/fault_injector.h
create mode 100644 src/runtime/global_config.cpp
create mode 100644 src/runtime/global_config.h
create mode 100644 src/runtime/message_utils.cpp
create mode 100644 src/runtime/message_utils.h
create mode 100644 src/runtime/nativerun.cpp
create mode 100644 src/runtime/nativerun.h
create mode 100644 src/runtime/node_scoper.h
create mode 100644 src/runtime/pipeline.h
create mode 100644 src/runtime/profiler.cpp
create mode 100644 src/runtime/profiler.h
create mode 100644 src/runtime/profiler_header.h
create mode 100644 src/runtime/providers.common.cpp
create mode 100644 src/runtime/providers.common.h
create mode 100644 src/runtime/rpc/CMakeLists.txt
create mode 100644 src/runtime/rpc/asio_net_provider.cpp
create mode 100644 src/runtime/rpc/asio_net_provider.h
create mode 100644 src/runtime/rpc/asio_rpc_session.cpp
create mode 100644 src/runtime/rpc/asio_rpc_session.h
create mode 100644 src/runtime/rpc/dns_resolver.cpp
create mode 100644 src/runtime/rpc/dns_resolver.h
create mode 100644 src/runtime/rpc/dsn_message_parser.cpp
create mode 100644 src/runtime/rpc/dsn_message_parser.h
create mode 100644 src/runtime/rpc/group_address.h
create mode 100644 src/runtime/rpc/group_host_port.h
create mode 100644 src/runtime/rpc/message_parser.cpp
create mode 100644 src/runtime/rpc/message_parser.h
create mode 100644 src/runtime/rpc/message_parser_manager.h
create mode 100644 src/runtime/rpc/network.cpp
create mode 100644 src/runtime/rpc/network.h
create mode 100644 src/runtime/rpc/network.sim.cpp
create mode 100644 src/runtime/rpc/network.sim.h
create mode 100644 src/runtime/rpc/raw_message_parser.cpp
create mode 100644 src/runtime/rpc/raw_message_parser.h
create mode 100644 src/runtime/rpc/request_meta.thrift
create mode 100644 src/runtime/rpc/rpc_address.cpp
create mode 100644 src/runtime/rpc/rpc_address.h
create mode 100644 src/runtime/rpc/rpc_engine.cpp
create mode 100644 src/runtime/rpc/rpc_engine.h
create mode 100644 src/runtime/rpc/rpc_holder.h
create mode 100644 src/runtime/rpc/rpc_host_port.cpp
create mode 100644 src/runtime/rpc/rpc_host_port.h
create mode 100644 src/runtime/rpc/rpc_message.cpp
create mode 100644 src/runtime/rpc/rpc_message.h
create mode 100644 src/runtime/rpc/rpc_stream.h
create mode 100644 src/runtime/rpc/rpc_task.cpp
create mode 100644 src/runtime/rpc/serialization.h
create mode 100644 src/runtime/rpc/thrift_message_parser.cpp
create mode 100644 src/runtime/rpc/thrift_message_parser.h
create mode 100644 src/runtime/scheduler.cpp
create mode 100644 src/runtime/scheduler.h
create mode 100644 src/runtime/serverlet.h
create mode 100644 src/runtime/service_api_c.cpp
create mode 100644 src/runtime/service_app.h
create mode 100644 src/runtime/service_engine.cpp
create mode 100644 src/runtime/service_engine.h
create mode 100644 src/runtime/sim_clock.h
create mode 100644 src/runtime/simulator.cpp
create mode 100644 src/runtime/simulator.h
create mode 100644 src/runtime/task/CMakeLists.txt
create mode 100644 src/runtime/task/async_calls.h
create mode 100644 src/runtime/task/future_types.h
create mode 100644 src/runtime/task/hpc_task_queue.cpp
create mode 100644 src/runtime/task/hpc_task_queue.h
create mode 100644 src/runtime/task/simple_task_queue.cpp
create mode 100644 src/runtime/task/simple_task_queue.h
create mode 100644 src/runtime/task/task.cpp
create mode 100644 src/runtime/task/task.h
create mode 100644 src/runtime/task/task_code.cpp
create mode 100644 src/runtime/task/task_code.h
create mode 100644 src/runtime/task/task_engine.cpp
create mode 100644 src/runtime/task/task_engine.h
create mode 100644 src/runtime/task/task_engine.sim.cpp
create mode 100644 src/runtime/task/task_engine.sim.h
create mode 100644 src/runtime/task/task_queue.cpp
create mode 100644 src/runtime/task/task_queue.h
create mode 100644 src/runtime/task/task_spec.cpp
create mode 100644 src/runtime/task/task_spec.h
create mode 100644 src/runtime/task/task_tracker.cpp
create mode 100644 src/runtime/task/task_tracker.h
create mode 100644 src/runtime/task/task_worker.cpp
create mode 100644 src/runtime/task/task_worker.h
create mode 100644 src/runtime/task/timer_service.h
create mode 100644 src/runtime/test/CMakeLists.txt
create mode 100644 src/runtime/test/address_test.cpp
create mode 100644 src/runtime/test/async_call.cpp
rename src/{rdsn/src => }/runtime/test/clear.sh (100%)
rename src/{rdsn/src => }/runtime/test/command.txt (100%)
create mode 100644 src/runtime/test/config-test-corrupt-message.ini
create mode 100644 src/runtime/test/config-test-sim.ini
create mode 100644 src/runtime/test/config-test.ini
create mode 100644 src/runtime/test/corrupt_message.cpp
rename src/{rdsn/src => }/runtime/test/gtest.filter (100%)
create mode 100644 src/runtime/test/host_port_test.cpp
create mode 100644 src/runtime/test/lpc.cpp
create mode 100644 src/runtime/test/main.cpp
create mode 100644 src/runtime/test/message_reader_test.cpp
create mode 100644 src/runtime/test/message_utils_test.cpp
create mode 100644 src/runtime/test/netprovider.cpp
create mode 100644 src/runtime/test/pipeline_test.cpp
create mode 100644 src/runtime/test/rpc.cpp
create mode 100644 src/runtime/test/rpc_holder_test.cpp
create mode 100644 src/runtime/test/rpc_message.cpp
rename src/{rdsn/src => }/runtime/test/run.sh (100%)
create mode 100644 src/runtime/test/service_api_c.cpp
create mode 100644 src/runtime/test/sim_lock.cpp
create mode 100644 src/runtime/test/task_engine.cpp
create mode 100644 src/runtime/test/task_test.cpp
create mode 100644 src/runtime/test/thrift_message_parser_test.cpp
create mode 100644 src/runtime/test_utils.h
create mode 100644 src/runtime/threadpool_code.cpp
create mode 100644 src/runtime/tool_api.cpp
create mode 100644 src/runtime/tool_api.h
create mode 100644 src/runtime/tracer.cpp
create mode 100644 src/runtime/tracer.h
create mode 100644 src/runtime/zlocks.cpp
create mode 100644 src/sample/CMakeLists.txt
delete mode 100644 src/sample/Makefile
create mode 100644 src/security/CMakeLists.txt
create mode 100644 src/security/access_controller.cpp
create mode 100644 src/security/access_controller.h
create mode 100644 src/security/client_negotiation.cpp
create mode 100644 src/security/client_negotiation.h
create mode 100644 src/security/init.cpp
create mode 100644 src/security/init.h
create mode 100644 src/security/kinit_context.cpp
create mode 100644 src/security/kinit_context.h
create mode 100644 src/security/meta_access_controller.cpp
create mode 100644 src/security/meta_access_controller.h
create mode 100644 src/security/negotiation.cpp
create mode 100644 src/security/negotiation.h
create mode 100644 src/security/negotiation_manager.cpp
create mode 100644 src/security/negotiation_manager.h
rename src/{rdsn/src/runtime => }/security/negotiation_utils.h (100%)
create mode 100644 src/security/replica_access_controller.cpp
create mode 100644 src/security/replica_access_controller.h
create mode 100644 src/security/sasl_client_wrapper.cpp
create mode 100644 src/security/sasl_client_wrapper.h
create mode 100644 src/security/sasl_init.cpp
create mode 100644 src/security/sasl_init.h
create mode 100644 src/security/sasl_server_wrapper.cpp
create mode 100644 src/security/sasl_server_wrapper.h
create mode 100644 src/security/sasl_wrapper.cpp
create mode 100644 src/security/sasl_wrapper.h
create mode 100644 src/security/server_negotiation.cpp
create mode 100644 src/security/server_negotiation.h
create mode 100644 src/security/test/CMakeLists.txt
create mode 100644 src/security/test/client_negotiation_test.cpp
create mode 100644 src/security/test/config.ini
create mode 100644 src/security/test/main.cpp
create mode 100644 src/security/test/meta_access_controller_test.cpp
create mode 100644 src/security/test/negotiation_manager_test.cpp
create mode 100644 src/security/test/replica_access_controller_test.cpp
create mode 100755 src/security/test/run.sh
create mode 100644 src/security/test/server_negotiation_test.cpp
delete mode 100644 src/server/brief_stat.cpp
delete mode 100644 src/server/brief_stat.h
create mode 100644 src/test/function_test/backup_restore/CMakeLists.txt
create mode 100644 src/test/function_test/backup_restore/main.cpp
create mode 100644 src/test/function_test/backup_restore/test_backup_and_restore.cpp
create mode 100644 src/test/function_test/base_api/CMakeLists.txt
create mode 100644 src/test/function_test/base_api/integration_test.cpp
create mode 100644 src/test/function_test/base_api/main.cpp
create mode 100644 src/test/function_test/base_api/test_basic.cpp
create mode 100644 src/test/function_test/base_api/test_batch_get.cpp
create mode 100644 src/test/function_test/base_api/test_check_and_mutate.cpp
create mode 100644 src/test/function_test/base_api/test_check_and_set.cpp
create mode 100644 src/test/function_test/base_api/test_copy.cpp
create mode 100644 src/test/function_test/base_api/test_incr.cpp
create mode 100644 src/test/function_test/base_api/test_range_read.cpp
create mode 100644 src/test/function_test/base_api/test_recall.cpp
create mode 100644 src/test/function_test/base_api/test_scan.cpp
create mode 100644 src/test/function_test/base_api/test_ttl.cpp
create mode 100644 src/test/function_test/bulk_load/CMakeLists.txt
create mode 100644 src/test/function_test/bulk_load/main.cpp
create mode 100644 src/test/function_test/bulk_load/test_bulk_load.cpp
create mode 100644 src/test/function_test/detect_hotspot/CMakeLists.txt
create mode 100644 src/test/function_test/detect_hotspot/main.cpp
create mode 100644 src/test/function_test/detect_hotspot/test_detect_hotspot.cpp
delete mode 100644 src/test/function_test/global_env.cpp
delete mode 100644 src/test/function_test/global_env.h
delete mode 100644 src/test/function_test/main.cpp
create mode 100644 src/test/function_test/partition_split/CMakeLists.txt
create mode 100644 src/test/function_test/partition_split/main.cpp
create mode 100644 src/test/function_test/partition_split/test_split.cpp
create mode 100644 src/test/function_test/recovery/CMakeLists.txt
create mode 100644 src/test/function_test/recovery/main.cpp
create mode 100644 src/test/function_test/recovery/test_recovery.cpp
create mode 100644 src/test/function_test/restore/CMakeLists.txt
create mode 100644 src/test/function_test/restore/main.cpp
create mode 100644 src/test/function_test/restore/test_restore.cpp
delete mode 100644 src/test/function_test/test_backup_and_restore.cpp
delete mode 100644 src/test/function_test/test_basic.cpp
delete mode 100644 src/test/function_test/test_batch_get.cpp
delete mode 100644 src/test/function_test/test_bulk_load.cpp
delete mode 100644 src/test/function_test/test_check_and_mutate.cpp
delete mode 100644 src/test/function_test/test_check_and_set.cpp
delete mode 100644 src/test/function_test/test_copy.cpp
delete mode 100644 src/test/function_test/test_detect_hotspot.cpp
delete mode 100644 src/test/function_test/test_incr.cpp
delete mode 100644 src/test/function_test/test_range_read.cpp
delete mode 100644 src/test/function_test/test_recall.cpp
delete mode 100644 src/test/function_test/test_recovery.cpp
delete mode 100644 src/test/function_test/test_restore.cpp
delete mode 100644 src/test/function_test/test_scan.cpp
delete mode 100644 src/test/function_test/test_split.cpp
delete mode 100644 src/test/function_test/test_throttle.cpp
delete mode 100644 src/test/function_test/test_ttl.cpp
create mode 100644 src/test/function_test/throttle/CMakeLists.txt
create mode 100644 src/test/function_test/throttle/main.cpp
create mode 100644 src/test/function_test/throttle/test_throttle.cpp
delete mode 100644 src/test/function_test/utils.h
create mode 100644 src/test/function_test/utils/CMakeLists.txt
create mode 100644 src/test/function_test/utils/global_env.cpp
create mode 100644 src/test/function_test/utils/global_env.h
create mode 100644 src/test/function_test/utils/test_util.cpp
create mode 100644 src/test/function_test/utils/test_util.h
create mode 100644 src/test/function_test/utils/utils.h
delete mode 100644 src/test/upgrade_test/CMakeLists.txt
delete mode 100644 src/test/upgrade_test/config.ini
delete mode 100644 src/test/upgrade_test/data_verifier.cpp
delete mode 100644 src/test/upgrade_test/data_verifier.h
delete mode 100644 src/test/upgrade_test/job.cpp
delete mode 100644 src/test/upgrade_test/job.h
delete mode 100644 src/test/upgrade_test/main.cpp
delete mode 100644 src/test/upgrade_test/process_upgrader.cpp
delete mode 100644 src/test/upgrade_test/process_upgrader.h
delete mode 100644 src/test/upgrade_test/upgrade_testor.cpp
delete mode 100644 src/test/upgrade_test/upgrade_testor.h
delete mode 100644 src/test/upgrade_test/upgrader_handler.h
delete mode 100644 src/test/upgrade_test/upgrader_handler_shell.cpp
delete mode 100644 src/test/upgrade_test/upgrader_handler_shell.h
delete mode 100644 src/test/upgrade_test/upgrader_registry.cpp
delete mode 100644 src/test/upgrade_test/upgrader_registry.h
create mode 100644 src/test_util/CMakeLists.txt
create mode 100644 src/test_util/test_util.cpp
create mode 100644 src/test_util/test_util.h
create mode 100644 src/tools/CMakeLists.txt
create mode 100644 src/tools/mutation_log_tool.cpp
create mode 100644 src/tools/mutation_log_tool.h
create mode 100644 src/utils/CMakeLists.txt
create mode 100644 src/utils/TokenBucket.h
create mode 100644 src/utils/alloc.cpp
create mode 100644 src/utils/alloc.h
create mode 100644 src/utils/api_utilities.h
create mode 100644 src/utils/autoref_ptr.h
create mode 100644 src/utils/binary_reader.cpp
create mode 100644 src/utils/binary_reader.h
create mode 100644 src/utils/binary_writer.cpp
create mode 100644 src/utils/binary_writer.h
create mode 100644 src/utils/blob.h
create mode 100644 src/utils/builtin_metrics.cpp
create mode 100644 src/utils/builtin_metrics.h
create mode 100644 src/utils/casts.h
rename src/{rdsn/include/dsn/utility => utils}/chrono_literals.h (100%)
create mode 100644 src/utils/clock.cpp
create mode 100644 src/utils/clock.h
create mode 100644 src/utils/command_manager.cpp
create mode 100644 src/utils/command_manager.h
create mode 100644 src/utils/config_api.cpp
create mode 100644 src/utils/config_api.h
create mode 100644 src/utils/config_helper.h
create mode 100644 src/utils/configuration.cpp
create mode 100644 src/utils/configuration.h
create mode 100644 src/utils/coredump.h
create mode 100644 src/utils/coredump.posix.cpp
create mode 100644 src/utils/crc.cpp
rename src/{rdsn/include/dsn/utility => utils}/crc.h (100%)
create mode 100644 src/utils/customizable_id.h
create mode 100644 src/utils/defer.h
create mode 100644 src/utils/distributed_lock_service.h
create mode 100644 src/utils/endians.h
create mode 100644 src/utils/enum_helper.h
create mode 100644 src/utils/env.cpp
create mode 100644 src/utils/env.h
create mode 100644 src/utils/error_code.cpp
create mode 100644 src/utils/error_code.h
create mode 100644 src/utils/errors.h
create mode 100644 src/utils/exp_delay.h
create mode 100644 src/utils/extensible_object.h
create mode 100644 src/utils/factory_store.h
create mode 100644 src/utils/fail_point.cpp
create mode 100644 src/utils/fail_point.h
create mode 100644 src/utils/fail_point_impl.h
create mode 100644 src/utils/filesystem.cpp
create mode 100644 src/utils/filesystem.h
create mode 100644 src/utils/fixed_size_buffer_pool.h
create mode 100644 src/utils/flags.cpp
create mode 100644 src/utils/flags.h
create mode 100644 src/utils/fmt_logging.h
create mode 100644 src/utils/fmt_utils.h
rename src/{rdsn/include/dsn/utility => utils}/function_traits.h (100%)
create mode 100644 src/utils/gpid.cpp
create mode 100644 src/utils/hpc_locks/autoresetevent.h
rename src/{rdsn/include/dsn/utility => utils}/hpc_locks/autoreseteventcondvar.h (100%)
create mode 100644 src/utils/hpc_locks/benaphore.h
rename src/{rdsn/include/dsn/utility => utils}/hpc_locks/bitfield.h (100%)
rename src/{rdsn/include/dsn/utility => utils}/hpc_locks/readme.txt (100%)
create mode 100644 src/utils/hpc_locks/rwlock.h
create mode 100644 src/utils/hpc_locks/sema.h
create mode 100644 src/utils/je_ctl.cpp
create mode 100644 src/utils/je_ctl.h
create mode 100644 src/utils/join_point.h
create mode 100644 src/utils/latency_tracer.cpp
create mode 100644 src/utils/latency_tracer.h
create mode 100644 src/utils/link.h
create mode 100644 src/utils/load_dump_object.h
create mode 100644 src/utils/lockp.std.h
create mode 100644 src/utils/logging.cpp
create mode 100644 src/utils/logging_provider.h
create mode 100644 src/utils/long_adder.cpp
create mode 100644 src/utils/long_adder.h
create mode 100644 src/utils/long_adder_bench/CMakeLists.txt
create mode 100644 src/utils/long_adder_bench/long_adder_bench.cpp
create mode 100644 src/utils/macros.h
create mode 100644 src/utils/math.cpp
rename src/{rdsn/include/dsn/utility => utils}/math.h (100%)
create mode 100644 src/utils/metrics.cpp
create mode 100644 src/utils/metrics.h
create mode 100644 src/utils/nth_element.h
rename src/{rdsn/include/dsn/utility => utils}/optional.h (100%)
create mode 100644 src/utils/output_utils.cpp
create mode 100644 src/utils/output_utils.h
create mode 100644 src/utils/ports.h
create mode 100644 src/utils/preloadable.h
create mode 100644 src/utils/priority_queue.h
create mode 100644 src/utils/process_utils.cpp
create mode 100644 src/utils/process_utils.h
create mode 100644 src/utils/rand.cpp
create mode 100644 src/utils/rand.h
create mode 100644 src/utils/safe_strerror_posix.cpp
create mode 100644 src/utils/safe_strerror_posix.h
create mode 100644 src/utils/shared_io_service.cpp
create mode 100644 src/utils/shared_io_service.h
create mode 100644 src/utils/simple_logger.cpp
create mode 100644 src/utils/simple_logger.h
rename src/{rdsn/include/dsn/utility => utils}/singleton.h (100%)
create mode 100644 src/utils/singleton_store.h
create mode 100644 src/utils/string_conv.h
rename src/{rdsn/include/dsn/utility => utils}/string_splitter.h (100%)
create mode 100644 src/utils/strings.cpp
create mode 100644 src/utils/strings.h
create mode 100644 src/utils/synchronize.h
create mode 100644 src/utils/sys_exit_hook.h
create mode 100644 src/utils/test/CMakeLists.txt
create mode 100644 src/utils/test/TokenBucketTest.cpp
create mode 100644 src/utils/test/TokenBucketTest.h
create mode 100644 src/utils/test/autoref_ptr_test.cpp
create mode 100644 src/utils/test/binary_reader_test.cpp
rename src/{rdsn/src => }/utils/test/clear.sh (100%)
create mode 100644 src/utils/test/command_manager_test.cpp
rename src/{rdsn/src => }/utils/test/config-bad-section.ini (100%)
rename src/{rdsn/src => }/utils/test/config-dup-key.ini (100%)
rename src/{rdsn/src => }/utils/test/config-dup-section.ini (100%)
rename src/{rdsn/src => }/utils/test/config-empty.ini (100%)
rename src/{rdsn/src => }/utils/test/config-no-key.ini (100%)
rename src/{rdsn/src => }/utils/test/config-no-section.ini (100%)
rename src/{rdsn/src => }/utils/test/config-null-section.ini (100%)
rename src/{rdsn/src => }/utils/test/config-sample.ini (100%)
rename src/{rdsn/src => }/utils/test/config-unmatch-section.ini (100%)
create mode 100644 src/utils/test/configuration.cpp
create mode 100644 src/utils/test/endian_test.cpp
create mode 100644 src/utils/test/enum_helper_test.cpp
create mode 100644 src/utils/test/env.cpp
create mode 100644 src/utils/test/fail_point_test.cpp
create mode 100644 src/utils/test/file_system_test.cpp
create mode 100644 src/utils/test/file_utils.cpp
create mode 100644 src/utils/test/flag_test.cpp
create mode 100644 src/utils/test/fmt_logging_test.cpp
create mode 100644 src/utils/test/hostname_test.cpp
create mode 100644 src/utils/test/je_ctl_test.cpp
create mode 100644 src/utils/test/join_point_test.cpp
create mode 100644 src/utils/test/json_helper_test.cpp
create mode 100644 src/utils/test/latency_tracer_test.cpp
create mode 100644 src/utils/test/load_dump_object_test.cpp
create mode 100644 src/utils/test/lock.std.cpp
create mode 100644 src/utils/test/logger.cpp
create mode 100644 src/utils/test/logging.cpp
create mode 100644 src/utils/test/long_adder_test.cpp
create mode 100644 src/utils/test/main.cpp
create mode 100644 src/utils/test/metrics_test.cpp
create mode 100644 src/utils/test/nth_element_bench/CMakeLists.txt
create mode 100644 src/utils/test/nth_element_bench/nth_element_bench.cpp
create mode 100644 src/utils/test/nth_element_test.cpp
create mode 100644 src/utils/test/nth_element_utils.h
create mode 100644 src/utils/test/output_utils_test.cpp
create mode 100644 src/utils/test/percentile_utils.h
create mode 100644 src/utils/test/priority_queue.cpp
create mode 100644 src/utils/test/rand_test.cpp
rename src/{rdsn/src => }/utils/test/run.sh (100%)
create mode 100644 src/utils/test/sema.cpp
create mode 100644 src/utils/test/string_conv_test.cpp
create mode 100644 src/utils/test/time_utils_test.cpp
create mode 100644 src/utils/test/token_bucket_throttling_controller_test.cpp
create mode 100644 src/utils/test/token_buckets_test.cpp
create mode 100644 src/utils/test/utils.cpp
create mode 100644 src/utils/test_macros.h
create mode 100644 src/utils/thread_access_checker.cpp
create mode 100644 src/utils/thread_access_checker.h
create mode 100644 src/utils/threadpool_code.h
create mode 100644 src/utils/threadpool_spec.h
create mode 100644 src/utils/throttling_controller.cpp
rename src/{rdsn/src => }/utils/throttling_controller.h (100%)
create mode 100644 src/utils/time_utils.cpp
create mode 100644 src/utils/time_utils.h
create mode 100644 src/utils/timer.h
create mode 100644 src/utils/token_bucket_throttling_controller.cpp
create mode 100644 src/utils/token_bucket_throttling_controller.h
create mode 100644 src/utils/token_buckets.cpp
create mode 100644 src/utils/token_buckets.h
create mode 100644 src/utils/uniq_timestamp_us.h
create mode 100644 src/utils/utils.cpp
create mode 100644 src/utils/utils.h
create mode 100644 src/utils/work_queue.h
create mode 100644 src/utils/zlock_provider.h
create mode 100644 src/utils/zlocks.h
create mode 100644 src/zookeeper/CMakeLists.txt
create mode 100644 src/zookeeper/distributed_lock_service_zookeeper.cpp
create mode 100644 src/zookeeper/distributed_lock_service_zookeeper.h
create mode 100644 src/zookeeper/lock_struct.cpp
create mode 100644 src/zookeeper/lock_struct.h
create mode 100644 src/zookeeper/lock_types.h
create mode 100644 src/zookeeper/test/CMakeLists.txt
rename src/{rdsn/src => }/zookeeper/test/clear.sh (100%)
create mode 100644 src/zookeeper/test/config-test.ini
create mode 100644 src/zookeeper/test/distributed_lock_zookeeper.cpp
create mode 100644 src/zookeeper/test/main.cpp
rename src/{rdsn/src => }/zookeeper/test/run.sh (100%)
create mode 100644 src/zookeeper/zookeeper_error.cpp
create mode 100644 src/zookeeper/zookeeper_error.h
create mode 100644 src/zookeeper/zookeeper_session.cpp
create mode 100644 src/zookeeper/zookeeper_session.h
create mode 100644 src/zookeeper/zookeeper_session_mgr.cpp
create mode 100644 src/zookeeper/zookeeper_session_mgr.h
delete mode 100644 thirdparty/fix_fds_for_macos.patch
create mode 100644 thirdparty/fix_prometheus-cpp_limits.patch
create mode 100644 thirdparty/fix_rocksdb-cmake-PORTABLE-option.patch
create mode 100644 thirdparty/fix_s2_build_with_absl_and_gtest.patch
delete mode 100644 thirdparty/fix_s2_for_aarch64.patch
create mode 100644 thirdparty/fix_snappy-Wsign-compare-warning.patch
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org