TestMultiSync test sync process with local node support two shards and sync shard data from two remote peers, it should be sync done.
(t *testing.T)
| 877 | // TestMultiSync test sync process with local node support two shards and sync shard data from two remote peers, |
| 878 | // it should be sync done. |
| 879 | func TestMultiSync(t *testing.T) { |
| 880 | var ( |
| 881 | kvSize = defaultChunkSize |
| 882 | kvEntries = uint64(16) |
| 883 | lastKvIndex = uint64(32) |
| 884 | ) |
| 885 | remotePeers := []*remotePeer{ |
| 886 | { |
| 887 | shards: []uint64{0}, |
| 888 | excludedList: make(map[uint64]struct{}), |
| 889 | }, |
| 890 | { |
| 891 | shards: []uint64{1}, |
| 892 | excludedList: make(map[uint64]struct{}), |
| 893 | }, |
| 894 | } |
| 895 | |
| 896 | testSync(t, defaultChunkSize, kvSize, kvEntries, []uint64{0, 1}, lastKvIndex, defaultEncodeType, 4, remotePeers, true) |
| 897 | } |
| 898 | |
| 899 | // TestSyncWithFewerResult test sync process with shard which is not full (lastKvIndex < kvSize), it should be sync done. |
| 900 | func TestSyncWithFewerResult(t *testing.T) { |
nothing calls this directly
no test coverage detected