gsadmin/ziti
1
0
Fork 0
mirror of https://github.com/openziti/ziti.git synced 2026-10-13 23:59:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Better max UDP packet size naming.

Browse Source
This commit is contained in:
Michael Quigley
2020-07-31 11:19:52 -04:00
parent f155eb1c27
commit ae78fa17f3
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tunnel/intercept/proxy/proxy.go
+1 -1
View File
@@ -158,7 +158,7 @@ type udpReader struct {
func (reader *udpReader) generateReadEvents(manager udp_vconn.Manager) {
log := pfxlog.Logger().WithField("service", reader.service)
bufPool := mempool.NewPool(16, info.MaxPacketSize)
bufPool := mempool.NewPool(16, info.MaxUdpPacketSize)
for {
buf := bufPool.AcquireBuffer()
n, srcAddr, err := reader.conn.ReadFromUDP(buf.Buf)
tunnel/intercept/tproxy/tproxy_linux.go
+3 -3
View File
@@ -172,12 +172,12 @@ func (t *tProxyInterceptor) acceptUDP(context ziti.Context) {
func (t *tProxyInterceptor) generateReadEvents(manager udp_vconn.Manager) {
oobSize := 1600
bufPool := mempool.NewPool(16, info.MaxPacketSize+oobSize)
bufPool := mempool.NewPool(16, info.MaxUdpPacketSize+oobSize)
for {
pooled := bufPool.AcquireBuffer()
oob := pooled.Buf[info.MaxPacketSize:]
pooled.Buf = pooled.Buf[:info.MaxPacketSize]
oob := pooled.Buf[info.MaxUdpPacketSize:]
pooled.Buf = pooled.Buf[:info.MaxUdpPacketSize]
n, oobn, _, srcAddr, err := t.udpLn.ReadMsgUDP(pooled.Buf, oob)
if err != nil {
manager.QueueError(err)
tunnel/tunnel.go
+1 -1
View File
@@ -67,7 +67,7 @@ func myCopy(dst net.Conn, src net.Conn, done chan int64) {
defer dst.Close()
defer log.WithFields(loggerFields).Info("stopping pipe")
copyBuf := make([]byte, info.MaxPacketSize)
copyBuf := make([]byte, info.MaxUdpPacketSize)
n, err := io.CopyBuffer(dst, src, copyBuf)
done <- n