- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 248 for matched (0.04 seconds)
-
internal/stmt_store/stmt_store.go
} // Store defines an interface for managing the caching operations of SQL statements (Stmt). // This interface provides methods for creating new statements, retrieving all cache keys, // getting cached statements, setting cached statements, and deleting cached statements. type Store interface { // New creates a new Stmt object and caches it. // Parameters: // ctx: The context for the request, which can carry deadlines, cancellation signals, etc.
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Apr 27 06:05:16 GMT 2025 - 6K bytes - Click Count (0) -
CONTRIBUTING.md
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Mar 29 22:00:27 GMT 2023 - 1.3K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/HtmlToXmlJavadocLexer.java
onInlineContent(); visitor.onEndJavadocTag(name); } @Override public void onText(String text) { boolean ws = text.matches("\\s*"); if (!ws) { onInlineContent(); visitor.onText(text); } else if (!elementStack.isEmpty() && !blockContent.contains(elementStack.getFirst())) {
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 5.8K bytes - Click Count (0) -
internal/kms/stub.go
matches := []madmin.KMSKeyInfo{} if req.Prefix == "" { req.Prefix = "*" } for _, keyName := range s.KeyNames { if wildcard.MatchAsPatternPrefix(req.Prefix, keyName) { matches = append(matches, madmin.KMSKeyInfo{Name: keyName, CreatedAt: StubCreatedAt, CreatedBy: StubCreatedBy}) } } return matches, "", nil }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Aug 18 06:43:03 GMT 2024 - 3.6K bytes - Click Count (0) -
cmd/iam.go
func (sys *IAMSys) periodicRoutines(ctx context.Context, baseInterval time.Duration) { // Watch for IAM config changes for iamStorageWatcher. watcher, isWatcher := sys.store.IAMStorageAPI.(iamStorageWatcher) if isWatcher { go func() { ch := watcher.watch(ctx, iamConfigPrefix) for event := range ch { if err := sys.loadWatchedEvent(ctx, event); err != nil { // we simply log errors
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
Pattern pidPattern = isWindows() ? WINDOWS_PID_PATTERN : UNIX_PID_PATTERN; psOutput.forEach(line -> { Matcher commandLineArgsMatcher = commandLineArgsPattern.matcher(line); Matcher pidMatcher = pidPattern.matcher(line); if (commandLineArgsMatcher.find() && pidMatcher.find()) { String pid = pidMatcher.group(1); if (!MY_PID.equals(pid)) {
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Sep 23 13:49:45 GMT 2025 - 12K bytes - Click Count (0) -
internal/mountinfo/mountinfo_linux.go
if strings.HasPrefix(mpath, ppath) { // At this point if the mount point has a common prefix two conditions can happen. // - mount.Path matches exact with `path` means we can proceed no error here. // - mount.Path doesn't match (means cross-device mount), should error out. if mount.Path != path { crossMounts = append(crossMounts, mount) } } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 4.7K bytes - Click Count (0) -
misc/ios/detect.go
for _, line := range lines { if len(line) == 0 { continue } xmlLines := getLines(parseMobileProvision(string(line))) matches := 0 for _, udid := range udids { for _, xmlLine := range xmlLines { if bytes.Contains(xmlLine, udid) { matches++ } } } if matches == len(udids) { files = append(files, string(line)) } } return files }Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Oct 19 23:33:30 GMT 2023 - 3.2K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/FindMissingDocumentationFiles.java
// and captures the content within the brackets. Files.readAllLines(file).forEach(line -> { if (line.matches("^\\s*\\[\\[(.*)\\]\\].*")) { String anchorName = line.replaceAll("^\\s*\\[\\[(.*)\\]\\].*$", "$1"); allAnchors.add(anchorName); }Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Aug 21 15:38:58 GMT 2025 - 8.5K bytes - Click Count (0) -
cmd/server_test.go
response, err = s.client.Do(request) c.Assert(err, nil) c.Assert(response.StatusCode, http.StatusOK) bucketPolicyReadBuf, err := io.ReadAll(response.Body) c.Assert(err, nil) // Verify if downloaded policy matches with previously uploaded. expectedPolicy, err := policy.ParseBucketPolicyConfig(strings.NewReader(bucketPolicyStr), bucketName) c.Assert(err, nil)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 118.1K bytes - Click Count (0)