import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
/**
 * Returns the environment variables for the given {@link Node}.
 * 
 * @param node
 *            The {@link Node} to get the environment variables from
 * @param additionalEnvironment
 *            environment added to the environment from the {@link Node}.
 *            Take precedence over environment from the {@link Node}.
 * @return the environment variables for the given {@link Node}
 * @since 1.0
 */
public static EnvVars getEnvironment(Node node,
		EnvVars additionalEnvironment) {
	EnvVars envVars = new EnvVars();
	EnvironmentVariablesNodeProperty env = node.getNodeProperties().get(
			EnvironmentVariablesNodeProperty.class);
	if (env != null) {
		envVars.putAll(env.getEnvVars());
	}
	envVars.overrideAll(additionalEnvironment);
	return envVars;
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
@Override
public boolean start() throws Exception {
    LOGGER.log(Level.FINE, "Starting container step.");
    String containerName = step.getName();

    KubernetesNodeContext nodeContext = new KubernetesNodeContext(getContext());
    client = nodeContext.connectToCloud();

    EnvironmentExpander env = getContext().get(EnvironmentExpander.class);
    EnvVars globalVars = null;
    Jenkins instance = Jenkins.getInstance();
    DescribableList<NodeProperty<?>, NodePropertyDescriptor> globalNodeProperties = instance
            .getGlobalNodeProperties();
    List<EnvironmentVariablesNodeProperty> envVarsNodePropertyList = globalNodeProperties
            .getAll(EnvironmentVariablesNodeProperty.class);
    if (envVarsNodePropertyList != null && envVarsNodePropertyList.size() != 0) {
        globalVars = envVarsNodePropertyList.get(0).getEnvVars();
    }
    decorator = new ContainerExecDecorator();
    decorator.setClient(client);
    decorator.setPodName(nodeContext.getPodName());
    decorator.setContainerName(containerName);
    decorator.setNamespace(nodeContext.getNamespace());
    decorator.setEnvironmentExpander(env);
    decorator.setWs(getContext().get(FilePath.class));
    decorator.setGlobalVars(globalVars);
    getContext().newBodyInvoker()
            .withContext(BodyInvoker
                    .mergeLauncherDecorators(getContext().get(LauncherDecorator.class), decorator))
            .withCallback(new ContainerExecCallback(decorator))
            .start();
    return false;
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
@Before
public void configureCloud() throws Exception {
    cloud = setupCloud(this);
    createSecret(cloud.connect());
    cloud.getTemplates().clear();
    cloud.addTemplate(buildBusyboxTemplate("busybox"));

    // Agents running in Kubernetes (minikube) need to connect to this server, so localhost does not work
    URL url = r.getURL();

    String hostAddress = System.getProperty("jenkins.host.address");
    if (hostAddress == null) {
        hostAddress = InetAddress.getLocalHost().getHostAddress();
    }
    URL nonLocalhostUrl = new URL(url.getProtocol(), hostAddress, url.getPort(),
            url.getFile());
    JenkinsLocationConfiguration.get().setUrl(nonLocalhostUrl.toString());

    r.jenkins.clouds.add(cloud);

    DescribableList<NodeProperty<?>, NodePropertyDescriptor> list =  r.jenkins.getGlobalNodeProperties();
    EnvironmentVariablesNodeProperty newEnvVarsNodeProperty = new hudson.slaves.EnvironmentVariablesNodeProperty();
    list.add(newEnvVarsNodeProperty);
    EnvVars envVars = newEnvVarsNodeProperty.getEnvVars();
    envVars.put("GLOBAL", "GLOBAL");
    envVars.put("JAVA_HOME_X", "java-home-x");
    r.jenkins.save();
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
public Expand(Map<String, String> map) {
	Jenkins jenkins = Jenkins.getInstance();
	if (jenkins == null) {
		logger.warning("Jenkins instance is null!");
		return;
	}

	DescribableList<NodeProperty<?>, NodePropertyDescriptor> props = jenkins.getGlobalNodeProperties();
	if (props != null) {
		for (NodeProperty<?> node : props) {
			if (node instanceof EnvironmentVariablesNodeProperty) {
				EnvironmentVariablesNodeProperty env = (EnvironmentVariablesNodeProperty) node;
				formatTags.putAll((env).getEnvVars());
			}
		}
	}

	for (Entry<String, String> entry : map.entrySet()) {
		String key = entry.getKey();
		String value = entry.getValue();
		if (ReviewProp.isProp(key)) {
			// Known Perforce Review property; prefix with namespace
			key = ReviewProp.NAMESPACE + key;
		}
		set(key, value);
	}
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
/**
 * Get a map with the global node properties.
 *
 * @since 1.6
 * @return map with global node properties
 */
public static @Nonnull Map<String, Object> getGlobalNodeProperties() {
    Map<String, Object> map = new HashMap<String, Object>();
    Jenkins instance = Jenkins.getInstance();
    DescribableList<NodeProperty<?>, NodePropertyDescriptor> globalNodeProperties = instance.getGlobalNodeProperties();
    if (globalNodeProperties != null) {
        for (NodeProperty<?> nodeProperty : globalNodeProperties) {
            if (nodeProperty instanceof EnvironmentVariablesNodeProperty) {
                EnvironmentVariablesNodeProperty envNodeProperty = (EnvironmentVariablesNodeProperty) nodeProperty;
                map.putAll(envNodeProperty.getEnvVars());
            }
        }
    }
    return map;
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
@Test
public void testGetGlobalNodeProperties() {
    Map<?, ?> map = Utils.getGlobalNodeProperties();
    Map<String, String> testMap = new HashMap<String, String>();
    testMap.put("time", "20:13:13");
    EnvironmentVariablesNodeProperty.Entry entry = new EnvironmentVariablesNodeProperty.Entry("time",
            testMap.get("time"));
    EnvironmentVariablesNodeProperty envVarsNodeProp = new EnvironmentVariablesNodeProperty(entry);
    j.jenkins.getGlobalNodeProperties().add(envVarsNodeProp);
    map = Utils.getGlobalNodeProperties();
    assertEquals("20:13:13", map.values().iterator().next());
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
@Test
public void testScriptAccessingGlobalProperties() {
    Map<String, String> testMap = new HashMap<String, String>();
    testMap.put("time", "20:13:13");
    EnvironmentVariablesNodeProperty.Entry entry = new EnvironmentVariablesNodeProperty.Entry("NODE_TIME",
            testMap.get("time"));
    EnvironmentVariablesNodeProperty envVarsNodeProp = new EnvironmentVariablesNodeProperty(entry);
    j.jenkins.getGlobalNodeProperties().add(envVarsNodeProp);
    GroovyScript script = new GroovyScript(new SecureGroovyScript(SCRIPT, Boolean.FALSE, null),
            new SecureGroovyScript(FALLBACK_SCRIPT, Boolean.FALSE, null));
    ChoiceParameter param = new ChoiceParameter("param000", "description", "randomName", script,
            CascadeChoiceParameter.ELEMENT_TYPE_FORMATTED_HIDDEN_HTML, true, 0);

    assertEquals(Arrays.asList("a", "b", "20:13:13").toString(), param.getChoices().values().toString());
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
private Properties getEnvironmentVariables() {
    Properties properties;
    EnvironmentVariablesNodeProperty environmentVariablesNodeProperty;

    properties = new Properties();
    environmentVariablesNodeProperty = Jenkins.getInstance().getGlobalNodeProperties().get(EnvironmentVariablesNodeProperty.class);

    if (environmentVariablesNodeProperty != null) {
        for (Map.Entry<String, String> entry : environmentVariablesNodeProperty.getEnvVars().entrySet()) {
            properties.setProperty(entry.getKey(), entry.getValue());
        }
    }

    return properties;
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
public static void setEnvironmentVariables(JenkinsRule j, Map<String, String> params) throws IOException {
    EnvironmentVariablesNodeProperty prop = new EnvironmentVariablesNodeProperty();
    EnvVars envVars = prop.getEnvVars();
    envVars.putAll(params);
    j.jenkins.getGlobalNodeProperties().add(prop);
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
@Override
public Boolean call() throws Throwable {
    final Jenkins jenkins = Jenkins.getInstance();

    String logName = "com.github.kostyasha.yad";
    final LogRecorder logRecorder = new LogRecorder(logName);
    logRecorder.targets.add(new LogRecorder.Target("com.github.kostyasha.yad", Level.ALL));
    jenkins.getLog().logRecorders.put("logName", logRecorder);
    logRecorder.save();

    // prepare jenkins global (url, cred)
    JenkinsLocationConfiguration.get().setUrl(String.format("http://%s:%d", dockerUri.getHost(), jenkinsPort));

    SystemCredentialsProvider.getInstance().getCredentials().add(dockerServerCredentials);

    //verify doTestConnection
    final DescriptorImpl descriptor = (DescriptorImpl) jenkins.getDescriptor(DockerConnector.class);
    checkFormValidation(descriptor.doTestConnection(dockerUri.toString(), "",
            dockerServerCredentials.getId(), ConnectorType.NETTY, 10 * 1000, 11 * 1000));
    checkFormValidation(descriptor.doTestConnection(dockerUri.toString(), "",
            dockerServerCredentials.getId(), JERSEY, 10 * 1000, 11 * 1000));

    // prepare Docker Cloud
    final DockerConnector dockerConnector = new DockerConnector(dockerUri.toString());
    dockerConnector.setCredentialsId(dockerServerCredentials.getId());
    dockerConnector.setConnectTimeout(10 * 1000);
    dockerConnector.setReadTimeout(0);
    dockerConnector.setConnectorType(JERSEY);
    dockerConnector.testConnection();

    //launcher
    final DockerComputerJNLPLauncher launcher = new DockerComputerJNLPLauncher();
    launcher.setNoCertificateCheck(true);
    launcher.setJvmOpts("-XX:-PrintClassHistogram");
    final DockerPullImage pullImage = new DockerPullImage();
    pullImage.setPullStrategy(PULL_LATEST);

    //remove
    final DockerRemoveContainer removeContainer = new DockerRemoveContainer();
    removeContainer.setRemoveVolumes(true);
    removeContainer.setForce(true);

    //lifecycle
    final DockerContainerLifecycle containerLifecycle = new DockerContainerLifecycle();
    containerLifecycle.setImage(slaveImage);
    containerLifecycle.setPullImage(pullImage);
    containerLifecycle.setRemoveContainer(removeContainer);

    //template
    final Entry entry = new Entry("super-key", TEST_VALUE);
    final EnvironmentVariablesNodeProperty nodeProperty = new EnvironmentVariablesNodeProperty(entry);

    final ArrayList<NodeProperty<?>> nodeProperties = new ArrayList<>();
    nodeProperties.add(nodeProperty);
    nodeProperties.add(new DockerNodeProperty(CONTAINER_ID, CLOUD_ID, DOCKER_HOST));


    final DockerSlaveTemplate slaveTemplate = new DockerSlaveTemplate();
    slaveTemplate.setMaxCapacity(4);
    slaveTemplate.setLabelString(DOCKER_CLOUD_LABEL);
    slaveTemplate.setLauncher(launcher);
    slaveTemplate.setMode(Node.Mode.EXCLUSIVE);
    slaveTemplate.setRetentionStrategy(new DockerOnceRetentionStrategy(10));
    slaveTemplate.setDockerContainerLifecycle(containerLifecycle);
    slaveTemplate.setNodeProperties(nodeProperties);

    final List<DockerSlaveTemplate> templates = new ArrayList<>();
    templates.add(slaveTemplate);

    final DockerCloud dockerCloud = new DockerCloud(
            DOCKER_CLOUD_NAME,
            templates,
            3,
            dockerConnector
    );
    jenkins.clouds.add(dockerCloud);
    jenkins.save(); // either xmls a half broken

    return true;
}
 

import hudson.slaves.EnvironmentVariablesNodeProperty; //导入依赖的package包/类
protected void setVariables(Node node, EnvironmentVariablesNodeProperty.Entry... entries) throws IOException {
  node.getNodeProperties().replaceBy(
      Collections.singleton(new EnvironmentVariablesNodeProperty(
          entries)));

}