- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 826 for pselect (0.12 sec)
-
pilot/pkg/xds/pushqueue_test.go
go func() { con, _, _ := p.Dequeue() done <- con }() select { case ret := <-done: return ret case <-time.After(time.Millisecond * 500): return nil } } func ExpectTimeout(t *testing.T, p *PushQueue) { t.Helper() done := make(chan struct{}, 1) go func() { p.Dequeue() done <- struct{}{} }() select { case <-done: t.Fatalf("Expected timeout")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
integration-tests/gradle/build.gradle.kts
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 03 20:33:34 UTC 2024 - 7K bytes - Viewed (0) -
buildscripts/verify-healing-empty-erasure-set.sh
# Wait for all drives to be online and formatted while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done # Wait for all drives to be healed while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].healing | select(. != null) | select(. == true)' | wc -l) -gt 0 ]; do sleep 1; done # Wait for Status: in MinIO output while true; do rv=$(check_online)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 31 14:48:50 UTC 2024 - 3.9K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/futile-wakeup.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/XPathAPI.java
return factory.newXPath(); } catch (final Exception e) { throw new CrawlerSystemException("Failed to create XPath instance.", e); } } /** * Use an XPath string to select a nodelist. * XPath namespace prefixes are resolved from the contextNode. * * @param contextNode The node to start searching from. * @param expression A valid XPath string.
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 3.3K bytes - Viewed (0) -
internal/bpool/bpool.go
bp.Put(buf[:bp.w]) } } // Get gets a []byte from the BytePool, or creates a new one if none are // available in the pool. func (bp *BytePoolCap) Get() (b []byte) { if bp == nil { return nil } select { case b = <-bp.c: // reuse existing buffer default: // create new aligned buffer if bp.wcap > 0 { b = reedsolomon.AllocAligned(1, bp.wcap)[0][:bp.w] } else {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 19 16:44:59 UTC 2024 - 2.6K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/results/PerformanceFlakinessDataProvider.java
* in the flakiness detection builds divided by the total number of runs of the scenario. * * <pre> * SELECT TESTID, TESTPROJECT, AVG(CONVERT(CASEWHEN(DIFFCONFIDENCE > 0.97, 1, 0), DECIMAL)) AS FAILURE_RATE, * FROM TESTEXECUTION * WHERE (CHANNEL = 'flakiness-detection-master' OR CHANNEL = 'flakiness-detection-release')
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.3K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
proxies = append(proxies, conn) } return proxies } func wgDoneOrTimeout(wg *sync.WaitGroup, timeout time.Duration) bool { c := make(chan struct{}) go func() { wg.Wait() c <- struct{}{} }() select { case <-c: return true case <-time.After(timeout): return false } } func TestSendPushesManyPushes(t *testing.T) { stopCh := make(chan struct{}) defer close(stopCh)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/main/java/org/gradle/api/internal/tasks/userinput/UserQuestions.java
* @return the answer or the given default if not connected to a console. */ boolean askBooleanQuestion(String question, boolean defaultValue); /** * Asks the user to select an option from the given list and returns the answer. * Uses the {@link Object#toString()} representation of the options to format the prompt. * Does not prompt the user when there is only one option in the given list.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 3.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/tf_tfl_translate_cl.cc
llvm::cl::init(false)); // NOLINTNEXTLINE opt<bool> allow_all_select_tf_ops( "allow-all-select-tf-ops", llvm::cl::desc("Allow automatic pass through of TF ops (outside the flex " "allowlist) as select Tensorflow ops"), llvm::cl::init(false)); // The following approach allows injecting opdefs in addition
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 05 20:53:17 UTC 2024 - 7.9K bytes - Viewed (0)