Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 737 for vals (0.01 sec)

  1. container-tests/src/test/java/okhttp3/containers/BasicMockServerTest.kt

          apply {
            val keyStoreFactory = KeyStoreFactory(Configuration.configuration(), MockServerLogger())
    
            val socketFactory = keyStoreFactory.sslContext().socketFactory
    
            val trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm())
            trustManagerFactory.init(keyStoreFactory.loadOrCreateKeyStore())
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  2. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

    @Suppress("ktlint:standard:max-line-length")
    class LoggingEventListenerTest {
      @RegisterExtension
      val platform = PlatformRule()
    
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      @StartStop
      private val server = MockWebServer()
    
      private val handshakeCertificates = platform.localhostHandshakeCertificates()
      private val logRecorder =
        HttpLoggingInterceptorTest.LogRecorder(
          prefix = Regex("""\[\d+ ms] """),
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

      duration: Int,
      timeUnit: TimeUnit,
    ): Boolean {
      val nowNs = System.nanoTime()
      val originalDurationNs =
        if (timeout().hasDeadline()) {
          timeout().deadlineNanoTime() - nowNs
        } else {
          Long.MAX_VALUE
        }
      timeout().deadlineNanoTime(nowNs + minOf(originalDurationNs, timeUnit.toNanos(duration.toLong())))
      return try {
        val skipBuffer = Buffer()
        while (read(skipBuffer, 8192) != -1L) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 10.2K bytes
    - Viewed (1)
  4. .teamcity/src/main/kotlin/projects/CheckProject.kt

            var prevStage: Stage? = null
            val previousPerformanceTestPasses: MutableList<PerformanceTestsPass> = mutableListOf()
            val previousCrossVersionTests: MutableList<BaseGradleBuildType> = mutableListOf()
            model.stages.forEach { stage ->
                if (isSecurityFork() && stage.stageName > StageName.READY_FOR_RELEASE) {
                    return@forEach
                }
                val stageProject =
                    StageProject(
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Feb 12 09:12:03 UTC 2025
    - 3.9K bytes
    - Viewed (1)
  5. samples/tlssurvey/src/main/kotlin/okhttp3/survey/Iana.kt

    import okio.IOException
    
    /** Example: "0x00,0x08",TLS_RSA_EXPORT_WITH_DES40_CBC_SHA,Y,N,[RFC4346] */
    val IANA_CSV_PATTERN = "\"0x(\\w\\w),0x(\\w\\w)\",(\\w+).*".toRegex()
    
    fun parseIanaCsvRow(s: String): SuiteId? {
      if (s.contains("Reserved") || s.contains("Unassigned")) return null
      val matcher = IANA_CSV_PATTERN.matchEntire(s) ?: return null
      val id = (matcher.groupValues[1] + matcher.groupValues[2]).decodeHex()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    func (s *peerRESTServer) StartProfilingHandler(w http.ResponseWriter, r *http.Request) {
    	if !s.IsValid(w, r) {
    		s.writeErrorResponse(w, errors.New("Invalid request"))
    		return
    	}
    
    	vars := mux.Vars(r)
    	profiles := strings.Split(vars[peerRESTProfiler], ",")
    	if len(profiles) == 0 {
    		s.writeErrorResponse(w, errors.New("profiler name is missing"))
    		return
    	}
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  7. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt

    @Tag("Slowish")
    class EventSourceHttpTest {
      @RegisterExtension
      val platform = PlatformRule()
    
      @StartStop
      private val server = MockWebServer()
    
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
      private val eventListener = RecordingEventListener()
      private val listener = EventSourceRecorder()
      private var client =
        clientTestRule
          .newClientBuilder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpStatusCodes.kt

    const val HTTP_CONTINUE = 100
    
    /** `101 Switching Protocols` (HTTP/1.1 - RFC 9110)  */
    const val HTTP_SWITCHING_PROTOCOLS = 101
    
    /** `102 Processing` (WebDAV - RFC 2518)  */
    const val HTTP_PROCESSING = 102
    
    /** `103 Early Hints (Early Hints - RFC 8297)` */
    const val HTTP_EARLY_HINTS = 103
    
    /** `307 Temporary Redirect` (HTTP/1.1 - RFC 7231)  */
    const val HTTP_TEMP_REDIRECT = 307
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 14:39:28 UTC 2025
    - 2K bytes
    - Viewed (0)
  9. mockwebserver-junit5/src/main/kotlin/mockwebserver3/junit5/internal/StartStopExtension.kt

      override fun beforeAll(context: ExtensionContext) {
        val store = context.getStore(Namespace.create(StartStop::class.java))
    
        val staticFields =
          findAnnotatedFields(
            context.requiredTestClass,
            StartStop::class.java,
          ) { Modifier.isStatic(it.modifiers) }
    
        for (field in staticFields) {
          field.setAccessible(true)
          val server = field.get(null) as? MockWebServer ?: continue
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jun 19 11:44:16 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  10. settings.gradle.kts

    include(":samples:unixdomainsockets")
    include(":container-tests")
    
    project(":okhttp-logging-interceptor").name = "logging-interceptor"
    
    val androidHome = System.getenv("ANDROID_HOME")
    val localProperties = Properties().apply {
      val file = File("local.properties")
      if (file.exists()) {
        load(file.inputStream())
      }
    }
    val sdkDir = localProperties.getProperty("sdk.dir")
    if (androidHome != null || sdkDir != null) {
      include(":android-test")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jul 19 13:41:00 UTC 2025
    - 1.9K bytes
    - Viewed (0)
Back to top