Search Options

Results per page
Sort
Preferred Languages
Advance

Results 871 - 880 of 1,020 for err (0.02 sec)

  1. internal/crypto/sse_test.go

    	},
    }
    
    func TestSSECUnsealObjectKey(t *testing.T) {
    	for i, test := range ssecUnsealObjectKeyTests {
    		if _, err := SSEC.UnsealObjectKey(test.Headers, test.Metadata, test.Bucket, test.Object); err != test.ExpectedErr {
    			t.Errorf("Test %d: got: %v - want: %v", i, err, test.ExpectedErr)
    		}
    	}
    }
    
    var sseCopyUnsealObjectKeyTests = []struct {
    	Headers        http.Header
    	Bucket, Object string
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  2. src/archive/tar/strconv_test.go

    		{"đŸĩ𝟴đŸŗ𝟲𝟱.đŸ°đŸ¯đŸŽđŸ­đŸŦ", time.Time{}, false}, // Unicode numbers (U+1D7EC to U+1D7F5)
    		{"98765īš’43210", time.Time{}, false}, // Unicode period (U+FE52)
    	}
    
    	for _, v := range vectors {
    		ts, err := parsePAXTime(v.in)
    		ok := (err == nil)
    		if v.ok != ok {
    			if v.ok {
    				t.Errorf("parsePAXTime(%q): got parsing failure, want success", v.in)
    			} else {
    				t.Errorf("parsePAXTime(%q): got parsing success, want failure", v.in)
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Feb 09 05:28:50 UTC 2021
    - 14K bytes
    - Viewed (0)
  3. cmd/rebalance-admin.go

    	StoppedAt time.Time             `json:"stoppedAt,omitempty"`
    }
    
    func rebalanceStatus(ctx context.Context, z *erasureServerPools) (r rebalanceAdminStatus, err error) {
    	// Load latest rebalance status
    	meta := &rebalanceMeta{}
    	err = meta.load(ctx, z.serverPools[0])
    	if err != nil {
    		return r, err
    	}
    
    	// Compute disk usage percentage
    	si := z.StorageInfo(ctx, true)
    	diskStats := make([]struct {
    		AvailableSpace uint64
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Dec 22 00:56:43 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  4. cmd/main.go

    		// Override the logger os.Exit()
    		logger.ExitFunc = freeze
    
    		defer func() {
    			if err := recover(); err != nil {
    				fmt.Println("panic:", err)
    				fmt.Println("")
    				fmt.Println(string(debug.Stack()))
    			}
    			freeze(-1)
    		}()
    	}
    
    	// Run the app - exit on error.
    	if err := newApp(appName).Run(args); err != nil {
    		os.Exit(1) //nolint:gocritic
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 30 22:59:48 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  5. internal/bucket/replication/replication_test.go

    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			cfg, err := ParseConfig(bytes.NewReader([]byte(tc.inputConfig)))
    			if err != nil && tc.expectedParsingErr != nil && err.Error() != tc.expectedParsingErr.Error() {
    				t.Fatalf("%d: Expected '%v' during parsing but got '%v'", i+1, tc.expectedParsingErr, err)
    			}
    			if err == nil && tc.expectedParsingErr != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 32.5K bytes
    - Viewed (0)
  6. internal/hash/errors.go

    func (e ChecksumMismatch) Error() string {
    	return "Bad checksum: Want " + e.Want + " does not match calculated " + e.Got
    }
    
    // IsChecksumMismatch matches if 'err' is hash.ChecksumMismatch
    func IsChecksumMismatch(err error) bool {
    	var herr ChecksumMismatch
    	return errors.As(err, &herr)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon May 15 21:08:54 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  7. internal/s3select/jstream/scanner.go

    			close(sr.fillReady)
    		}()
    
    		for range sr.fillReq {
    		scan:
    			n, err := r.Read(sr.nbuf[:])
    
    			if n == 0 {
    				switch err {
    				case io.EOF: // reader is exhausted
    					return
    				case nil: // no data and no error, retry fill
    					goto scan
    				default: // unexpected reader error
    					sr.readerErr = err
    					return
    				}
    			}
    
    			rpos += int64(n)
    			sr.fillReady <- int64(n)
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  8. istioctl/pkg/checkinject/checkinject_test.go

    	}
    	var whs []admitv1.MutatingWebhookConfiguration
    	for _, whName := range whFiles {
    		file, err := os.ReadFile(whName)
    		if err != nil {
    			t.Fatal(err)
    		}
    		var wh *admitv1.MutatingWebhookConfiguration
    		if err := yaml.Unmarshal(file, &wh); err != nil {
    			t.Fatal(err)
    		}
    		whs = append(whs, *wh)
    	}
    	for _, c := range cases {
    		t.Run(c.name, func(t *testing.T) {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  9. istioctl/pkg/proxystatus/proxystatus_test.go

    			ctx := cli.NewFakeContext(&cli.NewFakeContextOption{
    				IstioNamespace: "istio-system",
    			})
    			if !c.noIstiod {
    				client, err := ctx.CLIClientWithRevision(c.revision)
    				assert.NoError(t, err)
    				_, err = client.Kube().CoreV1().Pods("istio-system").Create(context.TODO(), &corev1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      "istiod-test",
    						Namespace: "istio-system",
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Fri Mar 15 08:28:50 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. tests/helper_test.go

    	doCheckPet(t, pet, expect, false)
    }
    
    func doCheckPet(t *testing.T, pet Pet, expect Pet, unscoped bool) {
    	if pet.ID != 0 {
    		var newPet Pet
    		if err := db(unscoped).Where("id = ?", pet.ID).First(&newPet).Error; err != nil {
    			t.Fatalf("errors happened when query: %v", err)
    		} else {
    			AssertObjEqual(t, newPet, pet, "ID", "CreatedAt", "UpdatedAt", "DeletedAt", "UserID", "Name")
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Mar 19 03:50:28 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top