Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 208 for Continue (0.17 sec)

  1. cmd/tier-last-day-stats.go

    		l[tier] = l[tier].merge(st)
    	}
    }
    
    func (l DailyAllTierStats) addToTierInfo(tierInfos []madmin.TierInfo) []madmin.TierInfo {
    	for i := range tierInfos {
    		lst, ok := l[tierInfos[i].Name]
    		if !ok {
    			continue
    		}
    		for hr, st := range lst.Bins {
    			tierInfos[i].DailyStats.Bins[hr] = madmin.TierStats{
    				TotalSize:   st.TotalSize,
    				NumVersions: st.NumVersions,
    				NumObjects:  st.NumObjects,
    			}
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. internal/s3select/sql/jsonpath.go

    			if err != nil {
    				return nil, false, err
    			}
    
    			if flatten {
    				// Flatten if array.
    				if arr, ok := rval.([]interface{}); ok {
    					result = append(result, arr...)
    					continue
    				}
    			}
    			result = append(result, rval)
    		}
    		return result, true, nil
    	}
    	panic("cannot reach here")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  3. internal/hash/checksum.go

    		typ := ChecksumType(t)
    		length := typ.RawByteLen()
    		if length == 0 || len(b) < length {
    			break
    		}
    		// Skip main checksum
    		b = b[length:]
    		if !typ.Is(ChecksumIncludesMultipart) {
    			continue
    		}
    		parts, n := binary.Uvarint(b)
    		if n <= 0 {
    			break
    		}
    		if len(res) == 0 {
    			res = make([]map[string]string, parts)
    		}
    		b = b[n:]
    		for part := 0; part < int(parts); part++ {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  4. internal/s3select/select.go

    	}
    	var err error
    	sendRecord := func() bool {
    		buf := bufPool.Get().(*bytes.Buffer)
    		buf.Reset()
    
    		for _, outputRecord := range outputQueue {
    			if outputRecord == nil {
    				continue
    			}
    			before := buf.Len()
    			if err = s3Select.marshal(buf, outputRecord); err != nil {
    				bufPool.Put(buf)
    				return false
    			}
    			if buf.Len()-before > maxRecordSize {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  5. internal/disk/stat_linux.go

    		if err == nil {
    			devName := ""
    			diskstats, _ := bfs.ProcDiskstats()
    			for _, dstat := range diskstats {
    				// ignore all loop devices
    				if strings.HasPrefix(dstat.DeviceName, "loop") {
    					continue
    				}
    				if dstat.MajorNumber == info.Major && dstat.MinorNumber == info.Minor {
    					devName = dstat.DeviceName
    					break
    				}
    			}
    			if devName != "" {
    				info.Name = devName
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  6. internal/mountinfo/mountinfo_linux.go

    	for {
    		line, err := scanner.ReadString('\n')
    		if err == io.EOF {
    			break
    		}
    
    		fields := strings.Fields(line)
    		if len(fields) != expectedNumFieldsPerLine {
    			// ignore incorrect lines.
    			continue
    		}
    
    		// Freq should be an integer.
    		if _, err := strconv.Atoi(fields[4]); err != nil {
    			return nil, err
    		}
    
    		// Pass should be an integer.
    		if _, err := strconv.Atoi(fields[5]); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  7. cmd/admin-bucket-handlers.go

    				continue
    			}
    
    			bucketPolicyBytes, err := io.ReadAll(io.LimitReader(reader, sz))
    			if err != nil {
    				rpt.SetStatus(bucket, fileName, err)
    				continue
    			}
    
    			bucketPolicy, err := policy.ParseBucketPolicyConfig(bytes.NewReader(bucketPolicyBytes), bucket)
    			if err != nil {
    				rpt.SetStatus(bucket, fileName, err)
    				continue
    			}
    
    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)
  8. internal/logger/console.go

    				tagPrinted = true
    			} else {
    				fmt.Fprint(Output, emptyBanner)
    			}
    			// Restore the text color of the error message
    			ansiRestoreAttributes()
    			ansiMoveRight(bannerWidth)
    			// Continue  error message printing
    			fmt.Fprintln(Output, line)
    			break
    		}
    	}
    
    	// Exit because this is a fatal error message
    	ExitFunc(1)
    }
    
    type infoMsg struct{}
    
    var info infoMsg
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  9. internal/logger/targets.go

    	oldTargets, others := splitTargets(*targetList, types.TargetHTTP)
    	newWebhooks = append(newWebhooks, others...)
    
    	for i := range oldTargets {
    		currentTgt, ok := oldTargets[i].(*http.Target)
    		if !ok {
    			continue
    		}
    		var newTgt *http.Target
    
    		for ii := range tgts {
    			if currentTgt.Name() == tgts[ii].Name() {
    				newTgt = tgts[ii]
    				currentTgt.AssignMigrateTarget(newTgt)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  10. cmd/admin-handler-utils.go

    		// Validate request signature.
    		cred, adminAPIErr := checkAdminRequestAuth(ctx, r, action, "")
    		switch adminAPIErr {
    		case ErrNone:
    			return objectAPI, cred
    		case ErrAccessDenied:
    			// Try another
    			continue
    		default:
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(adminAPIErr), r.URL)
    			return nil, cred
    		}
    	}
    	writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAccessDenied), r.URL)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 8.2K bytes
    - Viewed (0)
Back to top