Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for special (0.17 sec)

  1. cmd/os-reliable.go

    		switch {
    		case isSysErrNotDir(err):
    			// File path cannot be verified since one of
    			// the parents is a file.
    			return errFileAccessDenied
    		case isSysErrPathNotFound(err):
    			// This is a special case should be handled only for
    			// windows, because windows API does not return "not a
    			// directory" error message. Handle this specifically
    			// here.
    			return errFileAccessDenied
    		}
    	}
    	return err
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  2. internal/http/listener.go

    	listeners := make([]net.Listener, 0, len(serverAddrs))
    	listenErrs = make([]error, len(serverAddrs))
    
    	// Unix listener with special TCP options.
    	listenCfg := net.ListenConfig{
    		Control: setTCPParametersFn(opts),
    	}
    
    	for i, serverAddr := range serverAddrs {
    		l, e := listenCfg.Listen(ctx, "tcp", serverAddr)
    		if e != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  3. istioctl/pkg/xds/client.go

    		return make([]grpc.DialOption, 0), nil
    	}
    	// Use bearer token
    	aud := tokenAudiences
    	isMCP := strings.HasSuffix(opts.Xds, ".googleapis.com") || strings.HasSuffix(opts.Xds, ".googleapis.com:443")
    	if isMCP {
    		// Special credentials handling when using ASM Managed Control Plane.
    		mem, err := getHubMembership(ctx, kubeClient)
    		if err != nil {
    			return nil, fmt.Errorf("failed to query Hub membership: %w", err)
    		}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Dec 19 22:42:42 GMT 2023
    - 3.7K bytes
    - Viewed (0)
  4. internal/config/api/help.go

    			Optional:    true,
    			Type:        "duration",
    		},
    		config.HelpKV{
    			Key:         apiODirect,
    			Description: "set to enable or disable O_DIRECT for writes under special conditions. NOTE: do not disable O_DIRECT without prior testing" + defaultHelpPostfix(apiODirect),
    			Optional:    true,
    			Type:        "boolean",
    		},
    		config.HelpKV{
    			Key:         apiRootAccess,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 15 01:07:19 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-utils.go

    		if err := xlMeta.LoadOrConvert(xlMetaBuf); err != nil {
    			return FileInfoVersions{}, err
    		}
    		versions, err = xlMeta.ListVersions(volume, path, allParts)
    	}
    	if err == nil && len(versions) == 0 {
    		// This special case is needed to handle len(xlMeta.versions) == 0
    		versions = []FileInfo{
    			{
    				Volume:   volume,
    				Name:     path,
    				Deleted:  true,
    				IsLatest: true,
    				ModTime:  timeSentinel1970,
    			},
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  6. cmd/speedtest.go

    			concurrency += (concurrency + 1) / 2
    		}
    	}()
    	return ch
    }
    
    func driveSpeedTest(ctx context.Context, opts madmin.DriveSpeedTestOpts) madmin.DriveSpeedTestResult {
    	perf := &dperf.DrivePerf{
    		Serial:    opts.Serial,
    		BlockSize: opts.BlockSize,
    		FileSize:  opts.FileSize,
    	}
    
    	localPaths := globalEndpoints.LocalDisksPaths()
    	var ignoredPaths []string
    	paths := func() (tmpPaths []string) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 28 18:04:17 GMT 2024
    - 9K bytes
    - Viewed (0)
  7. internal/http/dial_linux.go

    			if opts.Interface != "" {
    				if h, _, err := net.SplitHostPort(address); err == nil {
    					address = h
    				}
    				// Create socket on specific vrf device.
    				// To catch all kinds of special cases this filters specifically for loopback networks.
    				if ip := net.ParseIP(address); ip != nil && !ip.IsLoopback() {
    					_ = syscall.SetsockoptString(fd, syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface)
    				}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 4.3K bytes
    - Viewed (3)
  8. operator/cmd/mesh/profile-dump.go

    	}
    	return string(prettyJSON), nil
    }
    
    func profileDump(args []string, pdArgs *profileDumpArgs, l clog.Logger) error {
    	if len(args) == 1 && pdArgs.inFilenames != nil {
    		return fmt.Errorf("cannot specify both profile name and filename flag")
    	}
    
    	if err := validateProfileOutputFormatFlag(pdArgs.outputFormat); err != nil {
    		return err
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  9. istioctl/pkg/checkinject/checkinject.go

    			if len(args) == 0 && labelPairs == "" || len(args) > 1 {
    				cmd.Println(cmd.UsageString())
    				return fmt.Errorf("check-inject requires only [<resource-type>/]<resource-name>[.<namespace>], or specify labels flag")
    			}
    			return nil
    		},
    		RunE: func(cmd *cobra.Command, args []string) error {
    			kubeClient, err := ctx.CLIClient()
    			if err != nil {
    				return err
    			}
    			var podName, podNs string
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  10. internal/logger/help.go

    			Description: "path to client key for mTLS auth",
    			Optional:    true,
    			Type:        "path",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         KafkaVersion,
    			Description: "specify the version of the Kafka cluster",
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         QueueSize,
    			Description: "configure channel queue size for Kafka targets",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 07 20:17:46 GMT 2024
    - 6.4K bytes
    - Viewed (0)
Back to top