Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 420 for blocking (0.17 seconds)

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

  1. src/builtin/builtin.go

    // never the receiver, and has the effect of shutting down the channel after
    // the last sent value is received. After the last value has been received
    // from a closed channel c, any receive from c will succeed without
    // blocking, returning the zero value for the channel element. The form
    //
    //	x, ok := <-c
    //
    // will also set ok to false for a closed and empty channel.
    func close(c chan<- Type)
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Feb 26 17:14:40 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/base/Ascii.java

       */
      public static final byte SYN = 22;
    
      /**
       * End of Transmission Block: A communication control character used to indicate the end of a
       * block of data for communication purposes. ETB is used for blocking data where the block
       * structure is not necessarily related to the processing format.
       *
       * @since 8.0
       */
      public static final byte ETB = 23;
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  3. android-test/src/androidDeviceTest/java/okhttp/android/test/OkHttpTest.kt

        assumeTrue(Build.VERSION.SDK_INT >= 23)
    
        val request = Request.Builder().url("http://squareup.com/robots.txt").build()
    
        try {
          client.newCall(request).execute()
          fail<Any>("expected cleartext blocking")
        } catch (_: java.net.UnknownServiceException) {
        }
      }
    
      data class HowsMySslResults(
        val unknown_cipher_suite_supported: Boolean,
        val beast_vuln: Boolean,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 29.9K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

            }
            curr = succ;
          }
          break;
        }
      }
    
      // A heuristic for timed gets. If the remaining timeout is less than this, spin instead of
      // blocking. This value is what AbstractQueuedSynchronizer uses.
      private static final long SPIN_THRESHOLD_NANOS = 1000L;
    
      @VisibleForTesting
      static String atomicHelperTypeForTest() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  5. src/main/java/jcifs/util/SmbCircuitBreaker.java

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSException;
    
    /**
     * Circuit breaker pattern implementation for SMB operations.
     * Prevents cascading failures by temporarily blocking requests to a failing service.
     *
     * The circuit breaker has three states:
     * - CLOSED: Normal operation, requests pass through
     * - OPEN: Service is failing, requests are blocked
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/filter/LoadControlFilterTest.java

        @Test
        public void test_doFilter_componentNotAvailable() throws IOException, ServletException {
            // The real LoadControlFilter with ComponentUtil.available() returning false
            // should pass through without blocking
            mockRequest.setRequestURI("/search");
    
            loadControlFilter.doFilter(mockRequest, mockResponse, mockFilterChain);
    
            assertTrue(mockFilterChain.wasDoFilterCalled());
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 33.6K bytes
    - Click Count (0)
  7. cmd/admin-heal-ops.go

    	return jbytes, ErrNone
    }
    
    // healSource denotes single entity and heal option.
    type healSource struct {
    	bucket    string
    	object    string
    	versionID string
    	noWait    bool             // a non blocking call, if task queue is full return right away.
    	opts      *madmin.HealOpts // optional heal option overrides default setting
    }
    
    // healSequence - state for each heal sequence initiated on the
    // server.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  8. guava/src/com/google/common/base/Ascii.java

       */
      public static final byte SYN = 22;
    
      /**
       * End of Transmission Block: A communication control character used to indicate the end of a
       * block of data for communication purposes. ETB is used for blocking data where the block
       * structure is not necessarily related to the processing format.
       *
       * @since 8.0
       */
      public static final byte ETB = 23;
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  9. docs/ko/docs/async.md

    저는 AnyIO 위에 얇은 레이어로 또 다른 라이브러리를 만들었는데, 타입 어노테이션을 조금 개선하고 더 나은 **자동완성**, **인라인 오류** 등을 얻기 위한 것입니다. 또한 **이해**하고 **여러분만의 async 코드**를 작성하도록 돕는 친절한 소개와 튜토리얼도 제공합니다: [Asyncer](https://asyncer.tiangolo.com/). 특히 **async 코드와 일반**(blocking/동기) 코드를 **결합**해야 한다면 아주 유용합니다.
    
    ### 비동기 코드의 다른 형태 { #other-forms-of-asynchronous-code }
    
    `async`와 `await`를 사용하는 이 스타일은 언어에서 비교적 최근에 추가되었습니다.
    
    하지만 비동기 코드를 다루는 일을 훨씬 더 쉽게 만들어 줍니다.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:06:26 GMT 2026
    - 27.5K bytes
    - Click Count (0)
  10. docs/bucket/notifications/README.md

    mandatory      (on|off)    quietly ignore undelivered messages when set to 'off', default is 'on'
    durable        (on|off)    persist queue across broker restarts when set to 'on', default is 'off'
    no_wait        (on|off)    non-blocking message delivery when set to 'on', default is 'off'
    internal       (on|off)    set to 'on' for exchange to be not used directly by publishers, but only when bound to other exchanges
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
Back to Top