Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 208 for Continue (0.14 sec)

  1. cmd/batch-expire.go

    				continue // including latest version in toDel suffices, skipping other versions
    			}
    			versionsCount++
    		} else {
    			continue
    		}
    
    		if versionsCount <= matchedFilter.Purge.RetainVersions {
    			continue // retain versions
    		}
    		toDel = append(toDel, expireObjInfo{
    			ObjectInfo: result,
    		})
    	}
    	// Send any remaining objects downstream
    	if len(toDel) > 0 {
    		select {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  2. cmd/common-main.go

    		if file.Mode().IsRegular() || file.Name() == "CAs" || strings.HasPrefix(file.Name(), "..") {
    			continue
    		}
    		if file.Mode()&os.ModeSymlink == os.ModeSymlink {
    			file, err = Stat(filepath.Join(root.Name(), file.Name()))
    			if err != nil {
    				// not accessible ignore
    				continue
    			}
    			if !file.IsDir() {
    				continue
    			}
    		}
    
    		var (
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  3. cmd/peer-s3-client.go

    		for idx, buckets := range nodeBuckets {
    			if buckets == nil {
    				continue
    			}
    			if !slices.Contains(sys.peerClients[idx].GetPools(), poolIdx) {
    				continue
    			}
    			for _, bi := range buckets {
    				_, ok := resultMap[bi.Name]
    				if ok {
    					// Skip it, this bucket is found in another pool
    					continue
    				}
    				bucketsMap[bi.Name]++
    				if bucketsMap[bi.Name] >= quorum {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    				atomic.StoreInt64(&c.LastPong, time.Now().Unix())
    				continue
    			}
    		case toSend = <-c.outQueue:
    			if len(toSend) == 0 {
    				continue
    			}
    		}
    		if len(queue) < maxMergeMessages && queueSize+len(toSend) < writeBufferSize-1024 && len(c.outQueue) > 0 {
    			queue = append(queue, toSend)
    			queueSize += len(toSend)
    			continue
    		}
    		c.connChange.L.Lock()
    		for {
    			state := c.State()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  5. docs/debugging/pprofgoparser/main.go

    		searchRE, err = regexp.Compile(searchText)
    		if err != nil {
    			log.Fatal(err)
    		}
    	}
    
    	for _, arg := range flag.Args() {
    		if !strings.HasSuffix(arg, "-goroutines-before,debug=2.txt") {
    			continue
    		}
    		r, err := parseGoroutineType2(arg)
    		if err != nil {
    			log.Fatal(err)
    		}
    
    		profFName := path.Base(arg)
    		fmt.Println(strings.Repeat("=", len(profFName)))
    		fmt.Println(profFName)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 06 11:43:16 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  6. internal/grid/muxclient.go

    				errState = true
    				continue
    			case <-m.outBlock:
    			}
    			msg := message{
    				Op:      OpMuxClientMsg,
    				MuxID:   m.MuxID,
    				Seq:     1,
    				Payload: req,
    			}
    			msg.setZeroPayloadFlag()
    			err := m.send(msg)
    			PutByteBuffer(req)
    			if err != nil {
    				m.addErrorNonBlockingClose(internalResp, err)
    				errState = true
    				continue
    			}
    			msg.Seq++
    		}
    	}
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common_test.go

    		// Have 13 good xl.meta, 12 for default parity count = 4 (EC:4) and one
    		// to be tampered with.
    		if i > 12 {
    			modTimesThreeFour[i] = fourNanoSecs
    			modTimesThreeNone[i] = timeSentinel
    			continue
    		}
    		modTimesThreeFour[i] = threeNanoSecs
    		modTimesThreeNone[i] = threeNanoSecs
    	}
    
    	testCases := []struct {
    		modTimes       []time.Time
    		expectedTime   time.Time
    		errs           []error
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
  8. cmd/api-response.go

    			// values to client.
    			toRemove = append(toRemove, k)
    			continue
    		}
    
    		// https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w
    		if equals(k, xhttp.AmzMetaUnencryptedContentLength, xhttp.AmzMetaUnencryptedContentMD5) {
    			toRemove = append(toRemove, k)
    			continue
    		}
    	}
    
    	for _, k := range toRemove {
    		delete(m, k)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  9. cmd/handler-utils.go

    	xhost, err := xnet.ParseHost(host)
    	if err != nil {
    		return "", err
    	}
    
    	for _, domain := range domains {
    		if xhost.Name == minioReservedBucket+"."+domain {
    			continue
    		}
    		if !strings.HasSuffix(xhost.Name, "."+domain) {
    			continue
    		}
    		bucket := strings.TrimSuffix(xhost.Name, "."+domain)
    		return SlashSeparator + pathJoin(bucket, path), nil
    	}
    	return path, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  10. cmd/config.go

    			}
    			if withData {
    				data, err := readConfig(ctx, objAPI, obj.Name)
    				if err != nil {
    					// ignore history file if not readable.
    					continue
    				}
    
    				data, err = decryptData(data, obj.Name)
    				if err != nil {
    					// ignore history file that cannot be loaded.
    					continue
    				}
    
    				cfgEntry.Data = string(data)
    			}
    			configHistory = append(configHistory, cfgEntry)
    			count--
    			if count == 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
Back to top