- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 477 for acquire (0.19 sec)
-
internal/lsync/lrwmutex_test.go
lrwm := NewLRWMutex() if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() { time.Sleep(2 * time.Second) lrwm.RUnlock()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
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 Apr 28 00:10:09 GMT 2024 - Last Modified: Sun May 17 09:02:44 GMT 2020 - 6.3K 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 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/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/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) -
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) -
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) -
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)