- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 320 for Observe (0.18 sec)
-
doc/go_mem.html
<p> A read <i>r</i> of a memory location <i>x</i> holding a value that is not larger than a machine word must observe some write <i>w</i> such that <i>r</i> does not happen before <i>w</i> and there is no write <i>w'</i> such that <i>w</i> happens before <i>w'</i> and <i>w'</i> happens before <i>r</i>. That is, each read must observe a value written by a preceding or concurrent write. </p> <p>
HTML - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/ProjectExecutionListener.java
* under the License. */ package org.apache.maven.execution; import org.apache.maven.lifecycle.LifecycleExecutionException; /** * <p> * Extension point that allows build extensions observe and possibly veto project build execution. * </p> * <strong>Note:</strong> This interface is part of work in progress and can be changed or removed without notice. * * @see ExecutionListener * @see MojoExecutionListener
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Nov 22 13:26:01 GMT 2022 - 1.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
assertNotNull(object); assertSame(object, striped.getAt(i)); // idempotent observed.add(object); } assertTrue("All stripes observed", observed.size() == striped.size()); // this uses #get(key), makes sure an already observed stripe is returned for (int i = 0; i < striped.size() * 100; i++) { assertTrue(observed.contains(striped.get(new Object()))); } try { striped.getAt(-1);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.4K bytes - Viewed (0) -
CONTRIBUTING.md
### What are the coding guidelines for MinIO?
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Feb 12 00:51:25 GMT 2022 - 2.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/scope/WeakMojoExecutionListener.java
*/ package org.apache.maven.execution.scope; import org.apache.maven.execution.MojoExecutionEvent; import org.apache.maven.plugin.MojoExecutionException; /** * Extension point that allows build extensions observe and possibly veto mojo executions. * <p> * Unlike {@link org.apache.maven.execution.MojoExecutionListener}, this extension point does not
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Nov 22 13:26:01 GMT 2022 - 1.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheReferencesTest.java
LoadingCache<Integer, String> cache, CountingRemovalListener<Integer, String> removalListener) { // initialSize will most likely be 2, but it's possible for the GC to have already run, so we'll // observe a size of 1 long initialSize = cache.size(); assertTrue(initialSize == 1 || initialSize == 2); // wait up to 5s byte[] filler = new byte[1024]; for (int i = 0; i < 500; i++) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 6.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/MojoExecutionListener.java
* under the License. */ package org.apache.maven.execution; import org.apache.maven.plugin.MojoExecutionException; /** * <p> * Extension point that allows build extensions observe and possibly veto mojo executions. * </p> * <strong>Note:</strong> This interface is part of work in progress and can be changed or removed without notice. * * @see org.apache.maven.execution.scope.WeakMojoExecutionListener
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Nov 22 13:26:01 GMT 2022 - 1.5K bytes - Viewed (0) -
cmd/tier_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "testing" "time" ) func TestTierMetrics(t *testing.T) { tier := "WARM-1" globalTierMetrics.Observe(tier, 200*time.Millisecond) expSuccess := 10 expFailure := 5 for i := 0; i < expSuccess; i++ { globalTierMetrics.logSuccess(tier) } for i := 0; i < expFailure; i++ { globalTierMetrics.logFailure(tier) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Dec 21 04:13:40 GMT 2023 - 1.5K bytes - Viewed (0) -
cmd/tier.go
Buckets: []float64{0.01, 0.1, 1, 2, 5, 10, 60, 5 * 60, 15 * 60, 30 * 60}, }, []string{"tier"}), } func (t *tierMetrics) Observe(tier string, dur time.Duration) { t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds()) } func (t *tierMetrics) logSuccess(tier string) { t.Lock() defer t.Unlock() stat := t.requestsCount[tier] stat.success++
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/metrics-v2_test.go
// observations. This is to test the channel based // synchronization used internally. select { case <-ticker.C: ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val) } } metrics := getHistogramMetrics(ttfbHist, getBucketTTFBDistributionMD(), false) // additional labels for +Inf for all histogram metrics
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.3K bytes - Viewed (0)