Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #16990 from YaoC/backport-12890

Browse Source 
[3.4] backport #12890 learner support snapshot RPC
This commit is contained in:
Benjamin Wang
2023-11-23 13:56:28 +00:00
committed by GitHub
parent 5fb8e88d78 4ff558ee53
commit 75d2407fc0
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
etcdserver/api/v3rpc/interceptor.go
View File

@@ -35,6 +35,7 @@ import (
const (
maxNoLeaderCnt = 3
snapshotMethod = "/etcdserverpb.Maintenance/Snapshot"
)
type streamsMap struct {
@@ -200,7 +201,7 @@ func newStreamInterceptor(s *etcdserver.EtcdServer) grpc.StreamServerInterceptor
return rpctypes.ErrGRPCNotCapable
}
if s.IsMemberExist(s.ID()) && s.IsLearner() { // learner does not support stream RPC
if s.IsMemberExist(s.ID()) && s.IsLearner() && info.FullMethod != snapshotMethod { // learner does not support stream RPC except Snapshot
return rpctypes.ErrGPRCNotSupportedForLearner
}