From 547b4fb49bb8ae6baf7fd481053ddeb93b3a3b98 Mon Sep 17 00:00:00 2001 From: Shelikhoo Date: Sun, 16 Jan 2022 22:52:31 +0000 Subject: [PATCH] rewrite sockopt rxtx buf size message for darwin, freebsd --- transport/internet/sockopt_darwin.go | 4 ++-- transport/internet/sockopt_freebsd.go | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/transport/internet/sockopt_darwin.go b/transport/internet/sockopt_darwin.go index da7eecb77..d3a6d0aa7 100644 --- a/transport/internet/sockopt_darwin.go +++ b/transport/internet/sockopt_darwin.go @@ -44,13 +44,13 @@ func applyOutboundSocketOptions(network string, address string, fd uintptr, conf if config.SocketTxBufSize != 0 { if err := unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_SNDBUF, int(config.SocketTxBufSize)); err != nil { - return newError("failed to set SO_SNDBUF/SO_SNDBUFFORCE").Base(err) + return newError("failed to set SO_SNDBUF").Base(err) } } if config.SocketRxBufSize != 0 { if err := unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_RCVBUF, int(config.SocketRxBufSize)); err != nil { - return newError("failed to set SO_RCVBUF/SO_RCVBUFFORCE").Base(err) + return newError("failed to set SO_RCVBUF").Base(err) } } diff --git a/transport/internet/sockopt_freebsd.go b/transport/internet/sockopt_freebsd.go index 275eedf72..cf5bb55aa 100644 --- a/transport/internet/sockopt_freebsd.go +++ b/transport/internet/sockopt_freebsd.go @@ -174,13 +174,13 @@ func applyOutboundSocketOptions(network string, address string, fd uintptr, conf if config.SocketTxBufSize != 0 { if err := unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_SNDBUF, int(config.SocketTxBufSize)); err != nil { - return newError("failed to set SO_SNDBUF/SO_SNDBUFFORCE").Base(err) + return newError("failed to set SO_SNDBUF").Base(err) } } if config.SocketRxBufSize != 0 { if err := unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_RCVBUF, int(config.SocketRxBufSize)); err != nil { - return newError("failed to set SO_RCVBUF/SO_RCVBUFFORCE").Base(err) + return newError("failed to set SO_RCVBUF").Base(err) } } @@ -231,13 +231,13 @@ func applyInboundSocketOptions(network string, fd uintptr, config *SocketConfig) if config.SocketTxBufSize != 0 { if err := unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_SNDBUF, int(config.SocketTxBufSize)); err != nil { - return newError("failed to set SO_SNDBUF/SO_SNDBUFFORCE").Base(err) + return newError("failed to set SO_SNDBUF").Base(err) } } if config.SocketRxBufSize != 0 { if err := unix.SetsockoptInt(int(fd), unix.SOL_SOCKET, unix.SO_RCVBUF, int(config.SocketRxBufSize)); err != nil { - return newError("failed to set SO_RCVBUF/SO_RCVBUFFORCE").Base(err) + return newError("failed to set SO_RCVBUF").Base(err) } }