storageobjectcontainer.java

Java的面向对象数据库系统的源代码

// You can redistribute this software and/or modify it under the terms of
// the Ozone Library License version 1 published by ozone-db.org.
//
// This file is
// Copyright (C) 2003-@year@ Per Nyfelt. All rights reserved.
//
package org.ozoneDB.core.storage;

import org.ozoneDB.core.AbstractObjectContainer;
import org.ozoneDB.core.Transaction;
import org.ozoneDB.core.Env;
import org.ozoneDB.util.LogWriter;

import java.io.Externalizable;

/**
 * @author Per Nyfelt
 */
public abstract class StorageObjectContainer extends AbstractObjectContainer implements Externalizable {

    /** the parent cluster that holds us */
    protected Cluster  cluster;

    public void setCluster(Cluster cluster) {
        this.cluster = cluster;
        if (cluster == null) {
            // cluster is invalidated by the ClusterStore
            if (Env.currentEnv().logWriter.hasTarget(LogWriter.DEBUG3)) {
                Env.currentEnv().logWriter.newEntry(this, "setCluster(null).", LogWriter.DEBUG3);
            }
        }
    }

    public Cluster getCluster() {
        return cluster;
    }

    public abstract boolean isInvoked();

    public abstract boolean isDeleted();

    public void updateLockLevel(Transaction ta) throws Exception {
        // was
        if (getCluster().env().logWriter.hasTarget(LogWriter.DEBUG3)) {
            getCluster().env().logWriter.newEntry(this, "upgradeLockLevel(): ", LogWriter.DEBUG3);
        }
        getCluster().updateLockLevel(ta);
    }

    public boolean equals(Object obj) {
        if (obj != null && obj instanceof StorageObjectContainer) {
            StorageObjectContainer rhs = (StorageObjectContainer) obj;
            return id().equals(rhs.id());
        }
        return false;
    }
}