SagerNet/sing
1
0
Fork 0
mirror of https://github.com/SagerNet/sing.git synced 2025-04-04 20:37:40 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Improve buffered writer

Browse source
This commit is contained in:
世界 2023-02-07 14:17:19 +08:00
parent 3f1a1243a5
commit 27d2950cdb
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 31 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

31
common/bufio/buffer.go
View file

@ -3,6 +3,7 @@ package bufio
import (
"io"
"os"
"sync"
"github.com/sagernet/sing/common"
"github.com/sagernet/sing/common/buf"
@ -75,6 +76,7 @@ func (r *BufferedReader) Upstream() any {
type BufferedWriter struct {
upstream io.Writer
buffer *buf.Buffer
access sync.Mutex
}
func NewBufferedWriter(upstream io.Writer, buffer *buf.Buffer) *BufferedWriter {
@ -85,6 +87,11 @@ func NewBufferedWriter(upstream io.Writer, buffer *buf.Buffer) *BufferedWriter {
}
func (w *BufferedWriter) Write(p []byte) (n int, err error) {
w.access.Lock()
defer w.access.Unlock()
if w.buffer == nil {
return w.upstream.Write(p)
}
for {
var writeN int
writeN, err = w.buffer.Write(p[n:])
@ -100,6 +107,30 @@ func (w *BufferedWriter) Write(p []byte) (n int, err error) {
}
}
func (w *BufferedWriter) Fallthrough() error {
w.access.Lock()
defer w.access.Unlock()
if w.buffer == nil {
return nil
}
if !w.buffer.IsEmpty() {
_, err := w.upstream.Write(w.buffer.Bytes())
if err != nil {
return err
}
}
w.buffer.Release()
w.buffer = nil
return nil
}
func (w *BufferedWriter) ReadFrom(r io.Reader) (n int64, err error) {
if w.buffer == nil {
return Copy(w.upstream, r)
}
return CopyExtendedBuffer(NewExtendedWriter(w), NewExtendedReader(r), w.buffer)
}
func (w *BufferedWriter) WriterReplaceable() bool {
return w.buffer == nil
}