- Sort Score
- Num 10 results
- Language All
Results 941 - 950 of 1,143 for logger (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/jcifs/smb1/util/transport/Transport.java
ex0 = ex; // Defer to below where we're locked return; } finally { synchronized (run_thread) { if (run_thread != thread) { /* Thread no longer the one setup for this transport -- * doConnect returned too late, just ignore. */ if ((ex0 != null) && (LogStream.level >= 2)) {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 11.3K bytes - Click Count (0) -
tests/test_sse.py
# Keepalive ping tests keepalive_app = FastAPI() @keepalive_app.get("/slow-async", response_class=EventSourceResponse) async def slow_async_stream(): yield {"n": 1} # Sleep longer than the (monkeypatched) ping interval so a keepalive # comment is emitted before the next item. await asyncio.sleep(0.3) yield {"n": 2}
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sun Mar 01 09:21:52 GMT 2026 - 9.8K bytes - Click Count (0) -
docs/changelogs/changelog_1x.md
used. * Fix 1.5.0 regression where conditional cache responses could corrupt the connection pool. ## Version 1.5.0 _2014-03-07_ ##### OkHttp no longer uses the default SSL context. Applications that want to use the global SSL context with OkHttp should configure their OkHttpClient instances with the following: ```java
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 6.4K bytes - Click Count (0) -
src/test/java/jcifs/pac/PacCredentialTypeTest.java
assertEquals("Invalid PAC credential type", exception.getMessage()); } /** * Tests the constructor with a byte array that is larger than the minimal buffer size. */ @Test void testConstructorWithDataMuchLarger() { // A byte array with a length greater than 32 should also be considered too large.
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 3.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
internal const val OPCODE_CONTROL_CLOSE = 0x8 internal const val OPCODE_CONTROL_PING = 0x9 internal const val OPCODE_CONTROL_PONG = 0xa /** * Maximum length of frame payload. Larger payloads, if supported by the frame type, can use the * special values [PAYLOAD_SHORT] or [PAYLOAD_LONG]. */ internal const val PAYLOAD_BYTE_MAX = 125L /** Maximum length of close message in bytes. */
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 4.8K bytes - Click Count (0) -
docs/uk/docs/advanced/settings.md
## Налаштування в іншому модулі { #settings-in-another-module } Ви можете розмістити ці налаштування в іншому модулі, як ви бачили в [Більші застосунки - кілька файлів](../tutorial/bigger-applications.md). Наприклад, у вас може бути файл `config.py` з: {* ../../docs_src/settings/app01_py310/config.py *} А потім використати його у файлі `main.py`:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:27:41 GMT 2026 - 16.5K bytes - Click Count (0) -
docs/es/docs/advanced/async-tests.md
## Ejemplo { #example } Para un ejemplo simple, consideremos una estructura de archivos similar a la descrita en [Aplicaciones Más Grandes](../tutorial/bigger-applications.md) y [Testing](../tutorial/testing.md): ``` . ├── app │ ├── __init__.py │ ├── main.py │ └── test_main.py ``` El archivo `main.py` tendría:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 4K bytes - Click Count (0) -
docs/fr/docs/advanced/async-tests.md
## Exemple { #example } Pour un exemple simple, considérons une structure de fichiers similaire à celle décrite dans [Applications plus grandes](../tutorial/bigger-applications.md) et [Tests](../tutorial/testing.md) : ``` . ├── app │ ├── __init__.py │ ├── main.py │ └── test_main.py ``` Le fichier `main.py` contiendrait :Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 4.3K bytes - Click Count (0) -
internal/dsync/drwmutex.go
} // Copy write locks to stack array copy(locks, dm.writeLocks) } // Tolerance is not set, defaults to half of the locker clients. tolerance := len(restClnts) / 2 isReadLock := false started := time.Now() // Do async unlocking. // This means unlock will no longer block on the network or missing quorum. go func() { ctx, done := context.WithTimeout(ctx, drwMutexUnlockCallTimeout) defer done()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.3K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ObjectCountHashMap.java
entries[srcIndex] = UNSET; // also need to update whoever's "next" pointer was pointing to the last entry place // reusing "tableIndex" and "next"; these variables were no longer needed int tableIndex = getHash(lastEntry) & hashTableMask(); int lastNext = table[tableIndex]; if (lastNext == srcIndex) { // we need to update the root pointer
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 14.5K bytes - Click Count (0)