|
@@ -13,6 +13,32 @@ import (
|
|
func NewListenConfig(multi bool) net.ListenConfig {
|
|
func NewListenConfig(multi bool) net.ListenConfig {
|
|
return net.ListenConfig{
|
|
return net.ListenConfig{
|
|
Control: func(network, address string, c syscall.RawConn) error {
|
|
Control: func(network, address string, c syscall.RawConn) error {
|
|
|
|
+ var controlErr error
|
|
|
|
+ err := c.Control(func(fd uintptr) {
|
|
|
|
+ if err := syscall.SetsockoptInt(int(fd), syscall.SOL_SOCKET, syscall.SO_SNDBUF, 999999); err != nil {
|
|
|
|
+ controlErr = fmt.Errorf("SO_SNDBUF failed: %v", err)
|
|
|
|
+ return
|
|
|
|
+ }
|
|
|
|
+ })
|
|
|
|
+ if err != nil {
|
|
|
|
+ return err
|
|
|
|
+ }
|
|
|
|
+ if controlErr != nil {
|
|
|
|
+ return controlErr
|
|
|
|
+ }
|
|
|
|
+ err = c.Control(func(fd uintptr) {
|
|
|
|
+ if err := syscall.SetsockoptInt(int(fd), syscall.SOL_SOCKET, syscall.SO_RCVBUF, 999999); err != nil {
|
|
|
|
+ controlErr = fmt.Errorf("SO_RCVBUF failed: %v", err)
|
|
|
|
+ return
|
|
|
|
+ }
|
|
|
|
+ })
|
|
|
|
+ if err != nil {
|
|
|
|
+ return err
|
|
|
|
+ }
|
|
|
|
+ if controlErr != nil {
|
|
|
|
+ return controlErr
|
|
|
|
+ }
|
|
|
|
+
|
|
if multi {
|
|
if multi {
|
|
var controlErr error
|
|
var controlErr error
|
|
err := c.Control(func(fd uintptr) {
|
|
err := c.Control(func(fd uintptr) {
|