- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 226 for broken1 (0.38 sec)
-
internal/config/notify/parse.go
return nil, err } if !enabled { continue } var brokers []xnet.Host brokersEnv := target.EnvKafkaBrokers if k != config.Default { brokersEnv = brokersEnv + config.Default + k } kafkaBrokers := env.Get(brokersEnv, kv.Get(target.KafkaBrokers)) if len(kafkaBrokers) == 0 { return nil, config.Errorf("kafka 'brokers' cannot be empty") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 46.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClientConnection.java
throw new DaemonConnectionException("Could not receive a message from the daemon.", e); } finally { hasReceived = true; } } /** * Treat the connection as probably broken, and leniently handle failures writing outgoing messages. */ public void markSuspect() { suspect = true; } @Override public void stop() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 30 06:43:50 UTC 2024 - 4.2K bytes - Viewed (0) -
subprojects/build-events/src/integTest/groovy/org/gradle/build/event/BuildEventsParallelIntegrationTest.groovy
server.expect("serviceClosed") def build = executer.withTasks("b").start() handleA.waitForAllPendingCalls() // Increase the chance of the test to detect a broken implementation that doesn't wait for events to be processed before closing the service. sleep(1000) handleA.releaseAll() result = build.waitForFinish()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jun 06 19:15:46 UTC 2024 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/test/groovy/org/gradle/launcher/daemon/protocol/DaemonMessageSerializerTest.groovy
result2.value.result.serializedModel.size() == 1 result2.value.failure == null result2.value.exception == null def buildFailed = BuildActionResult.failed(new RuntimeException("broken")) def message3 = new Success(buildFailed) def result3 = serialize(message3, serializer) result3 instanceof Success result3.value instanceof BuildActionResult
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 12.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonStateControl.java
*/ void runCommand(Runnable command, String commandDisplayName) throws DaemonUnavailableException, DaemonStoppedException; enum State {Idle, Busy, Canceled, StopRequested, Stopped, ForceStopped, Broken}
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 3.6K bytes - Viewed (0) -
src/os/signal/doc.go
# SIGPIPE When a Go program writes to a broken pipe, the kernel will raise a SIGPIPE signal. If the program has not called Notify to receive SIGPIPE signals, then the behavior depends on the file descriptor number. A write to a broken pipe on file descriptors 1 or 2 (standard output or standard error) will cause the program to exit with a SIGPIPE signal. A write to a broken pipe on some other file descriptor will take no action on
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0) -
cmd/signature-v4-utils.go
return true case emptySHA256: // some broken clients set empty-sha256 // with > 0 content-length in the body, // we should skip such clients and allow // blindly such insecure clients only if // S3 strict compatibility is disabled. // We return true only in situations when // deployment has asked MinIO to allow for // such broken clients and content-length > 0.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 9.1K bytes - Viewed (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/BuildParams.kt
* Run docs tests with the configuration cache enabled. */ const val ENABLE_CONFIGURATION_CACHE_FOR_DOCS_TESTS = "enableConfigurationCacheForDocsTests" /** * Run docs tests that are knowingly broken when running with the configuration cache enabled. Only applied when #ENABLE_CONFIGURATION_CACHE_FOR_DOCS_TESTS is also set. */ const val RUN_BROKEN_CONFIGURATION_CACHE_DOCS_TESTS = "runBrokenConfigurationCacheDocsTests"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 04 06:42:07 UTC 2024 - 16.4K bytes - Viewed (0) -
doc/next/3-tools.md
The `go` command uses it automatically, avoiding "argument list too long" errors with a very large `CGO_LDFLAGS`. ### Trace {#trace} <!-- go.dev/issue/65316 --> The `trace` tool now better tolerates partially broken traces by attempting to recover what trace data it can. This functionality is particularly helpful when viewing a trace that was collected during a program crash, since the trace data
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 28 19:06:07 UTC 2024 - 3.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Comparators.java
} /** * Returns a {@code Collector} that returns the {@code k} smallest (relative to the specified * {@code Comparator}) input elements, in ascending order, as an unmodifiable {@code List}. Ties * are broken arbitrarily. * * <p>For example: * * <pre>{@code * Stream.of("foo", "quux", "banana", "elephant") * .collect(least(2, comparingInt(String::length))) * // returns {"foo", "quux"}
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 10.1K bytes - Viewed (0)