replicationmasterstorageimpl.cs

Perst开源实时数据库

namespace Perst.Impl    
{
    using Perst;

    public class ReplicationMasterStorageImpl : StorageImpl, ReplicationMasterStorage
    { 
        public ReplicationMasterStorageImpl(int port, string[] hosts, int asyncBufSize) 
        { 
            this.port = port;
            this.hosts = hosts;
            this.asyncBufSize = asyncBufSize;
        }
    
        public override void Open(IFile file, int pagePoolSize) 
        {
            base.Open(asyncBufSize != 0 
                ? (ReplicationMasterFile)new AsyncReplicationMasterFile(this, file, asyncBufSize)
                : new ReplicationMasterFile(this, file),
                pagePoolSize);
        }

        public int GetNumberOfAvailableHosts() 
        { 
            return ((ReplicationMasterFile)pool.file).GetNumberOfAvailableHosts();
        }

        internal string[] hosts;
        internal int      port;
        internal int      asyncBufSize;
    }
}