Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 221 - 230 of 857 for wlock (0.02 seconds)

  1. cmd/iam-object-store.go

    		objAPI:       objAPI,
    		usersSysType: usersSysType,
    	}
    }
    
    func (iamOS *IAMObjectStore) rlock() *iamCache {
    	iamOS.RLock()
    	return iamOS.iamCache
    }
    
    func (iamOS *IAMObjectStore) runlock() {
    	iamOS.RUnlock()
    }
    
    func (iamOS *IAMObjectStore) lock() *iamCache {
    	iamOS.Lock()
    	return iamOS.iamCache
    }
    
    func (iamOS *IAMObjectStore) unlock() {
    	iamOS.Unlock()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java

        }
    
        /**
         * Internal method to acquire a distributed lock with retry control.
         *
         * @param operationName the operation name used as the lock document ID.
         * @param data optional data to store with the operation document.
         * @param remainingRetries the number of remaining retry attempts for stale lock cleanup.
         * @return {@code true} if the lock was acquired.
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 33.3K bytes
    - Click Count (0)
  3. guava/src/com/google/common/cache/LocalCache.java

        }
      }
    
      /** A reference to a value. */
      interface ValueReference<K, V> {
        /** Returns the value. Does not block or throw exceptions. */
        @Nullable V get();
    
        /**
         * Waits for a value that may still be loading. Unlike get(), this method can block (in the case
         * of FutureValueReference).
         *
         * @throws ExecutionException if the loading thread throws an exception
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 148.9K bytes
    - Click Count (0)
  4. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BlockTableRenderer.java

    public class BlockTableRenderer {
        public void renderTo(Iterable<BlockDoc> blocks, Element parent) {
            Document document = parent.getOwnerDocument();
    
            // <thead>
            //   <tr>
            //     <td>Block</td>
            //     <td>Description</td>
            //   </tr>
            // </thead>
            Element thead = document.createElement("thead");
            parent.appendChild(thead);
            Element tr = document.createElement("tr");
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 2.8K bytes
    - Click Count (0)
  5. internal/config/certs.go

    	data = bytes.TrimSpace(data)
    
    	// Parse all certs in the chain.
    	current := data
    	for len(current) > 0 {
    		var pemBlock *pem.Block
    		if pemBlock, current = pem.Decode(current); pemBlock == nil {
    			return nil, ErrTLSUnexpectedData(nil).Msgf("Could not read PEM block from file %s", certFile)
    		}
    
    		var x509Cert *x509.Certificate
    		if x509Cert, err = x509.ParseCertificate(pemBlock.Bytes); err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Aug 14 17:11:51 GMT 2024
    - 3.8K bytes
    - Click Count (0)
  6. tensorflow/c/eager/c_api.h

    // you want the latter, use TFE_TensorHandleBackingDeviceName. This function
    // will block till the operation that produces `h` has completed.
    TF_CAPI_EXPORT extern const char* TFE_TensorHandleDeviceName(
        TFE_TensorHandle* h, TF_Status* status);
    
    // Returns the name of the device in whose memory `h` resides.
    //
    // This function will block till the operation that produces `h` has completed.
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Apr 27 21:07:00 GMT 2023
    - 22.8K bytes
    - Click Count (0)
  7. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java

            return resourceName.substring(pos + 1);
        }
    
        private void pad(StringBuilder buffer, int spaces) {
            String block = "                                        ";
            while (spaces > 0) {
                int n = Math.min(spaces, block.length());
                buffer.append(block, 0, n);
                spaces -= n;
            }
        }
    
        @Override
        public void transferSucceeded(TransferEvent event) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Apr 03 11:23:19 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  8. docs/en/docs/js/custom.js

    function setupTermynal() {
        document.querySelectorAll(".use-termynal").forEach(node => {
            node.style.display = "block";
            new Termynal(node, {
                lineDelay: 500
            });
        });
        const progressLiteralStart = "---> 100%";
        const promptLiteralStart = "$ ";
        const customPromptLiteralStart = "# ";
        const termynalActivateClass = "termy";
        let termynals = [];
    
        function createTermynals() {
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 17:59:48 GMT 2026
    - 7.7K bytes
    - Click Count (2)
  9. guava-tests/test/com/google/common/hash/MacHashFunctionTest.java

        byte[] key = fillByteArray(80, 0xaa);
        String data = "Test Using Larger Than Block-Size Key - Hash Key First";
    
        checkSha1("aa4ae5e15272d00e95705637ce8a3b55ed402112", key, data);
      }
    
      public void testRfc2202_hmacSha1_case7() {
        byte[] key = fillByteArray(80, 0xaa);
        String data = "Test Using Larger Than Block-Size Key and Larger Than One Block-Size Data";
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 14.2K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/testing/TestLogHandler.java

    @NullMarked
    public class TestLogHandler extends Handler {
      private final Object lock = new Object();
    
      /** We will keep a private list of all logged records */
      @GuardedBy("lock")
      private final List<LogRecord> list = new ArrayList<>();
    
      /** Adds the most recently logged record to our list. */
      @Override
      public void publish(@Nullable LogRecord record) {
        synchronized (lock) {
          if (record != null) {
            list.add(record);
          }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2.8K bytes
    - Click Count (0)
Back to Top