aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-07-27 02:26:43 -0700
committerChris Lu <chris.lu@gmail.com>2018-07-27 02:26:43 -0700
commitf82ac793b4db7dfcca3d69a5a9c7d0bb3e20d9ac (patch)
treef8168c1f66b819040737dc4fa5e2c893bea85a40
parent0d989491993a98753bf34569f74791c87cecb900 (diff)
parent10bb76fe6b7351b3131ae56d2faea34b03bf52af (diff)
downloadseaweedfs-f82ac793b4db7dfcca3d69a5a9c7d0bb3e20d9ac.tar.xz
seaweedfs-f82ac793b4db7dfcca3d69a5a9c7d0bb3e20d9ac.zip
Merge branch 'master' into add_topo_listener
-rw-r--r--weed/storage/needle.go4
-rw-r--r--weed/storage/needle_map_metric.go2
-rw-r--r--weed/storage/needle_parse_multipart.go7
3 files changed, 7 insertions, 6 deletions
diff --git a/weed/storage/needle.go b/weed/storage/needle.go
index f67556c72..ce6130711 100644
--- a/weed/storage/needle.go
+++ b/weed/storage/needle.go
@@ -59,10 +59,8 @@ func ParseUpload(r *http.Request) (
}
}
- isChunkedFile, _ = strconv.ParseBool(r.FormValue("cm"))
-
if r.Method == "POST" {
- fileName, data, mimeType, isGzipped, e = parseMultipart(r, isChunkedFile)
+ fileName, data, mimeType, isGzipped, isChunkedFile, e = parseMultipart(r)
} else {
isGzipped = false
mimeType = r.Header.Get("Content-Type")
diff --git a/weed/storage/needle_map_metric.go b/weed/storage/needle_map_metric.go
index 67b41f5a7..cc3d9e028 100644
--- a/weed/storage/needle_map_metric.go
+++ b/weed/storage/needle_map_metric.go
@@ -109,7 +109,7 @@ func reverseWalkIndexFile(r *os.File, initFn func(entryCount int64), fn func(key
return e
}
for i := int(nextBatchSize) - 1; i >= 0; i-- {
- key, offset, size := IdxFileEntry(bytes[i*NeedleEntrySize:i*NeedleEntrySize+NeedleEntrySize])
+ key, offset, size := IdxFileEntry(bytes[i*NeedleEntrySize : i*NeedleEntrySize+NeedleEntrySize])
if e = fn(key, offset, size); e != nil {
return e
}
diff --git a/weed/storage/needle_parse_multipart.go b/weed/storage/needle_parse_multipart.go
index af12b994d..d42bc4629 100644
--- a/weed/storage/needle_parse_multipart.go
+++ b/weed/storage/needle_parse_multipart.go
@@ -7,11 +7,12 @@ import (
"mime"
"net/http"
"path"
+ "strconv"
"strings"
)
-func parseMultipart(r *http.Request, isChunkedFile bool) (
- fileName string, data []byte, mimeType string, isGzipped bool, e error) {
+func parseMultipart(r *http.Request) (
+ fileName string, data []byte, mimeType string, isGzipped, isChunkedFile bool, e error) {
form, fe := r.MultipartReader()
if fe != nil {
glog.V(0).Infoln("MultipartReader [ERROR]", fe)
@@ -63,6 +64,8 @@ func parseMultipart(r *http.Request, isChunkedFile bool) (
}
}
+ isChunkedFile, _ = strconv.ParseBool(r.FormValue("cm"))
+
if !isChunkedFile {
dotIndex := strings.LastIndex(fileName, ".")