Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for Deferred (0.18 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/platform/android/DeferredSocketAdapter.kt

     * limitations under the License.
     */
    package okhttp3.internal.platform.android
    
    import javax.net.ssl.SSLSocket
    import okhttp3.Protocol
    
    /**
     * Deferred implementation of SocketAdapter that works by observing the socket
     * and initializing on first use.
     *
     * We use this because eager classpath checks cause confusion and excessive logging in Android,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

              } else {
                firstException.addSuppressed(throwable)
              }
            }
    
            val nextPlan = connectResult.nextPlan
            if (nextPlan != null) {
              // Try this plan's successor before deferred plans because it won the race!
              routePlanner.deferredPlans.addFirst(nextPlan)
            }
          }
        } finally {
          cancelInFlightConnects()
        }
    
        throw firstException!!
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt

      fun addPlan(): FakePlan {
        return FakePlan(nextPlanId++).also {
          plans += it
        }
      }
    
      override fun isCanceled() = canceled
    
      override fun plan(): FakePlan {
        // Return deferred plans preferentially. These don't require addPlan().
        if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst() as FakePlan
    
        if (nextPlanIndex >= plans.size && autoGeneratePlans) addPlan()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/Platform.java

    @ElementTypesAreNonnullByDefault
    final class Platform {
      /** Returns the platform preferred implementation of a map based on a hash table. */
      static <K extends @Nullable Object, V extends @Nullable Object>
          Map<K, V> newHashMapWithExpectedSize(int expectedSize) {
        return CompactHashMap.createWithExpectedSize(expectedSize);
      }
    
      /**
       * Returns the platform preferred implementation of an insertion ordered map based on a hash
       * table.
       */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 21:19:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  5. internal/config/browser/browser.go

    	// browserHSTSPreload setting name for Strict-Transport-Security response header 'preload' flag (true or false)
    	browserHSTSPreload = "hsts_preload"
    	// browserReferrerPolicy setting name for Referrer-Policy response header
    	browserReferrerPolicy = "referrer_policy"
    
    	EnvBrowserCSPPolicy             = "MINIO_BROWSER_CONTENT_SECURITY_POLICY"
    	EnvBrowserHSTSSeconds           = "MINIO_BROWSER_HSTS_SECONDS"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  6. analysis/analysis-api-fe10/tests-gen/org/jetbrains/kotlin/analysis/api/fe10/test/cases/generated/cases/components/typeProvider/Fe10IdeNormalAnalysisSourceModuleTypeReferenceTestGenerated.java

      }
    
      @Test
      @TestMetadata("underscoreTypeArgument_inferred.kt")
      public void testUnderscoreTypeArgument_inferred() {
        runTest("analysis/analysis-api/testData/components/typeProvider/typeReference/underscoreTypeArgument_inferred.kt");
      }
    
      @Test
      @TestMetadata("underscoreTypeArgument_reified.kt")
      public void testUnderscoreTypeArgument_reified() {
    Java
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Tue Feb 27 20:30:06 GMT 2024
    - 6.3K bytes
    - Viewed (0)
  7. doc/next/6-stdlib/1-time.md

    ### Timer changes
    
    Go 1.23 makes two significant changes to the implementation of
    [time.Timer] and [time.Ticker].
    
    First, `Timer`s and `Ticker`s that are no longer referred to by the program
    become eligible for garbage collection immediately, even if their
    `Stop` methods have not been called.
    Earlier versions of Go did not collect unstopped `Timer`s until after
    they had fired and never collected unstopped `Ticker`s.
    
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Apr 12 20:57:18 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  8. docs/site-replication/README.md

    # Automatic Site Replication
    
    This feature allows multiple independent MinIO sites (or clusters) that are using the same external IDentity Provider (IDP) to be configured as replicas. In this situation the set of replica sites are referred to as peer sites or just sites. When site-replication is enabled on a set of sites, the following changes are replicated to all other sites:
    
    - Creation and deletion of buckets and objects
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 21:30:28 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  9. cmd/erasure-decode.go

    	}
    }
    
    // preferReaders can mark readers as preferred.
    // These will be chosen before others.
    func (p *parallelReader) preferReaders(prefer []bool) {
    	if len(prefer) != len(p.orgReaders) {
    		return
    	}
    	// Copy so we don't change our input.
    	tmp := make([]io.ReaderAt, len(p.orgReaders))
    	copy(tmp, p.orgReaders)
    	p.readers = tmp
    	// next is the next non-preferred index.
    	next := 0
    	for i, ok := range prefer {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  10. cmd/tier-sweeper.go

    			ObjName:   os.RemoteObject,
    			VersionID: os.TransitionVersionID,
    			TierName:  os.TransitionTier,
    		}, true
    	}
    	return jentry{}, false
    }
    
    // Sweep removes the transitioned object if it's no longer referred to.
    func (os *objSweeper) Sweep() {
    	if je, ok := os.shouldRemoveRemoteObject(); ok {
    		globalExpiryState.enqueueTierJournalEntry(je)
    	}
    }
    
    type jentry struct {
    	ObjName   string
    	VersionID string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 4.7K bytes
    - Viewed (0)
Back to top