mount.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. //go:build linux
  2. // +build linux
  3. package devmapper // import "github.com/docker/docker/daemon/graphdriver/devmapper"
  4. import (
  5. "bytes"
  6. "fmt"
  7. "os"
  8. )
  9. type probeData struct {
  10. fsName string
  11. magic string
  12. offset uint64
  13. }
  14. // ProbeFsType returns the filesystem name for the given device id.
  15. func ProbeFsType(device string) (string, error) {
  16. probes := []probeData{
  17. {"btrfs", "_BHRfS_M", 0x10040},
  18. {"ext4", "\123\357", 0x438},
  19. {"xfs", "XFSB", 0},
  20. }
  21. maxLen := uint64(0)
  22. for _, p := range probes {
  23. l := p.offset + uint64(len(p.magic))
  24. if l > maxLen {
  25. maxLen = l
  26. }
  27. }
  28. file, err := os.Open(device)
  29. if err != nil {
  30. return "", err
  31. }
  32. defer file.Close()
  33. buffer := make([]byte, maxLen)
  34. l, err := file.Read(buffer)
  35. if err != nil {
  36. return "", err
  37. }
  38. if uint64(l) != maxLen {
  39. return "", fmt.Errorf("devmapper: unable to detect filesystem type of %s, short read", device)
  40. }
  41. for _, p := range probes {
  42. if bytes.Equal([]byte(p.magic), buffer[p.offset:p.offset+uint64(len(p.magic))]) {
  43. return p.fsName, nil
  44. }
  45. }
  46. return "", fmt.Errorf("devmapper: Unknown filesystem type on %s", device)
  47. }
  48. func joinMountOptions(a, b string) string {
  49. if a == "" {
  50. return b
  51. }
  52. if b == "" {
  53. return a
  54. }
  55. return a + "," + b
  56. }