Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 51 for Updates (0.19 sec)

  1. cmd/erasure-server-pool.go

    		for _, erObj := range z.sets {
    			resultIndex++
    			wg.Add(1)
    			go func(i int, erObj *erasureObjects) {
    				updates := make(chan dataUsageCache, 1)
    				defer xioutil.SafeClose(updates)
    				// Start update collector.
    				go func() {
    					defer wg.Done()
    					for info := range updates {
    						mu.Lock()
    						results[i] = info
    						mu.Unlock()
    					}
    				}()
    				// Start scanner. Blocks until done.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    // May or may not send an update upstream.
    func (f *folderScanner) sendUpdate() {
    	// Send at most an update every minute.
    	if f.updates == nil || time.Since(f.lastUpdate) < time.Minute {
    		return
    	}
    	if flat := f.updateCache.sizeRecursive(f.newCache.Info.Name); flat != nil {
    		select {
    		case f.updates <- flat.clone():
    		default:
    		}
    		f.lastUpdate = time.Now()
    	}
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    				rTimer.Reset(defaultHealthCheckReloadDuration)
    			case <-ctx.Done():
    				return
    			}
    		}
    	}()
    	go sys.heartBeat(ctx)
    	return sys
    }
    
    // UpdateAllTargets updates target to reflect metadata updates
    func (sys *BucketTargetSys) UpdateAllTargets(bucket string, tgts *madmin.BucketTargets) {
    	if sys == nil {
    		return
    	}
    	sys.Lock()
    	defer sys.Unlock()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    type ObjectLayer interface {
    	// Locking operations on object.
    	NewNSLock(bucket string, objects ...string) RWLocker
    
    	// Storage operations.
    	Shutdown(context.Context) error
    	NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, scanMode madmin.HealScanMode) error
    	BackendInfo() madmin.BackendInfo
    	Legacy() bool // Only returns true for deployments which use CRCMOD as its object distribution algorithm.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  5. docs/en/mkdocs.yml

        - tutorial/request-files.md
        - tutorial/request-forms-and-files.md
        - tutorial/handling-errors.md
        - tutorial/path-operation-configuration.md
        - tutorial/encoder.md
        - tutorial/body-updates.md
        - Dependencies:
          - tutorial/dependencies/index.md
          - tutorial/dependencies/classes-as-dependencies.md
          - tutorial/dependencies/sub-dependencies.md
    Others
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu May 02 22:37:31 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-decom.go

    		for k, pi := range rememberedPools {
    			pos, ok := specifiedPools[k]
    			if ok && pos != pi.position {
    				update = true // pool order is changing, its okay to allow it.
    			}
    		}
    	}
    
    	if !update {
    		update = len(specifiedPools) != len(rememberedPools)
    	}
    
    	return update, nil
    }
    
    func (p *poolMeta) load(ctx context.Context, pool *erasureSets, pools []*erasureSets) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  7. cmd/server-main.go

    			logger.Fatal(config.ErrCertsAndHTTPEndpoints(nil), "Unable to start the server")
    		}
    	}
    
    	// Check for updates in non-blocking manner.
    	go func() {
    		if !globalServerCtxt.Quiet && !globalInplaceUpdateDisabled {
    			// Check for new updates from dl.min.io.
    			bootstrapTrace("checkUpdate", func() {
    				checkUpdate(getMinioMode())
    			})
    		}
    	}()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  8. cni/README.md

    ## Reference
    
    ### Design details
    
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  9. docs/en/docs/deployment/concepts.md

    And it will work and will be useful **during development**.
    
    But if your connection to the server is lost, the **running process** will probably die.
    
    And if the server is restarted (for example after updates, or migrations from the cloud provider) you probably **won't notice it**. And because of that, you won't even know that you have to restart the process manually. So, your API will just stay dead. 😱
    
    ### Run Automatically on Startup
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu May 02 22:37:31 GMT 2024
    - 18K bytes
    - Viewed (0)
  10. cmd/admin-bucket-handlers.go

    		return
    	}
    	if globalSiteReplicationSys.isEnabled() && !update {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrRemoteTargetDenyAddError, err), r.URL)
    		return
    	}
    
    	if update {
    		// overlay the updates on existing target
    		tgt := globalBucketTargetSys.GetRemoteBucketTargetByArn(ctx, bucket, target.Arn)
    		if tgt.Empty() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
Back to top