Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 613 for continue (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/org/codelibs/fess/suggest/converter/ReadingConverterChain.java

                    if (results == null) {
                        continue;
                    }
                    for (final String result : results) {
                        // Skip null results
                        if (result == null) {
                            continue;
                        }
                        // Add to result set (automatically handles duplicates)
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Wed Dec 31 05:38:07 GMT 2025
    - 3.8K bytes
    - Click Count (1)
  2. cmd/prepare-storage.go

    		case errors.Is(err, errErasureReadQuorum):
    			// no quorum available continue to wait for minimum number of servers.
    			logger.Info("Waiting for a minimum of %d drives to come online (elapsed %s)\n",
    				len(endpoints)/2, getElapsedTime())
    		case errors.Is(err, errErasureWriteQuorum):
    			// no quorum available continue to wait for minimum number of servers.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  3. cmd/bucket-handlers.go

    	for bucket, records := range dnsBuckets {
    		if bucketsSet.Contains(bucket) {
    			continue
    		}
    
    		if globalDomainIPs.Intersection(set.CreateStringSet(getHostsSlice(records)...)).IsEmpty() {
    			// This is not for our server, so we can continue
    			continue
    		}
    
    		wg.Add(1)
    		go func(bucket string) {
    			defer wg.Done()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

              responseQueue.put(new Response(request.methodName, null, exception.getTargetException()));
              continue;
            } catch (Throwable throwable) {
              responseQueue.put(new Response(request.methodName, null, throwable));
              continue;
            }
            responseQueue.put(new Response(request.methodName, result, null));
          }
        } catch (ThreadDeath death) {
          return;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  5. internal/kms/context.go

    				dst.WriteByte(hexTable[b&0xF])
    			}
    			i++
    			start = i
    			continue
    		}
    		c, size := utf8.DecodeRuneInString(s[i:])
    		if c == utf8.RuneError && size == 1 {
    			if start < i {
    				dst.WriteString(s[start:i])
    			}
    			dst.WriteString(`\ufffd`)
    			i += size
    			start = i
    			continue
    		}
    		// U+2028 is LINE SEPARATOR.
    		// U+2029 is PARAGRAPH SEPARATOR.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 6K bytes
    - Click Count (0)
  6. 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)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Mar 06 11:43:16 GMT 2024
    - 3.4K bytes
    - Click Count (0)
  7. cmd/iam-store.go

    			g, ok := c.iamGroupsMap[group]
    			if !ok {
    				continue
    			}
    
    			// Group is disabled, so we return no policy - this
    			// ensures the request is denied.
    			if g.Status == statusDisabled {
    				continue
    			}
    		}
    
    		policy, ok := c.iamGroupPolicyMap.Load(group)
    		if !ok {
    			continue
    		}
    
    		policies = append(policies, policy.toSlice()...)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 87.1K bytes
    - Click Count (0)
  8. cmd/httprange_test.go

    		var o, l int64
    		rs, err1 = parseRequestRangeSpec(irs)
    		if err1 == nil {
    			o, l, err2 = rs.GetOffsetLength(resourceSize)
    		}
    		if isErrInvalidRange(err1) || (err1 == nil && isErrInvalidRange(err2)) {
    			continue
    		}
    		t.Errorf("Case %d: Expected errInvalidRange but: %v %v %d %d %v", i, rs, err1, o, l, err2)
    	}
    }
    
    func TestHTTPRequestRangeToHeader(t *testing.T) {
    	validRangeSpecs := []struct {
    		spec        string
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 3.7K bytes
    - Click Count (0)
  9. cmd/erasure-sets.go

    	defer s.erasureDisksMu.RUnlock()
    
    	for i := range s.setCount {
    		for j := 0; j < s.setDriveCount; j++ {
    			disk := s.erasureDisks[i][j]
    			if disk == OfflineDisk {
    				continue
    			}
    			if !disk.IsOnline() {
    				continue
    			}
    			diskMap[disk.Endpoint()] = disk
    		}
    	}
    	return diskMap
    }
    
    // Initializes a new StorageAPI from the endpoint argument, returns
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  10. .teamcity/src/test/kotlin/BuildTypeTest.kt

                    "-Dscan.value.tcPipeline=master",
                    "-s",
                    "%additional.gradle.parameters%",
                    "--continue",
                    "-DbuildScan.PartOf=QuickFeedbackLinuxOnly,QuickFeedback,PullRequestFeedback,ReadyforNightly,ReadyforRelease",
                    "-Dscan.tag.CompileAll",
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Jan 15 19:30:24 GMT 2026
    - 5.9K bytes
    - Click Count (0)
Back to Top