wip no need to export

client/lib/cgutil/cpuset_manager_v2.go

@@ -55,9 +55,9 @@ type cpusetManagerV2 struct {
 	initial   cpuset.CPUSet // set of initial cores (never changes)
 
 	lock      sync.RWMutex                 // hold this with regard to tracking fields
-	pool      cpuset.CPUSet                // cores being shared among across all tasks
-	sharing   map[identifier]nothing       // sharing tasks which use only cpus in the pool
-	isolating map[identifier]cpuset.CPUSet // remember which task goes where to avoid context switching
+	pool      cpuset.CPUSet                // cores being shared among all tasks
+	sharing   map[identifier]nothing       // sharing tasks which use only shared cores in the pool
+	isolating map[identifier]cpuset.CPUSet // isolating tasks which use reserved + shared cores
 }
 
 func NewCpusetManagerV2(parent string, logger hclog.Logger) CpusetManager {

drivers/docker/reconcile_cpuset.go

@@ -87,17 +87,17 @@ func (cf *cpusetFixer) fix(c coordinate) {
 }
 
 type coordinate struct {
-	ContainerID string
-	AllocID     string
-	Task        string
+	containerID string
+	allocID     string
+	task        string
 }
 
 func (c coordinate) NomadScope() string {
-	return cgutil.CgroupID(c.AllocID, c.Task)
+	return cgutil.CgroupID(c.allocID, c.task)
 }
 
 func (c coordinate) DockerScope() string {
-	return fmt.Sprintf("docker-%s.scope", c.ContainerID)
+	return fmt.Sprintf("docker-%s.scope", c.containerID)
 }
 
 func (d *Driver) trackedTasks() map[coordinate]struct{} {
@@ -107,9 +107,9 @@ func (d *Driver) trackedTasks() map[coordinate]struct{} {
 	m := make(map[coordinate]struct{}, len(d.tasks.store))
 	for _, h := range d.tasks.store {
 		m[coordinate{
-			ContainerID: h.containerID,
-			AllocID:     h.task.AllocID,
-			Task:        h.task.Name,
+			containerID: h.containerID,
+			allocID:     h.task.AllocID,
+			task:        h.task.Name,
 		}] = struct{}{}
 	}
 	return m