mirror of
https://git.sr.ht/~emersion/tlstunnel
synced 2024-11-19 15:53:50 +01:00
Revert "readme: fix issue tracker link"
This reverts commit 30dc7be08e8afa7a33da3a8228377755ae96d34a. This commit contains WIP changes committed by mistake.
This commit is contained in:
parent
26d1574702
commit
64285842fe
18
server.go
18
server.go
@ -15,10 +15,6 @@ import (
|
|||||||
"github.com/pires/go-proxyproto/tlvparse"
|
"github.com/pires/go-proxyproto/tlvparse"
|
||||||
)
|
)
|
||||||
|
|
||||||
type conn struct {
|
|
||||||
downstream, upstream net.Conn
|
|
||||||
}
|
|
||||||
|
|
||||||
type Server struct {
|
type Server struct {
|
||||||
Listeners map[string]*Listener // indexed by listening address
|
Listeners map[string]*Listener // indexed by listening address
|
||||||
Frontends []*Frontend
|
Frontends []*Frontend
|
||||||
@ -28,8 +24,6 @@ type Server struct {
|
|||||||
|
|
||||||
ACMEManager *certmagic.ACMEManager
|
ACMEManager *certmagic.ACMEManager
|
||||||
ACMEConfig *certmagic.Config
|
ACMEConfig *certmagic.Config
|
||||||
|
|
||||||
conns map[*conn]struct{}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewServer() *Server {
|
func NewServer() *Server {
|
||||||
@ -82,16 +76,10 @@ func (srv *Server) Start() error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (srv *Server) Close() error {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
type Listener struct {
|
type Listener struct {
|
||||||
Address string
|
Address string
|
||||||
Server *Server
|
Server *Server
|
||||||
Frontends map[string]*Frontend // indexed by server name
|
Frontends map[string]*Frontend // indexed by server name
|
||||||
|
|
||||||
ln net.Listener
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func newListener(srv *Server, addr string) *Listener {
|
func newListener(srv *Server, addr string) *Listener {
|
||||||
@ -117,8 +105,6 @@ func (ln *Listener) Start() error {
|
|||||||
}
|
}
|
||||||
log.Printf("listening on %q", ln.Address)
|
log.Printf("listening on %q", ln.Address)
|
||||||
|
|
||||||
ln.ln = netLn
|
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
if err := ln.serve(netLn); err != nil {
|
if err := ln.serve(netLn); err != nil {
|
||||||
log.Fatalf("listener %q: %v", ln.Address, err)
|
log.Fatalf("listener %q: %v", ln.Address, err)
|
||||||
@ -128,10 +114,6 @@ func (ln *Listener) Start() error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (ln *Listener) Close() error {
|
|
||||||
return ln.ln.Close()
|
|
||||||
}
|
|
||||||
|
|
||||||
func (ln *Listener) serve(netLn net.Listener) error {
|
func (ln *Listener) serve(netLn net.Listener) error {
|
||||||
for {
|
for {
|
||||||
conn, err := netLn.Accept()
|
conn, err := netLn.Accept()
|
||||||
|
Loading…
Reference in New Issue
Block a user