Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 859 for err (0.02 sec)

  1. cmd/format-erasure_test.go

    	b, err := json.Marshal(m)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.MkdirAll(pathJoin(rootPath, minioMetaBucket), os.FileMode(0o755)); err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.WriteFile(pathJoin(rootPath, minioMetaBucket, formatConfigFile), b, os.FileMode(0o644)); err != nil {
    		t.Fatal(err)
    	}
    
    	formatData, _, err := formatErasureMigrate(rootPath)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. tests/joins_test.go

    	onQuery := DB.Where(&Pet{Name: "joins-on_pet_1"})
    
    	if err := DB.Joins("NamedPet", onQuery).Where("users.name = ?", user.Name).First(&user1).Error; err != nil {
    		t.Fatalf("Failed to load with joins on, got error: %v", err)
    	}
    
    	AssertEqual(t, user1.NamedPet.Name, "joins-on_pet_1")
    
    	onQuery2 := DB.Where(&Pet{Name: "joins-on_pet_2"})
    	var user2 User
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Jun 17 03:58:13 UTC 2024
    - 15K bytes
    - Viewed (0)
  3. cmd/bucket-notification-handlers.go

    		return
    	}
    
    	_, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	config, err := globalBucketMetadataSys.GetNotificationConfig(bucketName)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	region := globalSite.Region()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  4. cmd/xl-storage-free-version_test.go

    			}
    		}
    	}
    
    	// Simulate scanner removing free-version
    	freefi := newtierfi
    	for _, fvID := range fvIDs {
    		freefi.VersionID = fvID
    		_, err = xl.DeleteVersion(freefi)
    		fatalErr(err)
    	}
    	report()
    
    	// Check number of free-versions
    	freeVersions, err = xl.listFreeVersions(newtierfi.Volume, newtierfi.Name)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  5. cmd/tier.go

    func (config *TierConfigMgr) Remove(ctx context.Context, tier string, force bool) error {
    	d, err := config.getDriver(ctx, tier)
    	if err != nil {
    		if errors.Is(err, errTierNotFound) {
    			return nil
    		}
    		return err
    	}
    	if !force {
    		if inuse, err := d.InUse(ctx); err != nil {
    			return err
    		} else if inuse {
    			return errTierBackendNotEmpty
    		}
    	}
    	config.Lock()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  6. cmd/data-usage_test.go

    	for _, f := range files {
    		err := os.MkdirAll(filepath.Dir(filepath.Join(base, bucket, f.name)), os.ModePerm)
    		if err != nil {
    			t.Fatal(err)
    		}
    		err = os.WriteFile(filepath.Join(base, bucket, f.name), make([]byte, f.size), os.ModePerm)
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. internal/logger/console.go

    func Fatal(err error, msg string, data ...interface{}) {
    	fatal(err, msg, data...)
    }
    
    func fatal(err error, msg string, data ...interface{}) {
    	if msg == "" {
    		if len(data) > 0 {
    			msg = fmt.Sprint(data...)
    		} else {
    			msg = "a fatal error"
    		}
    	} else {
    		msg = fmt.Sprintf(msg, data...)
    	}
    	consoleLog(fatalMessage, errorFmtFunc(msg, err, jsonFlag))
    }
    
    var fatalMessage fatalMsg
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  8. internal/logger/logonce.go

    		}
    	}
    	if uerr == nil {
    		leafErr = err
    	}
    	return leafErr
    }
    
    // One log message per error.
    func (l *logOnceType) logOnceIf(ctx context.Context, subsystem string, err error, id string, errKind ...interface{}) {
    	if err == nil {
    		return
    	}
    
    	nerr := unwrapErrs(err)
    	l.Lock()
    	shouldLog := true
    	prev, ok := l.IDMap[id]
    	if !ok {
    		l.IDMap[id] = onceErr{
    			Err:   nerr,
    			Count: 1,
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  9. src/archive/tar/example_test.go

    			Size: int64(len(file.Body)),
    		}
    		if err := tw.WriteHeader(hdr); err != nil {
    			log.Fatal(err)
    		}
    		if _, err := tw.Write([]byte(file.Body)); err != nil {
    			log.Fatal(err)
    		}
    	}
    	if err := tw.Close(); err != nil {
    		log.Fatal(err)
    	}
    
    	// Open and iterate through the files in the archive.
    	tr := tar.NewReader(&buf)
    	for {
    		hdr, err := tr.Next()
    		if err == io.EOF {
    			break // End of archive
    		}
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Nov 16 16:54:08 UTC 2017
    - 1.4K bytes
    - Viewed (0)
  10. internal/rest/client.go

    }
    
    func (r *respBodyMonitor) Read(p []byte) (n int, err error) {
    	n, err = r.ReadCloser.Read(p)
    	r.errorStatus(err)
    	return
    }
    
    func (r *respBodyMonitor) Close() (err error) {
    	err = r.ReadCloser.Close()
    	r.errorStatus(err)
    	return
    }
    
    func (r *respBodyMonitor) errorStatus(err error) {
    	if xnet.IsNetworkOrHostDown(err, r.expectTimeouts) {
    		r.errorStatusOnce.Do(func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
Back to top