- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 215 for isSelect (0.33 sec)
-
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) -
src/internal/trace/testdata/testprog/stress-start-stop.go
}() wg.Add(1) go func() { var tmp [1]byte rp.Read(tmp[:]) <-done wg.Done() }() time.Sleep(time.Millisecond) go func() { runtime.LockOSThread() for { select { case <-done: return default: runtime.Gosched() } } }() runtime.GC() // Trigger GC from malloc. n := 512 for i := 0; i < n; i++ { _ = make([]byte, 1<<20)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultChecksumAlgorithmService.java
.collect(Collectors.toList()); } @Override public ChecksumAlgorithm select(String algorithmName) { nonNull(algorithmName, "algorithmName"); try { return new DefaultChecksumAlgorithm(checksumAlgorithmFactorySelector.select(algorithmName)); } catch (IllegalArgumentException e) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Mar 25 10:50:01 UTC 2024 - 7.4K bytes - Viewed (0) -
internal/grid/stream.go
muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select { case s.Requests <- b: return nil case <-s.ctx.Done(): return context.Cause(s.ctx) } } // Results returns the results from the remote server one by one.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/mrf.go
if m == nil { return } select { case m.opCh <- op: default: } } var healSleeper = newDynamicSleeper(5, time.Second, false) // healRoutine listens to new disks reconnection events and // issues healing requests for queued objects belonging to the // corresponding erasure set func (m *mrfState) healRoutine(z *erasureServerPools) { for { select { case <-GlobalContext.Done(): return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.2K bytes - Viewed (0)