- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 213 for Closest (0.2 sec)
-
internal/http/check_port_linux.go
package http import ( "context" "net" "syscall" "time" ) // CheckPortAvailability - check if given host and port is already in use. // Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/plugin/use/internal/PluginRequestApplicator.java
/** * Resolves the given {@link PluginRequests} into the given {@link ScriptHandlerInternal#getScriptClassPath()}, * exports the resulting classpath into the given {@link ClassLoaderScope}, closes it and then applies * the requested plugins. * * A null target indicates that no plugin requests should be resolved but only the setup of the given * {@link ClassLoaderScope}. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComWrite.java
this.b = b; this.off = off; count = len; digest = null; /* otherwise recycled commands * like writeandx will choke if session * closes in between */ } int writeParameterWordsWireFormat( byte[] dst, int dstIndex ) { int start = dstIndex; writeInt2( fid, dst, dstIndex ); dstIndex += 2;
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 3K bytes - Viewed (0) -
guava/src/com/google/common/io/MultiInputStream.java
advance(); } @Override public void close() throws IOException { if (in != null) { try { in.close(); } finally { in = null; } } } /** Closes the current input stream and opens the next one, if any. */ private void advance() throws IOException { close(); if (it.hasNext()) { in = it.next().openStream(); } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/most_allocated.go
if weightSum == 0 { return 0 } return nodeScore / weightSum } } // The used capacity is calculated on a scale of 0-MaxNodeScore (MaxNodeScore is // constant with value set to 100). // 0 being the lowest priority and 100 being the highest. // The more resources are used the higher the score is. This function // is almost a reversed version of noderesources.leastRequestedScore.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 21 15:23:47 UTC 2022 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/seat_seconds.go
// no other code should use it. type SeatSeconds uint64 // MaxSeatsSeconds is the maximum representable value of SeatSeconds const MaxSeatSeconds = SeatSeconds(math.MaxUint64) // MinSeatSeconds is the lowest representable value of SeatSeconds const MinSeatSeconds = SeatSeconds(0) // SeatsTimeDuration produces the SeatSeconds value for the given factors. // This is intended only to produce small values, increments in work
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 20 09:16:46 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/least_allocated.go
weightSum += weight } if weightSum == 0 { return 0 } return nodeScore / weightSum } } // The unused capacity is calculated on a scale of 0-MaxNodeScore // 0 being the lowest priority and `MaxNodeScore` being the highest. // The more unused resources the higher the score is. func leastRequestedScore(requested, capacity int64) int64 { if capacity == 0 { return 0 } if requested > capacity {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 12 01:50:09 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/MultiProcessSafeIndexedCacheTest.groovy
when: cache.finishWork() then: 1 * fileAccess.writeFile(!null) >> { Runnable action -> action.run() } 1 * backingCache.close() 0 * _._ } def "closes cache when closed"() { given: cacheOpened() when: cache.finishWork() then: 1 * fileAccess.writeFile(!null) >> { Runnable action -> action.run() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 3.5K bytes - Viewed (0) -
src/container/heap/example_pq_test.go
type PriorityQueue []*Item func (pq PriorityQueue) Len() int { return len(pq) } func (pq PriorityQueue) Less(i, j int) bool { // We want Pop to give us the highest, not lowest, priority so we use greater than here. return pq[i].priority > pq[j].priority } func (pq PriorityQueue) Swap(i, j int) { pq[i], pq[j] = pq[j], pq[i] pq[i].index = i pq[j].index = j }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 20:27:36 UTC 2024 - 2.5K bytes - Viewed (0) -
src/net/netip/uint128.go
package netip import "math/bits" // uint128 represents a uint128 using two uint64s. // // When the methods below mention a bit number, bit 0 is the most // significant bit (in hi) and bit 127 is the lowest (lo&1). type uint128 struct { hi uint64 lo uint64 } // mask6 returns a uint128 bitmask with the topmost n bits of a // 128-bit number. func mask6(n int) uint128 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 07 21:28:44 UTC 2022 - 2.2K bytes - Viewed (1)