Skip to content
This repository was archived by the owner on Jun 18, 2022. It is now read-only.

Commit

Permalink
Merge pull request #93 from ibuildthecloud/unneeded
Browse files Browse the repository at this point in the history
Delete unneeded code
  • Loading branch information
Craig Jellick authored Nov 17, 2016
2 parents 4504f82 + e6aeae4 commit 40c8265
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 102 deletions.
2 changes: 0 additions & 2 deletions core/compute/compute.go
Original file line number Diff line number Diff line change
Expand Up @@ -82,8 +82,6 @@ func DoInstanceActivate(instance model.Instance, host model.Host, progress *prog
return errors.Wrap(err, constants.DoInstanceActivateError+"failed to set up networking")
}

flagSystemContainer(instance, &config)

setupProxy(instance, &config)

setupCattleConfigURL(instance, &config)
Expand Down
12 changes: 2 additions & 10 deletions core/compute/compute_common.go
Original file line number Diff line number Diff line change
Expand Up @@ -185,17 +185,9 @@ func setupHeathConfig(instanceFields model.InstanceFields, config *container.Con
config.Healthcheck = healthConfig
}

func flagSystemContainer(instance model.Instance, config *container.Config) {
if instance.SystemContainer != "" {
utils.AddLabel(config, constants.SystemLabels, instance.SystemContainer)
}
}

func setupProxy(instance model.Instance, config *container.Config) {
if instance.SystemContainer != "" {
for _, i := range constants.HTTPProxyList {
config.Env = append(config.Env, fmt.Sprintf("%v=%v", i, os.Getenv(i)))
}
for _, i := range constants.HTTPProxyList {
config.Env = append(config.Env, fmt.Sprintf("%v=%v", i, os.Getenv(i)))
}
}

Expand Down
93 changes: 4 additions & 89 deletions core/compute/compute_unix.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,10 +34,6 @@ func setupPublishPorts(hostConfig *container.HostConfig, instance model.Instance
}

func setupDNSSearch(hostConfig *container.HostConfig, instance model.Instance) error {
systemCon := instance.SystemContainer
if systemCon != "" {
return nil
}
// if only rancher search is specified,
// prepend search with params read from the system
allRancher := true
Expand Down Expand Up @@ -109,8 +105,6 @@ func setupNetworking(instance model.Instance, host model.Host, config *container
setupMacAndIP(instance, config, portsSupported, hostnameSupported)
setupPortsNetwork(instance, config, hostConfig, portsSupported)
setupLinksNetwork(instance, config, hostConfig)
setupIpsec(instance, host, config, hostConfig)
setupDNS(instance)
return nil
}

Expand Down Expand Up @@ -214,6 +208,10 @@ func setupNetworkMode(instance model.Instance, client *client.Client,
config.NetworkDisabled = false
hostConfig.NetworkMode = "none"
hostConfig.Links = nil
if strings.HasPrefix(infoData.Version.Version, "1.10") {
hostConfig.DNS = nil
hostConfig.DNSSearch = nil
}
}
}
return portsSupported, hostnameSupported, nil
Expand All @@ -233,89 +231,6 @@ func setupPortsNetwork(instance model.Instance, config *container.Config,
}
}

func setupIpsec(instance model.Instance, host model.Host, config *container.Config,
hostConfig *container.HostConfig) {
/*
If the supplied instance is a network agent, configures the ports needed
to achieve multi-host networking.
*/
networkAgent := false
if instance.SystemContainer == "" || instance.SystemContainer == "NetworkAgent" {
networkAgent = true
}
if !networkAgent || !utils.HasService(instance, "ipsecTunnelService") {
return
}
hostID := strconv.Itoa(host.ID)
if endPoint, ok := instance.Data.IPSec[hostID]; ok {
natValue := endPoint.Nat
isakmp := endPoint.Isakmp
binding := hostConfig.PortBindings

port1 := nat.Port(fmt.Sprintf("%v/%v", 500, "udp"))
port2 := nat.Port(fmt.Sprintf("%v/%v", 4500, "udp"))
bind1 := nat.PortBinding{
HostIP: "0.0.0.0",
HostPort: strconv.Itoa(int(isakmp)),
}
bind2 := nat.PortBinding{
HostIP: "0.0.0.0",
HostPort: strconv.Itoa(int(natValue)),
}
exposedPorts := map[nat.Port]struct{}{
port1: {},
port2: {},
}
if _, ok := binding[port1]; ok {
binding[port1] = append(binding[port1], bind1)
} else {
binding[port1] = []nat.PortBinding{bind1}
}
if _, ok := binding[port2]; ok {
binding[port2] = append(binding[port2], bind1)
} else {
binding[port2] = []nat.PortBinding{bind2}
}
if len(config.ExposedPorts) > 0 {
existingMap := config.ExposedPorts
for port := range exposedPorts {
existingMap[port] = struct{}{}
}
config.ExposedPorts = existingMap
} else {
config.ExposedPorts = exposedPorts
}
}
}

func setupDNS(instance model.Instance) {
if !utils.HasService(instance, "dnsService") || instance.Kind == "virtualMachine" {
return
}
ipAddress, macAddress, subnet := utils.FindIPAndMac(instance)

if ipAddress == "" || macAddress == "" {
return
}

parts := strings.Split(ipAddress, ".")
if len(parts) != 4 {
return
}
part2, _ := strconv.Atoi(parts[2])
part3, _ := strconv.Atoi(parts[3])
mark := strconv.Itoa(part2*1000 + part3)

utils.CheckOutput([]string{"iptables", "-w", "-t", "nat", "-A", "CATTLE_PREROUTING",
"!", "-s", subnet, "-d", "169.254.169.250", "-m", "mac",
"--mac-source", macAddress, "-j", "MARK", "--set-mark",
mark})
utils.CheckOutput([]string{"iptables", "-w", "-t", "nat", "-A", "CATTLE_POSTROUTING",
"!", "-s", subnet, "-d", "169.254.169.250", "-m", "mark", "--mark", mark,
"-j", "SNAT", "--to", ipAddress})

}

func setupLinksNetwork(instance model.Instance, config *container.Config,
hostConfig *container.HostConfig) {
/*
Expand Down
1 change: 0 additions & 1 deletion model/instance.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,6 @@ type Instance struct {
InstanceLinks []Link
NetworkContainer *Instance
NativeContainer bool
SystemContainer string
DataVolumesFromContainers []*Instance
CommandArgs []string
Labels map[string]interface{}
Expand Down

0 comments on commit 40c8265

Please sign in to comment.