Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 741 for continua (0.14 seconds)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

        protected void finishCrawling() {
            crawlerContext.decrementAndGetActiveThreadCount();
        }
    
        /**
         * Checks if the crawling process should continue.
         * @param tcCount The thread check count.
         * @return true if the crawling should continue, false otherwise.
         */
        protected boolean isContinue(final int tcCount) {
            if (!crawlerContainer.available()) {
                // system shutdown
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Dec 31 09:07:38 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  2. cmd/erasure-encode_test.go

    			t.Fatalf("Test %d: failed to generate random test data: %v", i, err)
    		}
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(int64(len(data[test.offset:]))), test.algorithm, erasure.ShardSize())
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  3. scripts/add_latest_release_date.py

    def main() -> None:
        with open(RELEASE_NOTES_FILE) as f:
            lines = f.readlines()
    
        for i, line in enumerate(lines):
            match = RELEASE_HEADER_PATTERN.match(line)
            if not match:
                continue
    
            version = match.group(1)
            date_part = match.group(2)
    
            if date_part:
                print(f"Latest release {version} already has a date: {date_part}")
                sys.exit(0)
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Apr 03 12:06:36 GMT 2026
    - 1023 bytes
    - Click Count (0)
  4. internal/config/lambda/parse.go

    		webhookTargets, err := GetLambdaWebhook(cfg[config.LambdaWebhookSubSys], transport)
    		if err != nil {
    			return nil, err
    		}
    		for id, args := range webhookTargets {
    			if !args.Enable {
    				continue
    			}
    			t, err := target.NewWebhookTarget(ctx, id, args, logOnceIf, transport)
    			if err != nil {
    				return nil, err
    			}
    			targets = append(targets, t)
    		}
    	}
    	return targets, nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  5. .ci/scripts/packaging-test.ps1

    $env:JAVA_HOME=$null
    $env:SYSTEM_JAVA_HOME="C:\Users\jenkins\.java\$env:ES_RUNTIME_JAVA"
    Remove-Item -Recurse -Force \tmp -ErrorAction Ignore
    New-Item -ItemType directory -Path \tmp
    
    $ErrorActionPreference="Continue"
    & .\gradlew.bat -g "C:\Users\$env:username\.gradle" --parallel --no-daemon --scan --console=plain $GradleTasks
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 15 22:00:26 GMT 2021
    - 1.3K bytes
    - Click Count (0)
  6. cmd/streaming-v4-unsigned.go

    	// Read value
    	for {
    		v, err := cr.reader.ReadByte()
    		if err != nil {
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    		}
    		if v != '\r' {
    			valueBuffer.WriteByte(v)
    			continue
    		}
    		// Must end with \r\n\r\n
    		var tmp [3]byte
    		_, err = io.ReadFull(cr.reader, tmp[:])
    		if err != nil {
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 03 14:55:52 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

            }
    
            // Wait for an in-flight connect to complete or fail.
            if (connectResult == null) {
              connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue
            }
    
            if (connectResult.isSuccess) {
              // We have a connected TCP connection. Cancel and defer the racing connects that all lost.
              cancelInFlightConnects()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  8. docs/fr/docs/_llm-test.md

    s’agit d’une liste non exhaustive et non normative de termes (principalement) techniques présents dans les documents. Elle peut aider le concepteur de l’invite à déterminer pour quels termes le LLM a besoin d’un coup de main. Par exemple, lorsqu’il continue de remplacer une bonne traduction par une traduction sous-optimale. Ou lorsqu’il a des difficultés à conjuguer/décliner un terme dans votre langue.
    
    Voir par exemple la section `### List of English terms and their preferred German translations`...
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 12.8K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java

            // are handled in the switch statement's default case which continues the loop
            byte[] data = new byte[] { 1, 2 };
    
            // Use a type that's not SESSION_MESSAGE or SESSION_KEEP_ALIVE
            byte[] unknownHeader = new byte[] { (byte) 0x90, 0, 0, 0 };
    
            byte[] fullData = concat(unknownHeader, // Unknown packet type - will continue to next packet
                    messageHeader(2), data);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  10. cmd/bucket-targets.go

    		if t.Type == tgt.Type {
    			if t.Arn == tgt.Arn {
    				if !update {
    					return BucketRemoteAlreadyExists{Bucket: t.TargetBucket}
    				}
    				newtgts[idx] = *tgt
    				found = true
    				continue
    			}
    			// fail if endpoint is already present in list of targets and not a matching ARN
    			if t.Endpoint == tgt.Endpoint {
    				return BucketRemoteAlreadyExists{Bucket: t.TargetBucket}
    			}
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.9K bytes
    - Click Count (0)
Back to Top