- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for TestHookDidWritev (0.44 sec)
-
src/net/writev_test.go
}) } } } func testBuffer_writeTo(t *testing.T, chunks int, useCopy bool) { oldHook := poll.TestHookDidWritev defer func() { poll.TestHookDidWritev = oldHook }() var writeLog struct { sync.Mutex log []int } poll.TestHookDidWritev = func(size int) { writeLog.Lock() writeLog.log = append(writeLog.log, size) writeLog.Unlock() } var want bytes.Buffer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 5K bytes - Viewed (0) -
src/internal/poll/fd.go
for len(*v) > 0 { ln0 := int64(len((*v)[0])) if ln0 > n { (*v)[0] = (*v)[0][n:] return } n -= ln0 (*v)[0] = nil *v = (*v)[1:] } } // TestHookDidWritev is a hook for testing writev. var TestHookDidWritev = func(wrote int) {} // String is an internal string definition for methods/functions // that is not intended for use outside the standard libraries. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 17 23:16:28 UTC 2023 - 3.3K bytes - Viewed (0) -
src/internal/poll/writev.go
fd.iovecs = new([]syscall.Iovec) } *fd.iovecs = iovecs // cache var wrote uintptr wrote, err = writev(fd.Sysfd, iovecs) if wrote == ^uintptr(0) { wrote = 0 } TestHookDidWritev(int(wrote)) n += int64(wrote) consume(v, int64(wrote)) clear(iovecs) if err != nil { if err == syscall.EINTR { continue } if err == syscall.EAGAIN {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 1.8K bytes - Viewed (0) -
src/internal/poll/fd_windows.go
} o := &fd.wop o.InitBufs(buf) n, err := execIO(o, func(o *operation) error { return syscall.WSASend(o.fd.Sysfd, &o.bufs[0], uint32(len(o.bufs)), &o.qty, 0, &o.o, nil) }) o.ClearBufs() TestHookDidWritev(n) consume(buf, int64(n)) return int64(n), err } // WriteTo wraps the sendto network call. func (fd *FD) WriteTo(buf []byte, sa syscall.Sockaddr) (int, error) { if err := fd.writeLock(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 16:50:42 UTC 2024 - 34.1K bytes - Viewed (0)