- Sort Score
- Result 10 results
- Languages All
Results 281 - 290 of 359 for Goexit (0.74 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
service.startAsync().awaitRunning(); assertTrue(service.startUpCalled); assertEquals(Service.State.RUNNING, service.state()); exitRun.countDown(); // the service will exit voluntarily executionThread.join(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); service.stopAsync().awaitTerminated(); // no-opRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 12.9K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// We know that we are not going to get the lock anymore, // so exit out and release any locks that did get acquired done = true } } case <-ctx.Done(): // Capture timedout locks as failed or took too long locksFailed++ if locksFailed > tolerance { // We know that we are not going to get the lock anymore, // so exit out and release any locks that did get acquired done = true }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.3K bytes - Viewed (0) -
docs/resiliency/resiliency-tests.sh
# Initial setup docs/resiliency/resiliency-initial-script.sh RESULT=$(grep "script passed" <resiliency-initial.log) if [ "$RESULT" != "script passed" ]; then cleanup_and_prune exit 1 fi test_resiliency_healing_missing_xl_metas test_resiliency_healing_truncated_parts test_resiliency_healing_induced_bitrot test_resiliency_healing_inlined_metadata
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sat Dec 21 04:24:45 UTC 2024 - 20.5K bytes - Viewed (0) -
scripts/translate.py
translatable_langs = get_llm_translatable() if language: if language in translatable_langs: print(json.dumps([language])) return else: raise typer.Exit(code=1) print(json.dumps(translatable_langs)) @app.command() def commands_json( command: Annotated[str | None, typer.Option(envvar="COMMAND")] = None, ) -> None: available_commands = [
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 19:05:53 UTC 2025 - 34.1K bytes - Viewed (0) -
cmd/common-main.go
fmt.Println("Refer to the docs here on how to run it as a Windows Service https://github.com/minio/minio-service/tree/master/windows") fmt.Println("Press the Enter Key to Exit") fmt.Scanln() os.Exit(1) } } logger.Init(GOPATH, GOROOT) logger.RegisterError(config.FmtError) t, _ := minioVersionToReleaseTime(Version) if !t.IsZero() { globalVersionUnix = uint64(t.Unix()) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.5K bytes - Viewed (3) -
impl/maven-core/src/main/java/org/apache/maven/plugin/DefaultBuildPluginManager.java
new MojoExecutionEvent(session, project, mojoExecution, mojo, e)); throw e; } finally { mavenPluginManager.releaseMojo(mojo, mojoExecution); scope.exit(); Thread.currentThread().setContextClassLoader(oldClassLoader); legacySupport.setSession(oldSession); } } /**
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Sep 17 16:01:38 UTC 2025 - 11.5K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
} // For compatibility with the old builders, use a fallback bundle ID bundleID = "golang.gotest" exitCode, err := runMain() if err != nil { log.Fatalf("%v\n", err) } os.Exit(exitCode) } func runMain() (int, error) { var err error tmpdir, err = os.MkdirTemp("", "go_ios_exec_") if err != nil { return 1, err } if !debug { defer os.RemoveAll(tmpdir) }
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Sep 16 00:34:45 UTC 2025 - 8.7K bytes - Viewed (0) -
internal/s3select/csv/reader.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 8.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
service.startAsync().awaitRunning(); assertTrue(service.startUpCalled); assertEquals(Service.State.RUNNING, service.state()); exitRun.countDown(); // the service will exit voluntarily executionThread.join(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); service.stopAsync().awaitTerminated(); // no-opRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 12.9K bytes - Viewed (0) -
docs/site-replication/run-ssec-object-replication-with-compression.sh
#!/usr/bin/env bash # shellcheck disable=SC2120 exit_1() { cleanup echo "minio1 ============" cat /tmp/minio1_1.log echo "minio2 ============" cat /tmp/minio2_1.log exit 1 } cleanup() { echo -n "Cleaning up instances of MinIO ..." pkill minio || sudo pkill minio pkill -9 minio || sudo pkill -9 minio rm -rf /tmp/minio{1,2} echo "done" } cleanup export MINIO_CI_CD=1Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Sep 24 08:03:58 UTC 2024 - 8.3K bytes - Viewed (0)