- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 56 for moving (0.18 sec)
-
internal/http/transports.go
Proxy: http.ProxyFromEnvironment, DialContext: dialContext, MaxIdleConnsPerHost: maxIdleConnsPerHost, WriteBufferSize: 64 << 10, // 64KiB moving up from 4KiB default ReadBufferSize: 64 << 10, // 64KiB moving up from 4KiB default IdleConnTimeout: 15 * time.Second, ResponseHeaderTimeout: 15 * time.Minute, // Conservative timeout is the default (for MinIO internode)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.9K bytes - Viewed (0) -
internal/logger/logrotate.go
// writes an error in JSON form to stderr, if we cannot // compress. if err := w.compress(); err != nil { msg := fmt.Sprintf("unable to compress log file %v: %v, ignoring and moving on", w.f.Name(), err) stdErrEnc.Encode(&log.Entry{ Level: ErrorKind, Message: msg, Time: time.Now().UTC(), Trace: &log.Trace{Message: msg}, }) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
cmd/storage-datatypes.go
Rotational bool Metrics DiskMetrics Error string // carries the error over the network } // DiskMetrics has the information about XL Storage APIs // the number of calls of each API and the moving average of // the duration of each API. type DiskMetrics struct { LastMinute map[string]AccElem `json:"apiLatencies,omitempty"` APICalls map[string]uint64 `json:"apiCalls,omitempty"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ImmutableMapTest.java
Collection<String> collection = map.values(); LenientSerializableTester.reserializeAndAssertElementsEqual(collection); } // TODO: Re-enable this test after moving to new serialization format in ImmutableMap. @J2ktIncompatible @GwtIncompatible // SerializableTester @SuppressWarnings("unchecked")
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Apr 30 14:39:16 GMT 2024 - 37.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java
* generates a synthetic method for the body of the lambda, the actual method calls that Animal * Sniffer is flagging don't appear inside toImmutableSortedMultiset but rather inside that * synthetic method. By moving those calls to a named method, we're able to apply * @IgnoreJRERequirement somewhere that it will help. */ private static <T extends @Nullable Object, E> void mapAndAdd( T t, Multiset<E> multiset,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 35.7K bytes - Viewed (0) -
cmd/storage-rest-server.go
var hint string if endpoint.URL != nil { hint = fmt.Sprintf("Drive '%s' does not support O_DIRECT flags, MinIO erasure coding requires filesystems with O_DIRECT support", endpoint.Path) } else { hint = "Drives do not support O_DIRECT flags, MinIO erasure coding requires filesystems with O_DIRECT support" } logger.Fatal(config.ErrUnsupportedBackend(err).Hint(hint), "Unable to initialize backend")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
isDecommissioned := z.poolMeta.isBucketDecommissioned(idx, bucket.String()) z.poolMetaMutex.RUnlock() if isDecommissioned { if serverDebugLog { console.Debugln("decommission: already done, moving on", bucket) } z.poolMetaMutex.Lock() if z.poolMeta.BucketDone(idx, bucket) { // remove from pendingBuckets and persist. decomLogIf(ctx, z.poolMeta.save(ctx, z.serverPools)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
* * @return null if an explanation cannot be provided (e.g. because the future is done). * @since 23.0 */ @CheckForNull protected String pendingToString() { // TODO(diamondm) consider moving this into addPendingString so it's always in the output if (this instanceof ScheduledFuture) { return "remaining delay=[" + ((ScheduledFuture) this).getDelay(TimeUnit.MILLISECONDS) + " ms]";
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterables.java
// moving elements when remove() is called). Stop before 'from' because // we already know that should be kept. for (int n = list.size() - 1; n > from; n--) { if (predicate.apply(list.get(n))) { list.remove(n); } } // And now remove everything in the range [to, from) (going backwards). for (int n = from - 1; n >= to; n--) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 42.8K bytes - Viewed (0)