- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 510 for locks (0.03 sec)
-
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/ExtensionBlocksSummaryRenderer.java
parent.appendChild(section); Element title = document.createElement("title"); section.appendChild(title); title.appendChild(document.createTextNode("Script blocks added by the ")); Element literal = document.createElement("literal"); title.appendChild(literal); literal.appendChild(document.createTextNode(extension.getPluginId()));
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 2.6K bytes - Viewed (0) -
api/go1.13.txt
pkg syscall (netbsd-arm64-cgo), type RtMetrics struct, Expire int64 pkg syscall (netbsd-arm64-cgo), type RtMetrics struct, Hopcount uint64 pkg syscall (netbsd-arm64-cgo), type RtMetrics struct, Locks uint64 pkg syscall (netbsd-arm64-cgo), type RtMetrics struct, Mtu uint64 pkg syscall (netbsd-arm64-cgo), type RtMetrics struct, Pksent int64 pkg syscall (netbsd-arm64-cgo), type RtMetrics struct, Recvpipe uint64
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Aug 08 18:44:16 UTC 2019 - 452.6K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
return false } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) Close() error { return nil } var ( errLockConflict = errors.New("lock conflict") errLockNotFound = errors.New("lock not found") ) func toLockError(err error) error { if err == nil { return nil } switch err.Error() { case errLockConflict.Error(): return errLockConflict
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
cmd/site-replication-utils.go
if peer.DeploymentID == globalDeploymentID() { continue } rs, err := loadSiteResyncMetadata(ctx, objAPI, peer.DeploymentID) if err != nil { return err } sm.Lock() if _, ok := sm.peerResyncMap[peer.DeploymentID]; !ok { sm.peerResyncMap[peer.DeploymentID] = resyncState{resyncID: rs.ResyncID, LastSaved: time.Time{}} sm.resyncStatus[rs.ResyncID] = rs } sm.Unlock() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransCallNamedPipeResponse.java
if( pipe.pipeIn != null ) { TransactNamedPipeInputStream in = (TransactNamedPipeInputStream)pipe.pipeIn; synchronized( in.lock ) { in.receive( buffer, bufferIndex, len ); in.lock.notify(); } } return len; } public String toString() { return new String( "TransCallNamedPipeResponse[" + super.toString() + "]" );
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/primitives/Ints.java
// block of size n-d (a[d..n-1]), where in general these blocks have different sizes. If we // imagine a line separating the first block from the second, we can proceed by exchanging // the smaller of these blocks with the far end of the other one. That leaves us with a // smaller version of the same problem.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 18:05:56 UTC 2024 - 31K bytes - Viewed (0) -
internal/ioutil/append-file_windows.go
import ( "io" "os" "github.com/minio/minio/internal/lock" ) // AppendFile - appends the file "src" to the file "dst" func AppendFile(dst string, src string, osync bool) error { appendFile, err := lock.Open(dst, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0o666) if err != nil { return err } defer appendFile.Close() srcFile, err := lock.Open(src, os.O_RDONLY, 0o666) if err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 1.2K bytes - Viewed (0) -
guava/src/com/google/common/hash/Striped64.java
* needed. * * A single spinlock ("busy") is used for initializing and * resizing the table, as well as populating slots with new Cells. * There is no need for a blocking lock; when the lock is not * available, threads try other slots (or the base). During these * retries, there is increased contention and reduced locality, * which is still better than alternatives. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 14 17:55:55 UTC 2024 - 11.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
protected abstract <V> ListenableFuture<V> createListenableFuture( V value, @Nullable Exception except, CountDownLatch waitOn); /** Tests that the {@link Future#get()} method blocks until a value is available. */ public void testGetBlocksUntilValueAvailable() throws Throwable { assertFalse(future.isDone()); assertFalse(future.isCancelled());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/SplitterTest.java
} public void testCharacterSplitWithMultipleLetters() { Iterable<String> testCharacteringMotto = Splitter.on('-').split("Testing-rocks-Debugging-sucks"); assertThat(testCharacteringMotto) .containsExactly("Testing", "rocks", "Debugging", "sucks") .inOrder(); } public void testCharacterSplitWithMatcherDelimiter() { Iterable<String> testCharacteringMotto =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Sep 17 18:14:12 UTC 2024 - 29.6K bytes - Viewed (0)