diff --git a/garnet/go/src/amber/source/source.go b/garnet/go/src/amber/source/source.go index e33bacb683c4b8a6ed001df3c523929dbc026282..83d95583036a6487f55ca4d1f4207c0c03eaf508 100644 --- a/garnet/go/src/amber/source/source.go +++ b/garnet/go/src/amber/source/source.go @@ -705,6 +705,7 @@ func (f *Source) FetchInto(blob string, length int64, outputDir string) error { Temporary() bool Timeout() bool }); ok && e.Temporary() && e.Timeout() { + log.Printf("timed out fetching %s", blob) f.closeIdleConnections() continue } @@ -712,6 +713,7 @@ func (f *Source) FetchInto(blob string, length int64, outputDir string) error { if err != nil { return err } + break } defer resp.Body.Close()