Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 611 - 620 of 751 for happens (0.12 seconds)

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

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/transformer/impl/HtmlTransformer.java

            final StringBuilder buf = new StringBuilder(url.length() + 100);
            for (final char c : url.toCharArray()) {
                if (CharUtil.isUrlChar(c)) {
                    buf.append(c);
                } else {
                    try {
                        buf.append(URLEncoder.encode(String.valueOf(c), enc));
                    } catch (final UnsupportedEncodingException e) {
                        // NOP
                    }
                }
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Nov 29 07:42:33 GMT 2025
    - 30.5K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/curl/CurlRequestTest.java

        public void testLongUrl() {
            // Test with very long URL
            StringBuilder longUrl = new StringBuilder("https://example.com/path");
            for (int i = 0; i < 100; i++) {
                longUrl.append("/segment").append(i);
            }
    
            CurlRequest request = new CurlRequest(Method.GET, longUrl.toString());
            assertNotNull(request);
            assertEquals(Method.GET, request.method());
        }
    
        @Test
    Created: Sat Dec 20 09:13:53 GMT 2025
    - Last Modified: Mon Nov 24 03:10:07 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  3. cmd/event-notification.go

    		// which doesn't need to be listed as part of the ARN list
    		// This list is only meant for external targets, filter
    		// this out pro-actively.
    		if !strings.HasPrefix(targetID.ID, "httpclient+") {
    			arns = append(arns, targetID.ToARN(region).String())
    		}
    	}
    
    	return arns
    }
    
    // Loads notification policies for all buckets into EventNotifier.
    func (evnot *EventNotifier) set(bucket string, meta BucketMetadata) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jun 21 22:22:24 GMT 2024
    - 7.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // drop the contract on the method that enforces this queue like behavior since depending on it
        // is likely to be a bug anyway.
    
        // N.B. All writes to the list and the next pointers must have happened before the above
        // synchronized block, so we can iterate the list without the lock held here.
        RunnableExecutorPair reversedList = null;
        while (list != null) {
          RunnableExecutorPair tmp = list;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.9K bytes
    - Click Count (0)
  5. cmd/peer-rest-server.go

    	for _, ev := range values[peerRESTListenEvents] {
    		eventName, err := event.ParseName(ev)
    		if err != nil {
    			return grid.NewRemoteErr(err)
    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  6. src/bufio/example_test.go

    	// Output: Hello, world!
    }
    
    func ExampleWriter_AvailableBuffer() {
    	w := bufio.NewWriter(os.Stdout)
    	for _, i := range []int64{1, 2, 3, 4} {
    		b := w.AvailableBuffer()
    		b = strconv.AppendInt(b, i, 10)
    		b = append(b, ' ')
    		w.Write(b)
    	}
    	w.Flush()
    	// Output: 1 2 3 4
    }
    
    // ExampleWriter_ReadFrom demonstrates how to use the ReadFrom method of Writer.
    func ExampleWriter_ReadFrom() {
    	var buf bytes.Buffer
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Nov 01 21:52:12 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java

                String line;
                while ((line = br.readLine()) != null) {
                    sb.append(line);
                }
            }
            return sb.toString().replaceAll(Pattern.quote("${fess.dictionary.path}"), dictionaryPath);
        }
    
        /**
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Thu Aug 07 02:41:28 GMT 2025
    - 26.5K bytes
    - Click Count (0)
  8. cmd/endpoint_test.go

    	}
    	getExpectedEndpoints := func(args []string, prefix string) ([]*url.URL, []bool) {
    		var URLs []*url.URL
    		var localFlags []bool
    		for _, arg := range args {
    			u, _ := url.Parse(arg)
    			URLs = append(URLs, u)
    			localFlags = append(localFlags, strings.HasPrefix(arg, prefix))
    		}
    
    		return URLs, localFlags
    	}
    
    	case1Endpoint1 := "http://" + nonLoopBackIP + "/d1"
    	case1Endpoint2 := "http://" + nonLoopBackIP + "/d2"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  9. docs/bigdata/README.md

    fs.s3a.block.size=512M
    fs.s3a.buffer.dir=${hadoop.tmp.dir}/s3a
    fs.s3a.committer.magic.enabled=false
    fs.s3a.committer.name=directory
    fs.s3a.committer.staging.abort.pending.uploads=true
    fs.s3a.committer.staging.conflict-mode=append
    fs.s3a.committer.staging.tmp.path=/tmp/staging
    fs.s3a.committer.staging.unique-filenames=true
    fs.s3a.connection.establish.timeout=5000
    fs.s3a.connection.ssl.enabled=false
    fs.s3a.connection.timeout=200000
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  10. cmd/erasure-sets_test.go

    		// so that newErasureSets initializes non existing paths
    		// and successfully returns initialized object layer.
    		disk := filepath.Join(globalTestTmpDir, "minio-"+nextSuffix())
    		erasureDisks = append(erasureDisks, disk)
    		defer os.RemoveAll(disk)
    	}
    
    	endpoints := mustGetNewEndpoints(0, 16, erasureDisks...)
    	_, _, err := waitForFormatErasure(true, endpoints, 1, 0, 16, "")
    	if err != errInvalidArgument {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.8K bytes
    - Click Count (0)
Back to Top