Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 510 for locks (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top