mt-multiserver-proxy/listen.go

package proxy

import (
	"fmt"
	"net"
	"sync"

	"github.com/anon55555/mt"
)

type Listener struct {
	mt.Listener
	mu sync.RWMutex

	clts map[*ClientConn]struct{}
}

func Listen(pc net.PacketConn) *Listener {
	return &Listener{
		Listener: mt.Listen(pc),
		clts:     make(map[*ClientConn]struct{}),
	}
}

func (l *Listener) Clts() map[*ClientConn]struct{} {
	clts := make(map[*ClientConn]struct{})

	l.mu.RLock()
	defer l.mu.RUnlock()

	for cc := range l.clts {
		clts[cc] = struct{}{}
	}

	return clts
}

func (l *Listener) Accept() (*ClientConn, error) {
	p, err := l.Listener.Accept()
	if err != nil {
		return nil, err
	}

	cc := &ClientConn{
		Peer:   p,
		initCh: make(chan struct{}),
		modChs: make(map[string]struct{}),
	}

	l.mu.Lock()
	l.clts[cc] = struct{}{}
	l.mu.Unlock()

	go func() {
		<-cc.Closed()
		l.mu.Lock()
		defer l.mu.Unlock()

		delete(l.clts, cc)
	}()

	cc.Log("-->", "connect")
	go handleClt(cc)

	select {
	case <-cc.Closed():
		return nil, fmt.Errorf("%s is closed", cc.RemoteAddr())
	default:
	}

	return cc, nil
}