| commit | 3c4ce9170b6c5a5d64bcc4feecc5bcdf5dd1f101 | [log] [tgz] |
|---|---|---|
| author | Takuto Ikuta <tikuta@google.com> | Fri Jul 16 14:33:32 2021 +0900 |
| committer | GitHub <noreply@github.com> | Fri Jul 16 14:33:32 2021 +0900 |
| tree | 5397c30a605391be5e5a9e4df3077c9abeaec563 | |
| parent | d965bf95d0af9d88d90e9723aee6b332dc3ef93e [diff] |
allow to use streamBufSize larger than 32KiB (#369)
diff --git a/go/pkg/cas/client.go b/go/pkg/cas/client.go index 19d136b..1a8615f 100644 --- a/go/pkg/cas/client.go +++ b/go/pkg/cas/client.go
@@ -276,7 +276,7 @@ } streamBufSize := 32 * 1024 // by default, send 32KiB chunks. - if streamBufSize > c.Config.ByteStreamWrite.MaxSizeBytes { + if streamBufSize < c.Config.ByteStreamWrite.MaxSizeBytes { streamBufSize = int(c.Config.ByteStreamWrite.MaxSizeBytes) } c.streamBufs.New = func() interface{} {