projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
20318: Route (*KeepClient)Get() through disk cache layer.
[arvados.git]
/
services
/
keepstore
/
pull_worker.go
diff --git
a/services/keepstore/pull_worker.go
b/services/keepstore/pull_worker.go
index b9194fe6f66b029d4262122aa384788f80eff4eb..348bfb4df00087a1726ef36cbd186fe0eb5ea4c7 100644
(file)
--- a/
services/keepstore/pull_worker.go
+++ b/
services/keepstore/pull_worker.go
@@
-59,7
+59,7
@@
func (h *handler) pullItemAndProcess(pullRequest PullRequest) error {
signedLocator := SignLocator(h.Cluster, pullRequest.Locator, keepClient.Arvados.ApiToken, time.Now().Add(time.Minute))
signedLocator := SignLocator(h.Cluster, pullRequest.Locator, keepClient.Arvados.ApiToken, time.Now().Add(time.Minute))
- reader,
contentLen
, _, err := GetContent(signedLocator, keepClient)
+ reader,
_
, _, err := GetContent(signedLocator, keepClient)
if err != nil {
return err
}
if err != nil {
return err
}
@@
-73,7
+73,7
@@
func (h *handler) pullItemAndProcess(pullRequest PullRequest) error {
return err
}
return err
}
- if
(readContent == nil) || (int64(len(readContent)) != contentLen)
{
+ if
readContent == nil
{
return fmt.Errorf("Content not found for: %s", signedLocator)
}
return fmt.Errorf("Content not found for: %s", signedLocator)
}