- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 431 for callback1 (0.04 sec)
-
cmd/auth-handler.go
return ErrNone } if action == policy.ListBucketVersionsAction { // In AWS S3 s3:ListBucket permission is same as s3:ListBucketVersions permission // verify as a fallback. if globalPolicySys.IsAllowed(policy.BucketPolicyArgs{ AccountName: cred.AccessKey, Groups: cred.Groups, Action: policy.ListBucketAction, BucketName: bucket,Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
guava/src/com/google/common/base/FinalizableReferenceQueue.java
* public void close() throws IOException { * serverSocket.close(); * cleanable.clean(); * } * } * } * * <p>Some care is needed when using {@code Cleaner} to ensure that the callback passed to {@code * register} does not have a reference to the object (in this case, {@code MyServer}) that may be * garbage-collected. That's why we are careful to make a {@code Runnable} that does not have a
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 14.7K bytes - Viewed (0) -
fess-crawler/src/test/resources/ajax/js/jquery-2.1.1.min.js
lice():b],d?i.push(b):j(b)),this},fire:function(){return k.fireWith(this,arguments),this},fired:function(){return!!c}};return k},n.extend({Deferred:function(a){var b=[["resolve","done",n.Callbacks("once memory"),"resolved"],["reject","fail",n.Callbacks("once memory"),"rejected"],["notify","progress",n.Callbacks("memory")]],c="pending",d={state:function(){return c},always:function(){return e.done(arguments).fail(arguments),this},then:function(){var a=arguments;return n.Deferred(function(c){n.each...
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Oct 11 02:16:55 UTC 2015 - 82.3K bytes - Viewed (0) -
guava/src/com/google/common/base/MoreObjects.java
* * <p><b>Note:</b> if {@code first} is represented as an {@link Optional}, this can be * accomplished with {@link Optional#or(Object) first.or(second)}. That approach also allows for * lazy evaluation of the fallback instance, using {@link Optional#or(Supplier) * first.or(supplier)}. * * <p><b>Java 9 users:</b> use {@code java.util.Objects.requireNonNullElse(first, second)} * instead. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 16.6K bytes - Viewed (0) -
internal/lru/lru.go
package lru // golang -lru // https://github.com/hashicorp/golang-lru import ( "sync" "time" ) // EvictCallback is used to get a callback when a cache entry is evicted type EvictCallback[K comparable, V any] func(key K, value V) // LRU implements a thread-safe LRU with expirable entries. type LRU[K comparable, V any] struct { size int evictList *LruList[K, V] items map[K]*Entry[K, V] onEvict EvictCallback[K, V]
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 12.5K bytes - Viewed (0) -
apache-maven/src/assembly/maven/bin/mvn.cmd
@REM ==== END VALIDATION ==== :init set "CLASSWORLDS_CONF=%MAVEN_HOME%\bin\m2.conf" @REM Find the project basedir, i.e., the directory that contains the directory ".mvn". @REM Fallback to current working directory if not found. set "EXEC_DIR=%CD%" set "WDIR=%EXEC_DIR%" @REM Look for the --file switch and start the search for the .mvn directory from the specified @REM POM location, if supplied.
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Dec 10 16:40:06 UTC 2025 - 10.7K bytes - Viewed (3) -
docs/smb3-features/01-smb3-lease-design.md
} catch (TimeoutException e) { // Force lease release if break handling times out releaseLease(key); log.warn("Lease break timeout for key: {}", key); } } ``` ### 10.2 Fallback to Oplocks ```java if (!context.getConfig().isUseLeases() || !session.supports(SMB3_0)) { // Fall back to traditional oplock mechanism useOplockInstead(); } ``` ## 11. Monitoring and Metrics
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 22K bytes - Viewed (0) -
internal/s3select/select.go
if s3Select.progressReader != nil { return s3Select.progressReader.Stats() } return -1, -1 } // Open - opens S3 object by using callback for SQL selection query. // Currently CSV, JSON and Apache Parquet formats are supported. func (s3Select *S3Select) Open(rsc io.ReadSeekCloser) error { offset, length, err := s3Select.ScanRange.StartLen() if err != nil {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 21.2K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
} meta, err := loadBucketMetadataParse(ctx, objAPI, bucket, parse) if err != nil { if !globalIsErasure && !globalIsDistErasure && errors.Is(err, errVolumeNotFound) { // Only single drive mode needs this fallback. meta = newBucketMetadata(bucket) } else { return updatedAt, err } } updatedAt = UTCNow() switch configFile { case bucketPolicyConfig: meta.PolicyConfigJSON = configData
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.4K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
} s += "}" } res = append(res, []byte(s)...) } res = append(res, '}') return res, nil } // files returns files as callback. func (x xlMetaInlineData) files(fn func(name string, data []byte)) error { if len(x) == 0 { return nil } if !x.versionOK() { return errors.New("xlMetaInlineData: unknown version") }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 40.4K bytes - Viewed (0)