- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 106 for stop (0.18 sec)
-
cmd/signals.go
// Custom exit function exit := func(success bool) { if globalLoggerOutput != nil { globalLoggerOutput.Close() } // If global profiler is set stop before we exit. globalProfilerMu.Lock() defer globalProfilerMu.Unlock() for _, p := range globalProfiler { p.Stop() } if success { os.Exit(0) } os.Exit(1) } stopProcess := func() bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 2.8K bytes - Viewed (0) -
buildscripts/minio-iam-ldap-upgrade-import-test.sh
mc idp ldap policy attach old-minio readwrite --group=CN=project.c,ou=groups,ou=swengg,dc=min,dc=io mc idp ldap policy entities old-minio mc admin cluster iam export old-minio set +x mc admin service stop old-minio } import_iam_content_in_new_minio() { echo "Importing IAM content in new minio instance." # Assume current minio binary exists. MINIO_CI_CD=1 ./minio server /tmp/data/{1...4} & sleep 5 set -x
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:49:53 GMT 2024 - 3.4K bytes - Viewed (0) -
docs/docker/README.md
```sh docker start <container_id> ``` To stop a running container, you can use the [`docker stop`](https://docs.docker.com/engine/reference/commandline/stop/) command. ```sh docker stop <container_id> ``` ### MinIO container logs
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 8.2K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
return } t := time.NewTicker(time.Duration(pingInterval) * time.Second) defer t.Stop() emptyEventTicker = t.C } else { // Deprecated Apr 2023 t := time.NewTicker(500 * time.Millisecond) defer t.Stop() keepAliveTicker = t.C } enc := json.NewEncoder(w) for { select { case ev := <-mergeCh: _, err := w.Write(ev)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
Status rebalStatus `msg:"status"` // Current state of rebalance operation. One of Started|Stopped|Completed|Failed. } // rebalanceMeta contains information pertaining to an ongoing rebalance operation. type rebalanceMeta struct { cancel context.CancelFunc `msg:"-"` // to be invoked on rebalance-stop lastRefreshedAt time.Time `msg:"-"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
internal/http/server.go
} // Wait for opened connection to be closed up to Shutdown timeout. shutdownTimeout := srv.ShutdownTimeout shutdownTimer := time.NewTimer(shutdownTimeout) defer shutdownTimer.Stop() timer := time.NewTimer(nextPollInterval()) defer timer.Stop() for { select { case <-shutdownTimer.C: if atomic.LoadInt32(&srv.requestCount) <= 0 { return nil } // Write all running goroutines.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/license-update.go
} func licenceUpdaterLoop(ctx context.Context, objAPI ObjectLayer) { ctx, cancel := globalLeaderLock.GetLock(ctx) defer cancel() licenseUpdateTimer := time.NewTimer(licUpdateCycle) defer licenseUpdateTimer.Stop() for { select { case <-ctx.Done(): return case <-licenseUpdateTimer.C: if globalSubnetConfig.Registered() { performLicenseUpdate(ctx, objAPI) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
buildscripts/minio-upgrade.sh
verify_checksum_mc ./minio minio/minio-test/to-read/minio curl -s http://127.0.0.1:9000/minio-test/to-read/hosts | sha256sum MINIO_VERSION=dev docker-compose -f "buildscripts/upgrade-tests/compose.yml" stop } main() { MINIO_VERSION=dev docker-compose -f "buildscripts/upgrade-tests/compose.yml" up -d --build add_alias verify_checksum_after_heal minio/minio-test http://127.0.0.1:9000/minio-test/to-read/hosts
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 11:39:55 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/s3select/message.go
if !writer.write(newProgressMessage(bytesScanned, bytesProcessed, bytesReturned)) { quitFlag = true } } } close(writer.doneCh) recordStagingTicker.Stop() keepAliveTicker.Stop() if progressTicker != nil { progressTicker.Stop() } // Whatever drain the payloadCh to prevent from memory leaking. for len(writer.payloadCh) > 0 { payload := <-writer.payloadCh bufPool.Put(payload) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
// Once the disk has been deemed ok, it will return to online status. func (p *xlStorageDiskIDCheck) monitorDiskStatus(spent time.Duration, fn string) { t := time.NewTicker(5 * time.Second) defer t.Stop() for range t.C { if contextCanceled(p.diskCtx) { return } err := p.storage.WriteAll(context.Background(), minioMetaTmpBucket, fn, toWrite) if err != nil { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)