Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for walkCh (0.07 sec)

  1. cmd/batch-handlers.go

    				if err := api.Walk(ctx, r.Source.Bucket, prefix, prefixWalkCh, WalkOptions{
    					Marker:   lastObject,
    					Filter:   selectObj,
    					AskDisks: walkQuorum,
    				}); err != nil {
    					cancelCause(err)
    					xioutil.SafeClose(walkCh)
    					return
    				}
    				for obj := range prefixWalkCh {
    					walkCh <- obj
    				}
    			}
    			xioutil.SafeClose(walkCh)
    		}()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  2. cmd/xl-storage.go

    	major, minor uint32
    	fsType       string
    
    	immediatePurge       chan string
    	immediatePurgeCancel context.CancelFunc
    
    	// mutex to prevent concurrent read operations overloading walks.
    	rotational bool
    	walkMu     *sync.Mutex
    	walkReadMu *sync.Mutex
    }
    
    // checkPathLength - returns error if given path name length more than 255
    func checkPathLength(pathName string) error {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    	// .metadata.bin healing is not needed here, it is automatically healed via read() call.
    	return z.s3Peer.HealBucket(ctx, bucket, opts)
    }
    
    // Walk a bucket, optionally prefix recursively, until we have returned
    // all the contents of the provided bucket+prefix.
    func (z *erasureServerPools) Walk(ctx context.Context, bucket, prefix string, results chan<- itemOrErr[ObjectInfo], opts WalkOptions) error {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

                log.debug("Error deleting file during cleanup", e);
            }
        }
    
        private void deleteDirectory(Path dir) throws IOException {
            if (Files.exists(dir)) {
                Files.walk(dir)
                        .sorted((a, b) -> b.compareTo(a)) // Reverse order for deletion
                        .forEach(path -> {
                            try {
                                Files.delete(path);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 56K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Iterators.java

       * elements.
       */
      @SafeVarargs
      public static <T extends @Nullable Object> Iterator<T> cycle(T... elements) {
        return cycle(Lists.newArrayList(elements));
      }
    
      /**
       * Returns an Iterator that walks the specified array, nulling out elements behind it. This can
       * avoid memory leaks when an element is no longer necessary.
       *
       * <p>This method accepts an array with element type {@code @Nullable T}, but callers must pass an
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 50.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/thirdparty/publicsuffix/PublicSuffixPatterns.java

    ??taki!man???ebot?i&anoh?kasam?rabami??n&ania?egokamuk?oot??o&jias?kihcu?nustam?uhcukokihs?yi!es???u&kohik?zo????n!.&arukas,lapo,n&erukom,riheg,?omomus,stnim,teniesa.resu,xob-liam,yrovi,zapot,?amihs!.&a&d&amah?ho?usam??kustay?m&a?ihsoni&hsin?ko???wakih??e&namihs?ustam??i&g&aka?usay??konikak?mikih??nannu?o&mu&kay?zi!ihsagih?uko???nawust?tasim??u&stog?yamat????nep,?rotsnoihsaf,srev,t&awi!.&a&bahay?d&amay?on??koirom?t&a&honat?katnezukir??imus??w&as&ijuf?uzim??ihs???e&hon&i&hci?n??uk??tawi??i&a&duf?...
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Aug 12 15:39:59 UTC 2025
    - 75.3K bytes
    - Viewed (0)
Back to top