aboutsummaryrefslogtreecommitdiff
path: root/weed-fs/src/pkg
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2012-09-26 13:38:45 -0700
committerChris Lu <chris.lu@gmail.com>2012-09-26 13:38:45 -0700
commita847e2beee7f518d8f8360b862fe3d7fdb10226e (patch)
tree219fb5bd73489ed2c2af48ec97a9d3b4e00b60ca /weed-fs/src/pkg
parent3d53f730062a4e4fc3f4cb3f693480431ed1b3af (diff)
downloadseaweedfs-a847e2beee7f518d8f8360b862fe3d7fdb10226e.tar.xz
seaweedfs-a847e2beee7f518d8f8360b862fe3d7fdb10226e.zip
better error reporting and handling
Diffstat (limited to 'weed-fs/src/pkg')
-rw-r--r--weed-fs/src/pkg/operation/delete_content.go2
-rw-r--r--weed-fs/src/pkg/operation/upload_content.go8
2 files changed, 6 insertions, 4 deletions
diff --git a/weed-fs/src/pkg/operation/delete_content.go b/weed-fs/src/pkg/operation/delete_content.go
index 66a61f55c..aeab9c3ac 100644
--- a/weed-fs/src/pkg/operation/delete_content.go
+++ b/weed-fs/src/pkg/operation/delete_content.go
@@ -2,11 +2,13 @@ package operation
import (
"net/http"
+ "log"
)
func Delete(url string) error {
req, err := http.NewRequest("DELETE", url, nil)
if err != nil {
+ log.Println("failing to delete", url)
return err
}
_, err = http.DefaultClient.Do(req)
diff --git a/weed-fs/src/pkg/operation/upload_content.go b/weed-fs/src/pkg/operation/upload_content.go
index ce2e5af68..652cbe71b 100644
--- a/weed-fs/src/pkg/operation/upload_content.go
+++ b/weed-fs/src/pkg/operation/upload_content.go
@@ -6,6 +6,7 @@ import (
_ "fmt"
"io"
"io/ioutil"
+ "log"
"mime/multipart"
"net/http"
)
@@ -23,7 +24,7 @@ func Upload(uploadUrl string, filename string, reader io.Reader) (*UploadResult,
body_writer.Close()
resp, err := http.Post(uploadUrl, content_type, body_buf)
if err != nil {
- println("uploading to", uploadUrl)
+ log.Println("failing to upload to", uploadUrl)
return nil, err
}
defer resp.Body.Close()
@@ -34,9 +35,8 @@ func Upload(uploadUrl string, filename string, reader io.Reader) (*UploadResult,
var ret UploadResult
err = json.Unmarshal(resp_body, &ret)
if err != nil {
- println("upload response to", uploadUrl, resp_body)
- panic(err.Error())
+ log.Println("failing to read upload resonse", uploadUrl, resp_body)
+ return nil, err
}
- //fmt.Println("Uploaded " + strconv.Itoa(ret.Size) + " Bytes to " + uploadUrl)
return &ret, nil
}