MCPcopy Create free account

hub / github.com/acln0/zerocopy / functions

Functions53 in github.com/acln0/zerocopy

↓ 38 callersMethodClose
Close closes both sides of the pipe.
zerocopy.go:77
↓ 12 callersMethodWrite
Write writes data to the pipe.
zerocopy.go:67
↓ 11 callersMethodRead
Read reads data from the pipe.
zerocopy.go:57
↓ 7 callersFunctionNewPipe
NewPipe creates a new pipe.
zerocopy.go:24
↓ 7 callersFunctiontransferTestSocketPair
(network string)
zerocopy_linux_test.go:656
↓ 6 callersFunctionsplice
splice calls splice(2) with SPLICE_F_NONBLOCK.
zerocopy_linux.go:727
↓ 5 callersFunctionTransfer
Transfer is like io.Copy, but moves data through a pipe rather than through a userspace buffer. Given a pipe p, Transfer operates equivalently to p.Re
zerocopy.go:133
↓ 4 callersMethodTee
Tee arranges for data in the read side of the pipe to be mirrored to the specified writer. There is no internal buffering: writes must complete before
zerocopy.go:113
↓ 4 callersFunctionbenchTransfer
(b *testing.B, upNet, downNet string)
zerocopy_linux_test.go:596
↓ 4 callersFunctionnewSpliceTest
(t *testing.T)
zerocopy_linux_test.go:392
↓ 4 callersFunctionstartTransferClient
(conn net.Conn, op string, chunkSize, totalSize int)
zerocopy_linux_test.go:685
↓ 4 callersFunctiontestTransfer
(t *testing.T, upNet, downNet string)
zerocopy_linux_test.go:423
↓ 3 callersMethodCloseWrite
CloseWrite closes the write side of the pipe.
zerocopy.go:72
↓ 3 callersFunctionnewLocalListener
(network string)
zerocopy_linux_test.go:779
↓ 2 callersMethodBufferSize
BufferSize returns the buffer size of the pipe.
zerocopy.go:47
↓ 2 callersFunctiontee
tee calls tee(2) with SPLICE_F_NONBLOCK.
zerocopy_linux.go:722
↓ 1 callersMethodSetBufferSize
SetBufferSize sets the pipe's buffer size to n.
zerocopy.go:52
↓ 1 callersMethodbufferSize
()
zerocopy_linux.go:129
↓ 1 callersMethodread
(b []byte)
zerocopy_linux.go:170
↓ 1 callersMethodreadFrom
(src io.Reader)
zerocopy_linux.go:292
↓ 1 callersMethodsetBufferSize
(n int)
zerocopy_linux.go:151
↓ 1 callersFunctionspliceDrain
(p *Pipe, rrc syscall.RawConn, max int)
zerocopy_linux.go:629
↓ 1 callersFunctionsplicePump
(wrc syscall.RawConn, p *Pipe, inpipe int)
zerocopy_linux.go:662
↓ 1 callersMethodtee
(w io.Writer)
zerocopy_linux.go:708
↓ 1 callersFunctiontestTeeChain
(t *testing.T, n int)
zerocopy_linux_test.go:83
↓ 1 callersFunctiontestTransferIssue25985
(t *testing.T, upNet, downNet string)
zerocopy_linux_test.go:529
↓ 1 callersFunctiontestTransferReaderAtEOF
(t *testing.T, upNet, downNet string)
zerocopy_linux_test.go:498
↓ 1 callersFunctiontestUnixAddr
testUnixAddr uses ioutil.TempFile to get a name that is unique.
zerocopy_linux_test.go:797
↓ 1 callersFunctiontransfer
(dst io.Writer, src io.Reader)
zerocopy_linux.go:542
↓ 1 callersMethodwriteTo
(dst io.Writer)
zerocopy_linux.go:429
FunctionBenchmarkTransfer
(b *testing.B)
zerocopy_linux_test.go:589
MethodCloseRead
CloseRead closes the read side of the pipe.
zerocopy.go:62
MethodReadFrom
ReadFrom transfers data from src to the pipe. If src implements syscall.Conn, ReadFrom tries to use splice(2) for the data transfer from the source f
zerocopy.go:91
FunctionTestReadFrom
(t *testing.T)
zerocopy_linux_test.go:147
FunctionTestSetBufferSize
(t *testing.T)
zerocopy_linux_test.go:808
FunctionTestTeeChain
(t *testing.T)
zerocopy_linux_test.go:77
FunctionTestTeeRead
(t *testing.T)
zerocopy_linux_test.go:25
FunctionTestTransfer
TODO(acln): add test cases where we transfer to and from pipes TODO(acln): add test cases for WriteTo with more combinations of blocking source and de
zerocopy_linux_test.go:416
FunctionTestWriteTo
(t *testing.T)
zerocopy_linux_test.go:347
MethodWriteTo
WriteTo transfers data from the pipe to dst. If dst implements syscall.Conn, WriteTo tries to use splice(2) for the data transfer from the pipe to th
zerocopy.go:100
Methodbench
(b *testing.B)
zerocopy_linux_test.go:609
MethodbufferSize
()
zerocopy_other.go:15
Functioninit
()
zerocopy_linux_test.go:729
Methodread
(b []byte)
zerocopy_other.go:23
MethodreadFrom
(src io.Reader)
zerocopy_other.go:27
MethodsetBufferSize
(n int)
zerocopy_other.go:19
Methodtee
(w io.Writer)
zerocopy_other.go:39
Methodtest
(t *testing.T)
zerocopy_linux_test.go:441
FunctiontestReadFromBlockedInRead
(t *testing.T)
zerocopy_linux_test.go:212
FunctiontestReadFromBlockedInWrite
(t *testing.T)
zerocopy_linux_test.go:272
FunctiontestReadFromRacyOrder
(t *testing.T)
zerocopy_linux_test.go:155
Functiontransfer
(dst io.Writer, src io.Reader)
zerocopy_other.go:35
MethodwriteTo
(dst io.Writer)
zerocopy_other.go:31