Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 119 for recursively (0.09 sec)

  1. cmd/storage-rest-client.go

    	}
    
    	restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	if healthCheck {
    		// Use a separate client to avoid recursive calls.
    		healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    		healthClient.NoMetrics = true
    		restClient.HealthCheckFn = func() bool {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/collect/testing/AbstractIteratorTester.java

          throw new RuntimeException(Arrays.toString(stimuli), e);
        }
      }
    
      private void recurse(int level) {
        // We're going to reuse the stimuli array 3^steps times by overwriting it
        // in a recursive loop.  Sneaky.
        if (level == stimuli.length) {
          // We've filled the array.
          compareResultsForThisListOfStimuli();
        } else {
          // Keep recursing to fill the array.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    // delete the tracker on disk.
    func (h *healingTracker) delete(ctx context.Context) error {
    	return h.disk.Delete(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		},
    	)
    }
    
    func (h *healingTracker) isHealed(bucket string) bool {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    	return slices.Contains(h.HealedBuckets, bucket)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  4. cmd/erasure-object_test.go

    		files, _ := disk.ListDir(ctx, "", bucket, object, -1)
    		for _, file := range files {
    			if file != "xl.meta" {
    				disk.Delete(ctx, bucket, pathJoin(object, file), DeleteOptions{
    					Recursive: true,
    					Immediate: false,
    				})
    			}
    		}
    	}
    
    	gr, err := xl.GetObjectNInfo(ctx, bucket, object, nil, nil, opts)
    	if err != nil {
    		if err != toObjectErr(errErasureReadQuorum, bucket, object) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/reflect/TypeResolver.java

              // may generate something like <capture#1-of ? extends Foo&SubFoo>.
              // Checking subtype between declared and actual type bounds
              // adds recursive isSubtypeOf() call and feels complicated.
              // There is no contract one way or another as long as isSubtypeOf() works as expected.
              combined.addAll(asList(typeParam.getBounds()));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Sep 03 14:03:14 UTC 2025
    - 24.2K bytes
    - Viewed (0)
  6. cmd/erasure-metadata.go

    			index := index
    			ng.Go(func() error {
    				if disks[index] == nil {
    					return errDiskNotFound
    				}
    				return disks[index].Delete(ctx, bucket, pathJoin(prefix, xlStorageFormatFile), DeleteOptions{
    					Recursive: true,
    				})
    			}, index)
    		}
    		ng.Wait()
    	}
    
    	return evalDisks(disks, mErrs), err
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  7. cmd/storage-datatypes_gen.go

    				default:
    					err = dc.Skip()
    					if err != nil {
    						err = msgp.WrapError(err, "BaseOptions")
    						return
    					}
    				}
    			}
    		case "r":
    			z.Recursive, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "Recursive")
    				return
    			}
    		case "i":
    			z.Immediate, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "Immediate")
    				return
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 152K bytes
    - Viewed (0)
  8. cmd/admin-heal-ops.go

    	return func() error {
    		// NOTE: Healing on meta is run regardless
    		// of any bucket being selected, this is to ensure that
    		// meta are always upto date and correct.
    		h.settings.Recursive = true
    		return objAPI.HealObjects(h.ctx, minioMetaBucket, metaPrefix, h.settings, func(bucket, object, versionID string, scanMode madmin.HealScanMode) error {
    			if h.isQuitting() {
    				return errHealStopSignalled
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        CacheLoader<String, String> loader =
            new CacheLoader<String, String>() {
              @Override
              public String load(String key) throws Exception {
                return cache.get(key, identityLoader()); // recursive load, this should fail
              }
            };
        testLoadThrows(key, cache, loader);
      }
    
      public void testRecursiveLoadWithProxy() throws InterruptedException {
        String key = "key";
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 110.5K bytes
    - Viewed (0)
  10. cmd/format-erasure.go

    		return err
    	}
    
    	tmpFormat := mustGetUUID()
    
    	// Purge any existing temporary file, okay to ignore errors here.
    	defer disk.Delete(context.TODO(), minioMetaBucket, tmpFormat, DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    
    	// write to unique file.
    	if err = disk.WriteAll(context.TODO(), minioMetaBucket, tmpFormat, formatData); err != nil {
    		return err
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 23.1K bytes
    - Viewed (0)
Back to top