Showing 1,008 of 1,820 total issues
Method Updater.Run
has 7 return statements (exceeds 4 allowed). Open
Open
func (u *Updater) Run(ctx context.Context, slots []orchestrator.Slot) {
defer close(u.doneChan)
service := u.newService
Avoid deeply nested control flow statements. Open
Open
if integer < 128 {
count++
}
Avoid deeply nested control flow statements. Open
Open
if postIndex < 0 {
return ErrInvalidLengthRaft
}
Function DecryptPEMBlock
has 7 return statements (exceeds 4 allowed). Open
Open
func DecryptPEMBlock(block *pem.Block, password []byte) ([]byte, error) {
der := block.Bytes
var privKey encryptedPrivateKeyInfo
if _, err := asn1.Unmarshal(der, &privKey); err != nil {
Avoid deeply nested control flow statements. Open
Open
if shift >= 64 {
return ErrIntOverflowRaft
}
Avoid deeply nested control flow statements. Open
Open
if b < 0x80 {
break
}
Avoid deeply nested control flow statements. Open
Open
if packedLen < 0 {
return ErrInvalidLengthRaft
}
Method Supervisor.Restart
has 7 return statements (exceeds 4 allowed). Open
Open
func (r *Supervisor) Restart(ctx context.Context, tx store.Tx, cluster *api.Cluster, service *api.Service, t api.Task) error {
// TODO(aluzzardi): This function should not depend on `service`.
// Is the old task still in the process of restarting? If so, wait for
// its restart delay to elapse, to avoid tight restart loops (for
Function AuthorizeForwardedRoleAndOrg
has 7 return statements (exceeds 4 allowed). Open
Open
func AuthorizeForwardedRoleAndOrg(ctx context.Context, authorizedRoles, forwarderRoles []string, org string, blacklistedCerts map[string]*api.BlacklistedCertificate) (string, error) {
if isForwardedRequest(ctx) {
_, err := AuthorizeOrgAndRole(ctx, org, blacklistedCerts, forwarderRoles...)
if err != nil {
return "", status.Errorf(codes.PermissionDenied, "Permission denied: unauthorized forwarder role: %v", err)
Avoid deeply nested control flow statements. Open
Open
if assignments.addOrUpdateTask(readTx, v.Task) {
oneModification()
}
Avoid deeply nested control flow statements. Open
Open
if assignments.removeTask(readTx, v.Task) {
oneModification()
}
Method Scheduler.scheduleNTasksOnSubtree
has 6 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (s *Scheduler) scheduleNTasksOnSubtree(ctx context.Context, n int, taskGroup map[string]*api.Task, tree *decisionTree, schedulingDecisions map[string]schedulingDecision, nodeLess func(a *NodeInfo, b *NodeInfo) bool) int {
Function newRootRotationObject
has 6 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func newRootRotationObject(ctx context.Context, securityConfig *ca.SecurityConfig, apiRootCA *api.RootCA, newCARootCA ca.RootCA, extCAs []*api.ExternalCA, version uint64) (*api.RootCA, error) {
Avoid deeply nested control flow statements. Open
Open
if !request.IncludeOldObject {
eventMessage.OldObject = nil
}
Avoid deeply nested control flow statements. Open
Open
if oldTask, exists := tasksMap[v.Task.ID]; exists {
// States ASSIGNED and below are set by the orchestrator/scheduler,
// not the agent, so tasks in these states need to be sent to the
// agent even if nothing else has changed.
if equality.TasksEqualStable(oldTask, v.Task) && v.Task.Status.State > api.TaskStateAssigned {
Avoid deeply nested control flow statements. Open
Open
if time.Since(debouncingStarted) > maxLatency {
commitDebounceTimer.Stop()
commitDebounceTimer = nil
commitDebounceTimeout = nil
schedule()
Function validateConfigRefsSpec
has 7 return statements (exceeds 4 allowed). Open
Open
func validateConfigRefsSpec(spec api.TaskSpec) error {
container := spec.GetContainer()
if container == nil {
return nil
}
Method Scheduler.scheduleNTasksOnNodes
has 6 arguments (exceeds 4 allowed). Consider refactoring. Open
Open
func (s *Scheduler) scheduleNTasksOnNodes(ctx context.Context, n int, taskGroup map[string]*api.Task, nodes []NodeInfo, schedulingDecisions map[string]schedulingDecision, nodeLess func(a *NodeInfo, b *NodeInfo) bool) int {
Method Server.CreateService
has 7 return statements (exceeds 4 allowed). Open
Open
func (s *Server) CreateService(ctx context.Context, request *api.CreateServiceRequest) (*api.CreateServiceResponse, error) {
if err := validateServiceSpec(request.Spec); err != nil {
return nil, err
}
Method Server.Watch
has 7 return statements (exceeds 4 allowed). Open
Open
func (s *Server) Watch(request *api.WatchRequest, stream api.Watch_WatchServer) error {
ctx := stream.Context()
s.mu.Lock()
pctx := s.pctx