- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 741 for continua (0.14 seconds)
-
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) -
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) -
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) -
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) -
.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) -
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) -
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) -
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) -
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) -
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)