- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 4,372 for dwrite (0.11 sec)
-
src/io/pipe.go
// with code expecting an [io.Writer]. // // Reads and Writes on the pipe are matched one to one // except when multiple Reads are needed to consume a single Write. // That is, each Write to the [PipeWriter] blocks until it has satisfied // one or more Reads from the [PipeReader] that fully consume // the written data. // The data is copied directly from the Write to the corresponding
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
src/hash/maphash/maphash_test.go
} for _, h := range hh[1:] { h.SetSeed(hh[0].Seed()) } hh[0].Write(b) hh[1].WriteString(string(b)) writeByte := func(h *Hash, b byte) { err := h.WriteByte(b) if err != nil { t.Fatalf("WriteByte: %v", err) } } writeSingleByte := func(h *Hash, b byte) { _, err := h.Write([]byte{b}) if err != nil { t.Fatalf("Write single byte: %v", err) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 5.2K bytes - Viewed (0) -
src/io/pipe_test.go
. "io" "slices" "strings" "testing" "time" ) func checkWrite(t *testing.T, w Writer, data []byte, c chan int) { n, err := w.Write(data) if err != nil { t.Errorf("write: %v", err) } if n != len(data) { t.Errorf("short write: %d != %d", n, len(data)) } c <- 0 } // Test a single read/write pair. func TestPipe1(t *testing.T) { c := make(chan int) r, w := Pipe()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9K bytes - Viewed (0) -
internal/s3select/message.go
if !writer.write(newStatsMessage(writer.finBytesScanned, writer.finBytesProcessed, bytesReturned)) { break } writer.write(endMessage) } else { for payload.Len() > 0 { copiedLen := copy(writer.payloadBuffer[writer.payloadBufferIndex:], payload.Bytes()) writer.payloadBufferIndex += copiedLen payload.Next(copiedLen) // If buffer is filled, flush it now!
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 15.2K bytes - Viewed (0) -
src/compress/flate/deflate_test.go
} if err := zw.Close(); err != nil { t.Fatalf("Close: %v", err) } afterClose := b.Len() if c, err := zw.Write([]byte("Test")); err == nil || c != 0 { t.Fatalf("Write to closed writer: %v, %d", err, c) } if err := zw.Flush(); err == nil { t.Fatalf("Flush to closed writer: %s", err) } if err := zw.Close(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.6K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/tcp.go
ip, _, _ := net.SplitHostPort(conn.RemoteAddr().String()) // Write non-request fields specific to the instance out := &strings.Builder{} echo.StatusCodeField.Write(out, strconv.Itoa(http.StatusOK)) echo.ClusterField.WriteNonEmpty(out, s.Cluster) echo.IstioVersionField.WriteNonEmpty(out, s.IstioVersion) echo.NamespaceField.WriteNonEmpty(out, s.Namespace) echo.ServiceVersionField.Write(out, s.Version)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 16:20:31 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/proxy/util/linebuffer_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 12:38:25 UTC 2023 - 3.9K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/util/LineBufferingOutputStreamTest.groovy
LineBufferingOutputStream outputStream = new LineBufferingOutputStream(action, separator, 8) outputStream.write("line ".getBytes()) outputStream.write("1-line 2".getBytes()) then: 1 * action.text("line 1-") when: outputStream.write("-".getBytes()) then: 1 * action.text("line 2-") } def logsEmptyLines() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 12 07:56:08 UTC 2021 - 5.3K bytes - Viewed (0) -
test/fixedbugs/issue19168.go
func a(hdr *reflect.SliceHeader, p *byte) { hdr.Data = uintptr(unsafe.Pointer(p)) // ERROR "write barrier" } func b(hdr *reflect.StringHeader, p *byte) { hdr.Data = uintptr(unsafe.Pointer(p)) // ERROR "write barrier" } func c(hdrs *[1]reflect.SliceHeader, p *byte) { hdrs[0].Data = uintptr(unsafe.Pointer(p)) // ERROR "write barrier" } func d(hdr *struct{ s reflect.StringHeader }, p *byte) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 02 17:21:50 UTC 2017 - 1.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/locking/AbstractLockingIntegrationTest.groovy
lockedConf 'org:bar:1.+' } """ when: succeeds'dependencies', '--write-locks', '--refresh-dependencies' then: lockfileFixture.verifyLockfile('lockedConf', ['org:foo:1.0', 'org:bar:1.0']) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 02:50:41 UTC 2024 - 19.2K bytes - Viewed (0)