- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for synchronized (0.45 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
upstreamReader = Thread.currentThread() return@synchronized SOURCE_UPSTREAM } val bufferPos = upstreamPos - buffer.size // Bytes of the read precede the buffer. Read from the file. if (sourcePos < bufferPos) { return@synchronized SOURCE_FILE }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
check(socket == null) val socket = serverSocket!!.accept()!! this.socket = socket // Bail out now if this instance was closed while waiting for the socket to accept. synchronized(this) { if (executor.isShutdown) { socket.close() return } } val outputStream = socket.getOutputStream() val inputStream = socket.getInputStream()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
gradle/wrapper/gradle-wrapper.jar
META-INF/MANIFEST.MF Manifest-Version: 1.0 Implementation-Title: Gradle Wrapper org/gradle/cli/CommandLineArgumentE.class package org.gradle.cli; public final synchronized class CommandLineArgumentE extends RuntimeException { public void CommandLineArgumentE(String); } org/gradle/cli/CommandLineOption.class package org.gradle.cli; public final synchronized class CommandLineOption { public final java.util.HashSet options; public Class argumentType; public String description; public final java.util.HashSet...
Archive - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Dec 24 09:00:26 GMT 2023 - 42.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
*/ class RecordingCallback : Callback { private val responses = mutableListOf<RecordedResponse>() @Synchronized override fun onFailure( call: Call, e: IOException, ) { responses.add(RecordedResponse(call.request(), null, null, null, e)) (this as Object).notifyAll() } @Synchronized override fun onResponse( call: Call, response: Response, ) {
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) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
hitCount++ } } @Synchronized internal fun trackConditionalCacheHit() { hitCount++ } @Synchronized fun networkCount(): Int = networkCount @Synchronized fun hitCount(): Int = hitCount @Synchronized fun requestCount(): Int = requestCount private inner class RealCacheRequest(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/DeferredSocketAdapter.kt
} override fun getSelectedProtocol(sslSocket: SSLSocket): String? { return getDelegate(sslSocket)?.getSelectedProtocol(sslSocket) } @Synchronized private fun getDelegate(sslSocket: SSLSocket): SocketAdapter? { if (this.delegate == null && socketAdapterFactory.matchesSocket(sslSocket)) { this.delegate = socketAdapterFactory.create(sslSocket) }
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) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
fun tearDown() { taskQueue.shutdown() taskQueue.idleLatch().await(10, TimeUnit.SECONDS) } @Synchronized fun sentPingCount(): Int = sentPingCount @Synchronized fun receivedPingCount(): Int = receivedPingCount @Synchronized fun receivedPongCount(): Int = receivedPongCount @Throws(IOException::class) override fun onReadMessage(text: String) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
fun newClientBuilder(): OkHttpClient.Builder { return newClient().newBuilder() } @Synchronized private fun addEvent(event: String) { if (recordEvents) { logger?.info(event) synchronized(clientEventsList) { clientEventsList.add(event) } } } @Synchronized private fun initUncaughtException(throwable: Throwable) { if (uncaughtException == null) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
sink.writeUtf8("\r\n") sink.write(source, byteCount) sink.writeUtf8("\r\n") } @Synchronized override fun flush() { if (closed) return // Don't throw; this stream might have been closed on the caller's behalf. sink.flush() } @Synchronized override fun close() { if (closed) return closed = true sink.writeUtf8("0\r\n\r\n")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteDatabase.kt
private val _failedRoutes = mutableSetOf<Route>() val failedRoutes: Set<Route> @Synchronized get() = _failedRoutes.toSet() /** Records a failure connecting to [failedRoute]. */ @Synchronized fun failed(failedRoute: Route) { _failedRoutes.add(failedRoute) } /** Records success connecting to [route]. */ @Synchronized fun connected(route: Route) { _failedRoutes.remove(route) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 1.5K bytes - Viewed (0)