Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 29 of 29 for walkCh (0.12 sec)

  1. cmd/batch-expire.go

    	go func() {
    		prefixes := r.Prefix.F()
    		if len(prefixes) == 0 {
    			prefixes = []string{""}
    		}
    		for _, prefix := range prefixes {
    			prefixResultCh := make(chan itemOrErr[ObjectInfo], workerSize)
    			err := api.Walk(ctx, r.Bucket, prefix, prefixResultCh, WalkOptions{
    				Marker:       lastObject,
    				LatestOnly:   false, // we need to visit all versions of the object to implement purge: retainVersions
    				VersionsSort: WalkVersionsSortDesc,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Apr 22 11:16:32 UTC 2025
    - 23K bytes
    - Viewed (0)
  2. cmd/iam-object-store.go

    	ch := make(chan itemOrErr[string])
    
    	go func() {
    		defer xioutil.SafeClose(ch)
    
    		// Allocate new results channel to receive ObjectInfo.
    		objInfoCh := make(chan itemOrErr[ObjectInfo])
    
    		if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil {
    			select {
    			case ch <- itemOrErr[string]{Err: err}:
    			case <-ctx.Done():
    			}
    			return
    		}
    
    		for obj := range objInfoCh {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    	}
    	// mark resync status as resync started
    	if !heal {
    		s.markStatus(ResyncStarted, opts, objectAPI)
    	}
    
    	// Walk through all object versions - Walk() is always in ascending order needed to ensure
    	// delete marker replicated to target after object version is first created.
    	if err := objectAPI.Walk(ctx, opts.bucket, "", objInfoCh, WalkOptions{}); err != nil {
    		replLogIf(ctx, err)
    		return
    	}
    
    	s.RLock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K 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. src/main/webapp/js/admin/popper.min.js.map

    placement, returns all the subsequent placements\n * clockwise (or counter-clockwise).\n *\n * @method\n * @memberof Popper.Utils\n * @argument {String} placement - A valid placement (it accepts variations)\n * @argument {Boolean} counter - Set to true to walk the placements counterclockwise\n * @returns {Array} placements including their variations\n */\nexport default function clockwise(placement, counter = false) {\n  const index = validPlacements.indexOf(placement);\n  const arr = validPlacements\n ...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 120.9K bytes
    - Viewed (0)
  7. 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)
  8. src/main/webapp/js/admin/bootstrap.min.js.map

    })\n\n    // Restore body padding\n    const padding = $(document.body).data('padding-right')\n    $(document.body).removeData('padding-right')\n    document.body.style.paddingRight = padding ? padding : ''\n  }\n\n  _getScrollbarWidth() { // thx d.walsh\n    const scrollDiv = document.createElement('div')\n    scrollDiv.className = CLASS_NAME_SCROLLBAR_MEASURER\n    document.body.appendChild(scrollDiv)\n    const scrollbarWidth = scrollDiv.getBoundingClientRect().width - scrollDiv.clientWidth\n  ...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 180.9K bytes
    - Viewed (0)
  9. okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt

    2F8E          ; mapped                 ; 8840          # 3.0  KANGXI RADICAL BLOOD
    2F8F          ; mapped                 ; 884C          # 3.0  KANGXI RADICAL WALK ENCLOSURE
    2F90          ; mapped                 ; 8863          # 3.0  KANGXI RADICAL CLOTHES
    2F91          ; mapped                 ; 897E          # 3.0  KANGXI RADICAL WEST
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Feb 10 11:25:47 UTC 2024
    - 854.1K bytes
    - Viewed (0)
Back to top