Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 59 for blockedOn (0.09 sec)

  1. mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt

       * Returns the name of the server the client requested via the SNI (Server Name Indication)
       * attribute in the TLS handshake. Unlike the rest of the HTTP exchange, this name is sent in
       * cleartext and may be monitored or blocked by a proxy or other middlebox.
       */
      val handshakeServerNames: List<String>
    
      init {
        if (socket is SSLSocket) {
          try {
            this.handshake = socket.session.handshake()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                throw new RejectedExecutionException();
              }
            };
        final SequentialExecutor executor = new SequentialExecutor(delegate);
        final ExecutorService blocked = Executors.newCachedThreadPool();
        Future<?> first =
            blocked.submit(
                new Runnable() {
                  @Override
                  public void run() {
                    executor.execute(Runnables.doNothing());
                  }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. internal/lock/lock_test.go

    	case <-locked:
    		t.Error("unexpected unblocking")
    	case <-time.After(100 * time.Millisecond):
    	}
    
    	// unlock
    	if err = dupl.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	// the previously blocked routine should be unblocked
    	select {
    	case <-locked:
    	case <-time.After(1 * time.Second):
    		t.Error("unexpected blocking")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  4. tensorflow/c/c_api_experimental.h

    // "fifo_queue_dequeue_<tensor_id>", to be executed by this API call.
    
    // Caller must call TF_DeleteTensor() over the returned tensor. If the queue is
    // empty, this call is blocked.
    //
    // Tensors are enqueued via the corresponding TF enqueue op.
    // TODO(hongm): Add support for `timeout_ms`.
    TF_CAPI_EXPORT extern TF_Tensor* TF_DequeueNamedTensor(TF_Session* session,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 15.1K bytes
    - Viewed (0)
  5. apache-maven/src/assembly/maven/conf/settings.xml

          <id>maven-default-http-blocker</id>
          <mirrorOf>external:http:*</mirrorOf>
          <name>Pseudo repository to mirror external repositories initially using HTTP.</name>
          <url>http://0.0.0.0/</url>
          <blocked>true</blocked>
        </mirror>
      </mirrors>
    
      <!-- repositories
       | Specifies the list of default remote repositories that maven will search artifacts for.
      -->
      <repositories>
        <repository>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Oct 24 15:53:41 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. api/maven-api-settings/src/main/mdo/settings.mdo

                @since Maven 3.
              </description>
            </field>
            <field>
              <name>blocked</name>
              <version>1.2.0+</version>
              <type>boolean</type>
              <defaultValue>false</defaultValue>
              <description>
                <![CDATA[
                Whether this mirror should be blocked from any download request but fail the download process, explaining why.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Oct 08 13:46:42 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  7. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

       * specified access policy.
       *
       * @param capacity the capacity of this queue
       * @param fair if {@code true} then queue accesses for threads blocked on insertion or removal,
       *     are processed in FIFO order; if {@code false} the access order is unspecified.
       * @throws IllegalArgumentException if {@code capacity} is less than 1
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/TestThread.java

        sendRequest(methodName, arguments);
        assertEquals(expected, getResponse(methodName).getThrowable().getClass());
      }
    
      /**
       * 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)}.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java

            public void setMirroredRepositories(List<ArtifactRepository> mirroredRepositories) {}
    
            public boolean isBlocked() {
                return false;
            }
    
            public void setBlocked(boolean blocked) {}
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

       * state: BLOCKED, WAITING, or TIMED_WAITING.
       */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) {
        long startTime = System.nanoTime();
        for (; ; ) {
          Thread.State s = thread.getState();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
Back to top