Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 138 for rlocked (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. README.md

            analyzerSettings.setReadingAnalyzer("kuromoji_reading");
            analyzerSettings.setNormalizeAnalyzer("keyword");
        })
        .badWordSettings(badWordSettings -> {
            badWordSettings.setList(new String[]{"blocked", "terms"});
        })
        .elevateWordSettings(elevateWordSettings -> {
            elevateWordSettings.setElevateWords(Collections.singletonList(
                new ElevateWord("priority", 2.0f, Collections.emptyList())
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Sun Aug 31 03:31:14 GMT 2025
    - 12.1K bytes
    - Click Count (1)
  2. build-logic/binary-compatibility/src/main/groovy/gradlebuild/EnrichedReportRenderer.groovy

                        downloadLink.download = fileNameToSaveAs;
                        downloadLink.innerHTML = "Download File";
    
                        // Add the link to the DOM so that it can be clicked
                        downloadLink.href = window.URL.createObjectURL(textFileAsBlob);
                        downloadLink.style.display = "none";
                        document.body.appendChild(downloadLink);
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Feb 07 20:38:43 GMT 2023
    - 7.2K bytes
    - Click Count (0)
  3. internal/grid/connection.go

    // It will close all active requests and streams.
    // caller *must* hold reconnectMu.
    func (c *Connection) reconnected() {
    	c.updateState(StateConnectionError)
    	c.reconnects.Add(1)
    
    	// Drain the outQueue, so any blocked messages can be sent.
    	// We keep the queue, but start draining it, if it gets full.
    	stopDraining := make(chan struct{})
    	var wg sync.WaitGroup
    	wg.Add(1)
    	defer func() {
    		close(stopDraining)
    		wg.Wait()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

        sendRequest(methodName, arguments);
        assertThat(getResponse(methodName).getThrowable()).isInstanceOf(expected);
      }
    
      /**
       * Causes this thread to call the named method, and asserts that this thread becomes blocked on
       * the lock-like object. The lock-like object must have a method equivalent to {@link
       * java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 21:00:51 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  5. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

                    // Expected
                }
            }
    
            assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should be OPEN");
    
            // Try to execute - should be blocked with CIFSException
            CIFSException exception = assertThrows(CIFSException.class, () -> {
                circuitBreaker.executeWithCircuitBreaker(() -> "should not execute");
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 23.2K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb/SmbRenewableCredentialsTest.java

        @DisplayName("Mockito: verify renew() interaction and return value")
        void mockitoInteraction(@Mock CredentialsInternal returned, @Mock SmbRenewableCredentials renewable) {
            // Arrange: stub renew() to return a mocked CredentialsInternal
            when(renewable.renew()).thenReturn(returned);
    
            // Act: invoke renew()
            CredentialsInternal result = renewable.renew();
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7K bytes
    - Click Count (0)
  7. cmd/global-heal.go

    			lc, err = globalLifecycleSys.Get(bucket)
    			if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bucket}) {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			// Check if bucket is object locked.
    			lr, err = globalBucketObjectLockSys.Get(bucket)
    			if err != nil {
    				retErr = err
    				healingLogIf(ctx, err)
    				continue
    			}
    			rcfg, err = getReplicationConfig(ctx, bucket)
    			if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
            case WAITING:
              Thread.yield();
              break;
            case TIMED_WAITING:
              return;
            case TERMINATED:
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 26.5K bytes
    - Click Count (0)
  9. cmd/bucket-metadata-sys.go

    	g := errgroup.WithNErrs(len(buckets))
    	bucketMetas := make([]BucketMetadata, len(buckets))
    	for index := range buckets {
    		g.Go(func() error {
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  10. okhttp-tls/src/main/kotlin/okhttp3/tls/HandshakeCertificates.kt

         * it also has a regular-looking handshake.
         *
         * **This feature is not supported on Android API levels less than 24.** Prior releases lacked
         * a mechanism to trust some hosts and not others.
         *
         * @param hostname the exact hostname from the URL for insecure connections.
         */
        fun addInsecureHost(hostname: String) =
          apply {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat May 10 11:15:14 GMT 2025
    - 8.4K bytes
    - Click Count (0)
Back to Top