gistfile1.txt

// Allocate is the call that you can use to allocate a set of devices
// from the registered device plugins.
func (m *ManagerImpl) Allocate(node *schedulercache.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error {
        pod := attrs.Pod
        devicesToReuse := make(map[string]sets.String)
        // TODO: Reuse devices between init containers and regular containers.
        for _, container := range pod.Spec.InitContainers {
                if err := m.allocateContainerResources(pod, &container, devicesToReuse); err != nil {
                        return err
                }
                m.podDevices.addContainerAllocatedResources(string(pod.UID), container.Name, devicesToReuse)
        }
        for _, container := range pod.Spec.Containers {
                if err := m.allocateContainerResources(pod, &container, devicesToReuse); err != nil {
                        return err
                }
                m.podDevices.removeContainerAllocatedResources(string(pod.UID), container.Name, devicesToReuse)
        }

        m.mutex.Lock()
        defer m.mutex.Unlock()

        // quick return if no pluginResources requested
        if _, podRequireDevicePluginResource := m.podDevices[string(pod.UID)]; !podRequireDevicePluginResource {
                return nil
        }

        m.sanitizeNodeAllocatable(node)
        return nil
}