- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for walkCh (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/test/java/org/codelibs/fess/thumbnail/ThumbnailGeneratorTest.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 11.4K bytes - Viewed (0) -
cmd/storage-interface.go
ListVols(ctx context.Context) (vols []VolInfo, err error) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) // WalkDir will walk a directory on disk and return a metacache stream on wr. WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error // Metadata operations
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 5.3K bytes - Viewed (0)