- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 249 for Closest (0.35 sec)
-
src/net/http/fcgi/fcgi_test.go
var cleanUpTests = []struct { input []byte err error }{ // confirm that child.handleRecord closes req.pw after aborting req { bytes.Join([][]byte{ streamBeginTypeStdin, makeRecord(typeAbortRequest, 1, nil), }, nil), ErrRequestAborted, }, // confirm that child.serve closes all pipes after error reading record { bytes.Join([][]byte{ streamBeginTypeStdin, nil, },
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 10.6K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/execution/PartialEvaluatorTest.kt
) ) ) } @Test fun `Project target - script-plugin - empty`() { assertThat( "reduces to static program that closes target scope then applies base plugins", partialEvaluationOf( Program.Empty, ProgramKind.ScriptPlugin, ProgramTarget.Project ),
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 38.9K bytes - Viewed (0) -
guava/src/com/google/common/collect/TopKSelector.java
import org.checkerframework.checker.nullness.qual.Nullable; /** * An accumulator that selects the "top" {@code k} elements added to it, relative to a provided * comparator. "Top" can mean the greatest or the lowest elements, specified in the factory used to * create the {@code TopKSelector} instance. * * <p>If your input data is available as a {@link Stream}, prefer passing {@link
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 11.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TopKSelector.java
import org.checkerframework.checker.nullness.qual.Nullable; /** * An accumulator that selects the "top" {@code k} elements added to it, relative to a provided * comparator. "Top" can mean the greatest or the lowest elements, specified in the factory used to * create the {@code TopKSelector} instance. * * <p>If your input data is available as an {@link Iterable} or {@link Iterator}, prefer {@link
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 11.2K bytes - Viewed (0) -
platforms/software/resources/src/test/groovy/org/gradle/internal/resource/transfer/AccessorBackedExternalResourceTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 11.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClient.java
* <li>The client sends a {@link Finished} message once it has received the {@link Result} message. * It may no longer send any messages.</li> * <li>The client closes the connection.</li> * <li>The daemon closes the connection once it has received the {@link Finished} message.</li> * </ul> * * <p>To stop a daemon:</p> * * <ul> * <li>The client creates a connection to daemon.</li>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 16.5K bytes - Viewed (0) -
src/internal/trace/gc.go
c.mmu(window, &acc) return acc.mmu } // Examples returns n specific examples of the lowest mutator // utilization for the given window size. The returned windows will be // disjoint (otherwise there would be a huge number of // mostly-overlapping windows at the single lowest point). There are // no guarantees on which set of disjoint windows this returns.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 26K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer.go
// Afterwards the final priorities can be calculted from 0 (highest) to N (lowest) without skipping. priorityInt := int(loadAssignment.Endpoints[i].Priority*5) + priority loadAssignment.Endpoints[i].Priority = uint32(priorityInt) priorityMap[priorityInt] = append(priorityMap[priorityInt], i) } // since Priorities should range from 0 (highest) to N (lowest) without skipping. // 2. adjust the priorities in order
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 11.8K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// to the peer. type WriteOnCloser struct { io.Writer hasWritten bool } func (w *WriteOnCloser) Write(p []byte) (int, error) { w.hasWritten = true return w.Writer.Write(p) } // Close closes the WriteOnCloser. It behaves like io.Closer. func (w *WriteOnCloser) Close() error { if !w.hasWritten { _, err := w.Write(nil) if err != nil { return err } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
src/net/http/httptest/server.go
} log.Print(buf.String()) } // CloseClientConnections closes any open HTTP connections to the test Server. func (s *Server) CloseClientConnections() { s.mu.Lock() nconn := len(s.conns) ch := make(chan struct{}, nconn) for c := range s.conns { go s.closeConnChan(c, ch) } s.mu.Unlock() // Wait for outstanding closes to finish. // // Out of paranoia for making a late change in Go 1.6, we
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0)