- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 865 for acquire (0.19 sec)
-
src/main/java/jcifs/smb/SmbFileOutputStream.java
protected synchronized SmbFileHandleImpl ensureOpen () throws CIFSException { if ( !isOpen() ) { // one extra acquire to keep this open till the stream is released this.handle = this.file.openUnshared(this.openFlags, this.access, this.sharing, SmbConstants.ATTR_NORMAL, 0).acquire(); if ( this.append ) { this.fp = this.handle.getInitialSize(); if ( log.isDebugEnabled() ) {
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sat Nov 13 15:14:04 GMT 2021 - 11.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbRandomAccessFile.java
if ( this.handle == null || !this.handle.isValid() ) { // one extra acquire to keep this open till the stream is released this.handle = this.file.openUnshared(this.openFlags, this.access, this.sharing, SmbConstants.ATTR_NORMAL, this.options).acquire(); return this.handle; } return this.handle.acquire(); } /** * Ensures that the file descriptor is openend
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Wed Jan 08 12:01:33 GMT 2020 - 18.5K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/utils/InlineDelegatedPropertyAccessorsAnalyzer.kt
// and if a containing delegated property accessor is inline, // it might need this accessor's bytecode. // // If an accessor function is defined in a different module, // IDE tries to acquire its bytecode via the index, however, // the index doesn't cover classfiles from compiler output, // so the lowering fails. // // To solve the problem, we need to find all delegated properties with inline accessors
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Aug 29 23:55:31 GMT 2023 - 3.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
continue; } if ( log.isTraceEnabled() ) { log.trace("Reusing transport connection " + conn); } return conn.acquire(); } } return null; } @Override
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Dec 20 14:09:34 GMT 2020 - 12.5K bytes - Viewed (0) -
common-protos/k8s.io/api/coordination/v1/generated.proto
// leaseDurationSeconds is a duration that candidates for a lease need // to wait to force acquire it. This is measure against time of last // observed renewTime. // +optional optional int32 leaseDurationSeconds = 2; // acquireTime is a time when the current lease was acquired. // +optional optional k8s.io.apimachinery.pkg.apis.meta.v1.MicroTime acquireTime = 3;
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 2.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/escape/EscapersTest.java
assertEquals("<hello><hi><lo>", charEscaper.escape("x\uD800\uDC00")); assertEquals("<hello><hi><lo>", unicodeEscaper.escape("x\uD800\uDC00")); // Test that wrapped escapers acquire good Unicode semantics. assertEquals("<hi><hello><lo>", charEscaper.escape("\uD800x\uDC00")); try { unicodeEscaper.escape("\uD800x\uDC00"); fail("should have failed for bad Unicode input");
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
* was acquired, or null if no connection was acquired. The acquired connection will also be * given to [connectionUser] who may (for example) assign it to a [RealCall.connection]. * * This confirms the returned connection is healthy before returning it. If this encounters any * unhealthy connections in its search, this will clean them up. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
cmd/license-update.go
go func() { r := rand.New(rand.NewSource(time.Now().UnixNano())) // Leader node (that successfully acquires the lock inside licenceUpdaterLoop) // will keep performing the license update. If the leader goes down for some // reason, the lock will be released and another node will acquire it and // take over because of this loop. for { licenceUpdaterLoop(ctx, objAPI)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
return this.transportContext; } /** * {@inheritDoc} * * @see jcifs.util.transport.Transport#acquire() */ @Override public SmbTransportImpl acquire () { return (SmbTransportImpl) super.acquire(); } /** * @return the server's encryption key */ @Override public byte[] getServerEncryptionKey () {
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0) -
docs/contribute/concurrency.md
### Locks We have 3 different things that we synchronize on. #### Http2Connection This lock guards internal state of each connection. This lock is never held for blocking operations. That means that we acquire the lock, read or write a few fields and release the lock. No I/O and no application-layer callbacks. #### Http2Stream
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0)