- Sort Score
- Num 10 results
- Language All
Results 371 - 380 of 542 for Oplock (0.14 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/peer-rest-client.go
} st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload) if err != nil { return } st.Results(func(b []byte) error { select { case traceCh <- b: default: // Do not block on slow receivers. // Just recycle the buffer. grid.PutByteBuffer(b) } return nil }) } func (client *peerRESTClient) doListen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
internal/config/identity/openid/jwt.go
if err != nil { return err } pk.add(key.Kid, pkey) } return nil } func (pk *publicKeys) add(keyID string, key any) { pk.Lock() defer pk.Unlock() pk.pkMap[keyID] = key } func (pk *publicKeys) get(kid string) any { pk.RLock() defer pk.RUnlock() return pk.pkMap[kid] } // PopulatePublicKey - populates a new publickey from the JWKS URL.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.4K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
* the Transport thread is not setup until doConnect() * returns and we want to suppress all communication * until we have properly negotiated. */ synchronized (this.inLock) { if (prt == 139) { ssn139(); } else { if (prt == 0) { prt = DEFAULT_PORT; // 445 }
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 69.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Tables.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 24.9K bytes - Click Count (0) -
cmd/metacache.go
// Max time between client calls before dropping an async cache listing. metacacheMaxClientWait = 3 * time.Minute // metacacheBlockSize is the number of file/directory entries to have in each block. metacacheBlockSize = 5000 // metacacheSharePrefix controls whether prefixes on dirty paths are always shared. // This will make `test/a` and `test/b` share listings if they are concurrent.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Jul 12 16:23:16 GMT 2024 - 6K bytes - Click Count (0) -
src/main/java/jcifs/smb/DfsImpl.java
private final Object domainsLock = new Object(); private final Map<String, CacheEntry<DfsReferralDataInternal>> dcCache = new HashMap<>(); private final Object dcLock = new Object(); private CacheEntry<DfsReferralDataInternal> referrals = null; private final Object referralsLock = new Object(); /** * Constructs a DFS resolver implementation *
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 29.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
} /* * This is an unsynchronized read! After the read, the function returns immediately or acquires * the lock to check again. Since an IDLE state was observed inside the preceding synchronized * block, and reference field assignment is atomic, this may save reacquiring the lock when * another thread or the worker task has cleared the count and set the state. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 10.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
@BeforeEach fun setUp() { if (connectionType == H2) { platform.assumeHttp2Support() } // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. server = MockWebServer() server.serverSocketFactory =
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 9.4K bytes - Click Count (0) -
impl/maven-core/lifecycle-executor.txt
- plugin in any default values - check to see if anything is missing
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 9.7K bytes - Click Count (0) -
scripts/tests/test_translation_fixer/test_complex_doc/data/translated_doc.md
Комментарии внутри вложенного блока кода в тройных обратных кавычках НЕ БУДУТ сохранены. ```` Here is a code block with quadruple backticks that contains triple backticks inside: ```python # Этот комментарий НЕ будет сохранён def hello_world(): print("Hello, world") # Как и этот комментарий ``` ````
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Tue Feb 17 08:08:04 GMT 2026 - 11.2K bytes - Click Count (0)