projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
5824: Avoid sending empty slices through toRead chan. Fixes race in test case.
[arvados.git]
/
sdk
/
go
/
keepclient
/
keepclient_test.go
diff --git
a/sdk/go/keepclient/keepclient_test.go
b/sdk/go/keepclient/keepclient_test.go
index df4638619f488bc86dd3626cf2579a60fda62bed..4615ebc92ef2f8b59bc70ac1d8320833faee8a41 100644
(file)
--- a/
sdk/go/keepclient/keepclient_test.go
+++ b/
sdk/go/keepclient/keepclient_test.go
@@
-143,10
+143,9
@@
func (s *StandaloneSuite) TestUploadToStubKeepServer(c *C) {
make(chan string)}
UploadToStubHelper(c, st,
make(chan string)}
UploadToStubHelper(c, st,
- func(kc *KeepClient, url string, reader io.ReadCloser,
- writer io.WriteCloser, upload_status chan uploadStatus) {
+ func(kc *KeepClient, url string, reader io.ReadCloser, writer io.WriteCloser, upload_status chan uploadStatus) {
- go kc.uploadToKeepServer(url, st.expectPath, reader, upload_status, int64(len("foo")),
"TestUploadToStubKeepServer"
)
+ go kc.uploadToKeepServer(url, st.expectPath, reader, upload_status, int64(len("foo")),
0
)
writer.Write([]byte("foo"))
writer.Close()
writer.Write([]byte("foo"))
writer.Close()
@@
-178,7
+177,7
@@
func (s *StandaloneSuite) TestUploadToStubKeepServerBufferReader(c *C) {
br1 := tr.MakeStreamReader()
br1 := tr.MakeStreamReader()
- go kc.uploadToKeepServer(url, st.expectPath, br1, upload_status, 3,
"TestUploadToStubKeepServerBufferReader"
)
+ go kc.uploadToKeepServer(url, st.expectPath, br1, upload_status, 3,
0
)
writer.Write([]byte("foo"))
writer.Close()
writer.Write([]byte("foo"))
writer.Close()
@@
-238,7
+237,7
@@
func (s *StandaloneSuite) TestFailedUploadToStubKeepServer(c *C) {
func(kc *KeepClient, url string, reader io.ReadCloser,
writer io.WriteCloser, upload_status chan uploadStatus) {
func(kc *KeepClient, url string, reader io.ReadCloser,
writer io.WriteCloser, upload_status chan uploadStatus) {
- go kc.uploadToKeepServer(url, hash, reader, upload_status, 3,
"TestFailedUploadToStubKeepServer"
)
+ go kc.uploadToKeepServer(url, hash, reader, upload_status, 3,
0
)
writer.Write([]byte("foo"))
writer.Close()
writer.Write([]byte("foo"))
writer.Close()