hudson.Launcher.getListener()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(10.2k)|赞(0)|评价(0)|浏览(152)

本文整理了Java中hudson.Launcher.getListener()方法的一些代码示例，展示了Launcher.getListener()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Launcher.getListener()方法的具体详情如下：
包路径：hudson.Launcher
类名称：Launcher
方法名：getListener

Launcher.getListener介绍

[英]Gets the TaskListener that this launcher uses to report the commands that it's executing.
[中]获取此启动器用于报告其正在执行的命令的TaskListener。

代码示例

代码示例来源：origin: jenkinsci/jenkins

  1. @Override
  2. public TaskListener getListener() {
  3.   return inner.getListener();
  4. }

代码示例来源：origin: org.jenkins-ci.main/jenkins-core

  1. @Override
  2. public TaskListener getListener() {
  3.   return inner.getListener();
  4. }

代码示例来源：origin: jenkinsci/kubernetes-pipeline-plugin

  1. @Override
  2. public Proc launch(ProcStarter starter) throws IOException {
  3.   AtomicBoolean processAlive = new AtomicBoolean(false);
  4.   CountDownLatch processStarted = new CountDownLatch(1);
  5.   CountDownLatch processFinished = new CountDownLatch(1);
  6.   ExecWatch execWatch = kubernetes.exec(name, containerName, processAlive, processStarted, processFinished, launcher.getListener().getLogger(),
  7.       getCommands(starter)
  8.   );
  9.   return new PodExecProc(name, processAlive, processFinished, execWatch);
  10. }

代码示例来源：origin: jenkinsci/coverity-plugin

  1. private String[] getPrefix() {
  2.   String[] tp = prefix.clone();
  3.   if(tp.length > 0){
  4.     tp[0] = CoverityUtils.getCovBuild(decorated.getListener(), node);
  5.   }
  6.   return tp;
  7. }

代码示例来源：origin: jenkinsci/docker-workflow-plugin

  1. /**
  2.  * Who is executing this {@link DockerClient} instance.
  3.  *
  4.  * @return a {@link String} containing the <strong>uid:gid</strong>.
  5.  */
  6. public String whoAmI() throws IOException, InterruptedException {
  7.   ByteArrayOutputStream userId = new ByteArrayOutputStream();
  8.   launcher.launch().cmds("id", "-u").quiet(true).stdout(userId).start().joinWithTimeout(CLIENT_TIMEOUT, TimeUnit.SECONDS, launcher.getListener());
  9.   ByteArrayOutputStream groupId = new ByteArrayOutputStream();
  10.   launcher.launch().cmds("id", "-g").quiet(true).stdout(groupId).start().joinWithTimeout(CLIENT_TIMEOUT, TimeUnit.SECONDS, launcher.getListener());
  11.   final String charsetName = Charset.defaultCharset().name();
  12.   return String.format("%s:%s", userId.toString(charsetName).trim(), groupId.toString(charsetName).trim());
  13. }

代码示例来源：origin: io.jenkins.plugins/docker-slaves

  1. @Override
  2. public String createVolume(TaskListener listener) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("volume", "create");
  5.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  6.   Launcher launcher = new Launcher.LocalLauncher(listener);
  7.   int status = launchDockerCLI(launcher, args)
  8.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  9.   final String volume = out.toString(UTF_8).trim();
  10.   if (status != 0) {
  11.     throw new IOException("Failed to create docker volume");
  12.   }
  13.   return volume;
  14. }

代码示例来源：origin: jenkinsci/docker-slaves-plugin

  1. @Override
  2. public String createVolume(TaskListener listener) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("volume", "create");
  5.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  6.   Launcher launcher = new Launcher.LocalLauncher(listener);
  7.   int status = launchDockerCLI(launcher, args)
  8.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  9.   final String volume = out.toString(UTF_8).trim();
  10.   if (status != 0) {
  11.     throw new IOException("Failed to create docker volume");
  12.   }
  13.   return volume;
  14. }

代码示例来源：origin: jenkinsci/docker-slaves-plugin

  1. @Override
  2. public String serverVersion(TaskListener listener) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("version", "-f", "{{.Server.Version}}");
  5.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  6.   Launcher launcher = new Launcher.LocalLauncher(listener);
  7.   int status = launchDockerCLI(launcher, args)
  8.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  9.   final String version = out.toString(UTF_8).trim();
  10.   if (status != 0) {
  11.     throw new IOException("Failed to connect to docker API");
  12.   }
  13.   return version;
  14. }

代码示例来源：origin: io.jenkins.plugins/docker-slaves

  1. @Override
  2. public String serverVersion(TaskListener listener) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("version", "-f", "{{.Server.Version}}");
  5.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  6.   Launcher launcher = new Launcher.LocalLauncher(listener);
  7.   int status = launchDockerCLI(launcher, args)
  8.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  9.   final String version = out.toString(UTF_8).trim();
  10.   if (status != 0) {
  11.     throw new IOException("Failed to connect to docker API");
  12.   }
  13.   return version;
  14. }

代码示例来源：origin: jenkinsci/docker-slaves-plugin

  1. @Override
  2. public boolean hasContainer(TaskListener listener, String id) throws IOException, InterruptedException {
  3.   if (StringUtils.isEmpty(id)) {
  4.     return false;
  5.   }
  6.   ArgumentListBuilder args = new ArgumentListBuilder()
  7.       .add("inspect", "-f", "'{{.Id}}'", id);
  8.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  9.   Launcher launcher = new Launcher.LocalLauncher(listener);
  10.   int status = launchDockerCLI(launcher, args)
  11.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  12.   return status == 0;
  13. }

代码示例来源：origin: jenkinsci/docker-slaves-plugin

  1. protected void getFileContent(Launcher launcher, String containerId, String filename, OutputStream outputStream) throws IOException, InterruptedException {
  2.   ArgumentListBuilder args = new ArgumentListBuilder()
  3.       .add("cp", containerId + ":" + filename, "-");
  4.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  5.   int status = launchDockerCLI(launcher, args)
  6.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  7.   if (status != 0) {
  8.     throw new IOException("Failed to get file");
  9.   }
  10.   TarInputStream tar = new TarInputStream(new ByteArrayInputStream(out.toByteArray()));
  11.   tar.getNextEntry();
  12.   tar.copyEntryContents(outputStream);
  13.   tar.close();
  14. }

代码示例来源：origin: jenkinsci/docker-slaves-plugin

  1. @Override
  2. public boolean hasVolume(TaskListener listener, String name) throws IOException, InterruptedException {
  3.   if (StringUtils.isEmpty(name)) {
  4.     return false;
  5.   }
  6.   ArgumentListBuilder args = new ArgumentListBuilder()
  7.       .add("volume", "inspect", "-f", "'{{.Name}}'", name);
  8.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  9.   Launcher launcher = new Launcher.LocalLauncher(listener);
  10.   int status = launchDockerCLI(launcher, args)
  11.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  12.   return status == 0;
  13. }

代码示例来源：origin: io.jenkins.plugins/docker-slaves

  1. protected void getFileContent(Launcher launcher, String containerId, String filename, OutputStream outputStream) throws IOException, InterruptedException {
  2.   ArgumentListBuilder args = new ArgumentListBuilder()
  3.       .add("cp", containerId + ":" + filename, "-");
  4.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  5.   int status = launchDockerCLI(launcher, args)
  6.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  7.   if (status != 0) {
  8.     throw new IOException("Failed to get file");
  9.   }
  10.   TarInputStream tar = new TarInputStream(new ByteArrayInputStream(out.toByteArray()));
  11.   tar.getNextEntry();
  12.   tar.copyEntryContents(outputStream);
  13.   tar.close();
  14. }

代码示例来源：origin: io.jenkins.plugins/docker-slaves

  1. @Override
  2. public void pullImage(TaskListener listener, String image) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("pull")
  5.       .add(image);
  6.   Launcher launcher = new Launcher.LocalLauncher(listener);
  7.   int status =  launchDockerCLI(launcher, args)
  8.       .stdout(launcher.getListener().getLogger()).join();
  9.   if (status != 0) {
  10.     throw new IOException("Failed to pull image " + image);
  11.   }
  12. }

代码示例来源：origin: org.jvnet.hudson.plugins/clearcase

  1. public ClearTool createClearTool(AbstractBuild<?, ?> build, Launcher launcher) {
  2.   BuildVariableResolver variableResolver = new BuildVariableResolver(build);
  3.   ClearToolLauncher clearToolLauncher = createClearToolLauncher(launcher.getListener(), build.getWorkspace(), launcher);
  4.   return createClearTool(variableResolver, clearToolLauncher);
  5. }

代码示例来源：origin: jenkinsci/docker-slaves-plugin

  1. @Override
  2. public void pullImage(TaskListener listener, String image) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("pull")
  5.       .add(image);
  6.   Launcher launcher = new Launcher.LocalLauncher(listener);
  7.   int status =  launchDockerCLI(launcher, args)
  8.       .stdout(launcher.getListener().getLogger()).join();
  9.   if (status != 0) {
  10.     throw new IOException("Failed to pull image " + image);
  11.   }
  12. }

代码示例来源：origin: io.jenkins.plugins/docker-slaves

  1. @Override
  2. public void removeContainer(TaskListener listener, Container instance) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("rm", "-f", instance.getId());
  5.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  6.   Launcher launcher = new Launcher.LocalLauncher(listener);
  7.   int status = launchDockerCLI(launcher, args)
  8.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  9.   if (status != 0) {
  10.     throw new IOException("Failed to remove container " + instance.getId());
  11.   }
  12. }

代码示例来源：origin: jenkinsci/docker-slaves-plugin

  1. @Override
  2. public void removeContainer(TaskListener listener, Container instance) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("rm", "-f", instance.getId());
  5.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  6.   Launcher launcher = new Launcher.LocalLauncher(listener);
  7.   int status = launchDockerCLI(launcher, args)
  8.       .stdout(out).stderr(launcher.getListener().getLogger()).join();
  9.   if (status != 0) {
  10.     throw new IOException("Failed to remove container " + instance.getId());
  11.   }
  12. }

代码示例来源：origin: jenkinsci/docker-slaves-plugin

  1. @Override
  2. public boolean checkImageExists(TaskListener listener, String image) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("inspect")
  5.       .add("-f", "'{{.Id}}'")
  6.       .add(image);
  7.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  8.   Launcher launcher = new Launcher.LocalLauncher(listener);
  9.   return launchDockerCLI(launcher, args)
  10.       .stdout(out).stderr(launcher.getListener().getLogger()).join() == 0;
  11. }

代码示例来源：origin: io.jenkins.plugins/docker-slaves

  1. @Override
  2. public boolean checkImageExists(TaskListener listener, String image) throws IOException, InterruptedException {
  3.   ArgumentListBuilder args = new ArgumentListBuilder()
  4.       .add("inspect")
  5.       .add("-f", "'{{.Id}}'")
  6.       .add(image);
  7.   ByteArrayOutputStream out = new ByteArrayOutputStream();
  8.   Launcher launcher = new Launcher.LocalLauncher(listener);
  9.   return launchDockerCLI(launcher, args)
  10.       .stdout(out).stderr(launcher.getListener().getLogger()).join() == 0;
  11. }

内容来源于网络，如有侵权，请联系作者删除！

Launcher

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com