- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 865 for acquire (0.18 sec)
-
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 Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeConnection.java
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Tue Jul 07 10:50:16 GMT 2020 - 31K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileHandleImpl.java
} } /** * @return a file handle with increased usage count */ public SmbFileHandleImpl acquire () { long usage = this.usageCount.incrementAndGet(); if ( log.isTraceEnabled() ) { log.trace(String.format("Acquire %s (%d)", this, usage)); } return this; } /** * */ public void markClosed () {
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 8.6K 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 Apr 28 00:10:09 GMT 2024 - Last Modified: Sun May 17 08:55:14 GMT 2020 - 13.2K 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 Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 8.9K bytes - Viewed (0) -
common-protos/k8s.io/api/coordination/v1beta1/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.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 Apr 26 12:43:10 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 Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Nov 14 17:41:04 GMT 2021 - 49K bytes - Viewed (0) -
cmd/namespace-lock_test.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.1K bytes - Viewed (0)