- Sort Score
- Num 10 results
- Language All
Results 531 - 540 of 833 for chunks (0.04 seconds)
-
src/test/java/org/codelibs/fess/helper/IntervalControlHelperTest.java
// Test with cross-midnight rule IntervalRule crossRule = new IntervalRule("22:00", "02:00", "1", 1000); // Sunday only // For cross-midnight rule, when checking early morning hours (1:30), it checks day+1 // day=8 becomes day=1, so day+1=2, which is Monday (not Sunday) assertFalse(crossRule.isTarget(1, 30, 8)); // Should be treated as day 1 (Sunday), checking day+1=2 (Monday) } @TestCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 13.6K bytes - Click Count (0) -
cmd/utils_test.go
func TestStartProfiler(t *testing.T) { _, err := startProfiler("") if err == nil { t.Fatal("Expected a non nil error, but nil error returned for invalid profiler.") } } // checkURL - checks if passed address correspond func checkURL(urlStr string) (*url.URL, error) { if urlStr == "" { return nil, errors.New("Address cannot be empty") } u, err := url.Parse(urlStr) if err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.2K bytes - Click Count (0) -
internal/s3select/sql/analysis.go
// qProp contains analysis info about an SQL term. type qProp struct { isAggregation, isRowFunc bool err error } // `combine` combines a pair of `qProp`s, so that errors are // propagated correctly, and checks that an aggregation is not being // combined with a row-function term. func (p *qProp) combine(q qProp) { switch { case p.err != nil: // Do nothing case q.err != nil: p.err = q.err default:Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 8.6K bytes - Click Count (0) -
guava/src/com/google/common/collect/ConcurrentHashMultiset.java
* references to the map or modify it in any way. * * <p>The returned multiset is serializable if the input map is. * * @param countMap backing map for storing the elements in the multiset and their counts. It must * be empty. * @throws IllegalArgumentException if {@code countMap} is not empty * @since 20.0 */ public static <E> ConcurrentHashMultiset<E> create(ConcurrentMap<E, AtomicInteger> countMap) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 22.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/RelatedContentHelper.java
final String key = entity.getVirtualHost(); return StringUtil.isBlank(key) ? StringUtil.EMPTY : key; } /** * Retrieves related content for a given search query. * First checks for exact term matches, then evaluates regex patterns. * For regex matches, the query placeholder is replaced with the actual query. * * @param query the search query to find related content for
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 8.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/ByteStreamsTest.java
assertThat(out.toByteArray()).isEqualTo(expected); } public void testCopyFileChannel() throws IOException { int chunkSize = 14407; // Random prime, unlikely to match any internal chunk size ByteArrayOutputStream out = new ByteArrayOutputStream(); WritableByteChannel outChannel = Channels.newChannel(out); File testFile = createTempFile(); byte[] dummyData = newPreFilledByteArray(chunkSize);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 22K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
import org.junit.jupiter.api.extension.AfterEachCallback import org.junit.jupiter.api.extension.BeforeEachCallback import org.junit.jupiter.api.extension.ExtensionContext /** * Apply this rule to all tests. It adds additional checks for leaked resources and uncaught * exceptions. * * Use [newClient] as a factory for a OkHttpClient instances. These instances are specifically * configured for testing. */ class OkHttpClientTestRule :
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.8K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseContext.java
* @param maxCacheAge the maximum cache age in milliseconds */ public void setMaxCacheAge(long maxCacheAge) { this.maxCacheAge = maxCacheAge; } /** * Checks if directory change notifications are enabled for cache invalidation * @return true if change notifications are enabled */ public boolean isNotificationEnabled() { return notificationEnabled; }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 9.4K bytes - Click Count (0) -
.github/workflows/tests.yml
env: POSTGRES_PASSWORD: gorm POSTGRES_USER: gorm POSTGRES_DB: gorm TZ: Asia/Shanghai ports: - 9920:5432 # Set health checks to wait until postgres has started options: >- --health-cmd pg_isready --health-interval 10s --health-timeout 5s --health-retries 5 steps:Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Mon Mar 23 10:05:06 GMT 2026 - 9K bytes - Click Count (0) -
src/cmd/api/api_test.go
package main import ( "flag" "fmt" "go/build" "internal/testenv" "os" "path/filepath" "slices" "strings" "sync" "testing" ) var flagCheck = flag.Bool("check", false, "run API checks") func TestMain(m *testing.M) { flag.Parse() for _, c := range contexts { c.Compiler = build.Default.Compiler } build.Default.GOROOT = testenv.GOROOT(nil) os.Exit(m.Run()) } var (
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Mar 02 13:20:41 GMT 2026 - 7.6K bytes - Click Count (0)