Tryanks/gousb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add info about concurrency safety for stream.

Browse Source
This commit is contained in:
Sebastian Zagrodzki
2017-04-26 22:49:37 +02:00
parent 6c9e76f578
commit 76f4548b85
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
usb/transfer_stream.go
View File

@@ -59,6 +59,7 @@ type ReadStream struct {
// might be smaller than the length of p. // might be smaller than the length of p.
// After a non-nil error is returned, all subsequent attempts to read will // After a non-nil error is returned, all subsequent attempts to read will
// return io.ErrClosedPipe. // return io.ErrClosedPipe.
// Read cannot be called concurrently with other Read or Close.
func (r ReadStream) Read(p []byte) (int, error) { func (r ReadStream) Read(p []byte) (int, error) {
s := r.s s := r.s
if s.transfers == nil { if s.transfers == nil {
@@ -117,6 +118,7 @@ func (r ReadStream) Read(p []byte) (int, error) {
// subsequent Read()s will return data from all transfers that were already // subsequent Read()s will return data from all transfers that were already
// in progress before returning an io.EOF error, unless another error // in progress before returning an io.EOF error, unless another error
// was encountered earlier. // was encountered earlier.
// Close cannot be called concurrently with Read.
func (r ReadStream) Close() { func (r ReadStream) Close() {
r.s.setDelayedErr(io.EOF) r.s.setDelayedErr(io.EOF)
} }