|
@@ -686,12 +686,14 @@ func (s *EtcdServer) linearizableReadNotify(ctx context.Context) error {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func (s *EtcdServer) AuthInfoFromCtx(ctx context.Context) (*auth.AuthInfo, error) {
|
|
func (s *EtcdServer) AuthInfoFromCtx(ctx context.Context) (*auth.AuthInfo, error) {
|
|
|
- if s.Cfg.ClientCertAuthEnabled {
|
|
|
|
|
- authInfo := s.AuthStore().AuthInfoFromTLS(ctx)
|
|
|
|
|
- if authInfo != nil {
|
|
|
|
|
- return authInfo, nil
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ authInfo, err := s.AuthStore().AuthInfoFromCtx(ctx)
|
|
|
|
|
+ if authInfo != nil || err != nil {
|
|
|
|
|
+ return authInfo, err
|
|
|
|
|
+ }
|
|
|
|
|
+ if !s.Cfg.ClientCertAuthEnabled {
|
|
|
|
|
+ return nil, nil
|
|
|
}
|
|
}
|
|
|
|
|
+ authInfo = s.AuthStore().AuthInfoFromTLS(ctx)
|
|
|
|
|
+ return authInfo, nil
|
|
|
|
|
|
|
|
- return s.AuthStore().AuthInfoFromCtx(ctx)
|
|
|
|
|
}
|
|
}
|