- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 865 for acquire (0.22 sec)
-
src/main/java/jcifs/SmbTransportPool.java
/** * Get transport connection * * @param tc * context to use * @param address * @param port * @param exclusive * whether to acquire an unshared connection * @return a transport connection to the target */ SmbTransport getSmbTransport ( CIFSContext tc, Address address, int port, boolean exclusive ); /**
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun May 17 09:02:44 GMT 2020 - 6.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbPipeHandleImpl.java
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Mon Apr 13 17:05:22 GMT 2020 - 10.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeHandleImpl.java
release(); } /** * @return tree handle with increased usage count */ public SmbTreeHandleImpl acquire () { if ( this.usageCount.incrementAndGet() == 1 ) { this.treeConnection.acquire(); } return this; } @Override public void release () { long us = this.usageCount.decrementAndGet();
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 8.9K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(context.Background()) if !drwm2.GetRLock(ctx2, cancel2, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
* <p>To avoid races between threads doing release and acquire, we transition to the final state * in two steps. One thread will successfully CAS from RUNNING to COMPLETING, that thread will * then set the result of the computation, and only then transition to COMPLETED, CANCELLED, or * INTERRUPTED. * * <p>We don't use the integer argument passed between acquire methods so we pass around a -1 * everywhere. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
* <p>To avoid races between threads doing release and acquire, we transition to the final state * in two steps. One thread will successfully CAS from RUNNING to COMPLETING, that thread will * then set the result of the computation, and only then transition to COMPLETED, CANCELLED, or * INTERRUPTED. * * <p>We don't use the integer argument passed between acquire methods so we pass around a -1 * everywhere. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
throw new ClassCastException(); } /** * @return session increased usage count */ public SmbSessionImpl acquire () { long usage = this.usageCount.incrementAndGet(); if ( log.isTraceEnabled() ) { log.trace("Acquire session " + usage + " " + this); } if ( usage == 1 ) { synchronized ( this ) {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Nov 14 17:41:04 GMT 2021 - 49K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileInputStream.java
} else { this.handle = this.file.openUnshared(this.openFlags, this.access, this.sharing, SmbConstants.ATTR_NORMAL, 0).acquire(); } return this.handle; } return this.handle.acquire(); } protected static IOException seToIoe ( SmbException se ) { IOException ioe = se; Throwable root = se.getCause();
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun May 17 08:55:14 GMT 2020 - 13.2K 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 May 05 00:10:10 GMT 2024 - Last Modified: Sun Dec 20 14:09:34 GMT 2020 - 12.5K 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 May 05 00:10:10 GMT 2024 - Last Modified: Wed Jan 08 12:01:33 GMT 2020 - 18.5K bytes - Viewed (0)