- Sort Score
- Num 10 results
- Language All
Results 761 - 770 of 1,385 for makeT (0.07 seconds)
-
guava/src/com/google/common/graph/MapIteratorCache.java
* the entry was returned by the iterator, except through the setValue operation on the map entry" * As such, this field must be cleared before every map mutation. * * Note about volatile: volatile doesn't make it safe to read from a mutable graph in one thread * while writing to it in another. All it does is help with _reading_ from multiple threads * concurrently. For more information, see AbstractNetworkTest.concurrentIteration.
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 4.6K bytes - Click Count (0) -
guava/src/com/google/common/collect/ImmutableMapEntry.java
return (ImmutableMapEntry<K, V>[]) new ImmutableMapEntry<?, ?>[size]; } ImmutableMapEntry(K key, V value) { super(key, value); checkEntryNotNull(key, value); } // Redeclare methods to make them `final`, just to be extra-safe. @Override @ParametricNullness public final K getKey() { return super.getKey(); } @Override @ParametricNullness public final V getValue() {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Jul 01 21:42:29 GMT 2025 - 4.6K bytes - Click Count (0) -
cmd/dynamic-timeouts.go
index := entries - 1 if index < dynamicTimeoutLogSize { dt.mutex.Lock() dt.log[index] = duration // We leak entries while we copy if entries == dynamicTimeoutLogSize { // Make copy on stack in order to call adjust() logCopy := [dynamicTimeoutLogSize]time.Duration{} copy(logCopy[:], dt.log[:]) // reset log entries atomic.StoreInt64(&dt.entries, 0) dt.mutex.Unlock()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.5K bytes - Click Count (0) -
docs/metrics/prometheus/alerts.md
equal: ['alertname', 'dev', 'instance'] ``` This sample configuration uses a `webhook` at http://127.0.0.1:8010/webhook to post the alerts. Start the AlertManager and it listens on port `9093` by default. Make sure your webhook is up and listening for the alerts. ## Configure Prometheus to use AlertManager Add below section to your `prometheus.yml` ```yaml alerting: alertmanagers: - static_configs:
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 23 15:13:23 GMT 2025 - 4.4K bytes - Click Count (0) -
internal/config/subnet/config.go
cfg.Proxy = proxy if transport == nil { // when transport is nil, it means we are just validating the // inputs not performing any network calls. return cfg, nil } // Make sure to clone the transport before editing the ProxyURL if proxyURL != nil { if tr, ok := transport.(*http.Transport); ok { ctransport := tr.Clone() ctransport.Proxy = http.ProxyURL((*url.URL)(proxyURL))Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.9K bytes - Click Count (0) -
internal/logger/target/console/console.go
fmt.Fprintln(c.output, string(logJSON)) return nil } if entry.Level == logger.EventKind { fmt.Fprintln(c.output, entry.Message) return nil } traceLength := len(entry.Trace.Source) trace := make([]string, traceLength) // Add a sequence number and formatting for each stack trace // No formatting is required for the first entry for i, element := range entry.Trace.Source {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.9K bytes - Click Count (0) -
internal/s3select/simdj/reader_amd64_test.go
if !simdjson.SupportedCPU() { t.Skip("Unsupported cpu") } for _, tt := range testCases { t.Run(tt.name, func(t *testing.T) { ref := loadCompressed(t, tt.name) var err error dst := make(chan simdjson.Object, 100) dec := NewElementReader(dst, &err, &json.ReaderArgs{ContentType: "json"}) pj, err := simdjson.ParseND(ref, nil) if err != nil { t.Fatal(err) } i := pj.Iter() cpy := i
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.9K bytes - Click Count (0) -
.github/ISSUE_TEMPLATE/11-language-change.yml
validations: required: false - type: textarea id: learning-curve attributes: label: "Would this change make Go easier or harder to learn, and why?" - type: textarea id: cost-description attributes: label: "Cost Description"Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Aug 08 19:02:29 GMT 2024 - 4.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/SourceSinkTester.java
/** * @param <S> the source or sink type * @param <T> the data type (byte[] or String) * @param <F> the factory type * @author Colin Decker */ @AndroidIncompatible // TODO(b/230620681): Make this available (even though we won't run it). @NullUnmarked public class SourceSinkTester<S, T, F extends SourceSinkFactory<S, T>> extends TestCase { static final String LOREM_IPSUM =
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 4.9K bytes - Click Count (0) -
guava/src/com/google/common/math/DoubleUtils.java
return x.longValue(); } else if (exponent > MAX_EXPONENT) { return x.signum() * POSITIVE_INFINITY; } /* * We need the top SIGNIFICAND_BITS + 1 bits, including the "implicit" one bit. To make rounding * easier, we pick out the top SIGNIFICAND_BITS + 2 bits, so we have one to help us round up or * down. twiceSignifFloor will contain the top SIGNIFICAND_BITS + 2 bits, and signifFloor the
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 5.1K bytes - Click Count (0)