MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2024-12-24 22:25:54 -05:00
Code Issues Packages Projects Releases Wiki Activity

Add fs separator

Browse Source
This commit is contained in:
Harshavardhana 2015-10-17 12:01:19 -07:00
parent c2859c1f7d
commit 1256ca86d0
4 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
generic-handlers.go
View File

@ -131,9 +131,13 @@ func IgnoreResourcesHandler(h http.Handler) http.Handler {
return resourceHandler{h} return resourceHandler{h}
} }
const (
separator = "/"
)
// Resource handler ServeHTTP() wrapper // Resource handler ServeHTTP() wrapper
func (h resourceHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { func (h resourceHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
splits := strings.SplitN(r.URL.Path, "/", 3) splits := strings.SplitN(r.URL.Path, separator, 3)
switch len(splits) { switch len(splits) {
// bucket exists // bucket exists
case 2: case 2:

8
pkg/fs/fs-object.go
View File

@ -118,9 +118,9 @@ func getMetadata(rootPath, bucket, object string) (ObjectMetadata, *probe.Error)
// in a static manner so that we can send a proper 'ObjectNotFound' reply back upon os.Stat() // in a static manner so that we can send a proper 'ObjectNotFound' reply back upon os.Stat()
var objectPath string var objectPath string
if runtime.GOOS == "windows" { if runtime.GOOS == "windows" {
objectPath = rootPath + "\\" + bucket + "\\" + object objectPath = rootPath + string(os.PathSeparator) + bucket + string(os.PathSeparator) + object
} else { } else {
objectPath = rootPath + "/" + bucket + "/" + object objectPath = rootPath + string(os.PathSeparator) + bucket + string(os.PathSeparator) + object
} }
stat, err := os.Stat(objectPath) stat, err := os.Stat(objectPath)
if err != nil { if err != nil {
@ -275,9 +275,9 @@ func (fs API) DeleteObject(bucket, object string) *probe.Error {
// in a static manner so that we can send a proper 'ObjectNotFound' reply back upon os.Stat() // in a static manner so that we can send a proper 'ObjectNotFound' reply back upon os.Stat()
var objectPath string var objectPath string
if runtime.GOOS == "windows" { if runtime.GOOS == "windows" {
objectPath = fs.path + "\\" + bucket + "\\" + object objectPath = fs.path + string(os.PathSeparator) + bucket + string(os.PathSeparator) + object
} else { } else {
objectPath = fs.path + "/" + bucket + "/" + object objectPath = fs.path + string(os.PathSeparator) + bucket + string(os.PathSeparator) + object
} }
_, err := os.Stat(objectPath) _, err := os.Stat(objectPath)

10
pkg/fs/fs.go
View File

@ -260,7 +260,7 @@ func (fs API) ListObjects(bucket string, resources BucketResourcesMetadata) ([]O
/// automatically treat "/" delimiter as "\\" delimiter on windows due to its path constraints. /// automatically treat "/" delimiter as "\\" delimiter on windows due to its path constraints.
if resources.Delimiter == "/" { if resources.Delimiter == "/" {
if runtime.GOOS == "windows" { if runtime.GOOS == "windows" {
resources.Delimiter = "\\" resources.Delimiter = string(os.PathSeparator)
} }
} }
@ -344,11 +344,11 @@ func (fs API) ListObjects(bucket string, resources BucketResourcesMetadata) ([]O
// Split the root prefix from the incoming file pointer // Split the root prefix from the incoming file pointer
realFp := "" realFp := ""
if runtime.GOOS == "windows" { if runtime.GOOS == "windows" {
if splits := strings.Split(fp, p.root+"\\"); len(splits) > 1 { if splits := strings.Split(fp, (p.root + string(os.PathSeparator))); len(splits) > 1 {
realFp = splits[1] realFp = splits[1]
} }
} else { } else {
if splits := strings.Split(fp, p.root+"/"); len(splits) > 1 { if splits := strings.Split(fp, (p.root + string(os.PathSeparator))); len(splits) > 1 {
realFp = splits[1] realFp = splits[1]
} }
} }
@ -367,11 +367,11 @@ func (fs API) ListObjects(bucket string, resources BucketResourcesMetadata) ([]O
if resources.Marker != "" { if resources.Marker != "" {
if realFp != "" { if realFp != "" {
if runtime.GOOS == "windows" { if runtime.GOOS == "windows" {
if realFp < strings.Split(resources.Marker, "\\")[0] { if realFp < strings.Split(resources.Marker, string(os.PathSeparator))[0] {
return ErrSkipDir return ErrSkipDir
} }
} else { } else {
if realFp < strings.Split(resources.Marker, "/")[0] { if realFp < strings.Split(resources.Marker, string(os.PathSeparator))[0] {
return ErrSkipDir return ErrSkipDir
} }
} }

1
server_fs_test.go
View File

@ -489,7 +489,6 @@ func (s *MyAPIFSCacheSuite) TestNotImplemented(c *C) {
response, err := client.Do(request) response, err := client.Do(request)
c.Assert(err, IsNil) c.Assert(err, IsNil)
c.Assert(response.StatusCode, Equals, http.StatusNotImplemented) c.Assert(response.StatusCode, Equals, http.StatusNotImplemented)
} }
func (s *MyAPIFSCacheSuite) TestHeader(c *C) { func (s *MyAPIFSCacheSuite) TestHeader(c *C) {