Skip to content

Commit

Permalink
Merge pull request #11744 from hashicorp/b-node-copy
Browse files Browse the repository at this point in the history
Fix Node.Copy()
  • Loading branch information
schmichael authored and lgfa29 committed Jan 18, 2022
1 parent e7caa8c commit d5b51da
Show file tree
Hide file tree
Showing 3 changed files with 15 additions and 9 deletions.
3 changes: 3 additions & 0 deletions .changelog/11744.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
```release-note:bug
core: Fix missing fields in Node.Copy()
```
4 changes: 1 addition & 3 deletions nomad/node_endpoint_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1316,9 +1316,7 @@ func TestClientEndpoint_GetNode(t *testing.T) {
node.StatusUpdatedAt = resp2.Node.StatusUpdatedAt
node.SecretID = ""
node.Events = resp2.Node.Events
if !reflect.DeepEqual(node, resp2.Node) {
t.Fatalf("bad: %#v \n %#v", node, resp2.Node)
}
require.Equal(t, node, resp2.Node)

// assert that the node register event was set correctly
if len(resp2.Node.Events) != 1 {
Expand Down
17 changes: 11 additions & 6 deletions nomad/structs/structs.go
Original file line number Diff line number Diff line change
Expand Up @@ -1971,17 +1971,17 @@ func (n *Node) Copy() *Node {
nn := new(Node)
*nn = *n
nn.Attributes = helper.CopyMapStringString(nn.Attributes)
nn.Resources = nn.Resources.Copy()
nn.Reserved = nn.Reserved.Copy()
nn.NodeResources = nn.NodeResources.Copy()
nn.ReservedResources = nn.ReservedResources.Copy()
nn.Resources = nn.Resources.Copy()
nn.Reserved = nn.Reserved.Copy()
nn.Links = helper.CopyMapStringString(nn.Links)
nn.Meta = helper.CopyMapStringString(nn.Meta)
nn.Events = copyNodeEvents(n.Events)
nn.DrainStrategy = nn.DrainStrategy.Copy()
nn.Events = copyNodeEvents(n.Events)
nn.Drivers = copyNodeDrivers(n.Drivers)
nn.CSIControllerPlugins = copyNodeCSI(nn.CSIControllerPlugins)
nn.CSINodePlugins = copyNodeCSI(nn.CSINodePlugins)
nn.Drivers = copyNodeDrivers(n.Drivers)
nn.HostVolumes = copyNodeHostVolumes(n.HostVolumes)
return nn
}
Expand Down Expand Up @@ -2580,6 +2580,7 @@ func (n *NetworkResource) Copy() *NetworkResource {
}
newR := new(NetworkResource)
*newR = *n
newR.DNS = n.DNS.Copy()
if n.ReservedPorts != nil {
newR.ReservedPorts = make([]Port, len(n.ReservedPorts))
copy(newR.ReservedPorts, n.ReservedPorts)
Expand Down Expand Up @@ -2794,8 +2795,7 @@ func (n *NodeResources) Copy() *NodeResources {

newN := new(NodeResources)
*newN = *n

// Copy the networks
newN.Cpu = n.Cpu.Copy()
newN.Networks = n.Networks.Copy()

if n.NodeNetworks != nil {
Expand Down Expand Up @@ -2979,6 +2979,11 @@ type NodeCpuResources struct {
CpuShares int64
}

func (n NodeCpuResources) Copy() NodeCpuResources {
newN := n
return newN
}

func (n *NodeCpuResources) Merge(o *NodeCpuResources) {
if o == nil {
return
Expand Down

0 comments on commit d5b51da

Please sign in to comment.