Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for walkCh (0.05 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/metacache-walk.go

    				forward = forward[:idx]
    			}
    		}
    
    		if s.walkMu != nil {
    			s.walkMu.Lock()
    		}
    		entries, err := s.ListDir(ctx, "", opts.Bucket, current, -1)
    		if s.walkMu != nil {
    			s.walkMu.Unlock()
    		}
    		if err != nil {
    			// Folder could have gone away in-between
    			if err != errVolumeNotFound && err != errFileNotFound {
    				internalLogOnceIf(ctx, err, "metacache-walk-scan-dir")
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/base/Throwables.java

       * </pre>
       *
       * @throws IllegalArgumentException if there is a loop in the causal chain
       */
      public static Throwable getRootCause(Throwable throwable) {
        // Keep a second pointer that slowly walks the causal chain. If the fast pointer ever catches
        // the slower pointer, then there's a loop.
        Throwable slowPointer = throwable;
        boolean advanceSlowPointer = false;
    
        Throwable cause;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/ThemeHelper.java

                if (logger.isDebugEnabled()) {
                    logger.debug("{} does not exists.", dir);
                }
                return;
            }
            try (Stream<Path> walk = Files.walk(dir, FileVisitOption.FOLLOW_LINKS)) {
                walk.sorted(Comparator.reverseOrder()).forEach(f -> {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Deleting {}", f);
                    }
                    try {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

    /* jcifs smb client library in Java
     * Copyright (C) 2000  "Michael B. Allen" <jcifs at samba dot org>
     *                     "Paul Walker" <jcifs at samba dot org>
     *
     * This library is free software; you can redistribute it and/or
     * modify it under the terms of the GNU Lesser General Public
     * License as published by the Free Software Foundation; either
     * version 2.1 of the License, or (at your option) any later version.
     *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbNamedPipe.java

    /* jcifs smb client library in Java
     * Copyright (C) 2000  "Michael B. Allen" <jcifs at samba dot org>
     *                     "Paul Walker" <jcifs at samba dot org>
     *
     * This library is free software; you can redistribute it and/or
     * modify it under the terms of the GNU Lesser General Public
     * License as published by the Free Software Foundation; either
     * version 2.1 of the License, or (at your option) any later version.
     *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. cmd/object-api-interface.go

    	ListObjectVersions(ctx context.Context, bucket, prefix, marker, versionMarker, delimiter string, maxKeys int) (result ListObjectVersionsInfo, err error)
    	// Walk lists all objects including versions, delete markers.
    	Walk(ctx context.Context, bucket, prefix string, results chan<- itemOrErr[ObjectInfo], opts WalkOptions) error
    
    	// Object operations.
    
    	// GetObjectNInfo returns a GetObjectReader that satisfies the
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  8. src/test/java/jcifs/tests/persistent/PersistentHandleManagerTest.java

            // Clean up system property
            System.clearProperty("jcifs.smb.client.handleStateDirectory");
    
            // Clean up temp directory
            if (tempDir != null && Files.exists(tempDir)) {
                Files.walk(tempDir)
                        .sorted((a, b) -> b.compareTo(a)) // Delete files before directories
                        .forEach(path -> {
                            try {
                                Files.delete(path);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/thumbnail/ThumbnailGeneratorTest.java

            // Clean up temp files
            if (tempOutputFile != null && tempOutputFile.exists()) {
                tempOutputFile.delete();
            }
            if (tempDir != null) {
                Files.walk(tempDir).sorted((a, b) -> b.compareTo(a)).forEach(path -> {
                    try {
                        Files.delete(path);
                    } catch (IOException e) {
                        // Ignore cleanup errors
                    }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  10. docs/debugging/reorder-disks/main.go

    	}
    
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    
    	return result, nil
    }
    
    func getDiskUUIDMap() (map[string]string, error) {
    	result := make(map[string]string)
    	err := filepath.Walk("/dev/disk/by-uuid/",
    		func(path string, info os.FileInfo, err error) error {
    			if err != nil {
    				return err
    			}
    			realPath, err := filepath.EvalSymlinks(path)
    			if err != nil {
    				return err
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
Back to top