service_linux.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767
  1. package libnetwork
  2. import (
  3. "fmt"
  4. "io"
  5. "io/ioutil"
  6. "net"
  7. "os"
  8. "os/exec"
  9. "path/filepath"
  10. "runtime"
  11. "strconv"
  12. "strings"
  13. "sync"
  14. "syscall"
  15. "github.com/docker/docker/pkg/reexec"
  16. "github.com/docker/libnetwork/iptables"
  17. "github.com/docker/libnetwork/ipvs"
  18. "github.com/docker/libnetwork/ns"
  19. "github.com/gogo/protobuf/proto"
  20. "github.com/ishidawataru/sctp"
  21. "github.com/sirupsen/logrus"
  22. "github.com/vishvananda/netlink/nl"
  23. "github.com/vishvananda/netns"
  24. )
  25. func init() {
  26. reexec.Register("fwmarker", fwMarker)
  27. reexec.Register("redirecter", redirecter)
  28. }
  29. // Populate all loadbalancers on the network that the passed endpoint
  30. // belongs to, into this sandbox.
  31. func (sb *sandbox) populateLoadBalancers(ep *endpoint) {
  32. // This is an interface less endpoint. Nothing to do.
  33. if ep.Iface() == nil {
  34. return
  35. }
  36. n := ep.getNetwork()
  37. eIP := ep.Iface().Address()
  38. if n.ingress {
  39. if err := addRedirectRules(sb.Key(), eIP, ep.ingressPorts); err != nil {
  40. logrus.Errorf("Failed to add redirect rules for ep %s (%s): %v", ep.Name(), ep.ID()[0:7], err)
  41. }
  42. }
  43. }
  44. func (n *network) findLBEndpointSandbox() (*endpoint, *sandbox, error) {
  45. // TODO: get endpoint from store? See EndpointInfo()
  46. var ep *endpoint
  47. // Find this node's LB sandbox endpoint: there should be exactly one
  48. for _, e := range n.Endpoints() {
  49. epi := e.Info()
  50. if epi != nil && epi.LoadBalancer() {
  51. ep = e.(*endpoint)
  52. break
  53. }
  54. }
  55. if ep == nil {
  56. return nil, nil, fmt.Errorf("Unable to find load balancing endpoint for network %s", n.ID())
  57. }
  58. // Get the load balancer sandbox itself as well
  59. sb, ok := ep.getSandbox()
  60. if !ok {
  61. return nil, nil, fmt.Errorf("Unable to get sandbox for %s(%s) in for %s", ep.Name(), ep.ID(), n.ID())
  62. }
  63. ep = sb.getEndpoint(ep.ID())
  64. if ep == nil {
  65. return nil, nil, fmt.Errorf("Load balancing endpoint %s(%s) removed from %s", ep.Name(), ep.ID(), n.ID())
  66. }
  67. return ep, sb, nil
  68. }
  69. // Searches the OS sandbox for the name of the endpoint interface
  70. // within the sandbox. This is required for adding/removing IP
  71. // aliases to the interface.
  72. func findIfaceDstName(sb *sandbox, ep *endpoint) string {
  73. srcName := ep.Iface().SrcName()
  74. for _, i := range sb.osSbox.Info().Interfaces() {
  75. if i.SrcName() == srcName {
  76. return i.DstName()
  77. }
  78. }
  79. return ""
  80. }
  81. // Add loadbalancer backend to the loadbalncer sandbox for the network.
  82. // If needed add the service as well.
  83. func (n *network) addLBBackend(ip net.IP, lb *loadBalancer) {
  84. if len(lb.vip) == 0 {
  85. return
  86. }
  87. ep, sb, err := n.findLBEndpointSandbox()
  88. if err != nil {
  89. logrus.Errorf("addLBBackend %s/%s: %v", n.ID(), n.Name(), err)
  90. return
  91. }
  92. if sb.osSbox == nil {
  93. return
  94. }
  95. eIP := ep.Iface().Address()
  96. i, err := ipvs.New(sb.Key())
  97. if err != nil {
  98. logrus.Errorf("Failed to create an ipvs handle for sbox %s (%s,%s) for lb addition: %v", sb.ID()[0:7], sb.ContainerID()[0:7], sb.Key(), err)
  99. return
  100. }
  101. defer i.Close()
  102. s := &ipvs.Service{
  103. AddressFamily: nl.FAMILY_V4,
  104. FWMark: lb.fwMark,
  105. SchedName: ipvs.RoundRobin,
  106. }
  107. if !i.IsServicePresent(s) {
  108. // Add IP alias for the VIP to the endpoint
  109. ifName := findIfaceDstName(sb, ep)
  110. if ifName == "" {
  111. logrus.Errorf("Failed find interface name for endpoint %s(%s) to create LB alias", ep.ID(), ep.Name())
  112. return
  113. }
  114. err := sb.osSbox.AddAliasIP(ifName, &net.IPNet{IP: lb.vip, Mask: net.CIDRMask(32, 32)})
  115. if err != nil {
  116. logrus.Errorf("Failed add IP alias %s to network %s LB endpoint interface %s: %v", lb.vip, n.ID(), ifName, err)
  117. return
  118. }
  119. if sb.ingress {
  120. var gwIP net.IP
  121. if ep := sb.getGatewayEndpoint(); ep != nil {
  122. gwIP = ep.Iface().Address().IP
  123. }
  124. filteredPorts := filterPortConfigs(lb.service.ingressPorts, false)
  125. if err := programIngress(gwIP, filteredPorts, false); err != nil {
  126. logrus.Errorf("Failed to add ingress: %v", err)
  127. return
  128. }
  129. }
  130. logrus.Debugf("Creating service for vip %s fwMark %d ingressPorts %#v in sbox %s (%s)", lb.vip, lb.fwMark, lb.service.ingressPorts, sb.ID()[0:7], sb.ContainerID()[0:7])
  131. if err := invokeFWMarker(sb.Key(), lb.vip, lb.fwMark, lb.service.ingressPorts, eIP, false); err != nil {
  132. logrus.Errorf("Failed to add firewall mark rule in sbox %s (%s): %v", sb.ID()[0:7], sb.ContainerID()[0:7], err)
  133. return
  134. }
  135. if err := i.NewService(s); err != nil && err != syscall.EEXIST {
  136. logrus.Errorf("Failed to create a new service for vip %s fwmark %d in sbox %s (%s): %v", lb.vip, lb.fwMark, sb.ID()[0:7], sb.ContainerID()[0:7], err)
  137. return
  138. }
  139. }
  140. d := &ipvs.Destination{
  141. AddressFamily: nl.FAMILY_V4,
  142. Address: ip,
  143. Weight: 1,
  144. }
  145. // Remove the sched name before using the service to add
  146. // destination.
  147. s.SchedName = ""
  148. if err := i.NewDestination(s, d); err != nil && err != syscall.EEXIST {
  149. logrus.Errorf("Failed to create real server %s for vip %s fwmark %d in sbox %s (%s): %v", ip, lb.vip, lb.fwMark, sb.ID()[0:7], sb.ContainerID()[0:7], err)
  150. }
  151. }
  152. // Remove loadbalancer backend the load balancing endpoint for this
  153. // network. If 'rmService' is true, then remove the service entry as well.
  154. // If 'fullRemove' is true then completely remove the entry, otherwise
  155. // just deweight it for now.
  156. func (n *network) rmLBBackend(ip net.IP, lb *loadBalancer, rmService bool, fullRemove bool) {
  157. if len(lb.vip) == 0 {
  158. return
  159. }
  160. ep, sb, err := n.findLBEndpointSandbox()
  161. if err != nil {
  162. logrus.Debugf("rmLBBackend for %s/%s: %v -- probably transient state", n.ID(), n.Name(), err)
  163. return
  164. }
  165. if sb.osSbox == nil {
  166. return
  167. }
  168. eIP := ep.Iface().Address()
  169. i, err := ipvs.New(sb.Key())
  170. if err != nil {
  171. logrus.Errorf("Failed to create an ipvs handle for sbox %s (%s,%s) for lb removal: %v", sb.ID()[0:7], sb.ContainerID()[0:7], sb.Key(), err)
  172. return
  173. }
  174. defer i.Close()
  175. s := &ipvs.Service{
  176. AddressFamily: nl.FAMILY_V4,
  177. FWMark: lb.fwMark,
  178. }
  179. d := &ipvs.Destination{
  180. AddressFamily: nl.FAMILY_V4,
  181. Address: ip,
  182. Weight: 1,
  183. }
  184. if fullRemove {
  185. if err := i.DelDestination(s, d); err != nil && err != syscall.ENOENT {
  186. logrus.Errorf("Failed to delete real server %s for vip %s fwmark %d in sbox %s (%s): %v", ip, lb.vip, lb.fwMark, sb.ID()[0:7], sb.ContainerID()[0:7], err)
  187. }
  188. } else {
  189. d.Weight = 0
  190. if err := i.UpdateDestination(s, d); err != nil && err != syscall.ENOENT {
  191. logrus.Errorf("Failed to set LB weight of real server %s to 0 for vip %s fwmark %d in sbox %s (%s): %v", ip, lb.vip, lb.fwMark, sb.ID()[0:7], sb.ContainerID()[0:7], err)
  192. }
  193. }
  194. if rmService {
  195. s.SchedName = ipvs.RoundRobin
  196. if err := i.DelService(s); err != nil && err != syscall.ENOENT {
  197. logrus.Errorf("Failed to delete service for vip %s fwmark %d in sbox %s (%s): %v", lb.vip, lb.fwMark, sb.ID()[0:7], sb.ContainerID()[0:7], err)
  198. }
  199. if sb.ingress {
  200. var gwIP net.IP
  201. if ep := sb.getGatewayEndpoint(); ep != nil {
  202. gwIP = ep.Iface().Address().IP
  203. }
  204. filteredPorts := filterPortConfigs(lb.service.ingressPorts, true)
  205. if err := programIngress(gwIP, filteredPorts, true); err != nil {
  206. logrus.Errorf("Failed to delete ingress: %v", err)
  207. }
  208. }
  209. if err := invokeFWMarker(sb.Key(), lb.vip, lb.fwMark, lb.service.ingressPorts, eIP, true); err != nil {
  210. logrus.Errorf("Failed to delete firewall mark rule in sbox %s (%s): %v", sb.ID()[0:7], sb.ContainerID()[0:7], err)
  211. }
  212. // Remove IP alias from the VIP to the endpoint
  213. ifName := findIfaceDstName(sb, ep)
  214. if ifName == "" {
  215. logrus.Errorf("Failed find interface name for endpoint %s(%s) to create LB alias", ep.ID(), ep.Name())
  216. return
  217. }
  218. err := sb.osSbox.RemoveAliasIP(ifName, &net.IPNet{IP: lb.vip, Mask: net.CIDRMask(32, 32)})
  219. if err != nil {
  220. logrus.Errorf("Failed add IP alias %s to network %s LB endpoint interface %s: %v", lb.vip, n.ID(), ifName, err)
  221. }
  222. }
  223. }
  224. const ingressChain = "DOCKER-INGRESS"
  225. var (
  226. ingressOnce sync.Once
  227. ingressMu sync.Mutex // lock for operations on ingress
  228. ingressProxyTbl = make(map[string]io.Closer)
  229. portConfigMu sync.Mutex
  230. portConfigTbl = make(map[PortConfig]int)
  231. )
  232. func filterPortConfigs(ingressPorts []*PortConfig, isDelete bool) []*PortConfig {
  233. portConfigMu.Lock()
  234. iPorts := make([]*PortConfig, 0, len(ingressPorts))
  235. for _, pc := range ingressPorts {
  236. if isDelete {
  237. if cnt, ok := portConfigTbl[*pc]; ok {
  238. // This is the last reference to this
  239. // port config. Delete the port config
  240. // and add it to filtered list to be
  241. // plumbed.
  242. if cnt == 1 {
  243. delete(portConfigTbl, *pc)
  244. iPorts = append(iPorts, pc)
  245. continue
  246. }
  247. portConfigTbl[*pc] = cnt - 1
  248. }
  249. continue
  250. }
  251. if cnt, ok := portConfigTbl[*pc]; ok {
  252. portConfigTbl[*pc] = cnt + 1
  253. continue
  254. }
  255. // We are adding it for the first time. Add it to the
  256. // filter list to be plumbed.
  257. portConfigTbl[*pc] = 1
  258. iPorts = append(iPorts, pc)
  259. }
  260. portConfigMu.Unlock()
  261. return iPorts
  262. }
  263. func programIngress(gwIP net.IP, ingressPorts []*PortConfig, isDelete bool) error {
  264. addDelOpt := "-I"
  265. if isDelete {
  266. addDelOpt = "-D"
  267. }
  268. ingressMu.Lock()
  269. defer ingressMu.Unlock()
  270. chainExists := iptables.ExistChain(ingressChain, iptables.Nat)
  271. filterChainExists := iptables.ExistChain(ingressChain, iptables.Filter)
  272. ingressOnce.Do(func() {
  273. // Flush nat table and filter table ingress chain rules during init if it
  274. // exists. It might contain stale rules from previous life.
  275. if chainExists {
  276. if err := iptables.RawCombinedOutput("-t", "nat", "-F", ingressChain); err != nil {
  277. logrus.Errorf("Could not flush nat table ingress chain rules during init: %v", err)
  278. }
  279. }
  280. if filterChainExists {
  281. if err := iptables.RawCombinedOutput("-F", ingressChain); err != nil {
  282. logrus.Errorf("Could not flush filter table ingress chain rules during init: %v", err)
  283. }
  284. }
  285. })
  286. if !isDelete {
  287. if !chainExists {
  288. if err := iptables.RawCombinedOutput("-t", "nat", "-N", ingressChain); err != nil {
  289. return fmt.Errorf("failed to create ingress chain: %v", err)
  290. }
  291. }
  292. if !filterChainExists {
  293. if err := iptables.RawCombinedOutput("-N", ingressChain); err != nil {
  294. return fmt.Errorf("failed to create filter table ingress chain: %v", err)
  295. }
  296. }
  297. if !iptables.Exists(iptables.Nat, ingressChain, "-j", "RETURN") {
  298. if err := iptables.RawCombinedOutput("-t", "nat", "-A", ingressChain, "-j", "RETURN"); err != nil {
  299. return fmt.Errorf("failed to add return rule in nat table ingress chain: %v", err)
  300. }
  301. }
  302. if !iptables.Exists(iptables.Filter, ingressChain, "-j", "RETURN") {
  303. if err := iptables.RawCombinedOutput("-A", ingressChain, "-j", "RETURN"); err != nil {
  304. return fmt.Errorf("failed to add return rule to filter table ingress chain: %v", err)
  305. }
  306. }
  307. for _, chain := range []string{"OUTPUT", "PREROUTING"} {
  308. if !iptables.Exists(iptables.Nat, chain, "-m", "addrtype", "--dst-type", "LOCAL", "-j", ingressChain) {
  309. if err := iptables.RawCombinedOutput("-t", "nat", "-I", chain, "-m", "addrtype", "--dst-type", "LOCAL", "-j", ingressChain); err != nil {
  310. return fmt.Errorf("failed to add jump rule in %s to ingress chain: %v", chain, err)
  311. }
  312. }
  313. }
  314. if !iptables.Exists(iptables.Filter, "FORWARD", "-j", ingressChain) {
  315. if err := iptables.RawCombinedOutput("-I", "FORWARD", "-j", ingressChain); err != nil {
  316. return fmt.Errorf("failed to add jump rule to %s in filter table forward chain: %v", ingressChain, err)
  317. }
  318. arrangeUserFilterRule()
  319. }
  320. oifName, err := findOIFName(gwIP)
  321. if err != nil {
  322. return fmt.Errorf("failed to find gateway bridge interface name for %s: %v", gwIP, err)
  323. }
  324. path := filepath.Join("/proc/sys/net/ipv4/conf", oifName, "route_localnet")
  325. if err := ioutil.WriteFile(path, []byte{'1', '\n'}, 0644); err != nil {
  326. return fmt.Errorf("could not write to %s: %v", path, err)
  327. }
  328. ruleArgs := strings.Fields(fmt.Sprintf("-m addrtype --src-type LOCAL -o %s -j MASQUERADE", oifName))
  329. if !iptables.Exists(iptables.Nat, "POSTROUTING", ruleArgs...) {
  330. if err := iptables.RawCombinedOutput(append([]string{"-t", "nat", "-I", "POSTROUTING"}, ruleArgs...)...); err != nil {
  331. return fmt.Errorf("failed to add ingress localhost POSTROUTING rule for %s: %v", oifName, err)
  332. }
  333. }
  334. }
  335. for _, iPort := range ingressPorts {
  336. if iptables.ExistChain(ingressChain, iptables.Nat) {
  337. rule := strings.Fields(fmt.Sprintf("-t nat %s %s -p %s --dport %d -j DNAT --to-destination %s:%d",
  338. addDelOpt, ingressChain, strings.ToLower(PortConfig_Protocol_name[int32(iPort.Protocol)]), iPort.PublishedPort, gwIP, iPort.PublishedPort))
  339. if err := iptables.RawCombinedOutput(rule...); err != nil {
  340. errStr := fmt.Sprintf("setting up rule failed, %v: %v", rule, err)
  341. if !isDelete {
  342. return fmt.Errorf("%s", errStr)
  343. }
  344. logrus.Infof("%s", errStr)
  345. }
  346. }
  347. // Filter table rules to allow a published service to be accessible in the local node from..
  348. // 1) service tasks attached to other networks
  349. // 2) unmanaged containers on bridge networks
  350. rule := strings.Fields(fmt.Sprintf("%s %s -m state -p %s --sport %d --state ESTABLISHED,RELATED -j ACCEPT",
  351. addDelOpt, ingressChain, strings.ToLower(PortConfig_Protocol_name[int32(iPort.Protocol)]), iPort.PublishedPort))
  352. if err := iptables.RawCombinedOutput(rule...); err != nil {
  353. errStr := fmt.Sprintf("setting up rule failed, %v: %v", rule, err)
  354. if !isDelete {
  355. return fmt.Errorf("%s", errStr)
  356. }
  357. logrus.Warnf("%s", errStr)
  358. }
  359. rule = strings.Fields(fmt.Sprintf("%s %s -p %s --dport %d -j ACCEPT",
  360. addDelOpt, ingressChain, strings.ToLower(PortConfig_Protocol_name[int32(iPort.Protocol)]), iPort.PublishedPort))
  361. if err := iptables.RawCombinedOutput(rule...); err != nil {
  362. errStr := fmt.Sprintf("setting up rule failed, %v: %v", rule, err)
  363. if !isDelete {
  364. return fmt.Errorf("%s", errStr)
  365. }
  366. logrus.Warnf("%s", errStr)
  367. }
  368. if err := plumbProxy(iPort, isDelete); err != nil {
  369. logrus.Warnf("failed to create proxy for port %d: %v", iPort.PublishedPort, err)
  370. }
  371. }
  372. return nil
  373. }
  374. // In the filter table FORWARD chain the first rule should be to jump to
  375. // DOCKER-USER so the user is able to filter packet first.
  376. // The second rule should be jump to INGRESS-CHAIN.
  377. // This chain has the rules to allow access to the published ports for swarm tasks
  378. // from local bridge networks and docker_gwbridge (ie:taks on other swarm netwroks)
  379. func arrangeIngressFilterRule() {
  380. if iptables.ExistChain(ingressChain, iptables.Filter) {
  381. if iptables.Exists(iptables.Filter, "FORWARD", "-j", ingressChain) {
  382. if err := iptables.RawCombinedOutput("-D", "FORWARD", "-j", ingressChain); err != nil {
  383. logrus.Warnf("failed to delete jump rule to ingressChain in filter table: %v", err)
  384. }
  385. }
  386. if err := iptables.RawCombinedOutput("-I", "FORWARD", "-j", ingressChain); err != nil {
  387. logrus.Warnf("failed to add jump rule to ingressChain in filter table: %v", err)
  388. }
  389. }
  390. }
  391. func findOIFName(ip net.IP) (string, error) {
  392. nlh := ns.NlHandle()
  393. routes, err := nlh.RouteGet(ip)
  394. if err != nil {
  395. return "", err
  396. }
  397. if len(routes) == 0 {
  398. return "", fmt.Errorf("no route to %s", ip)
  399. }
  400. // Pick the first route(typically there is only one route). We
  401. // don't support multipath.
  402. link, err := nlh.LinkByIndex(routes[0].LinkIndex)
  403. if err != nil {
  404. return "", err
  405. }
  406. return link.Attrs().Name, nil
  407. }
  408. func plumbProxy(iPort *PortConfig, isDelete bool) error {
  409. var (
  410. err error
  411. l io.Closer
  412. )
  413. portSpec := fmt.Sprintf("%d/%s", iPort.PublishedPort, strings.ToLower(PortConfig_Protocol_name[int32(iPort.Protocol)]))
  414. if isDelete {
  415. if listener, ok := ingressProxyTbl[portSpec]; ok {
  416. if listener != nil {
  417. listener.Close()
  418. }
  419. }
  420. return nil
  421. }
  422. switch iPort.Protocol {
  423. case ProtocolTCP:
  424. l, err = net.ListenTCP("tcp", &net.TCPAddr{Port: int(iPort.PublishedPort)})
  425. case ProtocolUDP:
  426. l, err = net.ListenUDP("udp", &net.UDPAddr{Port: int(iPort.PublishedPort)})
  427. case ProtocolSCTP:
  428. l, err = sctp.ListenSCTP("sctp", &sctp.SCTPAddr{Port: int(iPort.PublishedPort)})
  429. default:
  430. err = fmt.Errorf("unknown protocol %v", iPort.Protocol)
  431. }
  432. if err != nil {
  433. return err
  434. }
  435. ingressProxyTbl[portSpec] = l
  436. return nil
  437. }
  438. func writePortsToFile(ports []*PortConfig) (string, error) {
  439. f, err := ioutil.TempFile("", "port_configs")
  440. if err != nil {
  441. return "", err
  442. }
  443. defer f.Close()
  444. buf, _ := proto.Marshal(&EndpointRecord{
  445. IngressPorts: ports,
  446. })
  447. n, err := f.Write(buf)
  448. if err != nil {
  449. return "", err
  450. }
  451. if n < len(buf) {
  452. return "", io.ErrShortWrite
  453. }
  454. return f.Name(), nil
  455. }
  456. func readPortsFromFile(fileName string) ([]*PortConfig, error) {
  457. buf, err := ioutil.ReadFile(fileName)
  458. if err != nil {
  459. return nil, err
  460. }
  461. var epRec EndpointRecord
  462. err = proto.Unmarshal(buf, &epRec)
  463. if err != nil {
  464. return nil, err
  465. }
  466. return epRec.IngressPorts, nil
  467. }
  468. // Invoke fwmarker reexec routine to mark vip destined packets with
  469. // the passed firewall mark.
  470. func invokeFWMarker(path string, vip net.IP, fwMark uint32, ingressPorts []*PortConfig, eIP *net.IPNet, isDelete bool) error {
  471. var ingressPortsFile string
  472. if len(ingressPorts) != 0 {
  473. var err error
  474. ingressPortsFile, err = writePortsToFile(ingressPorts)
  475. if err != nil {
  476. return err
  477. }
  478. defer os.Remove(ingressPortsFile)
  479. }
  480. addDelOpt := "-A"
  481. if isDelete {
  482. addDelOpt = "-D"
  483. }
  484. cmd := &exec.Cmd{
  485. Path: reexec.Self(),
  486. Args: append([]string{"fwmarker"}, path, vip.String(), fmt.Sprintf("%d", fwMark), addDelOpt, ingressPortsFile, eIP.String()),
  487. Stdout: os.Stdout,
  488. Stderr: os.Stderr,
  489. }
  490. if err := cmd.Run(); err != nil {
  491. return fmt.Errorf("reexec failed: %v", err)
  492. }
  493. return nil
  494. }
  495. // Firewall marker reexec function.
  496. func fwMarker() {
  497. runtime.LockOSThread()
  498. defer runtime.UnlockOSThread()
  499. if len(os.Args) < 7 {
  500. logrus.Error("invalid number of arguments..")
  501. os.Exit(1)
  502. }
  503. var ingressPorts []*PortConfig
  504. if os.Args[5] != "" {
  505. var err error
  506. ingressPorts, err = readPortsFromFile(os.Args[5])
  507. if err != nil {
  508. logrus.Errorf("Failed reading ingress ports file: %v", err)
  509. os.Exit(2)
  510. }
  511. }
  512. vip := os.Args[2]
  513. fwMark, err := strconv.ParseUint(os.Args[3], 10, 32)
  514. if err != nil {
  515. logrus.Errorf("bad fwmark value(%s) passed: %v", os.Args[3], err)
  516. os.Exit(3)
  517. }
  518. addDelOpt := os.Args[4]
  519. rules := [][]string{}
  520. for _, iPort := range ingressPorts {
  521. rule := strings.Fields(fmt.Sprintf("-t mangle %s PREROUTING -p %s --dport %d -j MARK --set-mark %d",
  522. addDelOpt, strings.ToLower(PortConfig_Protocol_name[int32(iPort.Protocol)]), iPort.PublishedPort, fwMark))
  523. rules = append(rules, rule)
  524. }
  525. ns, err := netns.GetFromPath(os.Args[1])
  526. if err != nil {
  527. logrus.Errorf("failed get network namespace %q: %v", os.Args[1], err)
  528. os.Exit(4)
  529. }
  530. defer ns.Close()
  531. if err := netns.Set(ns); err != nil {
  532. logrus.Errorf("setting into container net ns %v failed, %v", os.Args[1], err)
  533. os.Exit(5)
  534. }
  535. if addDelOpt == "-A" {
  536. eIP, subnet, err := net.ParseCIDR(os.Args[6])
  537. if err != nil {
  538. logrus.Errorf("Failed to parse endpoint IP %s: %v", os.Args[6], err)
  539. os.Exit(6)
  540. }
  541. ruleParams := strings.Fields(fmt.Sprintf("-m ipvs --ipvs -d %s -j SNAT --to-source %s", subnet, eIP))
  542. if !iptables.Exists("nat", "POSTROUTING", ruleParams...) {
  543. rule := append(strings.Fields("-t nat -A POSTROUTING"), ruleParams...)
  544. rules = append(rules, rule)
  545. err := ioutil.WriteFile("/proc/sys/net/ipv4/vs/conntrack", []byte{'1', '\n'}, 0644)
  546. if err != nil {
  547. logrus.Errorf("Failed to write to /proc/sys/net/ipv4/vs/conntrack: %v", err)
  548. os.Exit(7)
  549. }
  550. }
  551. }
  552. rule := strings.Fields(fmt.Sprintf("-t mangle %s INPUT -d %s/32 -j MARK --set-mark %d", addDelOpt, vip, fwMark))
  553. rules = append(rules, rule)
  554. for _, rule := range rules {
  555. if err := iptables.RawCombinedOutputNative(rule...); err != nil {
  556. logrus.Errorf("setting up rule failed, %v: %v", rule, err)
  557. os.Exit(8)
  558. }
  559. }
  560. }
  561. func addRedirectRules(path string, eIP *net.IPNet, ingressPorts []*PortConfig) error {
  562. var ingressPortsFile string
  563. if len(ingressPorts) != 0 {
  564. var err error
  565. ingressPortsFile, err = writePortsToFile(ingressPorts)
  566. if err != nil {
  567. return err
  568. }
  569. defer os.Remove(ingressPortsFile)
  570. }
  571. cmd := &exec.Cmd{
  572. Path: reexec.Self(),
  573. Args: append([]string{"redirecter"}, path, eIP.String(), ingressPortsFile),
  574. Stdout: os.Stdout,
  575. Stderr: os.Stderr,
  576. }
  577. if err := cmd.Run(); err != nil {
  578. return fmt.Errorf("reexec failed: %v", err)
  579. }
  580. return nil
  581. }
  582. // Redirecter reexec function.
  583. func redirecter() {
  584. runtime.LockOSThread()
  585. defer runtime.UnlockOSThread()
  586. if len(os.Args) < 4 {
  587. logrus.Error("invalid number of arguments..")
  588. os.Exit(1)
  589. }
  590. var ingressPorts []*PortConfig
  591. if os.Args[3] != "" {
  592. var err error
  593. ingressPorts, err = readPortsFromFile(os.Args[3])
  594. if err != nil {
  595. logrus.Errorf("Failed reading ingress ports file: %v", err)
  596. os.Exit(2)
  597. }
  598. }
  599. eIP, _, err := net.ParseCIDR(os.Args[2])
  600. if err != nil {
  601. logrus.Errorf("Failed to parse endpoint IP %s: %v", os.Args[2], err)
  602. os.Exit(3)
  603. }
  604. rules := [][]string{}
  605. for _, iPort := range ingressPorts {
  606. rule := strings.Fields(fmt.Sprintf("-t nat -A PREROUTING -d %s -p %s --dport %d -j REDIRECT --to-port %d",
  607. eIP.String(), strings.ToLower(PortConfig_Protocol_name[int32(iPort.Protocol)]), iPort.PublishedPort, iPort.TargetPort))
  608. rules = append(rules, rule)
  609. // Allow only incoming connections to exposed ports
  610. iRule := strings.Fields(fmt.Sprintf("-I INPUT -d %s -p %s --dport %d -m conntrack --ctstate NEW,ESTABLISHED -j ACCEPT",
  611. eIP.String(), strings.ToLower(PortConfig_Protocol_name[int32(iPort.Protocol)]), iPort.TargetPort))
  612. rules = append(rules, iRule)
  613. // Allow only outgoing connections from exposed ports
  614. oRule := strings.Fields(fmt.Sprintf("-I OUTPUT -s %s -p %s --sport %d -m conntrack --ctstate ESTABLISHED -j ACCEPT",
  615. eIP.String(), strings.ToLower(PortConfig_Protocol_name[int32(iPort.Protocol)]), iPort.TargetPort))
  616. rules = append(rules, oRule)
  617. }
  618. ns, err := netns.GetFromPath(os.Args[1])
  619. if err != nil {
  620. logrus.Errorf("failed get network namespace %q: %v", os.Args[1], err)
  621. os.Exit(4)
  622. }
  623. defer ns.Close()
  624. if err := netns.Set(ns); err != nil {
  625. logrus.Errorf("setting into container net ns %v failed, %v", os.Args[1], err)
  626. os.Exit(5)
  627. }
  628. for _, rule := range rules {
  629. if err := iptables.RawCombinedOutputNative(rule...); err != nil {
  630. logrus.Errorf("setting up rule failed, %v: %v", rule, err)
  631. os.Exit(6)
  632. }
  633. }
  634. if len(ingressPorts) == 0 {
  635. return
  636. }
  637. // Ensure blocking rules for anything else in/to ingress network
  638. for _, rule := range [][]string{
  639. {"-d", eIP.String(), "-p", "sctp", "-j", "DROP"},
  640. {"-d", eIP.String(), "-p", "udp", "-j", "DROP"},
  641. {"-d", eIP.String(), "-p", "tcp", "-j", "DROP"},
  642. } {
  643. if !iptables.ExistsNative(iptables.Filter, "INPUT", rule...) {
  644. if err := iptables.RawCombinedOutputNative(append([]string{"-A", "INPUT"}, rule...)...); err != nil {
  645. logrus.Errorf("setting up rule failed, %v: %v", rule, err)
  646. os.Exit(7)
  647. }
  648. }
  649. rule[0] = "-s"
  650. if !iptables.ExistsNative(iptables.Filter, "OUTPUT", rule...) {
  651. if err := iptables.RawCombinedOutputNative(append([]string{"-A", "OUTPUT"}, rule...)...); err != nil {
  652. logrus.Errorf("setting up rule failed, %v: %v", rule, err)
  653. os.Exit(8)
  654. }
  655. }
  656. }
  657. }