- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 4,375 for dwrite (0.28 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/runtime/time_fake.go
return faketime / 1e9, int32(faketime % 1e9), faketime } // write is like the Unix write system call. // We have to avoid write barriers to avoid potential deadlock // on write calls. // //go:nowritebarrierrec func write(fd uintptr, p unsafe.Pointer, n int32) int32 { if !(fd == 1 || fd == 2) { // Do an ordinary write. return write1(fd, p, n) } // Write with the playback header.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:15:13 UTC 2024 - 2.5K bytes - Viewed (0) -
test/fixedbugs/notinheap3.go
v1 t1 v2 t2 v1s []t1 v2s []t2 ) func f() { // Test direct writes v1.x = nil // no barrier v2.x = nil // ERROR "write barrier" v1.s = []nih(nil) // no barrier v2.s = []ih(nil) // ERROR "write barrier" } func g() { // Test aggregate writes v1 = t1{x: nil} // no barrier v2 = t2{x: nil} // ERROR "write barrier" } func h() { // Test copies and appends.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 02 17:46:15 UTC 2022 - 1.3K bytes - Viewed (0)