Class ActorId

java/api/src/main/java/io/ray/api/id/ActorId.java:8–52

import java.util.Random;

public class ActorId extends BaseId implements Serializable {

  private static final int UNIQUE_BYTES_LENGTH = 12;

  public static final int LENGTH = JobId.LENGTH + UNIQUE_BYTES_LENGTH;

  public static final ActorId NIL = nil();

  private ActorId(byte[] id) {
    super(id);
  }

  public static ActorId fromByteBuffer(ByteBuffer bb) {
    return new ActorId(byteBuffer2Bytes(bb));
  }

  public static ActorId fromBytes(byte[] bytes) {
    return new ActorId(bytes);
  }

  /** Generate a nil ActorId. */
  private static ActorId nil() {
    byte[] b = new byte[LENGTH];
    Arrays.fill(b, (byte) 0xFF);
    return new ActorId(b);
  }

  /** Generate an ActorId with random value. Used for local mode and test only. */
  public static ActorId fromRandom() {
    byte[] b = new byte[LENGTH];
    new Random().nextBytes(b);
    return new ActorId(b);
  }

  @Override
  public int size() {
    return LENGTH;
  }

  public JobId getJobId() {
    byte[] actorBytes = getBytes();
    ByteBuffer bf = ByteBuffer.wrap(actorBytes, UNIQUE_BYTES_LENGTH, JobId.LENGTH);
    return JobId.fromByteBuffer(bf);
  }
}