Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 145 for Carrier (0.05 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. CHANGELOG.md

     *  Breaking: Adopt Okio's new `Socket` interface for `MockResponse.socketHandler`.
    
    Note that any _Breaking_ changes above impact only APIs introduced in earlier 5.0.0-alpha releasees.
    We don't break binary compatibility with non-alpha APIs.
    
    
    ## Version 5.0.0-alpha.16
    
    _2025-05-29_
    
    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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top