mirrors/tailscale
1
0
Fork 0
mirror of https://github.com/tailscale/tailscale.git synced 2026-05-05 12:16:44 +02:00
Code Issues Packages Projects Releases Wiki Activity

more whitespace

Browse Source
This commit is contained in:
Josh Bleecher Snyder 2021-07-08 13:24:41 -07:00
parent 4847a89ecf
commit a1a2fb9181
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
net/uring/io_uring_linux.go
View File

@ -102,19 +102,25 @@ func NewUDPConn(pconn net.PacketConn) (*UDPConn, error) {
}
fd := file.Fd()
u.shutdown = append(u.shutdown, func() { file.Close() })
u.shutdown = append(u.shutdown, func() {
file.Close()
})
if ret := C.initialize(u.recvRing, C.int(fd)); ret < 0 {
u.doShutdown()
return nil, fmt.Errorf("recvRing initialization failed: %w", syscall.Errno(-ret))
}
u.shutdown = append(u.shutdown, func() { C.io_uring_queue_exit(u.recvRing) })
u.shutdown = append(u.shutdown, func() {
C.io_uring_queue_exit(u.recvRing)
})
if ret := C.initialize(u.sendRing, C.int(fd)); ret < 0 {
u.doShutdown()
return nil, fmt.Errorf("sendRing initialization failed: %w", syscall.Errno(-ret))
}
u.shutdown = append(u.shutdown, func() { C.io_uring_queue_exit(u.sendRing) })
u.shutdown = append(u.shutdown, func() {
C.io_uring_queue_exit(u.sendRing)
})
// Initialize buffers
for i := range u.recvReqs {