mirrors/etcd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update etcdserve apply workflow to process DowngradeVersionTestRequest

Browse Source 
Signed-off-by: Benjamin Wang <benjamin.ahrtr@gmail.com>
This commit is contained in:
Benjamin Wang 2025-01-26 09:17:44 +00:00
parent 2eca68e345
commit 1036e4e7e5
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/etcdserver/server.go
View File

@ -2006,7 +2006,7 @@ func (s *EtcdServer) applyEntryNormal(e *raftpb.Entry, shouldApplyV3 membership.
} }
func (s *EtcdServer) applyInternalRaftRequest(r *pb.InternalRaftRequest, shouldApplyV3 membership.ShouldApplyV3) *apply.Result { func (s *EtcdServer) applyInternalRaftRequest(r *pb.InternalRaftRequest, shouldApplyV3 membership.ShouldApplyV3) *apply.Result {
if r.ClusterVersionSet == nil && r.ClusterMemberAttrSet == nil && r.DowngradeInfoSet == nil { if r.ClusterVersionSet == nil && r.ClusterMemberAttrSet == nil && r.DowngradeInfoSet == nil && r.DowngradeVersionTest == nil {
if !shouldApplyV3 { if !shouldApplyV3 {
return nil return nil
} }
@ -2029,6 +2029,11 @@ func (s *EtcdServer) applyInternalRaftRequest(r *pb.InternalRaftRequest, shouldA
case r.DowngradeInfoSet != nil: case r.DowngradeInfoSet != nil:
op = "DowngradeInfoSet" // Implemented in 3.5.x op = "DowngradeInfoSet" // Implemented in 3.5.x
membershipApplier.DowngradeInfoSet(r.DowngradeInfoSet, shouldApplyV3) membershipApplier.DowngradeInfoSet(r.DowngradeInfoSet, shouldApplyV3)
case r.DowngradeVersionTest != nil:
op = "DowngradeVersionTest" // Implemented in 3.6 for test only
// do nothing, we are just to ensure etcdserver don't panic in case
// users(test cases) intentionally inject DowngradeVersionTestRequest
// into the WAL files.
default: default:
s.lg.Panic("not implemented apply", zap.Stringer("raft-request", r)) s.lg.Panic("not implemented apply", zap.Stringer("raft-request", r))
return nil return nil