- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for Hoon (0.15 sec)
-
guava/src/com/google/common/collect/ArrayListMultimap.java
@VisibleForTesting transient int expectedValuesPerKey; /** * Creates a new, empty {@code ArrayListMultimap} with the default initial capacities. * * <p>This method will soon be deprecated in favor of {@code * MultimapBuilder.hashKeys().arrayListValues().build()}. */ public static <K extends @Nullable Object, V extends @Nullable Object> ArrayListMultimap<K, V> create() {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 6.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ArrayListMultimap.java
@VisibleForTesting transient int expectedValuesPerKey; /** * Creates a new, empty {@code ArrayListMultimap} with the default initial capacities. * * <p>This method will soon be deprecated in favor of {@code * MultimapBuilder.hashKeys().arrayListValues().build()}. */ public static <K extends @Nullable Object, V extends @Nullable Object> ArrayListMultimap<K, V> create() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 6.9K bytes - Viewed (0) -
cmd/license-update.go
} } } func performLicenseUpdate(ctx context.Context, objectAPI ObjectLayer) { // the subnet license renewal api renews the license only // if required e.g. when it is expiring soon url := globalSubnetConfig.BaseURL + licRenewPath resp, err := globalSubnetConfig.Post(url, nil) if err != nil { subnetLogIf(ctx, fmt.Errorf("error from %s: %w", url, err)) return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
outFrames.add(OutFrame(frameCount++, bytesOut.size, false)) return writer } /** * Shortens the last frame from its original length to `length`. This will cause the peer to * close the socket as soon as this frame has been written; otherwise the peer stays open until * explicitly closed. */ fun truncateLastFrame(length: Int): Http2Writer { val lastFrame = outFrames.removeAt(outFrames.size - 1)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
fastapi/utils.py
*, name: str, path: str, method: str ) -> str: # pragma: nocover warnings.warn( "fastapi.utils.generate_operation_id_for_path() was deprecated, " "it is not used internally, and will be removed soon", DeprecationWarning, stacklevel=2, ) operation_id = f"{name}{path}" operation_id = re.sub(r"\W", "_", operation_id) operation_id = f"{operation_id}_{method.lower()}"
Python - Registered: Sun Apr 21 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:40:57 GMT 2024 - 7.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created. // in this case the CNI will be invoked soon and provide us with the netns. openNetns = s.currentPodSnapshot.Get(string(pod.UID)) if openNetns == nil { return nil, fmt.Errorf("can't find netns for pod, this is ok if this is a newly created pod (%w)", ErrPodNotFound)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.1K bytes - Viewed (1) -
cmd/metrics-resource.go
sectorSize := uint64(512) kib := float64(1 << 10) diffInSeconds := time.Now().UTC().Sub(lastDriveStatsRefresh).Seconds() if diffInSeconds == 0 { // too soon to update the stats return } diffStats := getDiffStats(latestStats, currentStats) updateResourceMetrics(driveSubsystem, readsPerSec, float64(diffStats.ReadIOs)/diffInSeconds, labels, false)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 17 05:10:25 GMT 2024 - 17.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
// Clean up again immediately. return 0L } earliestEvictableConnection != null -> { // A connection will be ready to evict soon. return earliestEvictableIdleAtNs + keepAliveDurationNs - now } inUseConnectionCount > 0 -> { // All connections are in use. It'll be at least the keep alive duration 'til we run again.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
if (strategy == ResumePriority.AfterOtherTasks && otherTasksStarted) { return yieldUntil(strategy, condition) } } private enum class ResumePriority { /** Resumes as soon as the condition is satisfied. */ BeforeOtherTasks, /** Resumes after the already-enqueued tasks. */ AfterEnqueuedTasks,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 12.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
routePlanner.autoGeneratePlans = true routePlanner.defaultConnectionIdleAtNanos = expireTime val address = routePlanner.address val pool = routePlanner.pool // Connections are created as soon as a policy is set setPolicy(pool, address, ConnectionPool.AddressPolicy(2)) assertThat(pool.connectionCount()).isEqualTo(2) // Connections are replaced if they idle out or are evicted from the pool
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0)