12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- package mux
- import (
- "errors"
- "github.com/xtaci/kcp-go"
- "net"
- "os"
- )
- func sysGetSock(fd *os.File) (bufferSize int, err error) {
-
-
-
-
- bufferSize = 5 * 1024 * 1024
- return
- }
- func getConnFd(c net.Conn) (fd *os.File, err error) {
- switch c.(type) {
- case *net.TCPConn:
-
-
-
-
- return
- case *net.UDPConn:
-
-
-
-
- return
- case *kcp.UDPSession:
-
-
-
-
-
- return
- default:
- err = errors.New("mux:unknown conn type, only tcp or kcp")
- return
- }
- }
|