Slow connects

square · Apr 27, 2024 · 0080615 · 0080615
1 parent 9899f03
commit 0080615
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt b/mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
@@ -45,6 +45,7 @@ import javax.net.ssl.SSLSocket
 import javax.net.ssl.SSLSocketFactory
 import javax.net.ssl.TrustManager
 import javax.net.ssl.X509TrustManager
+import kotlin.time.Duration.Companion.milliseconds
 import mockwebserver3.SocketPolicy.DisconnectAfterRequest
 import mockwebserver3.SocketPolicy.DisconnectAtEnd
 import mockwebserver3.SocketPolicy.DisconnectAtStart
@@ -376,9 +377,10 @@ class MockWebServer : Closeable {
     while (true) {
       val socketPolicy = dispatcher.peek().socketPolicy
 
-      if (socketPolicy is SocketPolicy.DelayAccept) {
-        Thread.sleep(socketPolicy.delay.inWholeMilliseconds)
-      }
+//      if (socketPolicy is SocketPolicy.DelayAccept) {
+        println("delay")
+        Thread.sleep(100.milliseconds.inWholeMilliseconds)
+//      }
 
       val socket: Socket
       try {

diff --git a/okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt b/okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt
@@ -120,7 +120,7 @@ internal object Locks {
       measureTimedValue { function() }.also {
         val lockDuration = it.duration
 //        if (lockDuration > 1.milliseconds) {
-//          println(Thread.currentThread().name + " await " + lockDuration)
+          println(Thread.currentThread().name + " await " + lockDuration)
 //          Exception().printStackTrace()
           threadLocalAwait.set(threadLocalAwait.get() + lockDuration)
 //        }

diff --git a/okhttp/src/test/java/okhttp3/SlowNetworkTest.kt b/okhttp/src/test/java/okhttp3/SlowNetworkTest.kt
@@ -84,6 +84,7 @@ class SlowNetworkTest {
             call: Call,
             response: Response,
           ) {
+            println("response")
             response.body.string()
             latch.countDown()
           }