hudson.model.Computer.isAcceptingTasks()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(6.4k)|赞(0)|评价(0)|浏览(118)

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

Computer.isAcceptingTasks介绍

[英]Returns true if the computer is accepting tasks. Needed to allow slaves programmatic suspension of task scheduling that does not overlap with being offline.
[中]如果计算机正在接受任务,则返回true。需要允许从程序暂停与脱机不重叠的任务调度。

代码示例

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

/**
 * {@inheritDoc}
 */
@Override
@OverridingMethodsMustInvokeSuper
public boolean isAcceptingTasks() {
  // our boolean flag is an override on any additional programmatic reasons why this agent might not be
  // accepting tasks.
  return acceptingTasks && super.isAcceptingTasks();
}

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

/**
 * Is this executor ready to accept some tasks?
 */
public boolean isAvailable() {
  return workUnit == null && !executor.getOwner().isOffline() && executor.getOwner().isAcceptingTasks();
}

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

@Override
@GuardedBy("hudson.model.Queue.lock")
public long check(T c) {
  if (!c.isConnecting() && c.isAcceptingTasks()) {
    if (isIdleForTooLong(c)) {
      try {
        Node n = c.getNode();
        if (n!=null)    // rare, but n==null if the node is deleted and being checked roughly at the same time
          kill(n);
      } catch (IOException e) {
        LOGGER.log(Level.WARNING, "Failed to remove "+c.getDisplayName(),e);
      }
    }
  }
  return checkCycle();
}

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

/**
 * {@code getTotalExecutors()-getBusyExecutors()}, plus executors that are being brought online.
 */
public int getIdleExecutors() {
  int r=0;
  for (Computer c : get_all())
    if((c.isOnline() || c.isConnecting()) && c.isAcceptingTasks())
      r += c.countIdle();
  return r;
}

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

public Builder with(@CheckForNull Computer computer) {
  if (computer == null) {
    return this;
  }
  if (computer.isOnline()) {
    final List<Executor> executors = computer.getExecutors();
    final boolean acceptingTasks = computer.isAcceptingTasks();
    for (Executor e : executors) {
      definedExecutors++;
      onlineExecutors++;
      if (e.getCurrentWorkUnit() != null) {
        busyExecutors++;
      } else {
        idleExecutors++;
        if (acceptingTasks) availableExecutors++;
      }
    }
  } else {
    final int numExecutors = computer.getNumExecutors();
    definedExecutors += numExecutors;
    if (computer.isConnecting()) {
      connectingExecutors += numExecutors;
    }
  }
  return this;
}

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

/**
 * Number of idle {@link Executor}s that can start working immediately.
 */
@Exported
public int getIdleExecutors() {
  int r=0;
  for (Node n : getNodes()) {
    Computer c = n.toComputer();
    if(c!=null && (c.isOnline() || c.isConnecting()) && c.isAcceptingTasks())
      r += c.countIdle();
  }
  return r;
}

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

@Override
public int computeIdleExecutors() {
  int r=0;
  for (Computer c : Jenkins.getInstance().getComputers()) {
    Node node = c.getNode();
    if (node != null && node.getMode() == Mode.NORMAL && (c.isOnline() || c.isConnecting()) && c.isAcceptingTasks()) {
      r += c.countIdle();
    }
  }
  return r;
}

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

final HashMap<Computer, Integer> availableComputers = new HashMap<>();
for (Computer o : Jenkins.get().getComputers()) {
  if ((o.isOnline() || o.isConnecting()) && o.isPartiallyIdle() && o.isAcceptingTasks()) {
    final int idleExecutors = o.countIdle();
    if (idleExecutors>0)

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

for (Node n : Jenkins.getInstance().getNodes()) {
  Computer c = n.toComputer();
  if (c != null && c.isOnline() && c.isAcceptingTasks() && n.getMode() == Mode.NORMAL) {

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

return new CauseOfBlockage.BecauseNodeIsOffline(node);
if (!executor.getOwner().isAcceptingTasks()) { // Node.canTake (above) does not consider RetentionStrategy.isAcceptingTasks
  return new CauseOfBlockage.BecauseNodeIsNotAcceptingTasks(node);

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

/**
 * {@inheritDoc}
 */
@Override
@OverridingMethodsMustInvokeSuper
public boolean isAcceptingTasks() {
  // our boolean flag is an override on any additional programmatic reasons why this agent might not be
  // accepting tasks.
  return acceptingTasks && super.isAcceptingTasks();
}

代码示例来源:origin: org.eclipse.hudson/hudson-core

/**
 * Is this executor ready to accept some tasks?
 */
@Override
public boolean isAvailable() {
  return workUnit == null && !executor.getOwner().isOffline() && executor.getOwner().isAcceptingTasks();
}

代码示例来源:origin: org.jvnet.hudson.main/hudson-core

/**
 * Is this executor ready to accept some tasks?
 */
public boolean isAvailable() {
  return workUnit == null && !executor.getOwner().isOffline() && executor.getOwner().isAcceptingTasks();
}

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

/**
 * Is this executor ready to accept some tasks?
 */
public boolean isAvailable() {
  return workUnit == null && !executor.getOwner().isOffline() && executor.getOwner().isAcceptingTasks();
}

代码示例来源:origin: org.eclipse.hudson.main/hudson-core

/**
 * Is this executor ready to accept some tasks?
 */
public boolean isAvailable() {
  return workUnit == null && !executor.getOwner().isOffline() && executor.getOwner().isAcceptingTasks();
}

代码示例来源:origin: hudson/hudson-2.x

/**
 * Is this executor ready to accept some tasks?
 */
public boolean isAvailable() {
  return workUnit == null && !executor.getOwner().isOffline() && executor.getOwner().isAcceptingTasks();
}

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

/**
 * {@code getTotalExecutors()-getBusyExecutors()}, plus executors that are being brought online.
 */
public int getIdleExecutors() {
  int r=0;
  for (Computer c : get_all())
    if((c.isOnline() || c.isConnecting()) && c.isAcceptingTasks())
      r += c.countIdle();
  return r;
}

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

@Override
@GuardedBy("hudson.model.Queue.lock")
public long check(T c) {
  if (!c.isConnecting() && c.isAcceptingTasks()) {
    if (isIdleForTooLong(c)) {
      try {
        Node n = c.getNode();
        if (n!=null)    // rare, but n==null if the node is deleted and being checked roughly at the same time
          kill(n);
      } catch (IOException e) {
        LOGGER.log(Level.WARNING, "Failed to remove "+c.getDisplayName(),e);
      }
    }
  }
  return checkCycle();
}

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

/**
 * Number of idle {@link Executor}s that can start working immediately.
 */
@Exported
public int getIdleExecutors() {
  int r=0;
  for (Node n : getNodes()) {
    Computer c = n.toComputer();
    if(c!=null && (c.isOnline() || c.isConnecting()) && c.isAcceptingTasks())
      r += c.countIdle();
  }
  return r;
}

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

@Override
public int computeIdleExecutors() {
  int r=0;
  for (Computer c : Jenkins.getInstance().getComputers()) {
    Node node = c.getNode();
    if (node != null && node.getMode() == Mode.NORMAL && (c.isOnline() || c.isConnecting()) && c.isAcceptingTasks()) {
      r += c.countIdle();
    }
  }
  return r;
}

相关文章

微信公众号

最新文章

更多