- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 4,223 for wsWrite (0.15 sec)
-
pilot/pkg/networking/core/cluster_cache.go
h := hash.New() h.WriteString(t.clusterName) h.Write(Separator) h.WriteString(t.proxyVersion) h.Write(Separator) h.WriteString(util.LocalityToString(t.locality)) h.Write(Separator) h.WriteString(t.proxyClusterID) h.Write(Separator) h.WriteString(strconv.FormatBool(t.proxySidecar)) h.Write(Separator) h.WriteString(strconv.FormatBool(t.http2)) h.Write(Separator) h.WriteString(strconv.FormatBool(t.downstreamAuto))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 6.1K bytes - Viewed (0) -
platforms/core-runtime/io/src/test/groovy/org/gradle/internal/io/StreamByteBufferTest.groovy
given: def streamBuf = new StreamByteBuffer(32000) def output = streamBuf.getOutputStream() when: output.write(1) output.write(2) output.write(3) output.write(255) output.close() then: def input = streamBuf.getInputStream() input.read() == 1 input.read() == 2 input.read() == 3
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 13:06:08 UTC 2024 - 13.3K bytes - Viewed (0) -
testing/integ-test/src/integTest/groovy/org/gradle/integtests/ProjectLoadingIntegrationTest.java
testFile("settings.gradle").write(" \n "); testFile("build.gradle").write(" "); inTestDirectory().withTasks("help").run(); } @Test public void canDetermineRootProjectAndDefaultProjectBasedOnCurrentDirectory() { File rootDir = getTestDirectory(); File childDir = new File(rootDir, "child"); testFile("settings.gradle").write("include('child')");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 18K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/util/PropertiesUtilsTest.groovy
expect: write([:]) == "" } def "empty properties with comment are written properly"() { expect: write([:], "Line comment") == normalize(""" #Line comment """) } def "simple properties are written sorted alphabetically"() { expect: write([one: "1", two: "2", three: "three"], "Line comment") == normalize("""
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.6K bytes - Viewed (0) -
internal/grid/connection.go
c.blockMessages.Store(&block) c.connMu.Unlock() } } // wsWriter writes websocket messages. type wsWriter struct { tmp [ws.MaxHeaderSize]byte } // writeMessage writes a message to w without allocations. func (ww *wsWriter) writeMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error { const fin = true var frame ws.Frame if s.ClientSide() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/outputorigin/IncrementalBuildOutputOriginIntegrationTest.groovy
firstBuildCacheKey != null originBuildInvocationId(":write") == null when: succeeds "write" then: executed ":write" def secondBuildId = buildInvocationId firstBuildId != secondBuildId with(origin(":write")) { buildInvocationId == firstBuildId buildCacheKey == firstBuildCacheKey } when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 02 08:27:17 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/util/hash/hash.go
func (i *instance) Write(p []byte) (n int) { n, _ = i.hash.Write(p) return } // Write wraps the Hash.Write function call // Hash.Write error always return nil, this func simplify caller handle error func (i *instance) WriteString(s string) (n int) { n, _ = i.hash.WriteString(s) return } func (i *instance) Sum64() uint64 { return i.hash.Sum64() } func (i *instance) Sum() string { sum := i.hash.Sum(nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 21 20:24:14 UTC 2023 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flushwriter/writer_test.go
fw := Wrap(w) for i := 0; i < 10; i++ { _, err := fw.Write([]byte("Test write")) if err != nil { t.Errorf("Unexpected error while writing with flush writer: %v", err) } } if w.flushCount != 10 { t.Errorf("Flush not called the expected number of times. Actual: %d", w.flushCount) } if w.writeCount != 10 { t.Errorf("Write not called the expected number of times. Actual: %d", w.writeCount) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 05 16:09:42 UTC 2017 - 2.1K bytes - Viewed (0) -
src/archive/tar/fuzz_test.go
for _, f := range files { if err := w.WriteHeader(f.header); err != nil { t.Fatalf("unable to write previously parsed header: %s", err) } if _, err := w.Write(f.content); err != nil { t.Fatalf("unable to write previously parsed content: %s", err) } } if err := w.Close(); err != nil { t.Fatalf("Unable to write archive: %s", err) } // TODO: We may want to check if the archive roundtrips. This would require
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 13 18:06:33 UTC 2022 - 2.2K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/io/DefaultModelWriter.java
} } @Override public void write(File output, Map<String, Object> options, org.apache.maven.model.Model model) throws IOException { write(output, options, model.getDelegate()); } @Override public void write(Writer output, Map<String, Object> options, org.apache.maven.model.Model model) throws IOException { write(output, options, model.getDelegate()); } @Override
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 07:40:37 UTC 2024 - 3.3K bytes - Viewed (0)