Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 106 for stop (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top