Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 614 for breaker (0.1 seconds)

  1. android/guava-tests/test/com/google/common/hash/FarmHashFingerprint64Test.java

        assertThat(fingerprint(stringA.getBytes(UTF_8)))
            .isNotEqualTo(fingerprint(stringB.getBytes(UTF_8)));
    
        // ISO 8859-1 only has 0-255 (ubyte) representation so throws away UTF-8 characters
        // greater than 127 (ie with their top bit set).
        // Don't attempt to do this in real code.
        assertEquals(
            fingerprint(stringA.getBytes(ISO_8859_1)), fingerprint(stringB.getBytes(ISO_8859_1)));
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 6.4K bytes
    - Click Count (0)
  2. internal/config/notify/help.go

    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpDurable,
    			Description: "persist queue across broker restarts when set to 'on', default is 'off'",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpNoWait,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 19.2K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java

                // Verify that results are reasonable relative to each other
                assertTrue("Result for 7 days should be greater than 1 day", result7 > result1);
                assertTrue("Result for 1 day should be greater than 0 days", result1 > result0);
    
                // Verify that the differences are approximately correct
                long diff1 = result1 - result0;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 12 01:46:45 GMT 2026
    - 28.7K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/util/InputStreamThread.java

     */
    public class InputStreamThread extends Thread {
        /** Logger instance for this class */
        private static final Logger logger = LogManager.getLogger(InputStreamThread.class);
    
        /** Buffered reader for reading from the input stream */
        private final BufferedReader br;
    
        /** Maximum buffer size constant */
        public static final int MAX_BUFFER_SIZE = 1000;
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  5. docs/tr/docs/tutorial/cors.md

    Listeyi `"*"` (bir "wildcard") olarak tanımlayıp, hepsine izin verildiğini söylemek de mümkündür.
    
    Ancak bu, credentials içeren her şeyi hariç tutarak yalnızca belirli iletişim türlerine izin verir: Cookie’ler, Bearer Token’larla kullanılanlar gibi Authorization header’ları, vb.
    
    Bu yüzden her şeyin düzgün çalışması için, izin verilen origin’leri açıkça belirtmek daha iyidir.
    
    ## `CORSMiddleware` Kullanımı { #use-corsmiddleware }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 07:53:17 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  6. internal/config/identity/openid/provider/keycloak.go

    	k.Lock()
    	accessToken := k.accessToken
    	k.Unlock()
    	if accessToken.AccessToken == "" {
    		return User{}, ErrAccessTokenExpired
    	}
    	req.Header.Set("Authorization", "Bearer "+accessToken.AccessToken)
    	resp, err := k.client.Do(req)
    	if err != nil {
    		return User{}, err
    	}
    	defer resp.Body.Close()
    	switch resp.StatusCode {
    	case http.StatusOK, http.StatusPartialContent:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jul 14 18:12:07 GMT 2024
    - 4.6K bytes
    - Click Count (0)
  7. internal/s3select/csv/args.go

    	CommentCharacter           string `xml:"Comments"`
    	AllowQuotedRecordDelimiter bool   `xml:"AllowQuotedRecordDelimiter"`
    	unmarshaled                bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 20 18:31:45 GMT 2024
    - 5.7K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

            final List<SynonymItem> itemList = new ArrayList<>();
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) {
                long id = 0;
                String line = null;
                while ((line = reader.readLine()) != null) {
                    if (line.length() == 0 || line.charAt(0) == '#') {
                        if (updater != null) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 07:09:00 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  9. cmd/batch-handlers.go

    	}
    	defer rd.Close()
    
    	hr, err := hash.NewReader(ctx, rd, objInfo.Size, "", "", objInfo.Size)
    	if err != nil {
    		return err
    	}
    	pReader := NewPutObjReader(hr)
    	_, err = api.PutObject(ctx, tgtBucket, tgtObject, pReader, opts)
    	return err
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  10. src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackTest.java

            assertEquals(0L, callback.getExecuteTime());
    
            // Store a document
            callback.store(new DataStoreParams(), new HashMap<>());
    
            // Execution time should be greater than 0
            assertTrue(callback.getExecuteTime() >= 10L);
        }
    
        @Test
        public void test_concurrent_stores() {
            // Test thread-safe implementation
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 12.5K bytes
    - Click Count (0)
Back to Top