Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 190 for Continue (0.32 sec)

  1. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  2. cmd/metacache-set.go

    			if returned {
    				// past limit
    				continue
    			}
    			mu.Lock()
    			returned = done
    			mu.Unlock()
    			if returned {
    				resCh = nil
    				continue
    			}
    			if !o.IncludeDirectories && (entry.isDir() || (!o.Versioned && entry.isObjectDir() && entry.isLatestDeletemarker())) {
    				continue
    			}
    			if o.Marker != "" && entry.name < o.Marker {
    				continue
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  3. cmd/notification.go

    	defer zipWriter.Close()
    
    	for _, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		data, err := client.DownloadProfileData()
    		if err != nil {
    			reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", client.host.String())
    			ctx := logger.SetReqInfo(ctx, reqInfo)
    			peersLogIf(ctx, err)
    			continue
    		}
    
    		profilingDataFound = true
    
    		for typ, data := range data {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  4. cmd/erasure-common.go

    		}
    		for i := range resps {
    			if disks[i] == nil {
    				continue
    			}
    			select {
    			case <-ctx.Done():
    			case gotFile, ok := <-resps[i]:
    				if !ok {
    					continue
    				}
    				if gotFile.Error != "" || !gotFile.Exists {
    					continue
    				}
    				if gotFile.File != wantFile || gotFile.Bucket != req.Bucket || gotFile.Prefix != req.Prefix {
    					continue
    				}
    				quorum++
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  5. cmd/metacache-entries.go

    			}
    
    			continue
    		}
    
    		if entry.isDir() {
    			if delimiter == "" {
    				continue
    			}
    			idx := strings.Index(strings.TrimPrefix(entry.name, prefix), delimiter)
    			if idx < 0 {
    				continue
    			}
    			idx = len(prefix) + idx + len(delimiter)
    			currPrefix := entry.name[:idx]
    			if currPrefix == prevPrefix {
    				continue
    			}
    			prevPrefix = currPrefix
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  6. cmd/untar.go

    		// if the header is nil, just skip it (not sure how this happens)
    		case header == nil:
    			continue
    		}
    
    		name := header.Name
    		switch path.Clean(name) {
    		case ".", slashSeparator:
    			continue
    		}
    
    		switch header.Typeflag {
    		case tar.TypeDir: // = directory
    			if o.ignoreDirs {
    				continue
    			}
    			name = trimLeadingSlash(pathJoin(name, slashSeparator))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  7. cmd/mrf.go

    				// No MRF needed for temporary objects
    				if wildcard.Match("buckets/*/.metacache/*", u.object) {
    					continue
    				}
    				if wildcard.Match("tmp/*", u.object) {
    					continue
    				}
    				if wildcard.Match("multipart/*", u.object) {
    					continue
    				}
    				if wildcard.Match("tmp-old/*", u.object) {
    					continue
    				}
    			}
    
    			now := time.Now()
    			if now.Sub(u.queued) < time.Second {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  8. cmd/site-replication.go

    		if dID == globalDeploymentID() {
    			continue
    		}
    		if !uStatus.UserInfoMismatch {
    			continue
    		}
    
    		if isUserInfoEqual(latestUserStat.userInfo.UserInfo, uStatus.userInfo.UserInfo) {
    			continue
    		}
    
    		peerName := info.Sites[dID].Name
    
    		u, ok := globalIAMSys.GetUser(ctx, user)
    		if !ok {
    			continue
    		}
    		creds := u.Credentials
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 184.1K bytes
    - Viewed (1)
  9. cmd/metacache-walk.go

    				// Do not retain the file, since it doesn't
    				// match the prefix.
    				entries[i] = ""
    				continue
    			}
    			if len(forward) > 0 && entry < forward {
    				// Do not retain the file, since its
    				// lexially smaller than 'forward'
    				entries[i] = ""
    				continue
    			}
    			if hasSuffixByte(entry, SlashSeparatorChar) {
    				if strings.HasSuffix(entry, globalDirSuffixWithSlash) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  10. internal/logger/config.go

    		for _, target := range loggerTargets {
    			endpoint := getCfgVal(legacyEnvLoggerHTTPEndpoint, target, "")
    			if endpoint == "" {
    				continue
    			}
    			url, err := xnet.ParseHTTPURL(endpoint)
    			if err != nil {
    				LogOnceIf(ctx, "logging", err, "logger-webhook-"+endpoint)
    				continue
    			}
    			cfg.HTTP[target] = http.Config{
    				Enabled:  true,
    				Endpoint: url,
    			}
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
Back to top