Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 47 for walkCh (0.08 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. src/archive/tar/writer.go

    	}
    	if isHeaderOnlyType(flag) {
    		size = 0
    	}
    	tw.curr = &regFileWriter{tw.w, size}
    	tw.pad = blockPadding(size)
    	return nil
    }
    
    // AddFS adds the files from fs.FS to the archive.
    // It walks the directory tree starting at the root of the filesystem
    // adding each file to the tar archive while maintaining the directory structure.
    func (tw *Writer) AddFS(fsys fs.FS) error {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/DfsImpl.java

                        if ( log.isTraceEnabled() ) {
                            log.trace("Found at " + link);
                        }
                        break;
                    }
    
                    // walk up trying to find a match, do not go up to the root
                    int nextSep = link.lastIndexOf('\\');
                    if ( nextSep > 0 ) {
                        link = link.substring(0, nextSep);
                    }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:07:29 UTC 2023
    - 29.1K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  7. configure.py

      makefile_download_dir = os.path.join(_TF_WORKSPACE_ROOT, 'tensorflow',
                                           'contrib', 'makefile', 'downloads')
      if os.path.isdir(makefile_download_dir):
        for root, _, filenames in os.walk(makefile_download_dir):
          for f in filenames:
            if f.endswith('BUILD'):
              os.remove(os.path.join(root, f))
    
    
    def get_var(environ_cp,
                var_name,
                query_item,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Oct 02 22:16:02 UTC 2024
    - 48.2K bytes
    - Viewed (0)
  8. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 50.3K bytes
    - Viewed (0)
  9. src/cmd/cgo/gcc.go

    // they follow the rules for passing pointers between Go and C.
    // This reports whether the package needs to import unsafe as _cgo_unsafe.
    func (p *Package) rewriteCalls(f *File) bool {
    	needsUnsafe := false
    	// Walk backward so that in C.f1(C.f2()) we rewrite C.f2 first.
    	for _, call := range f.Calls {
    		if call.Done {
    			continue
    		}
    		start := f.offset(call.Call.Pos())
    		end := f.offset(call.Call.End())
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 18 15:07:34 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  10. doc/go_spec.html

    	key         K
    	value       V
    }
    
    func (t *Tree[K, V]) walk(yield func(key K, val V) bool) bool {
    	return t == nil || t.left.walk(yield) && yield(t.key, t.value) && t.right.walk(yield)
    }
    
    func (t *Tree[K, V]) Walk(yield func(key K, val V) bool) {
    	t.walk(yield)
    }
    
    // walk tree t in-order
    var t Tree[string, int]
    for k, v := range t.Walk {
    	// process k, v
    }
    </pre>
    
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (0)
Back to top