Skip to content
This repository has been archived by the owner on Jun 23, 2022. It is now read-only.

feat(disk_balance): support and validate disk migration rpc #660

Merged
merged 37 commits into from
Nov 16, 2020
Merged
Show file tree
Hide file tree
Changes from 35 commits
Commits
Show all changes
37 commits
Select commit Hold shift + click to select a range
09f8d1e
add status and check
foreverneverer Nov 5, 2020
184cd01
add status and check
foreverneverer Nov 5, 2020
8b3c5de
add status and check
foreverneverer Nov 5, 2020
bdbe60c
init
foreverneverer Nov 5, 2020
4cae974
init
foreverneverer Nov 5, 2020
ceaa229
init
foreverneverer Nov 5, 2020
9c991db
init
foreverneverer Nov 5, 2020
7e1a32a
init
foreverneverer Nov 5, 2020
9919654
init
foreverneverer Nov 6, 2020
8a20639
init
foreverneverer Nov 9, 2020
e0ad25d
init
foreverneverer Nov 9, 2020
7ebcbdb
upate test
foreverneverer Nov 9, 2020
8bed904
refactor
foreverneverer Nov 9, 2020
2d856c4
refactor
foreverneverer Nov 9, 2020
aa52004
refactor
foreverneverer Nov 9, 2020
84d0048
refactor
foreverneverer Nov 9, 2020
98e191e
refactor
foreverneverer Nov 9, 2020
8b1016b
refactor
foreverneverer Nov 9, 2020
8b612f9
refactor
foreverneverer Nov 10, 2020
494b79c
refactor
foreverneverer Nov 10, 2020
1624659
refactor
foreverneverer Nov 10, 2020
640e990
refactor
foreverneverer Nov 10, 2020
6ca8e90
refactor
foreverneverer Nov 11, 2020
cc56670
refactor
foreverneverer Nov 11, 2020
b8bb0fe
refactor
foreverneverer Nov 11, 2020
f6139a3
refactor
foreverneverer Nov 11, 2020
1a239f0
refactor
foreverneverer Nov 11, 2020
85d772d
refactor
foreverneverer Nov 11, 2020
bf0dbf3
Merge branch 'master' into disk_balance_check
foreverneverer Nov 11, 2020
a5ad732
refactor
foreverneverer Nov 11, 2020
8914521
delete
foreverneverer Nov 12, 2020
a862769
delete
foreverneverer Nov 12, 2020
38436be
delete dir
foreverneverer Nov 12, 2020
3aa31f6
delete
foreverneverer Nov 12, 2020
78b386b
add comment
foreverneverer Nov 13, 2020
912bf57
update test
foreverneverer Nov 16, 2020
e5e2ef0
Merge branch 'master' into disk_balance_check
foreverneverer Nov 16, 2020
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions include/dsn/dist/replication/replication.codes.h
Original file line number Diff line number Diff line change
Expand Up @@ -158,6 +158,7 @@ MAKE_EVENT_CODE_RPC(RPC_SPLIT_NOTIFY_CATCH_UP, TASK_PRIORITY_COMMON)
MAKE_EVENT_CODE_RPC(RPC_SPLIT_UPDATE_CHILD_PARTITION_COUNT, TASK_PRIORITY_COMMON)
MAKE_EVENT_CODE_RPC(RPC_BULK_LOAD, TASK_PRIORITY_COMMON)
MAKE_EVENT_CODE_RPC(RPC_GROUP_BULK_LOAD, TASK_PRIORITY_COMMON)
MAKE_EVENT_CODE_RPC(RPC_MIGRATE_REPLICA, TASK_PRIORITY_COMMON)
MAKE_EVENT_CODE(LPC_REPLICATION_LOW, TASK_PRIORITY_LOW)
MAKE_EVENT_CODE(LPC_REPLICATION_COMMON, TASK_PRIORITY_COMMON)
MAKE_EVENT_CODE(LPC_REPLICATION_HIGH, TASK_PRIORITY_HIGH)
Expand Down
9 changes: 9 additions & 0 deletions include/dsn/dist/replication/replication_enums.h
Original file line number Diff line number Diff line change
Expand Up @@ -107,4 +107,13 @@ ENUM_REG(replication::split_status::PAUSING)
ENUM_REG(replication::split_status::PAUSED)
ENUM_REG(replication::split_status::CANCELING)
ENUM_END2(replication::split_status::type, split_status)

ENUM_BEGIN2(replication::disk_migration_status::type,
disk_migration_status,
replication::disk_migration_status::IDLE)
ENUM_REG(replication::disk_migration_status::IDLE)
ENUM_REG(replication::disk_migration_status::MOVING)
ENUM_REG(replication::disk_migration_status::MOVED)
ENUM_REG(replication::disk_migration_status::CLOSED)
ENUM_END2(replication::disk_migration_status::type, disk_migration_status)
}
129 changes: 129 additions & 0 deletions include/dsn/dist/replication/replication_types.h

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion src/common/fs_manager.h
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,8 @@ class fs_manager

friend class replica_stub;
friend class mock_replica_stub;
friend class replica_disk_test;
friend class replica_disk_migrator;
friend class replica_disk_test_base;
};
} // replication
} // dsn
Loading