uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgentInfo.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 * 
 *      http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
*/
package org.apache.uima.ducc.agent;

import java.io.Serializable;
import java.util.Properties;

public class NodeAgentInfo implements Serializable {
  // UNREACHABLE is set if the agent fails to send a ping within a window
  public enum AgentState {
    INITIALIZING, READY, STOPPED, UNREACHABLE, FAILED
  };

  public static final String OSName = "os.name";

  public static final String OSVersion = "os.version";

  public static final String OSArchitecture = "os.arch";

  public static final String NodeCpus = "node.cpus";

  public static final String JavaVendor = "java.vendor";

  public static final String JavaVersion = "java.version";

  private static final long serialVersionUID = 1L;

  private String hostname;

  private String ip = "N/A";

  private int jmxPort;

  private Properties properties = new Properties();

  private String id;

  // private ProcessGroup[] groups;
  private AgentState status = AgentState.INITIALIZING;

  private String agentLog = "N/A";

  private boolean firstHeartbeat = true;

  public NodeAgentInfo(String hostname, String id) {
    super();
    this.hostname = hostname;
    this.id = id;
  }

  public boolean isFirstHeartbeat() {
    return firstHeartbeat;
  }

  /**
   * @return the status
   */
  public AgentState getStatus() {
    return status;
  }

  public String getAgentLog() {
    return agentLog;
  }

  public void setAgentLog(String agentLog) {
    this.agentLog = agentLog;
  }

  public String getIp() {
    return ip;
  }

  public void setIp(String ip) {
    this.ip = ip;
  }

  /**
   * @param status
   *          the status to set
   */
  public void setStatus(AgentState status) {
    this.status = status;
  }

  public Properties getProperties() {
    return properties;
  }

  public void setProperties(Properties properties) {
    this.properties = properties;
  }

  public String getProperty(String key) {
    return properties.getProperty(key);
  }

  public void setProperty(String key, String value) {
    properties.put(key, value);
  }

  /**
   * @return the jmxPort
   */
  public int getJmxPort() {
    return jmxPort;
  }

  /**
   * @param jmxPort
   *          the jmxPort to set
   */
  public void setJmxPort(int jmxPort) {
    this.jmxPort = jmxPort;
  }

  /**
   * @return the hostname
   */
  public String getHostname() {
    return hostname;
  }

  /**
   * @return the id
   */
  public String getId() {
    return id;
  }

  // public void setProcessGroups(ProcessGroup[] groups) {
  // this.groups = groups;
  // }
  // public ProcessGroup[] getProcessGroups() {
  // return groups;
  // }
  public void dump() {
    if (firstHeartbeat) {
      firstHeartbeat = false;
      System.out.println("+++++++++++ Controller Received Agent Info. \n\tNode:" + getHostname()
              + "\n\tAgent Node IP:" + getIp() + "\n\tAgent Node ID:" + getId() + "\n\tAgent Log:"
              + getAgentLog() + "\n\tAgent Jmx Port:" + getJmxPort() + "\n\tAgent Node OS:"
              + getProperty(NodeAgentInfo.OSName) + "\n\tAgent Node OS Level:"
              + getProperty(NodeAgentInfo.OSVersion) + "\n\tAgent Node OS Architecture:"
              + getProperty(NodeAgentInfo.OSArchitecture) + "\n\tAgent Node CPU Count:"
              + getProperty(NodeAgentInfo.NodeCpus) + "\n\tAgent Node Java Vendor:"
              + getProperty(NodeAgentInfo.JavaVendor) + "\n\tAgent Node Java Version:"
              + getProperty(NodeAgentInfo.JavaVersion));
    }
  }

}