Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for closeLocked (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt

          result.onRequestStart(CloseSocket())
        }
    
        SocketPolicy.DISCONNECT_AFTER_REQUEST -> {
          result.onResponseStart(CloseSocket())
        }
    
        SocketPolicy.DISCONNECT_DURING_REQUEST_BODY -> {
          result.onRequestBody(CloseSocket())
        }
    
        SocketPolicy.DISCONNECT_DURING_RESPONSE_BODY -> {
          result.onResponseBody(CloseSocket())
        }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.3K bytes
    - Click Count (1)
  2. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

    import kotlin.time.Duration
    import kotlin.time.Duration.Companion.milliseconds
    import kotlin.time.measureTime
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketEffect.CloseSocket
    import mockwebserver3.SocketEffect.ShutdownConnection
    import mockwebserver3.junit5.StartStop
    import okhttp3.Headers.Companion.headersOf
    import okhttp3.HttpUrl.Companion.toHttpUrl
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 18.8K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt

    import java.util.concurrent.TimeUnit
    import javax.net.ssl.SSLException
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketEffect.CloseSocket
    import mockwebserver3.SocketEffect.ShutdownConnection
    import mockwebserver3.junit5.StartStop
    import okhttp3.Headers.Companion.headersOf
    import okhttp3.MediaType.Companion.toMediaType
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.3K bytes
    - Click Count (1)
  4. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketEffect.CloseSocket
    import mockwebserver3.junit5.StartStop
    import okhttp3.CallEvent.CacheConditionalHit
    import okhttp3.CallEvent.CacheHit
    import okhttp3.CallEvent.CacheMiss
    import okhttp3.CallEvent.CallEnd
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 70.7K bytes
    - Click Count (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

              stream.connection.shutdown(ErrorCode.NO_ERROR)
            } else {
              socket.close()
            }
          }
    
          is CloseSocket -> {
            if (effect.shutdownInput) socket.shutdownInput()
            if (effect.shutdownOutput) socket.shutdownOutput()
            if (effect.closeSocket) socket.close()
          }
    
          Stall -> {
            // Sleep until the socket is closed.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 40.3K bytes
    - Click Count (0)
Back to Top