Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/acln0/zerocopy
/ functions
Functions
53 in github.com/acln0/zerocopy
⨍
Functions
53
◇
Types & classes
4
↓ 38 callers
Method
Close
Close closes both sides of the pipe.
zerocopy.go:77
↓ 12 callers
Method
Write
Write writes data to the pipe.
zerocopy.go:67
↓ 11 callers
Method
Read
Read reads data from the pipe.
zerocopy.go:57
↓ 7 callers
Function
NewPipe
NewPipe creates a new pipe.
zerocopy.go:24
↓ 7 callers
Function
transferTestSocketPair
(network string)
zerocopy_linux_test.go:656
↓ 6 callers
Function
splice
splice calls splice(2) with SPLICE_F_NONBLOCK.
zerocopy_linux.go:727
↓ 5 callers
Function
Transfer
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 callers
Method
Tee
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 callers
Function
benchTransfer
(b *testing.B, upNet, downNet string)
zerocopy_linux_test.go:596
↓ 4 callers
Function
newSpliceTest
(t *testing.T)
zerocopy_linux_test.go:392
↓ 4 callers
Function
startTransferClient
(conn net.Conn, op string, chunkSize, totalSize int)
zerocopy_linux_test.go:685
↓ 4 callers
Function
testTransfer
(t *testing.T, upNet, downNet string)
zerocopy_linux_test.go:423
↓ 3 callers
Method
CloseWrite
CloseWrite closes the write side of the pipe.
zerocopy.go:72
↓ 3 callers
Function
newLocalListener
(network string)
zerocopy_linux_test.go:779
↓ 2 callers
Method
BufferSize
BufferSize returns the buffer size of the pipe.
zerocopy.go:47
↓ 2 callers
Function
tee
tee calls tee(2) with SPLICE_F_NONBLOCK.
zerocopy_linux.go:722
↓ 1 callers
Method
SetBufferSize
SetBufferSize sets the pipe's buffer size to n.
zerocopy.go:52
↓ 1 callers
Method
bufferSize
()
zerocopy_linux.go:129
↓ 1 callers
Method
read
(b []byte)
zerocopy_linux.go:170
↓ 1 callers
Method
readFrom
(src io.Reader)
zerocopy_linux.go:292
↓ 1 callers
Method
setBufferSize
(n int)
zerocopy_linux.go:151
↓ 1 callers
Function
spliceDrain
(p *Pipe, rrc syscall.RawConn, max int)
zerocopy_linux.go:629
↓ 1 callers
Function
splicePump
(wrc syscall.RawConn, p *Pipe, inpipe int)
zerocopy_linux.go:662
↓ 1 callers
Method
tee
(w io.Writer)
zerocopy_linux.go:708
↓ 1 callers
Function
testTeeChain
(t *testing.T, n int)
zerocopy_linux_test.go:83
↓ 1 callers
Function
testTransferIssue25985
(t *testing.T, upNet, downNet string)
zerocopy_linux_test.go:529
↓ 1 callers
Function
testTransferReaderAtEOF
(t *testing.T, upNet, downNet string)
zerocopy_linux_test.go:498
↓ 1 callers
Function
testUnixAddr
testUnixAddr uses ioutil.TempFile to get a name that is unique.
zerocopy_linux_test.go:797
↓ 1 callers
Function
transfer
(dst io.Writer, src io.Reader)
zerocopy_linux.go:542
↓ 1 callers
Method
writeTo
(dst io.Writer)
zerocopy_linux.go:429
Function
BenchmarkTransfer
(b *testing.B)
zerocopy_linux_test.go:589
Method
CloseRead
CloseRead closes the read side of the pipe.
zerocopy.go:62
Method
ReadFrom
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
Function
TestReadFrom
(t *testing.T)
zerocopy_linux_test.go:147
Function
TestSetBufferSize
(t *testing.T)
zerocopy_linux_test.go:808
Function
TestTeeChain
(t *testing.T)
zerocopy_linux_test.go:77
Function
TestTeeRead
(t *testing.T)
zerocopy_linux_test.go:25
Function
TestTransfer
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
Function
TestWriteTo
(t *testing.T)
zerocopy_linux_test.go:347
Method
WriteTo
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
Method
bench
(b *testing.B)
zerocopy_linux_test.go:609
Method
bufferSize
()
zerocopy_other.go:15
Function
init
()
zerocopy_linux_test.go:729
Method
read
(b []byte)
zerocopy_other.go:23
Method
readFrom
(src io.Reader)
zerocopy_other.go:27
Method
setBufferSize
(n int)
zerocopy_other.go:19
Method
tee
(w io.Writer)
zerocopy_other.go:39
Method
test
(t *testing.T)
zerocopy_linux_test.go:441
Function
testReadFromBlockedInRead
(t *testing.T)
zerocopy_linux_test.go:212
Function
testReadFromBlockedInWrite
(t *testing.T)
zerocopy_linux_test.go:272
Function
testReadFromRacyOrder
(t *testing.T)
zerocopy_linux_test.go:155
Function
transfer
(dst io.Writer, src io.Reader)
zerocopy_other.go:35
Method
writeTo
(dst io.Writer)
zerocopy_other.go:31