perf(proxy): reuse miner send buffer for writes
Co-Authored-By: Virgil <virgil@lethean.io>
This commit is contained in:
parent
5680539dbb
commit
d1a899805e
1 changed files with 8 additions and 2 deletions
|
|
@ -1277,8 +1277,14 @@ func (m *Miner) writeJSON(payload any) error {
|
|||
return err
|
||||
}
|
||||
data = append(data, '\n')
|
||||
n, err := m.conn.Write(data)
|
||||
m.tx += uint64(n)
|
||||
var written int
|
||||
if len(data) <= len(m.buf) {
|
||||
copy(m.buf[:], data)
|
||||
written, err = m.conn.Write(m.buf[:len(data)])
|
||||
} else {
|
||||
written, err = m.conn.Write(data)
|
||||
}
|
||||
m.tx += uint64(written)
|
||||
if err != nil {
|
||||
m.Close()
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue