replicationdynamicslavestorageimpl.java

这个是perst-269.zip下面的SOURCECODE,和大家分享了。

package org.garret.perst.impl;

import java.io.*;
import java.net.*;

import org.garret.perst.*;


public class ReplicationDynamicSlaveStorageImpl extends ReplicationSlaveStorageImpl
{
    public ReplicationDynamicSlaveStorageImpl(String host, int port) { 
        this.host = host;
        this.port = port;
    }

    public void open(IFile file, int pagePoolSize) {
        initialized = false;
        prevIndex = -1;
        outOfSync = true;
        super.open(file, pagePoolSize);
    }

    Socket getSocket() throws IOException { 
        if (opened) {
            throw new StorageError(StorageError.CONNECTION_FAILURE);
        }
        return new Socket(host, port);
    }

    protected String host;
    protected int    port;
}