Function CmdSSH has 10 return statements (exceeds 4 allowed).

Open

func CmdSSH(_ cmdutil.Factory) *cobra.Command {
    var sshConf = &pkgssh.SshConfig{}
    var ExtraCIDR []string
    cmd := &cobra.Command{
        Use:   "ssh",

Function CmdDev has 10 return statements (exceeds 4 allowed).

Open

func CmdDev(f cmdutil.Factory) *cobra.Command {
    var options = &dev.Options{
        NoProxy:        false,
        ExtraRouteInfo: handler.ExtraRouteInfo{},
    }

Method Server.Clone has 10 return statements (exceeds 4 allowed).

Open

func (svr *Server) Clone(req *rpc.CloneRequest, resp rpc.Daemon_CloneServer) (err error) {
    defer func() {
        util.InitLoggerForServer(true)
        log.SetOutput(svr.LogFile)
        config.Debug = false

Function run has 10 return statements (exceeds 4 allowed).

Open

func run(ctx context.Context, cli *client.Client, dockerCli *command.DockerCli, runConfig *RunConfig) (id string, err error) {
    rand.New(rand.NewSource(time.Now().UnixNano()))

    var config = runConfig.config
    var hostConfig = runConfig.hostConfig

Method CopyOptions.untarAll has 10 return statements (exceeds 4 allowed).

Open

func (o *CopyOptions) untarAll(prefix string, dest localPath, reader io.Reader) error {
    // TODO: use compression here?
    tarReader := tar.NewReader(reader)
    var linkList []tar.Header
    var genDstFilename = func(headerName string) localPath {

Function createContainer has 10 return statements (exceeds 4 allowed).

Open

func createContainer(ctx context.Context, dockerCli command.Cli, runConfig *RunConfig) (string, error) {
    config := runConfig.config
    hostConfig := runConfig.hostConfig
    networkingConfig := runConfig.networkingConfig
    var (

Function createTun has 10 return statements (exceeds 4 allowed).

Open

func createTun(cfg Config) (conn net.Conn, itf *net.Interface, err error) {
    if cfg.Addr == "" && cfg.Addr6 == "" {
        err = fmt.Errorf("IPv4 address and IPv6 address can not be empty at same time")
        return
    }

Consider simplifying this complex logical expression.

Open

            if (ipProtocol == int(layers.IPProtocolUDP) || ipProtocol == int(layers.IPProtocolUDPLite) || ipProtocol == int(layers.IPProtocolTCP)) &&
                (engine == config.EngineGvisor || (engine == config.EngineMix && (!config.CIDR.Contains(dst) && !config.CIDR6.Contains(dst)))) {

Function fromPatchToProbe has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func fromPatchToProbe(spec *v1.PodTemplateSpec, path []string, patch []P) {
    // 3 = readiness + liveness + startup
    if len(patch) != 3*len(spec.Spec.Containers) {
        log.Debugf("patch not match container num, not restore")
        return

• Read up
  Read up

Function ExtractSyncthingGUIZipToDir has 9 return statements (exceeds 4 allowed).

Open

func ExtractSyncthingGUIZipToDir(fs embed.FS, zipPath, targetDir string) error {
    zipData, err := fs.Open(zipPath)
    if err != nil {
        return err
    }

Function GetClient has 9 return statements (exceeds 4 allowed).

Open

func GetClient(isSudo bool) (cli rpc.DaemonClient) {
    sockPath := config.GetSockPath(isSudo)
    if _, err := os.Stat(sockPath); errors.Is(err, os.ErrNotExist) {
        return nil
    }

Function runContainer has 9 return statements (exceeds 4 allowed).

Open

func runContainer(ctx context.Context, dockerCli command.Cli, runConfig *RunConfig) error {
    config := runConfig.config
    stdout, stderr := dockerCli.Out(), dockerCli.Err()
    apiClient := dockerCli.Client()

Method admissionReviewHandler.handleCreate has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func (h *admissionReviewHandler) handleCreate(ar v1.AdmissionReview) *v1.AdmissionResponse {
    raw := ar.Request.Object.Raw
    pod := corev1.Pod{}
    deserializer := codecs.UniversalDeserializer()
    if _, _, err := deserializer.Decode(raw, nil, &pod); err != nil {

• Read up
  Read up

Function createTun has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func createTun(cfg Config) (conn net.Conn, itf *net.Interface, err error) {
    if cfg.Addr == "" && cfg.Addr6 == "" {
        err = fmt.Errorf("IPv4 address and IPv6 address can not be empty at same time")
        return
    }

• Read up
  Read up

Method Options.Dev has 9 return statements (exceeds 4 allowed).

Open

func (option *Options) Dev(ctx context.Context, cConfig *Config, hostConfig *HostConfig) error {
    templateSpec, err := option.GetPodTemplateSpec()
    if err != nil {
        return err
    }

Method Server.Get has 9 return statements (exceeds 4 allowed).

Open

func (svr *Server) Get(ctx context.Context, req *rpc.GetRequest) (*rpc.GetResponse, error) {
    if svr.connect == nil || svr.connect.Context() == nil {
        return nil, errors.New("not connected")
    }
    if svr.resourceLists == nil {

Method Krb5InitiatorClient.InitSecContext has 9 return statements (exceeds 4 allowed).

Open

func (k *Krb5InitiatorClient) InitSecContext(target string, token []byte, isGSSDelegCreds bool) ([]byte, bool, error) {
    GSSAPIFlags := []int{
        ContextFlagREADY,
        gssapi.ContextFlagInteg,
        gssapi.ContextFlagMutual,

Function PortMapUntil has 9 return statements (exceeds 4 allowed).

Open

func PortMapUntil(ctx context.Context, conf *SshConfig, remote, local netip.AddrPort) error {
    // Listen on remote server port
    var lc net.ListenConfig
    localListen, e := lc.Listen(ctx, "tcp", local.String())
    if e != nil {

Method SvrOption.detectUnixSocksFile has 9 return statements (exceeds 4 allowed).

Open

func (o *SvrOption) detectUnixSocksFile(ctx context.Context) {
    var f = func() {
        _, err := os.Stat(config.GetSockPath(o.IsSudo))
        if errors.Is(err, os.ErrNotExist) {
            o.Stop()

Similar blocks of code found in 49 locations. Consider refactoring.

Open

func (x *ListResponse) ProtoReflect() protoreflect.Message {
    mi := &file_daemon_proto_msgTypes[34]
    if protoimpl.UnsafeEnabled && x != nil {
        ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
        if ms.LoadMessageInfo() == nil {

• Read up
  Read up