Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for satisfied (0.04 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      static class FlagGuard extends Monitor.Guard {
    
        private boolean satisfied;
    
        protected FlagGuard(Monitor monitor) {
          super(monitor);
        }
    
        @Override
        public boolean isSatisfied() {
          return satisfied;
        }
    
        public void setSatisfied(boolean satisfied) {
          this.satisfied = satisfied;
        }
      }
    
      private final Method method;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  2. cmd/postpolicyform.go

    				condt, reflect.TypeOf(condt).String())
    		}
    	}
    	return parsedPolicy, nil
    }
    
    // checkPolicyCond returns a boolean to indicate if a condition is satisfied according
    // to the passed operator
    func checkPolicyCond(op string, input1, input2 string) bool {
    	switch op {
    	case policyCondEqual:
    		return input1 == input2
    	case policyCondStartsWith:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  3. tensorflow/BUILD

        ],
    )
    
    # Config setting that is satisfied when TensorFlow is being built with CUDA
    # support through e.g. `--config=cuda` (or `--config=cuda_clang` in OSS).
    alias(
        name = "is_cuda_enabled",
        actual = if_oss(
            "@local_config_cuda//:is_cuda_enabled",
            "@local_config_cuda//cuda:using_config_cuda",
        ),
    )
    
    # Config setting that is satisfied when CUDA device code should be compiled
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Thu Aug 28 19:11:51 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

            concurrentCallCapacity += connection.allocationLimit
          }
    
          // The policy was satisfied by existing connections, don't run again
          if (concurrentCallCapacity >= state.policy.minimumConcurrentCalls) return -1L
        }
    
        // If we got here then the policy was not satisfied -- open a connection!
        try {
          val connection = exchangeFinderFactory(this, state.address, PoolConnectionUser).find()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt

       *    has since been closed by the server.
       *  * A client timeout (HTTP 408).
       *  * A authorization challenge (HTTP 401 and 407) that is satisfied by the [Authenticator].
       *  * A retryable server failure (HTTP 503 with a `Retry-After: 0` response header).
       *  * A misdirected request (HTTP 421) on a coalesced connection.
       */
      open fun isOneShot(): Boolean = false
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 04 17:43:43 UTC 2025
    - 9K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        if (strategy == ResumePriority.AfterOtherTasks && otherTasksStarted) {
          return yieldUntil(strategy, condition)
        }
      }
    
      private enum class ResumePriority {
        /** Resumes as soon as the condition is satisfied. */
        BeforeOtherTasks,
    
        /** Resumes after the already-enqueued tasks. */
        AfterEnqueuedTasks,
    
        /** Resumes after all other tasks, including tasks enqueued while yielding. */
        AfterOtherTasks,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          service.execute(barrierTask); // submit directly to the service
          // the barrier task runs after the error task so we know that the error has been observed by
          // SequentialExecutor by the time the barrier is satisfied
          barrier.await(1, SECONDS);
          executor.execute(barrierTask);
          // timeout means the second task wasn't even tried
          barrier.await(1, SECONDS);
        } finally {
          service.shutdown();
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  8. src/cmd/api/api_test.go

    			required:  []string{"A", "B", "C"},
    			exception: []string{"B"},
    			ok:        true,
    			out:       "",
    		},
    
    		// Test that a feature required on a subset of ports is implicitly satisfied
    		// by the same feature being implemented on all ports. That is, it shouldn't
    		// say "pkg syscall (darwin-amd64), type RawSockaddrInet6 struct" is missing.
    		// See https://go.dev/issue/4303.
    		{
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri May 02 17:06:27 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

                unverifiedHandshake.peerCertificates,
                address.url.host,
              )
            }
          this.handshake = handshake
    
          // Check that the certificate pinner is satisfied by the certificates presented.
          certificatePinner.check(address.url.host) {
            handshake.peerCertificates.map { it as X509Certificate }
          }
    
          // Success! Save the handshake and the ALPN protocol.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

        withLock {
          val oldLimit = allocationLimit
          allocationLimit = settings.getMaxConcurrentStreams()
    
          if (allocationLimit < oldLimit) {
            // We might need new connections to keep policies satisfied
            connectionPool.scheduleOpener(route.address)
          } else if (allocationLimit > oldLimit) {
            // We might no longer need some connections
            connectionPool.scheduleCloser()
          }
        }
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
Back to top