Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,105 for errC (0.03 sec)

  1. cmd/notification.go

    	g.workers.Take()
    
    	go func() {
    		defer g.workers.Give()
    
    		g.errs[index] = NotificationPeerErr{
    			Host: addr,
    		}
    
    		retryCount := g.retryCount
    		for i := 0; i < retryCount; i++ {
    			g.errs[index].Err = nil
    			if err := f(); err != nil {
    				g.errs[index].Err = err
    
    				if contextCanceled(ctx) {
    					// context already canceled no retries.
    					retryCount = 0
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  2. cmd/erasure-metadata-utils_test.go

    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	nDisks := 16
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal(err)
    	}
    	objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    		removeRoots(disks)
    		t.Fatal(err)
    	}
    	defer removeRoots(disks)
    	z := objLayer.(*erasureServerPools)
    	testShuffleDisks(t, z)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    	wg.Wait()
    
    	// we should return 'errs' from per disk
    	if isAllNotFound(errs) {
    		if isAllVolumeNotFound(errs) {
    			return errVolumeNotFound
    		}
    		return nil
    	}
    
    	if err != nil {
    		return err
    	}
    
    	if contextCanceled(ctx) {
    		return ctx.Err()
    	}
    
    	for _, err := range errs {
    		if errors.Is(err, io.EOF) {
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. internal/rest/rpc-stats.go

    	"net/http/httptrace"
    	"sync/atomic"
    	"time"
    )
    
    var globalStats = struct {
    	errs uint64
    
    	tcpDialErrs                 uint64
    	tcpDialCount                uint64
    	tcpDialTotalDur             uint64
    	tcpTimeForFirstByteTotalDur uint64
    }{}
    
    // RPCStats holds information about the DHCP/TCP metrics and errors
    type RPCStats struct {
    	Errs uint64
    
    	DialAvgDuration uint64
    	TTFBAvgDuration uint64
    	DialErrs        uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net.go

    		errs = append(errs, err)
    	}
    	return errors.Join(errs...)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. gorm.go

    				return nil, applyErr
    			}
    			defer func(opt Option) {
    				if errr := opt.AfterInitialize(db); errr != nil {
    					err = errr
    				}
    			}(opt)
    		}
    	}
    
    	if d, ok := dialector.(interface{ Apply(*Config) error }); ok {
    		if err = d.Apply(config); err != nil {
    			return
    		}
    	}
    
    	if config.NamingStrategy == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  8. cmd/prepare-storage.go

    	// Attempt to load all `format.json` from all disks.
    	formatConfigs, sErrs := loadFormatErasureAll(storageDisks, false)
    
    	if err := checkDiskFatalErrs(sErrs); err != nil {
    		return nil, err
    	}
    
    	for i, err := range sErrs {
    		if err != nil && !errors.Is(err, errXLBackend) && !errors.Is(err, errUnformattedDisk) {
    			if errors.Is(err, errDiskNotFound) && verboseLogging {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  9. cmd/erasure-metadata_test.go

    	}
    
    	// Test them.
    	for _, testCase := range testCases {
    		index, offset, err := fi.ObjectToPartOffset(context.Background(), testCase.offset)
    		if err != testCase.expectedErr {
    			t.Fatalf("%+v: expected = %s, got: %s", testCase, testCase.expectedErr, err)
    		}
    		if index != testCase.expectedIndex {
    			t.Fatalf("%+v: index: expected = %d, got: %d", testCase, testCase.expectedIndex, index)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  10. cmd/bucket-handlers.go

    			if err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    			if checksum != nil && checksum.Valid() {
    				if err = hashReader.AddChecksumNoTrailer(formValues, true); err != nil {
    					writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    					return
    				}
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
Back to top