mirror of
https://github.com/minio/minio.git
synced 2025-01-12 07:23:23 -05:00
Merge pull request #1034 from harshavardhana/handle-cgo
build: Handle builds on env where CGO_ENABLED=0
This commit is contained in:
commit
8ff43086fb
18
.travis.yml
18
.travis.yml
@ -1,10 +1,24 @@
|
|||||||
|
sudo: false
|
||||||
language: go
|
language: go
|
||||||
|
|
||||||
|
os:
|
||||||
|
- linux
|
||||||
|
- osx
|
||||||
|
|
||||||
|
osx_image: xcode7.2
|
||||||
|
|
||||||
|
env:
|
||||||
|
- ARCH=x86_64
|
||||||
|
- ARCH=i686
|
||||||
|
|
||||||
script:
|
script:
|
||||||
- make test
|
- make test
|
||||||
- make test GOFLAGS="-race"
|
- make test GOFLAGS="-race"
|
||||||
sudo: false
|
|
||||||
go:
|
go:
|
||||||
- 1.5.1
|
- 1.5.2
|
||||||
|
- 1.5.3
|
||||||
|
|
||||||
notifications:
|
notifications:
|
||||||
slack:
|
slack:
|
||||||
secure: K9tsn5MvrCAxuEZTxn+m3Kq1K2NG2xMEJFSv/sTp+RQBW7TslPHzv859GsIvrm8mU1y1btOU9RlOzqrRUczI5cJpE8IL1oljPZbXrIXgetE0kbsw0Wpy99g27UQ2VGp933WDu8tfj7zU4cZv+BI0RltNLwqYO6GWXmcWP0IueCU=
|
secure: K9tsn5MvrCAxuEZTxn+m3Kq1K2NG2xMEJFSv/sTp+RQBW7TslPHzv859GsIvrm8mU1y1btOU9RlOzqrRUczI5cJpE8IL1oljPZbXrIXgetE0kbsw0Wpy99g27UQ2VGp933WDu8tfj7zU4cZv+BI0RltNLwqYO6GWXmcWP0IueCU=
|
||||||
|
20
vendor.json
20
vendor.json
@ -1,20 +0,0 @@
|
|||||||
{
|
|
||||||
"comment": "",
|
|
||||||
"ignore": "",
|
|
||||||
"package": [
|
|
||||||
{
|
|
||||||
"canonical": "github.com/minio/minio-xl/pkg/atomic",
|
|
||||||
"comment": "",
|
|
||||||
"local": "vendor/github.com/minio/minio-xl/pkg/atomic",
|
|
||||||
"revision": "a32fbc1006b4a09176c91f57d22e87faff22a423",
|
|
||||||
"revisionTime": "2015-11-17T22:59:41-08:00"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"canonical": "github.com/minio/minio-xl/pkg/quick",
|
|
||||||
"comment": "",
|
|
||||||
"local": "vendor/github.com/minio/minio-xl/pkg/quick",
|
|
||||||
"revision": "a32fbc1006b4a09176c91f57d22e87faff22a423",
|
|
||||||
"revisionTime": "2015-11-17T22:59:41-08:00"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
@ -1,3 +1,6 @@
|
|||||||
|
// +build 386 amd64 arm
|
||||||
|
// +build darwin
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
||||||
*
|
*
|
@ -1,3 +1,5 @@
|
|||||||
|
// +build 386 arm amd64,!cgo
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Minio Cloud Storage, (C) 2015 Minio, Inc.
|
* Minio Cloud Storage, (C) 2015 Minio, Inc.
|
||||||
*
|
*
|
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256_linux_amd64.go
generated
vendored
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256_linux_amd64.go
generated
vendored
@ -1,3 +1,5 @@
|
|||||||
|
// +build amd64,cgo
|
||||||
|
|
||||||
// Copyright 2009 The Go Authors. All rights reserved.
|
// Copyright 2009 The Go Authors. All rights reserved.
|
||||||
// Use of this source code is governed by a BSD-style
|
// Use of this source code is governed by a BSD-style
|
||||||
// license that can be found in the LICENSE file of
|
// license that can be found in the LICENSE file of
|
||||||
|
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256_linux_amd64_test.go
generated
vendored
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256_linux_amd64_test.go
generated
vendored
@ -1,3 +1,5 @@
|
|||||||
|
// +build amd64,cgo
|
||||||
|
|
||||||
// Copyright 2009 The Go Authors. All rights reserved.
|
// Copyright 2009 The Go Authors. All rights reserved.
|
||||||
// Use of this source code is governed by a BSD-style
|
// Use of this source code is governed by a BSD-style
|
||||||
// license that can be found in the LICENSE file of
|
// license that can be found in the LICENSE file of
|
||||||
|
53
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256_linux_arm.go
generated
vendored
53
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256_linux_arm.go
generated
vendored
@ -1,53 +0,0 @@
|
|||||||
/*
|
|
||||||
* Minio Cloud Storage, (C) 2015 Minio, Inc.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package sha256
|
|
||||||
|
|
||||||
import (
|
|
||||||
"hash"
|
|
||||||
"io"
|
|
||||||
|
|
||||||
"crypto/sha256"
|
|
||||||
)
|
|
||||||
|
|
||||||
// Sum256 - single caller sha256 helper
|
|
||||||
func Sum256(data []byte) []byte {
|
|
||||||
d := sha256.New()
|
|
||||||
d.Write(data)
|
|
||||||
return d.Sum(nil)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Sum - io.Reader based streaming sha256 helper
|
|
||||||
func Sum(reader io.Reader) ([]byte, error) {
|
|
||||||
d := sha256.New()
|
|
||||||
var err error
|
|
||||||
for err == nil {
|
|
||||||
length := 0
|
|
||||||
byteBuffer := make([]byte, 1024*1024)
|
|
||||||
length, err = reader.Read(byteBuffer)
|
|
||||||
byteBuffer = byteBuffer[0:length]
|
|
||||||
d.Write(byteBuffer)
|
|
||||||
}
|
|
||||||
if err != io.EOF {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return d.Sum(nil), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// New returns a new hash.Hash computing SHA256.
|
|
||||||
func New() hash.Hash {
|
|
||||||
return sha256.New()
|
|
||||||
}
|
|
@ -1,3 +1,6 @@
|
|||||||
|
// +build 386 amd64 arm
|
||||||
|
// +build windows
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
||||||
*
|
*
|
53
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256_windows_amd64.go
generated
vendored
53
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256_windows_amd64.go
generated
vendored
@ -1,53 +0,0 @@
|
|||||||
/*
|
|
||||||
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package sha256
|
|
||||||
|
|
||||||
import (
|
|
||||||
"hash"
|
|
||||||
"io"
|
|
||||||
|
|
||||||
"crypto/sha256"
|
|
||||||
)
|
|
||||||
|
|
||||||
// Sum256 - single caller sha256 helper
|
|
||||||
func Sum256(data []byte) []byte {
|
|
||||||
d := sha256.New()
|
|
||||||
d.Write(data)
|
|
||||||
return d.Sum(nil)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Sum - io.Reader based streaming sha256 helper
|
|
||||||
func Sum(reader io.Reader) ([]byte, error) {
|
|
||||||
d := sha256.New()
|
|
||||||
var err error
|
|
||||||
for err == nil {
|
|
||||||
length := 0
|
|
||||||
byteBuffer := make([]byte, 1024*1024)
|
|
||||||
length, err = reader.Read(byteBuffer)
|
|
||||||
byteBuffer = byteBuffer[0:length]
|
|
||||||
d.Write(byteBuffer)
|
|
||||||
}
|
|
||||||
if err != io.EOF {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return d.Sum(nil), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// New returns a new hash.Hash computing SHA256.
|
|
||||||
func New() hash.Hash {
|
|
||||||
return sha256.New()
|
|
||||||
}
|
|
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256block_linux_amd64.go
generated
vendored
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha256/sha256block_linux_amd64.go
generated
vendored
@ -1,4 +1,4 @@
|
|||||||
// +build amd64
|
// +build amd64,cgo
|
||||||
|
|
||||||
//
|
//
|
||||||
// Minio Cloud Storage, (C) 2015 Minio, Inc.
|
// Minio Cloud Storage, (C) 2015 Minio, Inc.
|
||||||
|
@ -1,3 +1,6 @@
|
|||||||
|
// +build 386 amd64 arm
|
||||||
|
// +build darwin
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
||||||
*
|
*
|
58
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512_darwin_amd64.go
generated
vendored
58
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512_darwin_amd64.go
generated
vendored
@ -1,58 +0,0 @@
|
|||||||
/*
|
|
||||||
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package sha512
|
|
||||||
|
|
||||||
import (
|
|
||||||
"hash"
|
|
||||||
"io"
|
|
||||||
|
|
||||||
"crypto/sha512"
|
|
||||||
)
|
|
||||||
|
|
||||||
// The size of a SHA512 checksum in bytes.
|
|
||||||
const (
|
|
||||||
Size = sha512.Size
|
|
||||||
)
|
|
||||||
|
|
||||||
// Sum512 - single caller sha512 helper
|
|
||||||
func Sum512(data []byte) []byte {
|
|
||||||
d := sha512.New()
|
|
||||||
d.Write(data)
|
|
||||||
return d.Sum(nil)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Sum - io.Reader based streaming sha512 helper
|
|
||||||
func Sum(reader io.Reader) ([]byte, error) {
|
|
||||||
d := sha512.New()
|
|
||||||
var err error
|
|
||||||
for err == nil {
|
|
||||||
length := 0
|
|
||||||
byteBuffer := make([]byte, 1024*1024)
|
|
||||||
length, err = reader.Read(byteBuffer)
|
|
||||||
byteBuffer = byteBuffer[0:length]
|
|
||||||
d.Write(byteBuffer)
|
|
||||||
}
|
|
||||||
if err != io.EOF {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return d.Sum(nil), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// New returns a new hash.Hash computing SHA512.
|
|
||||||
func New() hash.Hash {
|
|
||||||
return sha512.New()
|
|
||||||
}
|
|
@ -1,3 +1,5 @@
|
|||||||
|
// +build 386 arm amd64,!cgo
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
||||||
*
|
*
|
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512_linux_amd64.go
generated
vendored
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512_linux_amd64.go
generated
vendored
@ -1,3 +1,5 @@
|
|||||||
|
// +build amd64,cgo
|
||||||
|
|
||||||
// Copyright 2009 The Go Authors. All rights reserved.
|
// Copyright 2009 The Go Authors. All rights reserved.
|
||||||
// Use of this source code is governed by a BSD-style
|
// Use of this source code is governed by a BSD-style
|
||||||
// license that can be found in the LICENSE file of
|
// license that can be found in the LICENSE file of
|
||||||
|
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512_linux_amd64_test.go
generated
vendored
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512_linux_amd64_test.go
generated
vendored
@ -1,3 +1,5 @@
|
|||||||
|
// +build amd64,cgo
|
||||||
|
|
||||||
// Copyright 2009 The Go Authors. All rights reserved.
|
// Copyright 2009 The Go Authors. All rights reserved.
|
||||||
// Use of this source code is governed by a BSD-style
|
// Use of this source code is governed by a BSD-style
|
||||||
// license that can be found in the LICENSE file of
|
// license that can be found in the LICENSE file of
|
||||||
|
@ -1,3 +1,6 @@
|
|||||||
|
// +build 386 amd64 arm
|
||||||
|
// +build windows
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
||||||
*
|
*
|
58
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512_windows_amd64.go
generated
vendored
58
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512_windows_amd64.go
generated
vendored
@ -1,58 +0,0 @@
|
|||||||
/*
|
|
||||||
* Minio Cloud Storage, (C) 2014 Minio, Inc.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package sha512
|
|
||||||
|
|
||||||
import (
|
|
||||||
"hash"
|
|
||||||
"io"
|
|
||||||
|
|
||||||
"crypto/sha512"
|
|
||||||
)
|
|
||||||
|
|
||||||
// The size of a SHA512 checksum in bytes.
|
|
||||||
const (
|
|
||||||
Size = sha512.Size
|
|
||||||
)
|
|
||||||
|
|
||||||
// Sum512 - single caller sha512 helper
|
|
||||||
func Sum512(data []byte) []byte {
|
|
||||||
d := sha512.New()
|
|
||||||
d.Write(data)
|
|
||||||
return d.Sum(nil)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Sum - io.Reader based streaming sha512 helper
|
|
||||||
func Sum(reader io.Reader) ([]byte, error) {
|
|
||||||
d := sha512.New()
|
|
||||||
var err error
|
|
||||||
for err == nil {
|
|
||||||
length := 0
|
|
||||||
byteBuffer := make([]byte, 1024*1024)
|
|
||||||
length, err = reader.Read(byteBuffer)
|
|
||||||
byteBuffer = byteBuffer[0:length]
|
|
||||||
d.Write(byteBuffer)
|
|
||||||
}
|
|
||||||
if err != io.EOF {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return d.Sum(nil), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// New returns a new hash.Hash computing SHA512.
|
|
||||||
func New() hash.Hash {
|
|
||||||
return sha512.New()
|
|
||||||
}
|
|
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512block_linux_amd64.go
generated
vendored
2
vendor/github.com/minio/minio-xl/pkg/crypto/sha512/sha512block_linux_amd64.go
generated
vendored
@ -1,4 +1,4 @@
|
|||||||
// +build amd64
|
// +build amd64,cgo
|
||||||
|
|
||||||
//
|
//
|
||||||
// Minio Cloud Storage, (C) 2015 Minio, Inc.
|
// Minio Cloud Storage, (C) 2015 Minio, Inc.
|
||||||
|
149
vendor/github.com/minio/minio-xl/pkg/quick/quick.go
generated
vendored
149
vendor/github.com/minio/minio-xl/pkg/quick/quick.go
generated
vendored
@ -72,8 +72,7 @@ func CheckData(data interface{}) *probe.Error {
|
|||||||
|
|
||||||
// New - instantiate a new config
|
// New - instantiate a new config
|
||||||
func New(data interface{}) (Config, *probe.Error) {
|
func New(data interface{}) (Config, *probe.Error) {
|
||||||
err := CheckData(data)
|
if err := CheckData(data); err != nil {
|
||||||
if err != nil {
|
|
||||||
return nil, err.Trace()
|
return nil, err.Trace()
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -86,14 +85,14 @@ func New(data interface{}) (Config, *probe.Error) {
|
|||||||
// CheckVersion - loads json and compares the version number provided returns back true or false - any failure
|
// CheckVersion - loads json and compares the version number provided returns back true or false - any failure
|
||||||
// is returned as error.
|
// is returned as error.
|
||||||
func CheckVersion(filename string, version string) (bool, *probe.Error) {
|
func CheckVersion(filename string, version string) (bool, *probe.Error) {
|
||||||
_, err := os.Stat(filename)
|
_, e := os.Stat(filename)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
return false, probe.NewError(err)
|
return false, probe.NewError(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
fileData, err := ioutil.ReadFile(filename)
|
fileData, e := ioutil.ReadFile(filename)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
return false, probe.NewError(err)
|
return false, probe.NewError(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
if runtime.GOOS == "windows" {
|
if runtime.GOOS == "windows" {
|
||||||
@ -104,18 +103,18 @@ func CheckVersion(filename string, version string) (bool, *probe.Error) {
|
|||||||
}{
|
}{
|
||||||
Version: "",
|
Version: "",
|
||||||
}
|
}
|
||||||
err = json.Unmarshal(fileData, &data)
|
e = json.Unmarshal(fileData, &data)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
switch err := err.(type) {
|
switch e := e.(type) {
|
||||||
case *json.SyntaxError:
|
case *json.SyntaxError:
|
||||||
return false, probe.NewError(FormatJSONSyntaxError(bytes.NewReader(fileData), err))
|
return false, probe.NewError(FormatJSONSyntaxError(bytes.NewReader(fileData), e))
|
||||||
default:
|
default:
|
||||||
return false, probe.NewError(err)
|
return false, probe.NewError(e)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
config, perr := New(data)
|
config, err := New(data)
|
||||||
if perr != nil {
|
if err != nil {
|
||||||
return false, perr.Trace()
|
return false, err.Trace()
|
||||||
}
|
}
|
||||||
if config.Version() != version {
|
if config.Version() != version {
|
||||||
return false, nil
|
return false, nil
|
||||||
@ -125,33 +124,33 @@ func CheckVersion(filename string, version string) (bool, *probe.Error) {
|
|||||||
|
|
||||||
// Load - loads json config from filename for the a given struct data
|
// Load - loads json config from filename for the a given struct data
|
||||||
func Load(filename string, data interface{}) (Config, *probe.Error) {
|
func Load(filename string, data interface{}) (Config, *probe.Error) {
|
||||||
_, err := os.Stat(filename)
|
_, e := os.Stat(filename)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
return nil, probe.NewError(err)
|
return nil, probe.NewError(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
fileData, err := ioutil.ReadFile(filename)
|
fileData, e := ioutil.ReadFile(filename)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
return nil, probe.NewError(err)
|
return nil, probe.NewError(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
if runtime.GOOS == "windows" {
|
if runtime.GOOS == "windows" {
|
||||||
fileData = []byte(strings.Replace(string(fileData), "\r\n", "\n", -1))
|
fileData = []byte(strings.Replace(string(fileData), "\r\n", "\n", -1))
|
||||||
}
|
}
|
||||||
|
|
||||||
err = json.Unmarshal(fileData, &data)
|
e = json.Unmarshal(fileData, &data)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
switch err := err.(type) {
|
switch e := e.(type) {
|
||||||
case *json.SyntaxError:
|
case *json.SyntaxError:
|
||||||
return nil, probe.NewError(FormatJSONSyntaxError(bytes.NewReader(fileData), err))
|
return nil, probe.NewError(FormatJSONSyntaxError(bytes.NewReader(fileData), e))
|
||||||
default:
|
default:
|
||||||
return nil, probe.NewError(err)
|
return nil, probe.NewError(e)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
config, perr := New(data)
|
config, err := New(data)
|
||||||
if perr != nil {
|
if err != nil {
|
||||||
return nil, perr.Trace()
|
return nil, err.Trace()
|
||||||
}
|
}
|
||||||
|
|
||||||
return config, nil
|
return config, nil
|
||||||
@ -174,6 +173,25 @@ func (d config) Version() string {
|
|||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// writeFile writes data to a file named by filename.
|
||||||
|
// If the file does not exist, writeFile creates it;
|
||||||
|
// otherwise writeFile truncates it before writing.
|
||||||
|
func writeFile(filename string, data []byte) *probe.Error {
|
||||||
|
atomicFile, e := atomic.FileCreate(filename)
|
||||||
|
if e != nil {
|
||||||
|
return probe.NewError(e)
|
||||||
|
}
|
||||||
|
_, e = atomicFile.Write(data)
|
||||||
|
if e != nil {
|
||||||
|
return probe.NewError(e)
|
||||||
|
}
|
||||||
|
e = atomicFile.Close()
|
||||||
|
if e != nil {
|
||||||
|
return probe.NewError(e)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
// String converts JSON config to printable string
|
// String converts JSON config to printable string
|
||||||
func (d config) String() string {
|
func (d config) String() string {
|
||||||
configBytes, _ := json.MarshalIndent(d.data, "", "\t")
|
configBytes, _ := json.MarshalIndent(d.data, "", "\t")
|
||||||
@ -185,29 +203,42 @@ func (d config) Save(filename string) *probe.Error {
|
|||||||
d.lock.Lock()
|
d.lock.Lock()
|
||||||
defer d.lock.Unlock()
|
defer d.lock.Unlock()
|
||||||
|
|
||||||
jsonData, err := json.MarshalIndent(d.data, "", "\t")
|
// Check for existing file, if yes create a backup.
|
||||||
if err != nil {
|
st, e := os.Stat(filename)
|
||||||
return probe.NewError(err)
|
// If file exists and stat failed return here.
|
||||||
|
if e != nil && !os.IsNotExist(e) {
|
||||||
|
return probe.NewError(e)
|
||||||
|
}
|
||||||
|
// File exists and proceed to take backup.
|
||||||
|
if e == nil {
|
||||||
|
// File exists and is not a regular file return error.
|
||||||
|
if !st.Mode().IsRegular() {
|
||||||
|
return probe.NewError(fmt.Errorf("%s is not a regular file", filename))
|
||||||
|
}
|
||||||
|
// Read old data.
|
||||||
|
var oldData []byte
|
||||||
|
oldData, e = ioutil.ReadFile(filename)
|
||||||
|
if e != nil {
|
||||||
|
return probe.NewError(e)
|
||||||
|
}
|
||||||
|
// Save read data to the backup file.
|
||||||
|
if err := writeFile(filename+".old", oldData); err != nil {
|
||||||
|
return err.Trace(filename + ".old")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// Proceed to create or overwrite file.
|
||||||
|
jsonData, e := json.MarshalIndent(d.data, "", "\t")
|
||||||
|
if e != nil {
|
||||||
|
return probe.NewError(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
if runtime.GOOS == "windows" {
|
if runtime.GOOS == "windows" {
|
||||||
jsonData = []byte(strings.Replace(string(jsonData), "\n", "\r\n", -1))
|
jsonData = []byte(strings.Replace(string(jsonData), "\n", "\r\n", -1))
|
||||||
}
|
}
|
||||||
|
|
||||||
atomicFile, err := atomic.FileCreate(filename)
|
// Save data.
|
||||||
if err != nil {
|
err := writeFile(filename, jsonData)
|
||||||
return probe.NewError(err)
|
return err.Trace(filename)
|
||||||
}
|
|
||||||
_, err = atomicFile.Write(jsonData)
|
|
||||||
if err != nil {
|
|
||||||
return probe.NewError(err)
|
|
||||||
}
|
|
||||||
err = atomicFile.Close()
|
|
||||||
if err != nil {
|
|
||||||
return probe.NewError(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Load - loads JSON config from file and merge with currently set values
|
// Load - loads JSON config from file and merge with currently set values
|
||||||
@ -215,14 +246,14 @@ func (d *config) Load(filename string) *probe.Error {
|
|||||||
d.lock.Lock()
|
d.lock.Lock()
|
||||||
defer d.lock.Unlock()
|
defer d.lock.Unlock()
|
||||||
|
|
||||||
_, err := os.Stat(filename)
|
_, e := os.Stat(filename)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
return probe.NewError(err)
|
return probe.NewError(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
fileData, err := ioutil.ReadFile(filename)
|
fileData, e := ioutil.ReadFile(filename)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
return probe.NewError(err)
|
return probe.NewError(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
if runtime.GOOS == "windows" {
|
if runtime.GOOS == "windows" {
|
||||||
@ -235,18 +266,18 @@ func (d *config) Load(filename string) *probe.Error {
|
|||||||
return probe.NewError(fmt.Errorf("Argument struct [%s] does not contain field \"Version\".", st.Name()))
|
return probe.NewError(fmt.Errorf("Argument struct [%s] does not contain field \"Version\".", st.Name()))
|
||||||
}
|
}
|
||||||
|
|
||||||
err = json.Unmarshal(fileData, d.data)
|
e = json.Unmarshal(fileData, d.data)
|
||||||
if err != nil {
|
if e != nil {
|
||||||
switch err := err.(type) {
|
switch e := e.(type) {
|
||||||
case *json.SyntaxError:
|
case *json.SyntaxError:
|
||||||
return probe.NewError(FormatJSONSyntaxError(bytes.NewReader(fileData), err))
|
return probe.NewError(FormatJSONSyntaxError(bytes.NewReader(fileData), e))
|
||||||
default:
|
default:
|
||||||
return probe.NewError(err)
|
return probe.NewError(e)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := CheckData(d.data); err != nil {
|
if err := CheckData(d.data); err != nil {
|
||||||
return err.Trace()
|
return err.Trace(filename)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (*d).Version() != f.Value() {
|
if (*d).Version() != f.Value() {
|
||||||
|
59
vendor/github.com/minio/minio-xl/pkg/quick/quick_test.go
generated
vendored
59
vendor/github.com/minio/minio-xl/pkg/quick/quick_test.go
generated
vendored
@ -32,6 +32,21 @@ type MySuite struct{}
|
|||||||
|
|
||||||
var _ = Suite(&MySuite{})
|
var _ = Suite(&MySuite{})
|
||||||
|
|
||||||
|
func (s *MySuite) TestSaveFailOnDir(c *C) {
|
||||||
|
defer os.RemoveAll("test.json")
|
||||||
|
e := os.MkdirAll("test.json", 0644)
|
||||||
|
c.Assert(e, IsNil)
|
||||||
|
type myStruct struct {
|
||||||
|
Version string
|
||||||
|
}
|
||||||
|
saveMe := myStruct{"1"}
|
||||||
|
config, err := quick.New(&saveMe)
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
c.Assert(config, Not(IsNil))
|
||||||
|
err = config.Save("test.json")
|
||||||
|
c.Assert(err, Not(IsNil))
|
||||||
|
}
|
||||||
|
|
||||||
func (s *MySuite) TestCheckData(c *C) {
|
func (s *MySuite) TestCheckData(c *C) {
|
||||||
err := quick.CheckData(nil)
|
err := quick.CheckData(nil)
|
||||||
c.Assert(err, Not(IsNil))
|
c.Assert(err, Not(IsNil))
|
||||||
@ -69,7 +84,8 @@ func (s *MySuite) TestVersion(c *C) {
|
|||||||
config, err := quick.New(&saveMe)
|
config, err := quick.New(&saveMe)
|
||||||
c.Assert(err, IsNil)
|
c.Assert(err, IsNil)
|
||||||
c.Assert(config, Not(IsNil))
|
c.Assert(config, Not(IsNil))
|
||||||
config.Save("test.json")
|
err = config.Save("test.json")
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
|
||||||
valid, err := quick.CheckVersion("test.json", "1")
|
valid, err := quick.CheckVersion("test.json", "1")
|
||||||
c.Assert(err, IsNil)
|
c.Assert(err, IsNil)
|
||||||
@ -92,13 +108,15 @@ func (s *MySuite) TestSaveLoad(c *C) {
|
|||||||
config, err := quick.New(&saveMe)
|
config, err := quick.New(&saveMe)
|
||||||
c.Assert(err, IsNil)
|
c.Assert(err, IsNil)
|
||||||
c.Assert(config, Not(IsNil))
|
c.Assert(config, Not(IsNil))
|
||||||
config.Save("test.json")
|
err = config.Save("test.json")
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
|
||||||
loadMe := myStruct{Version: "1"}
|
loadMe := myStruct{Version: "1"}
|
||||||
newConfig, err := quick.New(&loadMe)
|
newConfig, err := quick.New(&loadMe)
|
||||||
c.Assert(err, IsNil)
|
c.Assert(err, IsNil)
|
||||||
c.Assert(newConfig, Not(IsNil))
|
c.Assert(newConfig, Not(IsNil))
|
||||||
newConfig.Load("test.json")
|
err = newConfig.Load("test.json")
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
|
||||||
c.Assert(config.Data(), DeepEquals, newConfig.Data())
|
c.Assert(config.Data(), DeepEquals, newConfig.Data())
|
||||||
c.Assert(config.Data(), DeepEquals, &loadMe)
|
c.Assert(config.Data(), DeepEquals, &loadMe)
|
||||||
@ -107,6 +125,41 @@ func (s *MySuite) TestSaveLoad(c *C) {
|
|||||||
c.Assert(newConfig.Data(), Not(DeepEquals), &mismatch)
|
c.Assert(newConfig.Data(), Not(DeepEquals), &mismatch)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *MySuite) TestSaveBackup(c *C) {
|
||||||
|
defer os.RemoveAll("test.json")
|
||||||
|
defer os.RemoveAll("test.json.old")
|
||||||
|
type myStruct struct {
|
||||||
|
Version string
|
||||||
|
User string
|
||||||
|
Password string
|
||||||
|
Folders []string
|
||||||
|
}
|
||||||
|
saveMe := myStruct{"1", "guest", "nopassword", []string{"Work", "Documents", "Music"}}
|
||||||
|
config, err := quick.New(&saveMe)
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
c.Assert(config, Not(IsNil))
|
||||||
|
err = config.Save("test.json")
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
|
||||||
|
loadMe := myStruct{Version: "1"}
|
||||||
|
newConfig, err := quick.New(&loadMe)
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
c.Assert(newConfig, Not(IsNil))
|
||||||
|
err = newConfig.Load("test.json")
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
|
||||||
|
c.Assert(config.Data(), DeepEquals, newConfig.Data())
|
||||||
|
c.Assert(config.Data(), DeepEquals, &loadMe)
|
||||||
|
|
||||||
|
mismatch := myStruct{"1.1", "guest", "nopassword", []string{"Work", "Documents", "Music"}}
|
||||||
|
c.Assert(newConfig.Data(), Not(DeepEquals), &mismatch)
|
||||||
|
config, err = quick.New(&mismatch)
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
c.Assert(config, Not(IsNil))
|
||||||
|
err = config.Save("test.json")
|
||||||
|
c.Assert(err, IsNil)
|
||||||
|
}
|
||||||
|
|
||||||
func (s *MySuite) TestDiff(c *C) {
|
func (s *MySuite) TestDiff(c *C) {
|
||||||
type myStruct struct {
|
type myStruct struct {
|
||||||
Version string
|
Version string
|
||||||
|
16
vendor/vendor.json
vendored
16
vendor/vendor.json
vendored
@ -39,8 +39,8 @@
|
|||||||
},
|
},
|
||||||
{
|
{
|
||||||
"path": "github.com/minio/minio-xl/pkg/atomic",
|
"path": "github.com/minio/minio-xl/pkg/atomic",
|
||||||
"revision": "008404af67dcf66bdde580245cd43951b425ed39",
|
"revision": "69c47f638917ab1cb9e24649c84ac38e6f1891b8",
|
||||||
"revisionTime": "2015-11-17T16:21:42-08:00"
|
"revisionTime": "2016-01-14T18:12:05-08:00"
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"path": "github.com/minio/minio-xl/pkg/cpu",
|
"path": "github.com/minio/minio-xl/pkg/cpu",
|
||||||
@ -49,13 +49,13 @@
|
|||||||
},
|
},
|
||||||
{
|
{
|
||||||
"path": "github.com/minio/minio-xl/pkg/crypto/sha256",
|
"path": "github.com/minio/minio-xl/pkg/crypto/sha256",
|
||||||
"revision": "a4e6504a5f94cf43bdbe3dec1a622317031b145d",
|
"revision": "69c47f638917ab1cb9e24649c84ac38e6f1891b8",
|
||||||
"revisionTime": "2015-11-14T00:48:52-08:00"
|
"revisionTime": "2016-01-14T18:12:05-08:00"
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"path": "github.com/minio/minio-xl/pkg/crypto/sha512",
|
"path": "github.com/minio/minio-xl/pkg/crypto/sha512",
|
||||||
"revision": "a4e6504a5f94cf43bdbe3dec1a622317031b145d",
|
"revision": "69c47f638917ab1cb9e24649c84ac38e6f1891b8",
|
||||||
"revisionTime": "2015-11-14T00:48:52-08:00"
|
"revisionTime": "2016-01-14T18:12:05-08:00"
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"path": "github.com/minio/minio-xl/pkg/minhttp",
|
"path": "github.com/minio/minio-xl/pkg/minhttp",
|
||||||
@ -69,8 +69,8 @@
|
|||||||
},
|
},
|
||||||
{
|
{
|
||||||
"path": "github.com/minio/minio-xl/pkg/quick",
|
"path": "github.com/minio/minio-xl/pkg/quick",
|
||||||
"revision": "008404af67dcf66bdde580245cd43951b425ed39",
|
"revision": "69c47f638917ab1cb9e24649c84ac38e6f1891b8",
|
||||||
"revisionTime": "2015-11-17T16:21:42-08:00"
|
"revisionTime": "2016-01-14T18:12:05-08:00"
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"path": "github.com/rs/cors",
|
"path": "github.com/rs/cors",
|
||||||
|
Loading…
Reference in New Issue
Block a user