- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 299 for writeLoc (0.14 sec)
-
src/os/zero_copy_stub.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build !linux package os import "io" func (f *File) writeTo(w io.Writer) (written int64, handled bool, err error) { return 0, false, nil } func (f *File) readFrom(r io.Reader) (n int64, handled bool, err error) { return 0, false, nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 17 23:16:28 UTC 2023 - 406 bytes - Viewed (0) -
src/net/unixsock.go
} // WriteToUnix acts like [UnixConn.WriteTo] but takes a [UnixAddr]. func (c *UnixConn) WriteToUnix(b []byte, addr *UnixAddr) (int, error) { if !c.ok() { return 0, syscall.EINVAL } n, err := c.writeTo(b, addr) if err != nil { err = &OpError{Op: "write", Net: c.fd.net, Source: c.fd.laddr, Addr: addr.opAddr(), Err: err} } return n, err } // WriteTo implements the [PacketConn] WriteTo method.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.1K bytes - Viewed (0) -
src/net/udpsock.go
err = &OpError{Op: "read", Net: c.fd.net, Source: c.fd.laddr, Addr: c.fd.raddr, Err: err} } return } // WriteToUDP acts like WriteTo but takes a UDPAddr. func (c *UDPConn) WriteToUDP(b []byte, addr *UDPAddr) (int, error) { if !c.ok() { return 0, syscall.EINVAL } n, err := c.writeTo(b, addr) if err != nil { err = &OpError{Op: "write", Net: c.fd.net, Source: c.fd.laddr, Addr: addr.opAddr(), Err: err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 16:58:25 UTC 2023 - 11.8K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/test/kotlin/org/gradle/internal/cc/impl/serialization/codecs/AbstractUserTypeCodecTest.kt
val outputStream = ByteArrayOutputStream() writeTo( outputStream, graph, codec, object : AbstractProblemsListener() { override fun onProblem(problem: PropertyProblem) { println(problem) } } ) return outputStream.toByteArray() } private fun writeTo( outputStream: OutputStream,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 7.3K bytes - Viewed (0) -
src/io/io_test.go
rb := new(bytes.Buffer) // implements WriteTo. wb := new(Buffer) rb.WriteString("hello, world.") Copy(wb, rb) if wb.String() != "hello, world." { t.Errorf("Copy did not work properly") } } // Version of bytes.Buffer that checks whether WriteTo was called or not type writeToChecker struct { bytes.Buffer writeToCalled bool } func (wt *writeToChecker) WriteTo(w Writer) (int64, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 09 22:04:41 UTC 2023 - 18.9K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_unix.go
//go:build darwin || dragonfly || freebsd || illumos || linux || netbsd || openbsd package filelock import ( "io/fs" "syscall" ) type lockType int16 const ( readLock lockType = syscall.LOCK_SH writeLock lockType = syscall.LOCK_EX ) func lock(f File, lt lockType) (err error) { for { err = syscall.Flock(int(f.Fd()), int(lt)) if err != syscall.EINTR { break } } if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 17 02:24:35 UTC 2023 - 723 bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_windows.go
//go:build windows package filelock import ( "internal/syscall/windows" "io/fs" "syscall" ) type lockType uint32 const ( readLock lockType = 0 writeLock lockType = windows.LOCKFILE_EXCLUSIVE_LOCK ) const ( reserved = 0 allBytes = ^uint32(0) ) func lock(f File, lt lockType) error { // Per https://golang.org/issue/19098, “Programs currently expect the Fd
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 17 02:24:35 UTC 2023 - 1.3K bytes - Viewed (0) -
test/fixedbugs/issue9321.go
"bytes" "runtime" "runtime/pprof" "sync" ) func test() { var wg sync.WaitGroup wg.Add(2) test := func() { for i := 0; i < 10; i++ { buf := &bytes.Buffer{} pprof.Lookup("goroutine").WriteTo(buf, 2) } wg.Done() } go test() go test() wg.Wait() } func main() { runtime.GOMAXPROCS(4) for i := 0; i < 10; i++ { test() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 538 bytes - Viewed (0) -
src/net/iprawsock_posix.go
} return } func (c *IPConn) writeTo(b []byte, addr *IPAddr) (int, error) { if c.fd.isConnected { return 0, ErrWriteToConnected } if addr == nil { return 0, errMissingAddress } sa, err := addr.sockaddr(c.fd.family) if err != nil { return 0, err } return c.fd.writeTo(b, sa) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 3.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/BufferMockResponseBody.kt
return BufferMockResponseBody(defensiveCopy) } internal class BufferMockResponseBody( val buffer: Buffer, ) : MockResponseBody { override val contentLength = buffer.size override fun writeTo(sink: BufferedSink) { buffer.copyTo(sink.buffer) sink.emitCompleteSegments() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 07 16:05:34 UTC 2024 - 1.1K bytes - Viewed (0)