func NewMutexQueue() *MutexQueue {
	return &MutexQueue{
		muList: list.New(),
	}
}
MutexQueue implements mutex queue with FIFO support
package transport
import (
	"container/list"
	"net"
	"os"
	"strconv"
	"strings"
	"sync"
	"syscall"
	"github.com/patrickmn/go-cache"
	"gopkg.in/alexcesaro/statsd.v2"
	"github.com/Lookyan/netramesh/internal/config"
	"github.com/Lookyan/netramesh/pkg/estabcache"
	"github.com/Lookyan/netramesh/pkg/log"
	"github.com/Lookyan/netramesh/pkg/protocol"
)
const SO_ORIGINAL_DST = 80
var addrPool = &sync.Pool{
	New: func() interface{} {
		return make([]byte, 0, 20)
	},
}
func TcpCopyRequest(
	logger *log.Logger,
	r *net.TCPConn,
	w *net.TCPConn,
	connCh chan *net.TCPConn,
	netRequest protocol.NetRequest,
	netHandler protocol.NetHandler,
	isInBoundConn bool,
	f *os.File,
	addrCh chan string,
	originalDst string,
) {
	w = netHandler.HandleRequest(r, w, connCh, addrCh, netRequest, isInBoundConn, originalDst)
	f.Close()
	closeConn(logger, r)
	if w != nil {
		closeConn(logger, w)
	}
}
func TcpCopyResponse(
	logger *log.Logger,
	r *net.TCPConn,
	w *net.TCPConn,
	netRequest protocol.NetRequest,
	netHandler protocol.NetHandler,
	isInBoundConn bool,
	f *os.File,
) {
	netHandler.HandleResponse(r, w, netRequest, isInBoundConn, false)
	f.Close()
	closeConn(logger, r)
	closeConn(logger, w)
}
func HandleConnection(
	logger *log.Logger,
	conn *net.TCPConn,
	ec *estabcache.EstablishedCache,
	tracingContextMapping *cache.Cache,
	routingInfoContextMapping *cache.Cache,
	statsdMetrics *statsd.Client,
) {
	if conn == nil {
		return
	}
	f, err := conn.File()
	if err != nil {
		closeConn(logger, conn)
		logger.Debug("Closed src conn")
		return
	}
	err = syscall.SetNonblock(int(f.Fd()), true)
	if err != nil {
		logger.Debug("Can't turn fd into non-blocking mode")
	}
	addr, err := syscall.GetsockoptIPv6Mreq(int(f.Fd()), syscall.IPPROTO_IP, SO_ORIGINAL_DST)
	if err != nil {
		f.Close()
		closeConn(logger, conn)
		return
	}
	ipBuilder := addrPool.Get().([]byte)
	ipBuilder = append(ipBuilder, strconv.Itoa(int(addr.Multiaddr[4]))...)
	ipBuilder = append(ipBuilder, '.')
	ipBuilder = append(ipBuilder, strconv.Itoa(int(addr.Multiaddr[5]))...)
	ipBuilder = append(ipBuilder, '.')
	ipBuilder = append(ipBuilder, strconv.Itoa(int(addr.Multiaddr[6]))...)
	ipBuilder = append(ipBuilder, '.')
	ipBuilder = append(ipBuilder, strconv.Itoa(int(addr.Multiaddr[7]))...)
	ipv4 := string(ipBuilder)
	ipBuilder = ipBuilder[:0]
	addrPool.Put(ipBuilder)
	port := uint16(addr.Multiaddr[2])<<8 + uint16(addr.Multiaddr[3])
	isInBoundConn := ipv4 == strings.Split(conn.LocalAddr().String(), ":")[0]
	dstAddrBuilder := addrPool.Get().([]byte)
	dstAddrBuilder = append(dstAddrBuilder, ipv4...)
	dstAddrBuilder = append(dstAddrBuilder, ':')
	dstAddrBuilder = append(dstAddrBuilder, strconv.Itoa(int(port))...)
	originalDstAddr := string(dstAddrBuilder)
	dstAddrBuilder = dstAddrBuilder[:0]
	addrPool.Put(dstAddrBuilder)
	p := protocol.Determine(originalDstAddr)
	netRequest := protocol.GetNetRequest(p, isInBoundConn, logger, tracingContextMapping, statsdMetrics)
	netHandler := protocol.GetNetworkHandler(p, logger, tracingContextMapping)
	if config.GetHTTPConfig().RoutingEnabled {
		addrCh := make(chan string)
		connCh := make(chan *net.TCPConn)
		go TcpCopyRequest(
			logger,
			conn,
			nil,
			connCh,
			netRequest,
			netHandler,
			isInBoundConn,
			f,
			addrCh,
			originalDstAddr)
		defer netRequest.CleanUp()
		callCh := make(chan func(), 10)
		wg := sync.WaitGroup{}
		go func() {
			for f := range callCh {
				f()
				wg.Done()
			}
		}()
		for {
			dstAddr := <-addrCh
			if dstAddr == "" {
				f.Close()
				closeConn(logger, conn)
				close(connCh)
				close(callCh)
				return
			}
			tcpDstAddr, err := net.ResolveTCPAddr("tcp", dstAddr)
			if err != nil {
				logger.Warningf("Error while resolving tcp addr %s", originalDstAddr)
				connCh <- nil
				f.Close()
				closeConn(logger, conn)
				close(connCh)
				close(callCh)
				return
			}
			targetConn, err := net.DialTCP("tcp", nil, tcpDstAddr)
			if err != nil {
				logger.Warning(err.Error())
				connCh <- nil
				f.Close()
				closeConn(logger, conn)
				close(connCh)
				close(callCh)
				return
			}
			connCh <- targetConn
			respRoutine := func() {
				netHandler.HandleResponse(targetConn, conn, netRequest, isInBoundConn, true)
				closeConn(logger, targetConn)
			}
			wg.Add(1)
			callCh <- respRoutine
		}
		wg.Wait()
		close(callCh)
	} else {
		tcpDstAddr, err := net.ResolveTCPAddr("tcp", originalDstAddr)
		if err != nil {
			logger.Warningf("Error while resolving tcp addr %s", originalDstAddr)
			f.Close()
			closeConn(logger, conn)
			return
		}
		targetConn, err := net.DialTCP("tcp", nil, tcpDstAddr)
		if err != nil {
			logger.Warning(err.Error())
			f.Close()
			closeConn(logger, conn)
			return
		}
		go TcpCopyRequest(
			logger,
			conn,
			targetConn,
			nil,
			netRequest,
			netHandler,
			isInBoundConn,
			f,
			nil,
			originalDstAddr)
		go TcpCopyResponse(logger, targetConn, conn, netRequest, netHandler, isInBoundConn, f)
	}
}
func closeConn(logger *log.Logger, conn *net.TCPConn) {
	logger.Debug("Closing conn")
	conn.CloseRead()
	conn.CloseWrite()
	conn.Close()
	logger.Debug("Closed conn")
}
type MutexQueue struct {
	muList *list.List
	mu     sync.Mutex
}