mirror of
https://github.com/minio/minio.git
synced 2024-12-25 06:35:56 -05:00
32f097b4d6
* Test code for controller-handler operations: * Heal operations * List operation * Switch to "testing" lib, moving away from gocheck * Minor refactors * Remove extra call to initGracefulShutdown * Remove dead code in mainControl: Dead code found by the TestControlMain() test function that always passes. * Add tests for control-*-main.go
353 lines
9.3 KiB
Go
353 lines
9.3 KiB
Go
/*
|
|
* 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 cmd
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"encoding/xml"
|
|
"errors"
|
|
"fmt"
|
|
"io"
|
|
"net"
|
|
"net/http"
|
|
"os"
|
|
"os/exec"
|
|
"path/filepath"
|
|
"runtime"
|
|
"strings"
|
|
"sync"
|
|
"syscall"
|
|
|
|
"encoding/json"
|
|
|
|
"github.com/pkg/profile"
|
|
)
|
|
|
|
// make a copy of http.Header
|
|
func cloneHeader(h http.Header) http.Header {
|
|
h2 := make(http.Header, len(h))
|
|
for k, vv := range h {
|
|
vv2 := make([]string, len(vv))
|
|
copy(vv2, vv)
|
|
h2[k] = vv2
|
|
|
|
}
|
|
return h2
|
|
}
|
|
|
|
// checkDuplicates - function to validate if there are duplicates in a slice of strings.
|
|
func checkDuplicates(list []string) error {
|
|
// Empty lists are not allowed.
|
|
if len(list) == 0 {
|
|
return errInvalidArgument
|
|
}
|
|
// Empty keys are not allowed.
|
|
for _, key := range list {
|
|
if key == "" {
|
|
return errInvalidArgument
|
|
}
|
|
}
|
|
listMaps := make(map[string]int)
|
|
// Navigate through each configs and count the entries.
|
|
for _, key := range list {
|
|
listMaps[key]++
|
|
}
|
|
// Validate if there are any duplicate counts.
|
|
for key, count := range listMaps {
|
|
if count != 1 {
|
|
return fmt.Errorf("Duplicate key: \"%s\" found of count: \"%d\"", key, count)
|
|
}
|
|
}
|
|
// No duplicates.
|
|
return nil
|
|
}
|
|
|
|
// splits network path into its components Address and Path.
|
|
func splitNetPath(networkPath string) (netAddr, netPath string, err error) {
|
|
if runtime.GOOS == "windows" {
|
|
if volumeName := filepath.VolumeName(networkPath); volumeName != "" {
|
|
return "", networkPath, nil
|
|
}
|
|
}
|
|
networkParts := strings.SplitN(networkPath, ":", 2)
|
|
if len(networkParts) == 1 {
|
|
return "", networkPath, nil
|
|
}
|
|
if networkParts[1] == "" {
|
|
return "", "", &net.AddrError{Err: "Missing path in network path", Addr: networkPath}
|
|
} else if networkParts[0] == "" {
|
|
return "", "", &net.AddrError{Err: "Missing address in network path", Addr: networkPath}
|
|
} else if !filepath.IsAbs(networkParts[1]) {
|
|
return "", "", &net.AddrError{Err: "Network path should be absolute", Addr: networkPath}
|
|
}
|
|
return networkParts[0], networkParts[1], nil
|
|
}
|
|
|
|
// xmlDecoder provide decoded value in xml.
|
|
func xmlDecoder(body io.Reader, v interface{}, size int64) error {
|
|
var lbody io.Reader
|
|
if size > 0 {
|
|
lbody = io.LimitReader(body, size)
|
|
} else {
|
|
lbody = body
|
|
}
|
|
d := xml.NewDecoder(lbody)
|
|
return d.Decode(v)
|
|
}
|
|
|
|
// checkValidMD5 - verify if valid md5, returns md5 in bytes.
|
|
func checkValidMD5(md5 string) ([]byte, error) {
|
|
return base64.StdEncoding.DecodeString(strings.TrimSpace(md5))
|
|
}
|
|
|
|
/// http://docs.aws.amazon.com/AmazonS3/latest/dev/UploadingObjects.html
|
|
const (
|
|
// maximum object size per PUT request is 5GiB
|
|
maxObjectSize = 1024 * 1024 * 1024 * 5
|
|
// minimum Part size for multipart upload is 5MB
|
|
minPartSize = 1024 * 1024 * 5
|
|
// maximum Part ID for multipart upload is 10000 (Acceptable values range from 1 to 10000 inclusive)
|
|
maxPartID = 10000
|
|
)
|
|
|
|
// isMaxObjectSize - verify if max object size
|
|
func isMaxObjectSize(size int64) bool {
|
|
return size > maxObjectSize
|
|
}
|
|
|
|
// Check if part size is more than or equal to minimum allowed size.
|
|
func isMinAllowedPartSize(size int64) bool {
|
|
return size >= minPartSize
|
|
}
|
|
|
|
// isMaxPartNumber - Check if part ID is greater than the maximum allowed ID.
|
|
func isMaxPartID(partID int) bool {
|
|
return partID > maxPartID
|
|
}
|
|
|
|
func contains(stringList []string, element string) bool {
|
|
for _, e := range stringList {
|
|
if e == element {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
// Represents a type of an exit func which will be invoked upon shutdown signal.
|
|
type onExitFunc func(code int)
|
|
|
|
// Represents a type for all the the callback functions invoked upon shutdown signal.
|
|
type cleanupOnExitFunc func() errCode
|
|
|
|
// Represents a collection of various callbacks executed upon exit signals.
|
|
type shutdownCallbacks struct {
|
|
// Protect callbacks list from a concurrent access
|
|
*sync.RWMutex
|
|
// genericCallbacks - is the list of function callbacks executed one by one
|
|
// when a shutdown starts. A callback returns 0 for success and 1 for failure.
|
|
// Failure is considered an emergency error that needs an immediate exit
|
|
genericCallbacks []cleanupOnExitFunc
|
|
// objectLayerCallbacks - contains the list of function callbacks that
|
|
// need to be invoked when a shutdown starts. These callbacks will be called before
|
|
// the general callback shutdowns
|
|
objectLayerCallbacks []cleanupOnExitFunc
|
|
}
|
|
|
|
// globalShutdownCBs stores regular and object storages callbacks
|
|
var globalShutdownCBs *shutdownCallbacks
|
|
|
|
func (s *shutdownCallbacks) RunObjectLayerCBs() errCode {
|
|
s.RLock()
|
|
defer s.RUnlock()
|
|
exitCode := exitSuccess
|
|
for _, callback := range s.objectLayerCallbacks {
|
|
exitCode = callback()
|
|
if exitCode != exitSuccess {
|
|
break
|
|
}
|
|
}
|
|
return exitCode
|
|
}
|
|
|
|
func (s *shutdownCallbacks) RunGenericCBs() errCode {
|
|
s.RLock()
|
|
defer s.RUnlock()
|
|
exitCode := exitSuccess
|
|
for _, callback := range s.genericCallbacks {
|
|
exitCode = callback()
|
|
if exitCode != exitSuccess {
|
|
break
|
|
}
|
|
}
|
|
return exitCode
|
|
}
|
|
|
|
func (s *shutdownCallbacks) AddObjectLayerCB(callback cleanupOnExitFunc) error {
|
|
s.Lock()
|
|
defer s.Unlock()
|
|
if callback == nil {
|
|
return errInvalidArgument
|
|
}
|
|
s.objectLayerCallbacks = append(s.objectLayerCallbacks, callback)
|
|
return nil
|
|
}
|
|
|
|
func (s *shutdownCallbacks) AddGenericCB(callback cleanupOnExitFunc) error {
|
|
s.Lock()
|
|
defer s.Unlock()
|
|
if callback == nil {
|
|
return errInvalidArgument
|
|
}
|
|
s.genericCallbacks = append(s.genericCallbacks, callback)
|
|
return nil
|
|
}
|
|
|
|
// Initialize graceful shutdown mechanism.
|
|
func initGracefulShutdown(onExitFn onExitFunc) error {
|
|
// Validate exit func.
|
|
if onExitFn == nil {
|
|
return errInvalidArgument
|
|
}
|
|
globalShutdownCBs = &shutdownCallbacks{
|
|
RWMutex: &sync.RWMutex{},
|
|
}
|
|
// Return start monitor shutdown signal.
|
|
return startMonitorShutdownSignal(onExitFn)
|
|
}
|
|
|
|
type shutdownSignal int
|
|
|
|
const (
|
|
shutdownHalt = iota
|
|
shutdownRestart
|
|
)
|
|
|
|
// Starts a profiler returns nil if profiler is not enabled, caller needs to handle this.
|
|
func startProfiler(profiler string) interface {
|
|
Stop()
|
|
} {
|
|
// Set ``MINIO_PROFILE_DIR`` to the directory where profiling information should be persisted
|
|
profileDir := os.Getenv("MINIO_PROFILE_DIR")
|
|
// Enable profiler if ``MINIO_PROFILER`` is set. Supported options are [cpu, mem, block].
|
|
switch profiler {
|
|
case "cpu":
|
|
return profile.Start(profile.CPUProfile, profile.NoShutdownHook, profile.ProfilePath(profileDir))
|
|
case "mem":
|
|
return profile.Start(profile.MemProfile, profile.NoShutdownHook, profile.ProfilePath(profileDir))
|
|
case "block":
|
|
return profile.Start(profile.BlockProfile, profile.NoShutdownHook, profile.ProfilePath(profileDir))
|
|
default:
|
|
return nil
|
|
}
|
|
}
|
|
|
|
// Global shutdown signal channel.
|
|
var globalShutdownSignalCh = make(chan shutdownSignal, 1)
|
|
|
|
// Global profiler to be used by shutdown go-routine.
|
|
var globalProfiler interface {
|
|
Stop()
|
|
}
|
|
|
|
// Start to monitor shutdownSignal to execute shutdown callbacks
|
|
func startMonitorShutdownSignal(onExitFn onExitFunc) error {
|
|
// Validate exit func.
|
|
if onExitFn == nil {
|
|
return errInvalidArgument
|
|
}
|
|
|
|
// Custom exit function
|
|
runExitFn := func(exitCode errCode) {
|
|
// If global profiler is set stop before we exit.
|
|
if globalProfiler != nil {
|
|
globalProfiler.Stop()
|
|
}
|
|
// Call user supplied user exit function
|
|
onExitFn(int(exitCode))
|
|
}
|
|
|
|
// Start listening on shutdown signal.
|
|
go func() {
|
|
defer close(globalShutdownSignalCh)
|
|
|
|
// Monitor signals.
|
|
trapCh := signalTrap(os.Interrupt, syscall.SIGTERM)
|
|
for {
|
|
select {
|
|
case <-trapCh:
|
|
// Initiate graceful shutdown.
|
|
globalShutdownSignalCh <- shutdownHalt
|
|
case signal := <-globalShutdownSignalCh:
|
|
// Call all object storage shutdown
|
|
// callbacks and exit for emergency
|
|
exitCode := globalShutdownCBs.RunObjectLayerCBs()
|
|
if exitCode != exitSuccess {
|
|
runExitFn(exitCode)
|
|
}
|
|
|
|
exitCode = globalShutdownCBs.RunGenericCBs()
|
|
if exitCode != exitSuccess {
|
|
runExitFn(exitCode)
|
|
}
|
|
|
|
// All shutdown callbacks ensure that
|
|
// the server is safely terminated and
|
|
// any concurrent process could be
|
|
// started again
|
|
if signal == shutdownRestart {
|
|
path := os.Args[0]
|
|
cmdArgs := os.Args[1:]
|
|
cmd := exec.Command(path, cmdArgs...)
|
|
cmd.Stdout = os.Stdout
|
|
cmd.Stderr = os.Stderr
|
|
|
|
err := cmd.Start()
|
|
if err != nil {
|
|
errorIf(errors.New("Unable to reboot."), err.Error())
|
|
}
|
|
|
|
// Successfully forked.
|
|
runExitFn(exitSuccess)
|
|
}
|
|
|
|
// Exit as success if no errors.
|
|
runExitFn(exitSuccess)
|
|
}
|
|
}
|
|
}()
|
|
// Successfully started routine.
|
|
return nil
|
|
}
|
|
|
|
// dump the request into a string in JSON format.
|
|
func dumpRequest(r *http.Request) string {
|
|
header := cloneHeader(r.Header)
|
|
header.Set("Host", r.Host)
|
|
req := struct {
|
|
Method string `json:"method"`
|
|
Path string `json:"path"`
|
|
Query string `json:"query"`
|
|
Header http.Header `json:"header"`
|
|
}{r.Method, r.URL.Path, r.URL.RawQuery, header}
|
|
jsonBytes, err := json.Marshal(req)
|
|
if err != nil {
|
|
return "<error dumping request>"
|
|
}
|
|
return string(jsonBytes)
|
|
}
|