mirror of
https://github.com/ipfs/kubo.git
synced 2025-07-02 12:20:03 +08:00
ctxio: fix buffer of 1 so goroutine exits when io completes.
This commit is contained in:
@ -45,7 +45,7 @@ func (w *ctxWriter) Write(buf []byte) (int, error) {
|
|||||||
buf2 := make([]byte, len(buf))
|
buf2 := make([]byte, len(buf))
|
||||||
copy(buf2, buf)
|
copy(buf2, buf)
|
||||||
|
|
||||||
c := make(chan ioret)
|
c := make(chan ioret, 1)
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
n, err := w.w.Write(buf2)
|
n, err := w.w.Write(buf2)
|
||||||
@ -92,7 +92,7 @@ func NewReader(ctx context.Context, r io.Reader) *ctxReader {
|
|||||||
func (r *ctxReader) Read(buf []byte) (int, error) {
|
func (r *ctxReader) Read(buf []byte) (int, error) {
|
||||||
buf2 := make([]byte, len(buf))
|
buf2 := make([]byte, len(buf))
|
||||||
|
|
||||||
c := make(chan ioret)
|
c := make(chan ioret, 1)
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
n, err := r.r.Read(buf2)
|
n, err := r.r.Read(buf2)
|
||||||
|
Reference in New Issue
Block a user