- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 445 for if (0.38 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
@Throws(IOException::class) fun initialize() { this.assertThreadHoldsLock() if (initialized) { return // Already initialized. } // If a bkp file exists, use it instead. if (fileSystem.exists(journalFileBackup)) { // If journal file also exists just delete backup file. if (fileSystem.exists(journalFile)) { fileSystem.delete(journalFileBackup) } else {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
frameLength = (b1 and B1_MASK_LENGTH).toLong() if (frameLength == PAYLOAD_SHORT.toLong()) { frameLength = (source.readShort() and 0xffff).toLong() // Value is unsigned. } else if (frameLength == PAYLOAD_LONG.toLong()) { frameLength = source.readLong() if (frameLength < 0L) { throw ProtocolException(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
if (errorCode != null) { return false } if ((source.finished || source.closed) && (sink.finished || sink.closed) && hasResponseHeaders ) { return false } return true } } /** Returns true if this stream was created by this peer. */ val isLocallyInitiated: Boolean get() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
// If the connection is in use, keep searching. if (pruneAndGetAllocationCount(connection, now) > 0) { inUseConnectionCount++ return@withLock } val idleAtNs = connection.idleAtNs if (idleAtNs < earliestOldIdleAtNs) { earliestOldIdleAtNs = idleAtNs earliestOldConnection = connection }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10ExpressionTypeProvider.kt
// Handle callable declarations with explicit return type first if (declaration is KtCallableDeclaration) { val typeReference = declaration.typeReference if (typeReference != null) { val bindingContext = analysisContext.analyze(typeReference, AnalysisMode.PARTIAL) val kotlinType = if (declaration is KtParameter && declaration.isVarArg) {
Plain Text - Registered: Fri May 03 08:18:13 GMT 2024 - Last Modified: Tue Oct 24 20:59:56 GMT 2023 - 15.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
* for conditional GETs) or warnings to the cached response (if the cached data is potentially * stale). */ class CacheStrategy internal constructor( /** The request to send on the network, or null if this call doesn't use the network. */ val networkRequest: Request?, /** The cached response to return or validate; or null if this call doesn't use a cache. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
if (response.socketPolicy === DisconnectAfterRequest) { socket.close() return false } if (response.socketPolicy === HalfCloseAfterRequest) { socket.shutdownOutput() return false } if (response.socketPolicy === NoResponse) { // This read should block until the socket is closed. (Because nobody is writing.) if (source.exhausted()) return false
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/references/FirReferenceResolveHelper.kt
): KtSymbol? { val classLikeDeclaration = this.toSymbol(session)?.fir if (classLikeDeclaration is FirRegularClass) { if (calleeReference is FirResolvedNamedReference) { val callee = calleeReference.resolvedSymbol.fir as? FirCallableDeclaration // TODO: check callee owner directly? if (callee !is FirConstructor && callee?.isStatic != true) {
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Mon Apr 15 10:59:01 GMT 2024 - 37.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/testing/PlatformRule.kt
if (platformSystemProperty == JDK9_PROPERTY) { if (System.getProperty("javax.net.debug") == null) { System.setProperty("javax.net.debug", "") } } else if (platformSystemProperty == CONSCRYPT_PROPERTY) { if (Security.getProviders()[0].name != "Conscrypt") { if (!Conscrypt.isAvailable()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.3K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
*/ fun peekHeader(): DerHeader? { var result = peekedHeader if (result == null) { result = readHeader() peekedHeader = result } if (result.isEndOfData) return null return result } /** * Consume the next header in the stream and return it. If there is no header to read because we * have reached a limit, this returns [END_OF_DATA]. */
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)