- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 3,239 for Write (0.04 sec)
-
maven-repository-metadata/src/main/java/org/apache/maven/artifact/repository/metadata/io/xpp3/MetadataXpp3Writer.java
} /** * Method write. * * @param writer a writer object * @param metadata a Metadata object * @throws java.io.IOException java.io.IOException if any */ public void write(Writer writer, Metadata metadata) throws java.io.IOException { try { delegate.write(writer, metadata.getDelegate()); } catch (XMLStreamException e) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 2.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/FileOperator.kt
import java.nio.channels.FileChannel import okio.Buffer /** * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)` * this class offers: * * * **Read/write:** read and write using the same operator. * * **Random access:** access any position within the file. * * **Shared channels:** read and write a file channel that's shared between
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0) -
src/cmd/dist/testjson.go
"encoding/json" "errors" "fmt" "io" "sync" "time" ) // lockedWriter serializes Write calls to an underlying Writer. type lockedWriter struct { lock sync.Mutex w io.Writer } func (w *lockedWriter) Write(b []byte) (int, error) { w.lock.Lock() defer w.lock.Unlock() return w.w.Write(b) } // testJSONFilter is an io.Writer filter that replaces the Package field in // test2json output.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 20:46:32 UTC 2024 - 4.6K 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) -
internal/s3select/message.go
buf := new(bytes.Buffer) binary.Write(buf, binary.BigEndian, uint32(totalLength)) binary.Write(buf, binary.BigEndian, uint32(headerLength)) prelude := buf.Bytes() binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude)) buf.Write(header) if payload != nil { buf.Write(payload) } message := buf.Bytes() binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(message)) return buf.Bytes()
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
return } r := NewReader(buf) // Write half the input and read back. for i := 0; i < 2; i++ { var lo, hi int if i == 0 { lo, hi = 0, (len(input)+1)/2 } else { lo, hi = (len(input)+1)/2, len(input) } t.Logf("#%d: write %d-%d", i, lo, hi) if _, err := w.Write(input[lo:hi]); err != nil { t.Errorf("testSync: write: %v", err) return } if i == 0 {
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/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) -
src/io/pipe_test.go
"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() var buf = make([]byte, 64)
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)