splitNetPath: Add support for windows paths including volumeNames e.g ip:C:\network\path

cmd/object-common.go

@@ -56,18 +56,21 @@ func fsHouseKeeping(storageDisk StorageAPI) error {
 // Check if a network path is local to this node.
 func isLocalStorage(networkPath string) bool {
 	if idx := strings.LastIndex(networkPath, ":"); idx != -1 {
-		// e.g 10.0.0.1:9000:/mnt/networkPath
-		netAddr, _ := splitNetPath(networkPath)
-		var netHost string
-		var err error
-		netHost, _, err = net.SplitHostPort(netAddr)
+		// e.g 10.0.0.1:/mnt/networkPath
+		netAddr, _, err := splitNetPath(networkPath)
 		if err != nil {
-			netHost = netAddr
+			errorIf(err, "Splitting into ip and path failed")
+			return false
+		}
+		// netAddr will only be set if this is not a local path.
+		if netAddr == "" {
+			return true
 		}
 		// Resolve host to address to check if the IP is loopback.
 		// If address resolution fails, assume it's a non-local host.
-		addrs, err := net.LookupHost(netHost)
+		addrs, err := net.LookupHost(netAddr)
 		if err != nil {
+			errorIf(err, "Failed to lookup host")
 			return false
 		}
 		for _, addr := range addrs {
@@ -77,12 +80,14 @@ func isLocalStorage(networkPath string) bool {
 		}
 		iaddrs, err := net.InterfaceAddrs()
 		if err != nil {
+			errorIf(err, "Unable to list interface addresses")
 			return false
 		}
 		for _, addr := range addrs {
 			for _, iaddr := range iaddrs {
 				ip, _, err := net.ParseCIDR(iaddr.String())
 				if err != nil {
+					errorIf(err, "Unable to parse CIDR")
 					return false
 				}
 				if ip.String() == addr {

cmd/storage-rpc-client.go

@@ -36,14 +36,6 @@ const (
 	storageRPCPath = reservedBucket + "/storage"
 )
 
-// splits network path into its components Address and Path.
-func splitNetPath(networkPath string) (netAddr, netPath string) {
-	index := strings.LastIndex(networkPath, ":")
-	netAddr = networkPath[:index]
-	netPath = networkPath[index+1:]
-	return netAddr, netPath
-}
-
 // Converts rpc.ServerError to underlying error. This function is
 // written so that the storageAPI errors are consistent across network
 // disks as well.
@@ -111,7 +103,10 @@ func newRPCClient(networkPath string) (StorageAPI, error) {
 	}
 
 	// TODO validate netAddr and netPath.
-	netAddr, netPath := splitNetPath(networkPath)
+	netAddr, netPath, err := splitNetPath(networkPath)
+	if err != nil {
+		return nil, err
+	}
 
 	// Dial minio rpc storage http path.
 	rpcPath := path.Join(storageRPCPath, netPath)

cmd/utils.go

@@ -21,9 +21,12 @@ import (
 	"encoding/xml"
 	"errors"
 	"io"
+	"net"
 	"net/http"
 	"os"
 	"os/exec"
+	"path/filepath"
+	"runtime"
 	"strings"
 	"sync"
 	"syscall"
@@ -43,6 +46,28 @@ func cloneHeader(h http.Header) http.Header {
 	return h2
 }
 
+// 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)
+	switch len(networkParts) {
+	case 1:
+		return "", networkPath, nil
+	case 2:
+		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}
+		}
+		return networkParts[0], networkParts[1], nil
+	}
+	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