package sun.jvm.hotspot.memory;
import java.io.PrintStream;
import sun.jvm.hotspot.utilities.Observable;
import sun.jvm.hotspot.utilities.Observer;
import sun.jvm.hotspot.debugger.Address;
import sun.jvm.hotspot.debugger.OopHandle;
import sun.jvm.hotspot.gc.epsilon.EpsilonHeap;
import sun.jvm.hotspot.gc.g1.G1CollectedHeap;
import sun.jvm.hotspot.gc.parallel.ParallelScavengeHeap;
import sun.jvm.hotspot.gc.serial.SerialHeap;
import sun.jvm.hotspot.gc.shared.CollectedHeap;
import sun.jvm.hotspot.gc.shenandoah.ShenandoahHeap;
import sun.jvm.hotspot.gc.z.ZCollectedHeap;
import sun.jvm.hotspot.oops.Oop;
import sun.jvm.hotspot.runtime.BasicType;
import sun.jvm.hotspot.runtime.VM;
import sun.jvm.hotspot.runtime.VMObject;
import sun.jvm.hotspot.runtime.VirtualConstructor;
import sun.jvm.hotspot.types.AddressField;
import sun.jvm.hotspot.types.CIntegerField;
import sun.jvm.hotspot.types.Type;
import sun.jvm.hotspot.types.TypeDataBase;
public class Universe {
private static AddressField collectedHeapField;
private static VirtualConstructor heapConstructor;
private static sun.jvm.hotspot.types.OopField mainThreadGroupField;
private static sun.jvm.hotspot.types.OopField systemThreadGroupField;
static {
VM.registerVMInitializedObserver(new Observer() {
public void update(Observable o, Object data) {
initialize(VM.getVM().getTypeDataBase());
}
});
}
private static boolean typeExists(TypeDataBase db, String type) {
try {
db.lookupType(type);
} catch (RuntimeException e) {
return false;
}
return true;
}
private static void addHeapTypeIfInDB(TypeDataBase db, Class<? extends VMObject> heapClass) {
String heapName = heapClass.getSimpleName();
if (typeExists(db, heapName)) {
heapConstructor.addMapping(heapName, heapClass);
}
}
private static synchronized void initialize(TypeDataBase db) {
Type type = db.lookupType("Universe");
collectedHeapField = type.getAddressField("_collectedHeap");
heapConstructor = new VirtualConstructor(db);
addHeapTypeIfInDB(db, SerialHeap.class);
addHeapTypeIfInDB(db, ParallelScavengeHeap.class);
addHeapTypeIfInDB(db, G1CollectedHeap.class);
addHeapTypeIfInDB(db, EpsilonHeap.class);
addHeapTypeIfInDB(db, ZCollectedHeap.class);
addHeapTypeIfInDB(db, ShenandoahHeap.class);
mainThreadGroupField = type.getOopField("_main_thread_group");
systemThreadGroupField = type.getOopField("_system_thread_group");
UniverseExt.initialize(heapConstructor);
}
public Universe() {
}
public CollectedHeap heap() {
return (CollectedHeap) heapConstructor.instantiateWrapperFor(collectedHeapField.getValue());
}
public boolean isIn(Address p) {
return heap().isIn(p);
}
public boolean isInReserved(Address p) {
return heap().isInReserved(p);
}
private Oop newOop(OopHandle handle) {
return VM.getVM().getObjectHeap().newOop(handle);
}
public Oop mainThreadGroup() {
return newOop(mainThreadGroupField.getValue());
}
public Oop systemThreadGroup() {
return newOop(systemThreadGroupField.getValue());
}
public void print() { printOn(System.out); }
public void printOn(PrintStream tty) {
heap().printOn(tty);
}
public static boolean elementTypeShouldBeAligned(BasicType type) {
return type == BasicType.T_DOUBLE || type == BasicType.T_LONG;
}
public static boolean fieldTypeShouldBeAligned(BasicType type) {
return type == BasicType.T_DOUBLE || type == BasicType.T_LONG;
}
}