Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 80 for read_file (0.07 sec)

  1. cni/pkg/iptables/iptables_linux.go

    	return forEachLoopbackRoute(cfg, "remove", netlink.RouteDel)
    }
    
    const ipv6DisabledLo = "/proc/sys/net/ipv6/conf/lo/disable_ipv6"
    
    func ReadSysctl(key string) (string, error) {
    	data, err := os.ReadFile(key)
    	if err != nil {
    		return "", err
    	}
    	return strings.TrimSpace(string(data)), nil
    }
    
    func forEachLoopbackRoute(cfg *Config, operation string, f func(*netlink.Route) error) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Sep 06 09:44:28 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. istioctl/pkg/describe/describe_test.go

    	wantException bool
    }
    
    // Tests Pilot /debug
    func TestDescribe(t *testing.T) {
    	productPageConfigPath := "testdata/describe/http_config.json"
    	config, err := os.ReadFile(productPageConfigPath)
    	if err != nil {
    		t.Fatalf("failed to read %s: %v", productPageConfigPath, err)
    	}
    	cases := []execAndK8sConfigTestCase{
    		{ // case 0
    			args:           []string{},
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  3. cmd/metacache-walk.go

    				meta.name = decodeDirObject(meta.name)
    
    				return send(meta)
    			}
    			// Check legacy.
    			if HasSuffix(entry, xlStorageFormatFileV1) && legacy {
    				var meta metaCacheEntry
    				meta.metadata, err = xioutil.ReadFile(pathJoinBuf(sb, volumeDir, current, entry))
    				diskHealthCheckOK(ctx, err)
    				if err != nil {
    					if !IsErrIgnored(err, io.EOF, io.ErrUnexpectedEOF) {
    						internalLogIf(ctx, err)
    					}
    					continue
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/pilot/status_test.go

    			for key, ss := range tt.input {
    				input[key] = ss
    			}
    
    			err := sw.PrintAll(input)
    			if tt.wantErr {
    				assert.Error(t, err)
    			} else {
    				assert.NoError(t, err)
    			}
    			want, _ := os.ReadFile(tt.want)
    			if err := util.Compare(got.Bytes(), want); err != nil {
    				t.Error(err)
    			}
    		})
    	}
    }
    
    const clientConfigType = "type.googleapis.com/envoy.service.status.v3.ClientConfig"
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  5. istioctl/pkg/workload/workload_test.go

    					ObjectMeta: metav1.ObjectMeta{Namespace: "istio-system", Name: "istio-rev-1"},
    					Data: map[string]string{
    						"mesh": string(util.ReadFile(t, path.Join(testdir, "meshconfig.yaml"))),
    					},
    				}, metav1.CreateOptions{})
    				client.Kube().CoreV1().Secrets("bar").Create(context.Background(), &v1.Secret{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  6. docs/debugging/inspect/main.go

    )
    
    func main() {
    	flag.Parse()
    
    	if *genkey {
    		generateKeys()
    		os.Exit(0)
    	}
    	var privateKey []byte
    	if *keyHex == "" {
    		if b, err := os.ReadFile(*privKeyPath); err == nil {
    			privateKey = b
    			fmt.Println("Using private key from", *privKeyPath)
    		}
    
    		// Prompt for decryption key if no --key or --private-key are provided
    		if len(privateKey) == 0 && !*stdin {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 31 14:49:23 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2_test.go

    		if dataDir != tc.expectedDataDir {
    			t.Fatalf("Expected %s but got %s", tc.expectedDataDir, dataDir)
    		}
    		count++
    	}
    }
    
    func Benchmark_mergeXLV2Versions(b *testing.B) {
    	data, err := os.ReadFile("testdata/xl.meta-v1.2.zst")
    	if err != nil {
    		b.Fatal(err)
    	}
    	dec, _ := zstd.NewReader(nil)
    	data, err = dec.DecodeAll(data, nil)
    	if err != nil {
    		b.Fatal(err)
    	}
    
    	var xl xlMetaV2
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    // tries to verify whether the disk has bitrot.
    //
    // Additionally ReadFile also starts reading from an offset. ReadFile
    // semantics are same as io.ReadFull.
    func (s *xlStorage) ReadFile(ctx context.Context, volume string, path string, offset int64, buffer []byte, verifier *BitrotVerifier) (int64, error) {
    	if offset < 0 {
    		return 0, errInvalidArgument
    	}
    
    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  9. cmd/sftp-server.go

    	if sshPrivateKey == "" {
    		logger.Fatal(fmt.Errorf("invalid arguments passed, private key file is mandatory for --sftp='ssh-private-key=path/to/id_ecdsa'"), "unable to start SFTP server")
    	}
    
    	privateBytes, err := os.ReadFile(sshPrivateKey)
    	if err != nil {
    		logger.Fatal(fmt.Errorf("invalid arguments passed, private key file is not accessible: %v", err), "unable to start SFTP server")
    	}
    
    	private, err := ssh.ParsePrivateKey(privateBytes)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 20:00:29 UTC 2024
    - 16K bytes
    - Viewed (0)
  10. cmd/storage-interface.go

    	// File operations.
    	ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) ([]string, error)
    	ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error)
    	AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top