mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
ec43197344
The context error with cancel code is typically for user cancellation which should be at debug level. For other error codes we should display a warning. Fixes #9085
97 lines
3.7 KiB
Go
97 lines
3.7 KiB
Go
// Copyright 2016 The etcd Authors
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package v3rpc
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/coreos/etcd/auth"
|
|
"github.com/coreos/etcd/etcdserver"
|
|
"github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
|
|
"github.com/coreos/etcd/etcdserver/membership"
|
|
"github.com/coreos/etcd/lease"
|
|
"github.com/coreos/etcd/mvcc"
|
|
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
)
|
|
|
|
var toGRPCErrorMap = map[error]error{
|
|
membership.ErrIDRemoved: rpctypes.ErrGRPCMemberNotFound,
|
|
membership.ErrIDNotFound: rpctypes.ErrGRPCMemberNotFound,
|
|
membership.ErrIDExists: rpctypes.ErrGRPCMemberExist,
|
|
membership.ErrPeerURLexists: rpctypes.ErrGRPCPeerURLExist,
|
|
etcdserver.ErrNotEnoughStartedMembers: rpctypes.ErrMemberNotEnoughStarted,
|
|
|
|
mvcc.ErrCompacted: rpctypes.ErrGRPCCompacted,
|
|
mvcc.ErrFutureRev: rpctypes.ErrGRPCFutureRev,
|
|
etcdserver.ErrRequestTooLarge: rpctypes.ErrGRPCRequestTooLarge,
|
|
etcdserver.ErrNoSpace: rpctypes.ErrGRPCNoSpace,
|
|
etcdserver.ErrTooManyRequests: rpctypes.ErrTooManyRequests,
|
|
|
|
etcdserver.ErrNoLeader: rpctypes.ErrGRPCNoLeader,
|
|
etcdserver.ErrNotLeader: rpctypes.ErrGRPCNotLeader,
|
|
etcdserver.ErrStopped: rpctypes.ErrGRPCStopped,
|
|
etcdserver.ErrTimeout: rpctypes.ErrGRPCTimeout,
|
|
etcdserver.ErrTimeoutDueToLeaderFail: rpctypes.ErrGRPCTimeoutDueToLeaderFail,
|
|
etcdserver.ErrTimeoutDueToConnectionLost: rpctypes.ErrGRPCTimeoutDueToConnectionLost,
|
|
etcdserver.ErrUnhealthy: rpctypes.ErrGRPCUnhealthy,
|
|
etcdserver.ErrKeyNotFound: rpctypes.ErrGRPCKeyNotFound,
|
|
etcdserver.ErrCorrupt: rpctypes.ErrGRPCCorrupt,
|
|
|
|
lease.ErrLeaseNotFound: rpctypes.ErrGRPCLeaseNotFound,
|
|
lease.ErrLeaseExists: rpctypes.ErrGRPCLeaseExist,
|
|
|
|
auth.ErrRootUserNotExist: rpctypes.ErrGRPCRootUserNotExist,
|
|
auth.ErrRootRoleNotExist: rpctypes.ErrGRPCRootRoleNotExist,
|
|
auth.ErrUserAlreadyExist: rpctypes.ErrGRPCUserAlreadyExist,
|
|
auth.ErrUserEmpty: rpctypes.ErrGRPCUserEmpty,
|
|
auth.ErrUserNotFound: rpctypes.ErrGRPCUserNotFound,
|
|
auth.ErrRoleAlreadyExist: rpctypes.ErrGRPCRoleAlreadyExist,
|
|
auth.ErrRoleNotFound: rpctypes.ErrGRPCRoleNotFound,
|
|
auth.ErrAuthFailed: rpctypes.ErrGRPCAuthFailed,
|
|
auth.ErrPermissionDenied: rpctypes.ErrGRPCPermissionDenied,
|
|
auth.ErrRoleNotGranted: rpctypes.ErrGRPCRoleNotGranted,
|
|
auth.ErrPermissionNotGranted: rpctypes.ErrGRPCPermissionNotGranted,
|
|
auth.ErrAuthNotEnabled: rpctypes.ErrGRPCAuthNotEnabled,
|
|
auth.ErrInvalidAuthToken: rpctypes.ErrGRPCInvalidAuthToken,
|
|
auth.ErrInvalidAuthMgmt: rpctypes.ErrGRPCInvalidAuthMgmt,
|
|
}
|
|
|
|
func togRPCError(err error) error {
|
|
// let gRPC server convert to codes.Canceled, codes.DeadlineExceeded
|
|
if err == context.Canceled || err == context.DeadlineExceeded {
|
|
return err
|
|
}
|
|
grpcErr, ok := toGRPCErrorMap[err]
|
|
if !ok {
|
|
return status.Error(codes.Unknown, err.Error())
|
|
}
|
|
return grpcErr
|
|
}
|
|
|
|
func isClientCtxErr(ctxErr error, err error) bool {
|
|
if ctxErr != nil {
|
|
return true
|
|
}
|
|
|
|
ev, ok := status.FromError(err)
|
|
if !ok {
|
|
return false
|
|
}
|
|
code := ev.Code()
|
|
return code == codes.Canceled || code == codes.DeadlineExceeded
|
|
}
|