- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 316 for ones (0.02 seconds)
-
api/maven-api-core/src/main/java/org/apache/maven/api/services/ProjectManager.java
*/ void attachArtifact(@Nonnull Project project, @Nonnull ProducedArtifact artifact, @Nonnull Path path); /** * {@return all source root directories}, including the disabled ones, for all languages and scopes. * For listing only the {@linkplain SourceRoot#enabled() enabled} source roots, * the following code can be used: * * <pre>{@literalCreated: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Jan 30 23:29:13 GMT 2025 - 12K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
// stop the replay go-routine. if h.store != nil { h.storeCtxCancel() } // Set logch to nil and close it. // This will block all Send operations, // and finish the existing ones. // All future ones will be discarded. h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock() if h.producer != nil { h.producer.Close() h.client.Close() }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
docs/en/docs/tutorial/first-steps.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sat Mar 07 09:29:03 GMT 2026 - 13.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* with underutilization, then we want stored permits to be given out /faster/ than fresh ones, * because underutilization = free resources for the taking. If we are primarily interested to * deal with overflow, then stored permits could be given out /slower/ than fresh ones. Thus, we * require a (different in each case) function that translates storedPermits to throttling time. *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed May 14 19:40:47 GMT 2025 - 19.3K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/BwcVersions.java
* </ul> * In addition to these, there will be a fifth one when a minor reaches feature freeze, we call this the <i>staged</i> * version: * <ul> * <li>the unreleased <b>staged</b>, M.N-2.0 (N > 2) on the `M.(N-2)` branch</li> * </ul> * <p> * Each build is only concerned with versions before it, as those are the ones that need to be tested
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 16.8K bytes - Click Count (0) -
internal/logger/target/http/http.go
h.storeCtxCancel() // Wait for messages to be sent... h.wg.Wait() // Set logch to nil and close it. // This will block all Send operations, // and finish the existing ones. // All future ones will be discarded. h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/exception/DefaultExceptionHandler.java
- asking to use a plugin for which you do not have a version defined - tools to easily select versions - goal not found in a plugin (probably could list the ones that are) */ // PluginNotFoundException, PluginResolutionException, PluginDescriptorParsingException, // CycleDetectedInPluginGraphException; /** * Transform an exception into useful end-user message. */
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 10.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
/** * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until * the already-requested ones are in service, otherwise we might create more threads than we need. * * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we * need. Both fields are guarded by `this`. */
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Aug 30 11:30:11 GMT 2025 - 10.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
for (Future<?> result : results) { if (!result.isCancelled()) { result.get(10, SECONDS); } // TODO(cpovirk): Verify that the cancelled futures are exactly ones that we expect. } assertThat(logHandler.getStoredLogRecords()).isEmpty(); } public void testAvoidsStackOverflow_manySubmitted() throws Exception {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
src/bufio/scan.go
// in the tests. func isSpace(r rune) bool { if r <= '\u00FF' { // Obvious ASCII ones: \t through \r plus space. Plus two Latin-1 oddballs. switch r { case ' ', '\t', '\n', '\v', '\f', '\r': return true case '\u0085', '\u00A0': return true } return false } // High-valued ones. if '\u2000' <= r && r <= '\u200a' { return true } switch r {
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Wed May 21 18:05:26 GMT 2025 - 14.2K bytes - Click Count (0)