| java.lang.Object com.caucho.server.cluster.StoreManager com.caucho.server.cluster.FileStore
FileStore | public class FileStore extends StoreManager (Code) | | Class storing distributed objects based on the filesystem.
|
Constructor Summary | |
public | FileStore() Create a new file-based persistent store. |
Method Summary | |
public void | accessImpl(String uniqueId) Updates the object's access time in the persistent store. | public void | addText(String value) | public void | clearOldObjects() Clears the files which are too old. | ClusterObject | create(Store store, String id) Creates the cluster object. | public Path | getPath() | public boolean | init() Initialize. | protected boolean | isPrimary(String id) Returns true if this server is a primary for the given object id. | public boolean | load(ClusterObject clusterObj, Object obj) Loads the session from the filesystem. | public void | remove(ClusterObject obj) When the session is no longer valid, remove it from the backing store. | public void | setExpireInterval(String uniqueId, long expires) Sets the timef for the expires interval.
Parameters: uniqueId - the identifier of the object. | public void | setPath(Path path) Sets the file store's path. | public boolean | start() | public void | store(ClusterObject obj, TempStream tempStream, long crc) Saves the session to the filesystem. |
FileStore | public FileStore()(Code) | | Create a new file-based persistent store.
|
accessImpl | public void accessImpl(String uniqueId) throws Exception(Code) | | Updates the object's access time in the persistent store.
Parameters: uniqueId - the identifier of the object. |
clearOldObjects | public void clearOldObjects()(Code) | | Clears the files which are too old.
|
getPath | public Path getPath()(Code) | | |
isPrimary | protected boolean isPrimary(String id)(Code) | | Returns true if this server is a primary for the given object id.
|
setExpireInterval | public void setExpireInterval(String uniqueId, long expires) throws Exception(Code) | | Sets the timef for the expires interval.
Parameters: uniqueId - the identifier of the object. long the time in ms for the expire |
setPath | public void setPath(Path path)(Code) | | Sets the file store's path.
|
store | public void store(ClusterObject obj, TempStream tempStream, long crc) throws Exception(Code) | | Saves the session to the filesystem.
Parameters: obj - the object to save Parameters: tempStream - stream to the serialized object Parameters: crc - digest of the serialized stream Parameters: updateCount - how many times the object has been updated |
Methods inherited from com.caucho.server.cluster.StoreManager | public void access(String uniqueId) throws Exception(Code)(Java Doc) public void access(Store store, String id) throws Exception(Code)(Java Doc) abstract public void accessImpl(String uniqueId) throws Exception(Code)(Java Doc) public void classLoaderDestroy(DynamicClassLoader loader)(Code)(Java Doc) public void classLoaderInit(DynamicClassLoader loader)(Code)(Java Doc) public void clearOldObjects() throws Exception(Code)(Java Doc) ClusterObject create(Store store, String id)(Code)(Java Doc) ClusterObject createClusterObject(Store store, String id)(Code)(Java Doc) public Store createStore(String storeId, ObjectManager objectManager)(Code)(Java Doc) static int decode(int code)(Code)(Java Doc) public void destroy()(Code)(Java Doc) public void environmentConfig(EnvironmentClassLoader loader)(Code)(Java Doc) public void environmentStart(EnvironmentClassLoader loader)(Code)(Java Doc) public void environmentStop(EnvironmentClassLoader loader)(Code)(Java Doc) public long getAccessWindowTime()(Code)(Java Doc) public PersistentStoreMXBean getAdmin()(Code)(Java Doc) public Cluster getCluster()(Code)(Java Doc) ClusterObject getClusterObject(Store store, String id)(Code)(Java Doc) ClusterObject getClusterObject(String storeId, String id)(Code)(Java Doc) ClusterObject getClusterObject(String uniqueId)(Code)(Java Doc) public long getIdleCheckTime()(Code)(Java Doc) public long getLoadCount()(Code)(Java Doc) public long getLoadFailCount()(Code)(Java Doc) public long getMaxIdleTime()(Code)(Java Doc) public long getObjectCount()(Code)(Java Doc) protected ServerConnector getOwningServer(String objectId)(Code)(Java Doc) public int getPrimaryIndex(String id, int offset)(Code)(Java Doc) public long getSaveCount()(Code)(Java Doc) public long getSaveFailCount()(Code)(Java Doc) public int getSecondaryIndex(String id, int offset)(Code)(Java Doc) protected int getSelfIndex()(Code)(Java Doc) protected ServerConnector[] getServerList()(Code)(Java Doc) public Store getStore(String storeId)(Code)(Java Doc) public int getTertiaryIndex(String id, int offset)(Code)(Java Doc) public void handleAlarm(Alarm alarm)(Code)(Java Doc) public boolean init() throws Exception(Code)(Java Doc) public boolean isAlwaysLoad()(Code)(Java Doc) public boolean isAlwaysSave()(Code)(Java Doc) protected boolean isPrimary(String id)(Code)(Java Doc) abstract protected boolean load(ClusterObject clusterObject, Object obj) throws Exception(Code)(Java Doc) public void remove(ClusterObject obj) throws Exception(Code)(Java Doc) public void remove(Store store, String objectId) throws Exception(Code)(Java Doc) ClusterObject removeClusterObject(String storeId, String id)(Code)(Java Doc) public Store removeStore(String storeId)(Code)(Java Doc) public void setAlwaysLoad(boolean alwaysLoad)(Code)(Java Doc) public void setAlwaysSave(boolean alwaysSave)(Code)(Java Doc) public void setCluster(Cluster cluster)(Code)(Java Doc) public void setExpireInterval(String uniqueId, long expires) throws Exception(Code)(Java Doc) public void setMaxIdleTime(Period maxIdleTime)(Code)(Java Doc) public boolean start() throws Exception(Code)(Java Doc) public void store(Store store, String id, Object obj) throws IOException(Code)(Java Doc) abstract protected void store(ClusterObject clusterObject, TempStream tempStream, long crc) throws Exception(Code)(Java Doc) public String toString()(Code)(Java Doc) public void update(String storeId, String objectId) throws Exception(Code)(Java Doc) public void updateIdleCheckInterval(long idleCheckInterval)(Code)(Java Doc) public void updateOwner(String objectId, String uniqueId) throws Exception(Code)(Java Doc)
|
|
|