Skip to content

Commit

Permalink
simplify active request tracking
Browse files Browse the repository at this point in the history
No functional change expected.
  • Loading branch information
marten-seemann committed Aug 20, 2024
1 parent 0a64ee9 commit dfedf58
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions proxy.go
Original file line number Diff line number Diff line change
Expand Up @@ -90,27 +90,23 @@ func (s *Proxy) ProxyConnectedSocket(w http.ResponseWriter, _ *Request, conn *ne
s.mx.Unlock()

var wg sync.WaitGroup
s.refCount.Add(3)
wg.Add(3)
go func() {
defer wg.Done()
defer s.refCount.Done()
if err := s.proxyConnSend(conn, str); err != nil {
log.Printf("proxying send side to %s failed: %v", conn.RemoteAddr(), err)
}
str.Close()
}()
go func() {
defer wg.Done()
defer s.refCount.Done()
if err := s.proxyConnReceive(conn, str); err != nil && !s.closed.Load() {
log.Printf("proxying receive side to %s failed: %v", conn.RemoteAddr(), err)
}
str.Close()
}()
go func() {
defer wg.Done()
defer s.refCount.Done()
// discard all capsules sent on the request stream
if err := skipCapsules(quicvarint.NewReader(str)); err == io.EOF {
log.Printf("reading from request stream failed: %v", err)
Expand Down

0 comments on commit dfedf58

Please sign in to comment.