portallocator.go 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201
  1. package portallocator
  2. import (
  3. "bufio"
  4. "errors"
  5. "fmt"
  6. "net"
  7. "os"
  8. "sync"
  9. "github.com/Sirupsen/logrus"
  10. )
  11. const (
  12. DefaultPortRangeStart = 49153
  13. DefaultPortRangeEnd = 65535
  14. )
  15. var (
  16. beginPortRange = DefaultPortRangeStart
  17. endPortRange = DefaultPortRangeEnd
  18. )
  19. type portMap struct {
  20. p map[int]struct{}
  21. last int
  22. }
  23. func newPortMap() *portMap {
  24. return &portMap{
  25. p: map[int]struct{}{},
  26. last: endPortRange,
  27. }
  28. }
  29. type protoMap map[string]*portMap
  30. func newProtoMap() protoMap {
  31. return protoMap{
  32. "tcp": newPortMap(),
  33. "udp": newPortMap(),
  34. }
  35. }
  36. type ipMapping map[string]protoMap
  37. var (
  38. ErrAllPortsAllocated = errors.New("all ports are allocated")
  39. ErrUnknownProtocol = errors.New("unknown protocol")
  40. )
  41. var (
  42. defaultIP = net.ParseIP("0.0.0.0")
  43. DefaultPortAllocator = New()
  44. RequestPort = DefaultPortAllocator.RequestPort
  45. ReleasePort = DefaultPortAllocator.ReleasePort
  46. ReleaseAll = DefaultPortAllocator.ReleaseAll
  47. )
  48. type PortAllocator struct {
  49. mutex sync.Mutex
  50. ipMap ipMapping
  51. }
  52. func New() *PortAllocator {
  53. return &PortAllocator{
  54. ipMap: ipMapping{},
  55. }
  56. }
  57. type ErrPortAlreadyAllocated struct {
  58. ip string
  59. port int
  60. }
  61. func NewErrPortAlreadyAllocated(ip string, port int) ErrPortAlreadyAllocated {
  62. return ErrPortAlreadyAllocated{
  63. ip: ip,
  64. port: port,
  65. }
  66. }
  67. func init() {
  68. const portRangeKernelParam = "/proc/sys/net/ipv4/ip_local_port_range"
  69. portRangeFallback := fmt.Sprintf("using fallback port range %d-%d", beginPortRange, endPortRange)
  70. file, err := os.Open(portRangeKernelParam)
  71. if err != nil {
  72. logrus.Warnf("port allocator - %s due to error: %v", portRangeFallback, err)
  73. return
  74. }
  75. var start, end int
  76. n, err := fmt.Fscanf(bufio.NewReader(file), "%d\t%d", &start, &end)
  77. if n != 2 || err != nil {
  78. if err == nil {
  79. err = fmt.Errorf("unexpected count of parsed numbers (%d)", n)
  80. }
  81. logrus.Errorf("port allocator - failed to parse system ephemeral port range from %s - %s: %v", portRangeKernelParam, portRangeFallback, err)
  82. return
  83. }
  84. beginPortRange = start
  85. endPortRange = end
  86. }
  87. func PortRange() (int, int) {
  88. return beginPortRange, endPortRange
  89. }
  90. func (e ErrPortAlreadyAllocated) IP() string {
  91. return e.ip
  92. }
  93. func (e ErrPortAlreadyAllocated) Port() int {
  94. return e.port
  95. }
  96. func (e ErrPortAlreadyAllocated) IPPort() string {
  97. return fmt.Sprintf("%s:%d", e.ip, e.port)
  98. }
  99. func (e ErrPortAlreadyAllocated) Error() string {
  100. return fmt.Sprintf("Bind for %s:%d failed: port is already allocated", e.ip, e.port)
  101. }
  102. // RequestPort requests new port from global ports pool for specified ip and proto.
  103. // If port is 0 it returns first free port. Otherwise it cheks port availability
  104. // in pool and return that port or error if port is already busy.
  105. func (p *PortAllocator) RequestPort(ip net.IP, proto string, port int) (int, error) {
  106. p.mutex.Lock()
  107. defer p.mutex.Unlock()
  108. if proto != "tcp" && proto != "udp" {
  109. return 0, ErrUnknownProtocol
  110. }
  111. if ip == nil {
  112. ip = defaultIP
  113. }
  114. ipstr := ip.String()
  115. protomap, ok := p.ipMap[ipstr]
  116. if !ok {
  117. protomap = newProtoMap()
  118. p.ipMap[ipstr] = protomap
  119. }
  120. mapping := protomap[proto]
  121. if port > 0 {
  122. if _, ok := mapping.p[port]; !ok {
  123. mapping.p[port] = struct{}{}
  124. return port, nil
  125. }
  126. return 0, NewErrPortAlreadyAllocated(ipstr, port)
  127. }
  128. port, err := mapping.findPort()
  129. if err != nil {
  130. return 0, err
  131. }
  132. return port, nil
  133. }
  134. // ReleasePort releases port from global ports pool for specified ip and proto.
  135. func (p *PortAllocator) ReleasePort(ip net.IP, proto string, port int) error {
  136. p.mutex.Lock()
  137. defer p.mutex.Unlock()
  138. if ip == nil {
  139. ip = defaultIP
  140. }
  141. protomap, ok := p.ipMap[ip.String()]
  142. if !ok {
  143. return nil
  144. }
  145. delete(protomap[proto].p, port)
  146. return nil
  147. }
  148. // ReleaseAll releases all ports for all ips.
  149. func (p *PortAllocator) ReleaseAll() error {
  150. p.mutex.Lock()
  151. p.ipMap = ipMapping{}
  152. p.mutex.Unlock()
  153. return nil
  154. }
  155. func (pm *portMap) findPort() (int, error) {
  156. port := pm.last
  157. for i := 0; i <= endPortRange-beginPortRange; i++ {
  158. port++
  159. if port > endPortRange {
  160. port = beginPortRange
  161. }
  162. if _, ok := pm.p[port]; !ok {
  163. pm.p[port] = struct{}{}
  164. pm.last = port
  165. return port, nil
  166. }
  167. }
  168. return 0, ErrAllPortsAllocated
  169. }