- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 611 for channels (1.68 sec)
-
cmd/metrics-v2_test.go
}, } ticker := time.NewTicker(1 * time.Millisecond) defer ticker.Stop() for _, obs := range observations { // Send observations once every 1ms, to simulate delay between // observations. This is to test the channel based // synchronization used internally. <-ticker.C ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val) } metrics := getHistogramMetrics(ttfbHist, getBucketTTFBDistributionMD(), false, false)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 6.8K bytes - Viewed (0) -
.github/PULL_REQUEST_TEMPLATE.md
## Description ## Motivation and Context ## How to test this PR? ## Types of changes - [ ] Bug fix (non-breaking change which fixes an issue) - [ ] New feature (non-breaking change which adds functionality) - [ ] Optimization (provides speedup with no functional changes) - [ ] Breaking change (fix or feature that would cause existing functionality to change) ## Checklist:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Nov 14 17:29:11 UTC 2023 - 1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/trans/nt/NtTransNotifyChange.java
import jcifs.util.Hexdump; /** * SMB1 NT Transaction subcommand for file system change notification. * * This transaction allows monitoring of file system changes in a directory, * such as file creation, modification, deletion, and attribute changes. */ public class NtTransNotifyChange extends SmbComNtTransaction { int fid; private final int completionFilter; private final boolean watchTree; /**Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.7K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/MethodsRemovedInInternalSuperClassRule.groovy
oldMethods.removeAll(newMethods) if (oldMethods.isEmpty()) { return null } List<String> changes = filterChangesToReport(oldClass, oldMethods) if (changes.isEmpty()) { return null } return acceptOrReject(c, changes, Violation.error(c, " methods removed in internal super class")) } private Set<CtMethod> collectAllPublicApiMethods(CtClass c) {
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Wed Dec 24 14:15:15 UTC 2025 - 4.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/stemmeroverride/StemmerOverrideFile.java
* This class handles the process of writing changes to a temporary file * and then replacing the original file upon successful commit. */ protected class StemmerOverrideUpdater implements Closeable { /** A flag indicating whether the changes have been committed. */ protected boolean isCommit = false; /** The temporary file to write changes to. */ protected File newFile;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 05:56:45 UTC 2025 - 14.2K bytes - Viewed (0) -
cmd/erasure.go
Info: dataUsageCacheInfo{ Name: dataUsageRoot, NextCycle: oldCache.Info.NextCycle, }, Cache: make(map[string]dataUsageEntry, len(oldCache.Cache)), } // Put all buckets into channel. bucketCh := make(chan BucketInfo, len(buckets)) // Shuffle buckets to ensure total randomness of buckets, being scanned. // Otherwise same set of buckets get scanned across erasure sets always.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 16.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java
reload(updater); } } /** * Reloads the character mapping items from the dictionary file. * * @param updater the mapping updater to use for writing changes, or null for read-only reload */ protected void reload(final MappingUpdater updater) { try (CurlResponse curlResponse = dictionaryManager.getContentResponse(this)) {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 05:56:45 UTC 2025 - 15.3K bytes - Viewed (0) -
.github/workflows/CheckBadMerge.groovy
* * When merging `releaseX` branch into `master`, we should only use the release note from the `master` branch, * but sometimes changes on release notes.md was brought to master and merged unnoticed, * e.g https://github.com/gradle/gradle/pull/25825 * * This script is to check if there is any merge commit that brings changes from release branch to master. * Usage: groovy CheckBadMerge.groovy <commit1> <commit2> ...
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Fri Jan 24 10:03:31 UTC 2025 - 5.8K bytes - Viewed (0) -
internal/ioutil/ioutil.go
dw := &DeadlineWorker{ timeout: timeout, } return dw } // Run runs the given function, passing it a stopper channel. If the deadline passes before // the function finishes executing, Run returns context.DeadlineExceeded to the caller. // channel so that the work function can attempt to exit gracefully. // Multiple calls to Run will run independently of each other.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 11.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.8.md
- [Action Required](#action-required) - [Other notable changes](#other-notable-changes) - [v1.8.14](#v1814) - [Downloads for v1.8.14](#downloads-for-v1814) - [Client Binaries](#client-binaries-1) - [Server Binaries](#server-binaries-1) - [Node Binaries](#node-binaries-1) - [Changelog since v1.8.13](#changelog-since-v1813) - [Other notable changes](#other-notable-changes-1) - [v1.8.13](#v1813)Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 312.2K bytes - Viewed (0)