- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 56 for walkCh (0.12 seconds)
-
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) }()Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 63.5K bytes - Click Count (1) -
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") }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon May 26 07:06:43 GMT 2025 - 12.6K bytes - Click Count (0) -
src/cmd/cgo/ast.go
f.walk(n.Assign, ctxStmt, visit) f.walk(n.Body, ctxTypeSwitch, visit) case *ast.CommClause: f.walk(n.Comm, ctxStmt, visit) f.walk(n.Body, ctxStmt, visit) case *ast.SelectStmt: f.walk(n.Body, ctxStmt, visit) case *ast.ForStmt: f.walk(n.Init, ctxStmt, visit) f.walk(&n.Cond, ctxExpr, visit) f.walk(n.Post, ctxStmt, visit) f.walk(n.Body, ctxStmt, visit) case *ast.RangeStmt:
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Jan 08 17:58:59 GMT 2026 - 14.4K bytes - Click Count (0) -
src/cmd/api/main_test.go
} func NewWalker(context *build.Context, root string) *Walker { w := &Walker{ context: context, root: root, features: map[string]bool{}, imported: map[string]*apiPackage{"unsafe": &apiPackage{Package: types.Unsafe}}, } w.loadImports() return w } func (w *Walker) Features() (fs []string) { for f := range w.features { fs = append(fs, f) }
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Mar 02 13:20:41 GMT 2026 - 31.4K bytes - Click Count (0) -
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;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 20.6K bytes - Click Count (0) -
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;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 20.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/ThemeHelper.java
if (logger.isDebugEnabled()) { logger.debug("Path does not exist: path={}", dir); } return; } try (Stream<Path> walk = Files.walk(dir, FileVisitOption.FOLLOW_LINKS)) { walk.sorted(Comparator.reverseOrder()).forEach(f -> { if (logger.isDebugEnabled()) { logger.debug("Deleting: path={}", f); }
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 7.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
hanging from the roof. There were doors all round the hall, but they were all locked; and when Alice had been all the way down one side and up the other, trying every door, she walked sadly down the middle, wondering how she was ever to get out again. Suddenly she came upon a little three-legged table, all made of solid glass; there was nothing on it except a tiny golden key,
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Apr 21 02:27:51 GMT 2017 - 145.2K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/test/rest/CopyRestApiTask.java
try { // check source folder for tests if (sourceResourceDir != null && new File(sourceResourceDir, REST_TEST_PREFIX).exists()) { return Files.walk(sourceResourceDir.toPath().resolve(REST_TEST_PREFIX)) .anyMatch(p -> p.getFileName().toString().endsWith("yml")); } // check output for cases where tests are copied programmaticallyCreated: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 22 07:24:59 GMT 2021 - 7.4K bytes - Click Count (0) -
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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.5K bytes - Click Count (0)