Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for selects (0.04 seconds)

  1. cmd/bucket-replication.go

    				}
    				traceFn(sz, err)
    				select {
    				case <-ctx.Done():
    					return
    				case <-s.resyncCancelCh:
    					return
    				case resultCh <- st:
    				}
    			}
    		}(ctx, i)
    	}
    	for res := range objInfoCh {
    		if res.Err != nil {
    			resyncStatus = ResyncFailed
    			replLogIf(ctx, res.Err)
    			return
    		}
    		select {
    		case <-s.resyncCancelCh:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  2. cmd/admin-handlers.go

    	go func() {
    		var buf bytes.Buffer
    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case li := <-logCh:
    				if !li.SendLog(node, logKind) {
    					continue
    				}
    				buf.Reset()
    				if err := enc.Encode(li); err != nil {
    					continue
    				}
    				select {
    				case <-ctx.Done():
    					return
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  3. cmd/object-handlers.go

    	for k, v := range reqParams {
    		if header, ok := supportedHeadGetReqParams[strings.ToLower(k)]; ok {
    			w.Header()[header] = []string{strings.Join(v, ",")}
    		}
    	}
    }
    
    // SelectObjectContentHandler - GET Object?select
    // ----------
    // This implementation of the GET operation retrieves object content based
    // on an SQL expression. In the request, along with the sql expression, you must
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  4. cmd/site-replication.go

    	defer cancel()
    
    	healTimer := time.NewTimer(siteHealTimeInterval)
    	defer healTimer.Stop()
    
    	var maxRefreshDurationSecondsForLog float64 = 10 // 10 seconds..
    
    	for {
    		select {
    		case <-healTimer.C:
    			c.RLock()
    			enabled := c.enabled
    			c.RUnlock()
    			if enabled {
    				refreshStart := time.Now()
    				c.healIAMSystem(ctx, objAPI) // heal IAM system first
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  5. cmd/metrics-v2.go

    		populateAndPublish(metricsGroups, func(m MetricV2) bool {
    			if m.VariableLabels == nil {
    				m.VariableLabels = make(map[string]string)
    			}
    			m.VariableLabels[serverName] = globalLocalNodeName
    			for {
    				select {
    				case ch <- m:
    					return true
    				case <-ctx.Done():
    					return false
    				}
    			}
    		})
    	}()
    	return ch
    }
    
    // minioNodeCollector is the Custom Collector
    //
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  6. api/maven-api-model/src/main/mdo/maven.mdo

                Projects should only list the license(s) that applies to the project
                and not the licenses that apply to dependencies.
                If multiple licenses are listed, it is assumed that the user can select
                any of them, not that they must accept all.
                ]]>
              </description>
              <association>
                <type>License</type>
                <multiplicity>*</multiplicity>
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Nov 26 03:07:35 GMT 2025
    - 133.3K bytes
    - Click Count (0)
Back to Top