Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 531 - 540 of 833 for chunks (0.04 seconds)

  1. 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)
        }
    
        @Test
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. .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)
  10. 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)
Back to Top