rename.go 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. package daemon
  2. import (
  3. "errors"
  4. "fmt"
  5. "strings"
  6. "github.com/Sirupsen/logrus"
  7. dockercontainer "github.com/docker/docker/container"
  8. "github.com/docker/libnetwork"
  9. )
  10. // ContainerRename changes the name of a container, using the oldName
  11. // to find the container. An error is returned if newName is already
  12. // reserved.
  13. func (daemon *Daemon) ContainerRename(oldName, newName string) error {
  14. var (
  15. sid string
  16. sb libnetwork.Sandbox
  17. )
  18. if oldName == "" || newName == "" {
  19. return errors.New("Neither old nor new names may be empty")
  20. }
  21. if newName[0] != '/' {
  22. newName = "/" + newName
  23. }
  24. container, err := daemon.GetContainer(oldName)
  25. if err != nil {
  26. return err
  27. }
  28. oldName = container.Name
  29. oldIsAnonymousEndpoint := container.NetworkSettings.IsAnonymousEndpoint
  30. if oldName == newName {
  31. return errors.New("Renaming a container with the same name as its current name")
  32. }
  33. container.Lock()
  34. defer container.Unlock()
  35. links := map[string]*dockercontainer.Container{}
  36. for k, v := range daemon.linkIndex.children(container) {
  37. if !strings.HasPrefix(k, oldName) {
  38. return fmt.Errorf("Linked container %s does not match parent %s", k, oldName)
  39. }
  40. links[strings.TrimPrefix(k, oldName)] = v
  41. }
  42. if newName, err = daemon.reserveName(container.ID, newName); err != nil {
  43. return fmt.Errorf("Error when allocating new name: %v", err)
  44. }
  45. for k, v := range links {
  46. daemon.nameIndex.Reserve(newName+k, v.ID)
  47. daemon.linkIndex.link(container, v, newName+k)
  48. }
  49. container.Name = newName
  50. container.NetworkSettings.IsAnonymousEndpoint = false
  51. defer func() {
  52. if err != nil {
  53. container.Name = oldName
  54. container.NetworkSettings.IsAnonymousEndpoint = oldIsAnonymousEndpoint
  55. daemon.reserveName(container.ID, oldName)
  56. for k, v := range links {
  57. daemon.nameIndex.Reserve(oldName+k, v.ID)
  58. daemon.linkIndex.link(container, v, oldName+k)
  59. daemon.linkIndex.unlink(newName+k, v, container)
  60. daemon.nameIndex.Release(newName + k)
  61. }
  62. daemon.releaseName(newName)
  63. }
  64. }()
  65. for k, v := range links {
  66. daemon.linkIndex.unlink(oldName+k, v, container)
  67. daemon.nameIndex.Release(oldName + k)
  68. }
  69. daemon.releaseName(oldName)
  70. if err = container.ToDisk(); err != nil {
  71. return err
  72. }
  73. attributes := map[string]string{
  74. "oldName": oldName,
  75. }
  76. if !container.Running {
  77. daemon.LogContainerEventWithAttributes(container, "rename", attributes)
  78. return nil
  79. }
  80. defer func() {
  81. if err != nil {
  82. container.Name = oldName
  83. container.NetworkSettings.IsAnonymousEndpoint = oldIsAnonymousEndpoint
  84. if e := container.ToDisk(); e != nil {
  85. logrus.Errorf("%s: Failed in writing to Disk on rename failure: %v", container.ID, e)
  86. }
  87. }
  88. }()
  89. sid = container.NetworkSettings.SandboxID
  90. if sid != "" && daemon.netController != nil {
  91. sb, err = daemon.netController.SandboxByID(sid)
  92. if err != nil {
  93. return err
  94. }
  95. err = sb.Rename(strings.TrimPrefix(container.Name, "/"))
  96. if err != nil {
  97. return err
  98. }
  99. }
  100. daemon.LogContainerEventWithAttributes(container, "rename", attributes)
  101. return nil
  102. }