- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 145 for Carrier (0.05 seconds)
-
guava/src/com/google/common/base/FinalizableReferenceQueue.java
* java.lang.ref.Cleaner Cleaner}; see example <a href="#cleaner">below</a>. * * <p>Keep a strong reference to this object until all of the associated referents have been * finalized. If this object is garbage collected earlier, the backing thread will not invoke {@code * finalizeReferent()} on the remaining references. * * <p>As an example of how this is used, imagine you have a class {@code MyServer} that creates a
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 14.7K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* request, and ensure that (1/QPS) seconds have elapsed since then. For example, for a rate of * QPS=5 (5 tokens per second), if we ensure that a request isn't granted earlier than 200ms after * the last one, then we achieve the intended rate. If a request comes and the last request was * granted only 100ms ago, then we wait for another 100ms. At this rate, serving 15 fresh permits
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed May 14 19:40:47 GMT 2025 - 19.3K bytes - Click Count (0) -
cmd/update.go
"github.com/valyala/bytebufferpool" ) const ( envMinisignPubKey = "MINIO_UPDATE_MINISIGN_PUBKEY" updateTimeout = 10 * time.Second ) var ( // Newer official download info URLs appear earlier below. minioReleaseInfoURL = MinioReleaseURL + "minio.sha256sum" // For windows our files have .exe additionally. minioReleaseWindowsInfoURL = MinioReleaseURL + "minio.exe.sha256sum" )
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 18.9K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/ReactorReader.java
// Check if the project is part of the session (not filtered by -pl, -rf, etc). If so, we check // if a possible earlier Maven invocation produced some output for that project which we can use. boolean projectHasOutputFromPreviousSession = !session.getProjects().contains(project) && outputDirectory.exists();Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Dec 15 11:20:38 GMT 2025 - 24.4K bytes - Click Count (0) -
internal/config/config.go
// during `init()`. func RegisterDefaultKVS(kvsMap map[string]KVS) { maps.Copy(DefaultKVS, kvsMap) } // HelpSubSysMap - help for all individual KVS for each sub-systems // also carries a special empty sub-system which dumps // help for each sub-system key. var HelpSubSysMap = map[string]HelpKVS{} // RegisterHelpSubSys - this function saves // input help KVS for each sub-system globally,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 37.7K bytes - Click Count (0) -
CHANGELOG.md
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 05 16:02:59 GMT 2025 - 36.2K bytes - Click Count (2) -
docs/bucket/replication/README.md
```
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 18.3K bytes - Click Count (0) -
internal/bucket/lifecycle/lifecycle_test.go
events := evaluator.eval([]ObjectOpts{opts}, time.Time{}) event := events[0] if event.Action != TransitionAction { t.Fatalf("Expected %v action but got %v", TransitionAction, event.Action) } // The earlier upcoming lifecycle event must be picked, i.e rule with id "Transition-10" if exp := ExpectedExpiryTime(opts.ModTime, 10); exp != event.Due { t.Fatalf("Expected due %v but got %v, ruleID=%v", exp, event.Due, event.RuleID) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 55.5K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
// (hypothetical) unsafe read by our caller. Note: adding 'volatile' does not fix this issue, // it would just add an edge such that if done() observed non-null, then it would also // definitely observe all earlier writes, but we still have no guarantee that done() would see // the initial write (just stronger guarantees if it does). // // See: http://cs.oswego.edu/pipermail/concurrency-interest/2015-January/013800.html
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 64.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* * Note that response failures do not necessarily fail the entire call. * * Starting with OkHttp 4.3 this may be invoked without a prior call to [responseHeadersStart] * or [responseBodyStart]. In earlier releases this method was documented to only be invoked after * one of those methods. */ open fun responseFailed( call: Call, ioe: IOException, ) { } /**
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:03:04 GMT 2025 - 24.9K bytes - Click Count (0)