names.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. package daemon
  2. import (
  3. "fmt"
  4. "strings"
  5. "github.com/Sirupsen/logrus"
  6. "github.com/docker/docker/api"
  7. "github.com/docker/docker/container"
  8. "github.com/docker/docker/pkg/namesgenerator"
  9. "github.com/docker/docker/pkg/registrar"
  10. "github.com/docker/docker/pkg/stringid"
  11. )
  12. var (
  13. validContainerNameChars = api.RestrictedNameChars
  14. validContainerNamePattern = api.RestrictedNamePattern
  15. )
  16. func (daemon *Daemon) registerName(container *container.Container) error {
  17. if daemon.Exists(container.ID) {
  18. return fmt.Errorf("Container is already loaded")
  19. }
  20. if err := validateID(container.ID); err != nil {
  21. return err
  22. }
  23. if container.Name == "" {
  24. name, err := daemon.generateNewName(container.ID)
  25. if err != nil {
  26. return err
  27. }
  28. container.Name = name
  29. if err := container.ToDiskLocking(); err != nil {
  30. logrus.Errorf("Error saving container name to disk: %v", err)
  31. }
  32. }
  33. return daemon.nameIndex.Reserve(container.Name, container.ID)
  34. }
  35. func (daemon *Daemon) generateIDAndName(name string) (string, string, error) {
  36. var (
  37. err error
  38. id = stringid.GenerateNonCryptoID()
  39. )
  40. if name == "" {
  41. if name, err = daemon.generateNewName(id); err != nil {
  42. return "", "", err
  43. }
  44. return id, name, nil
  45. }
  46. if name, err = daemon.reserveName(id, name); err != nil {
  47. return "", "", err
  48. }
  49. return id, name, nil
  50. }
  51. func (daemon *Daemon) reserveName(id, name string) (string, error) {
  52. if !validContainerNamePattern.MatchString(strings.TrimPrefix(name, "/")) {
  53. return "", fmt.Errorf("Invalid container name (%s), only %s are allowed", name, validContainerNameChars)
  54. }
  55. if name[0] != '/' {
  56. name = "/" + name
  57. }
  58. if err := daemon.nameIndex.Reserve(name, id); err != nil {
  59. if err == registrar.ErrNameReserved {
  60. id, err := daemon.nameIndex.Get(name)
  61. if err != nil {
  62. logrus.Errorf("got unexpected error while looking up reserved name: %v", err)
  63. return "", err
  64. }
  65. return "", fmt.Errorf("Conflict. The container name %q is already in use by container %q. You have to remove (or rename) that container to be able to reuse that name.", name, id)
  66. }
  67. return "", fmt.Errorf("error reserving name: %q, error: %v", name, err)
  68. }
  69. return name, nil
  70. }
  71. func (daemon *Daemon) releaseName(name string) {
  72. daemon.nameIndex.Release(name)
  73. }
  74. func (daemon *Daemon) generateNewName(id string) (string, error) {
  75. var name string
  76. for i := 0; i < 6; i++ {
  77. name = namesgenerator.GetRandomName(i)
  78. if name[0] != '/' {
  79. name = "/" + name
  80. }
  81. if err := daemon.nameIndex.Reserve(name, id); err != nil {
  82. if err == registrar.ErrNameReserved {
  83. continue
  84. }
  85. return "", err
  86. }
  87. return name, nil
  88. }
  89. name = "/" + stringid.TruncateID(id)
  90. if err := daemon.nameIndex.Reserve(name, id); err != nil {
  91. return "", err
  92. }
  93. return name, nil
  94. }
  95. func validateID(id string) error {
  96. if id == "" {
  97. return fmt.Errorf("Invalid empty id")
  98. }
  99. return nil
  100. }