File tree Expand file tree Collapse file tree 2 files changed +6
-3
lines changed
manager/state/raft/transport Expand file tree Collapse file tree 2 files changed +6
-3
lines changed Original file line number Diff line number Diff line change 44 "context"
55 "io"
66 "net"
7+ "slices"
78 "time"
89
910 "github.com/moby/swarmkit/v2/api"
@@ -130,7 +131,7 @@ func (r *mockRaft) StreamRaftMessage(stream api.Raft_StreamRaftMessageServer) er
130131 }
131132
132133 // Append received snapshot chunk to the chunk that was already received.
133- assembledMessage .Message .Snapshot .Data = append (assembledMessage .Message .Snapshot .Data , recvdMsg .Message .Snapshot .Data ... )
134+ assembledMessage .Message .Snapshot .Data = slices . Concat (assembledMessage .Message .Snapshot .Data , recvdMsg .Message .Snapshot .Data )
134135 }
135136
136137 // We should have the complete snapshot. Verify and process.
Original file line number Diff line number Diff line change @@ -11,10 +11,12 @@ import (
1111 "go.etcd.io/raft/v3/raftpb"
1212)
1313
14+ const testSnapSize = 1 << 20 // 1 MB
15+
1416// Build a snapshot message where each byte in the data is of the value (index % sizeof(byte))
1517func newSnapshotMessage (from uint64 , to uint64 ) raftpb.Message {
16- data := make ([]byte , GRPCMaxMsgSize )
17- for i := 0 ; i < GRPCMaxMsgSize ; i ++ {
18+ data := make ([]byte , testSnapSize )
19+ for i := 0 ; i < testSnapSize ; i ++ {
1820 data [i ] = byte (i % (1 << 8 ))
1921 }
2022
You can’t perform that action at this time.
0 commit comments