Skip to content

Commit

Permalink
more log
Browse files Browse the repository at this point in the history
  • Loading branch information
Fangliding authored Jan 7, 2025
1 parent 824217c commit f60c5ee
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion common/mux/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -174,6 +174,7 @@ type ClientWorker struct {
link transport.Link
done *done.Instance
strategy ClientStrategy
timeCretaed time.Time
}

var (
Expand All @@ -188,6 +189,7 @@ func NewClientWorker(stream transport.Link, s ClientStrategy) (*ClientWorker, er
link: stream,
done: done.New(),
strategy: s,
timeCretaed: time.Now(),
}

go c.fetchOutput()
Expand Down Expand Up @@ -299,7 +301,7 @@ func (m *ClientWorker) Dispatch(ctx context.Context, link *transport.Link) bool
return false
}
errors.LogInfo(ctx, "allocated mux.cool subConnection ID: ", s.ID, "/", m.strategy.MaxReuseTimes)
errors.LogInfo(ctx, "living subConnections:", sm.Size() , "/", m.strategy.MaxConcurrency)
errors.LogInfo(ctx, "living subConnections:", m.ActiveConnections(), "/", m.strategy.MaxConcurrency, ", this mux connection has been created for ", time.Since(m.timeCretaed))
s.input = link.Reader
s.output = link.Writer
go fetchInput(ctx, s, m.link.Writer)
Expand Down

0 comments on commit f60c5ee

Please sign in to comment.