Package com.killcoding.file

Class DiskFile

java.lang.Object

com.killcoding.file.BaseFile

com.killcoding.file.DiskFile

public class DiskFile
extends BaseFile

Field Summary

Fields

Modifier and Type	Field	Description
private FileChannel	channel
protected boolean	copyStructureOnly
private FileLock	lock
protected static Integer	MAX_POOL_SIZE
private long	modifyTimeMs
private static final Map<String,Long>	QUEUE_PATH_MAPPING
static final int	RETRY_OPEN_LIMITED
private static ExecutorService	splitPool

Fields inherited from class com.killcoding.file.BaseFile

CACHE_ARRAY_FILTER_TIMER, CHARSET, LOGIC_ACCESS_TIMEOUT_MS, LOGIC_CHECK_TIMEOUT_MS, LOGIC_TIMEOUT_MS, origin, stopSync, SYNC_PATH_ALLOWED, SYNC_PATH_IGNORED, syncRoot, TEMP_DIR, TMP_EXT_ACCESS_FILE, TMP_EXT_CHECK_FILE, TMP_EXT_MODIFY_FILE, TMP_MATCHES_EDIT, TMP_MATCHES_VI_SWP, TMP_WRITING_FILE, TMP_WRITING_FOR_REPLACE, TMP_WRITING_SWP

Constructor Summary

Constructors

Constructor	Description
DiskFile(File origin)
DiskFile(String path)

Method Summary

Modifier and Type	Method	Description
protected static boolean	addQueuePathMapping(String path)
void	afterCreateLink(String target)
void	afterDelete(boolean realDeleted)
void	afterMkdirs()
void	afterWrite()
boolean	beforeCreateLink(String target)
boolean	beforeDelete(boolean realDeleted)
boolean	beforeMkdirs()
boolean	beforeWrite()
static boolean	checkQueuePathMapping()
protected boolean	checkSyncPathAvailable(String path)
private void	close()
boolean	complete()
protected static DiskFile	copyAttrs(DiskFile source, boolean _copyStructureOnly, File _syncRoot)
void	copyTo(String toPath)
boolean	createLink(String target)
private static void	debugLog(String point, RemoteFile rf, CacheArrayFilter filter)
boolean	delete()
private boolean	deleteFrom()
boolean	exists()
private CacheArrayFilter	getFullAsyncFilter(DiskFile the, long timerMs, String replaceRootPath, String replaceTo, Runnable completedCallback)
Timestamp	getModifyTime()
Timestamp	getModifyTimeForClock()
File	getParentFile()
static Map<String,Long>	getQueuePathMapping()
private CacheArrayFilter	getScanDeleteFilter(RemoteFile rootDir, Integer filePartDataTable, long timerMs, String replaceTo, String replaceRootPath, Runnable completedCallback)
private static void	initDefaultPool()
static void	initPool(int poolSize)
boolean	isCopyStructureOnly()
boolean	isDirectory()
boolean	isFile()
boolean	isLink()
protected boolean	isLogicAccess()
protected boolean	isLogicCheck()
protected boolean	isLogicModify()
private boolean	isViEditSwp(String fileName)
protected DiskFile	logicAccess()
protected DiskFile	logicAccess(String msg)
protected DiskFile	logicCheck()
DiskFile	logicCheck(String msg)
protected DiskFile	logicModify()
protected DiskFile	logicModify(String msg)
void	manualClose()
boolean	manualOpen(boolean append)
void	manualWrite(byte[] data)
void	manualWrite(String data)
boolean	mkdirs()
void	moveTo(String toPath)
byte[]	readAllBytes()
private byte[]	readAllBytesFrom()
String	readAllString()
String	readAllString(String charset)
String	readLink()
protected void	removeLogicAccess()
protected void	removeLogicCheck()
protected void	removeLogicModify()
protected static void	removeQueuePathMapping(String path)
void	setCopyStructureOnly(boolean copyStructureOnly)
void	setModifyTime(Timestamp modifyTime)
void	setModifyTimeFromClock(Timestamp modifyTimeFromClock)
void	setModifyTimeMs(long modifyTimeMs)
void	setModifyTimeMsFromClock(long modifyTimeMsFromClock)
long	size()
void	split(int partSize, FilePart filePart)
void	startFullAsync(long timerMs, String replaceTo)
void	startFullAsync(long timerMs, String replaceTo, Runnable completedCallback)
void	startFullAsync(long timerMs, String replaceTo, Runnable completedCallback, Runnable checkDeleteCompletedCallback)
private void	startFullAsync(long timerMs, String replaceRootPath, String replaceTo, Runnable completedCallback, Runnable checkDeleteCompletedCallback)
private void	startFullAsyncThread(long timerMs, String replaceRootPath, String replaceTo, Runnable completedCallback)
private void	startFullSyncForDelete(Integer filePartDataTable, long timerMs, String replaceTo, String replaceRootPath, Runnable completedCallback)
boolean	write(byte[] data)
boolean	write(byte[] data, boolean append)
boolean	write(String data)
boolean	write(String data, boolean append)
boolean	write(String data, String charset)
boolean	write(String data, String charset, boolean append)
RemoteFile	writeToRemote(RemoteFile remoteFile)
RemoteFile	writeToRemote(RemoteFile remoteFile, Runnable completedCallback)

Methods inherited from class com.killcoding.file.BaseFile

checkSyncPathAvailable, checkUsage, debugLog, getOrigin, getParent, getParents, getPath, isDebug, isDir, isHidden, isStopSync, memoryUsage, memoryUsage, memoryUsing, parsePath, replacePath, setTmpDir, stopSync, timeZoneConver, toAccessTmpFilePath, toCheckTmpFilePath, toModifyTmpFilePath, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

RETRY_OPEN_LIMITED

public static final int RETRY_OPEN_LIMITED

See Also:

• Constant Field Values

MAX_POOL_SIZE

protected static Integer MAX_POOL_SIZE

QUEUE_PATH_MAPPING

private static final Map<String,Long> QUEUE_PATH_MAPPING

splitPool

private static ExecutorService splitPool

copyStructureOnly

protected boolean copyStructureOnly

channel

private FileChannel channel

lock

private FileLock lock

modifyTimeMs

private long modifyTimeMs

Constructor Details

DiskFile

public DiskFile(String path)

DiskFile

public DiskFile(File origin)

Method Details

initPool

public static void initPool(int poolSize)

initDefaultPool

private static void initDefaultPool()

split

public void split(int partSize,
 FilePart filePart)
           throws IOException

Throws:

IOException

copyTo

public void copyTo(String toPath)
            throws IOException

Specified by:

copyTo in class BaseFile

Throws:

IOException

moveTo

public void moveTo(String toPath)
            throws IOException

Specified by:

moveTo in class BaseFile

Throws:

IOException

writeToRemote

public RemoteFile writeToRemote(RemoteFile remoteFile)
                         throws IOException

Throws:

IOException

writeToRemote

public RemoteFile writeToRemote(RemoteFile remoteFile,
 Runnable completedCallback)
                         throws IOException

Throws:

IOException

isLogicModify

protected boolean isLogicModify()
                         throws Exception

Throws:

Exception

logicModify

protected DiskFile logicModify()
                        throws Exception

Throws:

Exception

logicModify

protected DiskFile logicModify(String msg)
                        throws Exception

Throws:

Exception

removeLogicModify

protected void removeLogicModify()

isLogicAccess

protected boolean isLogicAccess()
                         throws Exception

Throws:

Exception

logicAccess

protected DiskFile logicAccess()
                        throws Exception

Throws:

Exception

logicAccess

protected DiskFile logicAccess(String msg)
                        throws Exception

Throws:

Exception

removeLogicAccess

protected void removeLogicAccess()

isLogicCheck

protected boolean isLogicCheck()
                        throws Exception

Throws:

Exception

logicCheck

protected DiskFile logicCheck()
                       throws Exception

Throws:

Exception

logicCheck

public DiskFile logicCheck(String msg)
                    throws Exception

Throws:

Exception

removeLogicCheck

protected void removeLogicCheck()

beforeDelete

public boolean beforeDelete(boolean realDeleted)

Specified by:

beforeDelete in class BaseFile

afterDelete

public void afterDelete(boolean realDeleted)

Specified by:

afterDelete in class BaseFile

beforeMkdirs

public boolean beforeMkdirs()

Specified by:

beforeMkdirs in class BaseFile

afterMkdirs

public void afterMkdirs()

Specified by:

afterMkdirs in class BaseFile

beforeCreateLink

public boolean beforeCreateLink(String target)

Specified by:

beforeCreateLink in class BaseFile

afterCreateLink

public void afterCreateLink(String target)

Specified by:

afterCreateLink in class BaseFile

beforeWrite

public boolean beforeWrite()

Specified by:

beforeWrite in class BaseFile

afterWrite

public void afterWrite()

Specified by:

afterWrite in class BaseFile

delete

public boolean delete()
               throws IOException

Specified by:

delete in class BaseFile

Throws:

IOException

deleteFrom

private boolean deleteFrom()
                    throws IOException

Throws:

IOException

isFile

public boolean isFile()
               throws IOException

Specified by:

isFile in class BaseFile

Throws:

IOException

isDirectory

public boolean isDirectory()
                    throws IOException

Specified by:

isDirectory in class BaseFile

Throws:

IOException

isLink

public boolean isLink()
               throws IOException

Specified by:

isLink in class BaseFile

Throws:

IOException

exists

public boolean exists()
               throws IOException

Specified by:

exists in class BaseFile

Throws:

IOException

mkdirs

public boolean mkdirs()
               throws IOException

Specified by:

mkdirs in class BaseFile

Throws:

IOException

write

public boolean write(byte[] data,
 boolean append)
              throws IOException

Specified by:

write in class BaseFile

Throws:

IOException

manualOpen

public boolean manualOpen(boolean append)
                   throws IOException,
FileAlreadyExistsException

Throws:

IOException

FileAlreadyExistsException

manualWrite

public void manualWrite(byte[] data)
                 throws IOException

Throws:

IOException

manualWrite

public void manualWrite(String data)
                 throws IOException

Throws:

IOException

manualClose

public void manualClose()
                 throws IOException

Throws:

IOException

write

public boolean write(byte[] data)
              throws IOException

Specified by:

write in class BaseFile

Throws:

IOException

write

public boolean write(String data,
 boolean append)
              throws IOException

Specified by:

write in class BaseFile

Throws:

IOException

write

public boolean write(String data,
 String charset,
 boolean append)
              throws IOException

Throws:

IOException

write

public boolean write(String data)
              throws IOException

Specified by:

write in class BaseFile

Throws:

IOException

write

public boolean write(String data,
 String charset)
              throws IOException

Throws:

IOException

createLink

public boolean createLink(String target)
                   throws IOException

Specified by:

createLink in class BaseFile

Throws:

IOException

readLink

public String readLink()
                throws IOException

Specified by:

readLink in class BaseFile

Throws:

IOException

readAllBytes

public byte[] readAllBytes()
                    throws IOException

Specified by:

readAllBytes in class BaseFile

Throws:

IOException

readAllBytesFrom

private byte[] readAllBytesFrom()
                         throws IOException

Throws:

IOException

readAllString

public String readAllString()
                     throws IOException

Specified by:

readAllString in class BaseFile

Throws:

IOException

readAllString

public String readAllString(String charset)
                     throws IOException

Throws:

IOException

size

public long size()
          throws IOException

Specified by:

size in class BaseFile

Throws:

IOException

close

private void close()

complete

public boolean complete()
                 throws IOException

Specified by:

complete in class BaseFile

Throws:

IOException

setModifyTimeMs

public void setModifyTimeMs(long modifyTimeMs)
                     throws IOException

Throws:

IOException

setModifyTimeMsFromClock

public void setModifyTimeMsFromClock(long modifyTimeMsFromClock)
                              throws IOException

Throws:

IOException

setModifyTime

public void setModifyTime(Timestamp modifyTime)
                   throws IOException

Specified by:

setModifyTime in class BaseFile

Throws:

IOException

setModifyTimeFromClock

public void setModifyTimeFromClock(Timestamp modifyTimeFromClock)
                            throws IOException

Throws:

IOException

getModifyTime

public Timestamp getModifyTime()
                        throws IOException

Specified by:

getModifyTime in class BaseFile

Throws:

IOException

getModifyTimeForClock

public Timestamp getModifyTimeForClock()
                                throws IOException

Throws:

IOException

startFullAsync

public void startFullAsync(long timerMs,
 String replaceTo)
                    throws IOException

Throws:

IOException

startFullAsync

public void startFullAsync(long timerMs,
 String replaceTo,
 Runnable completedCallback)
                    throws IOException

Throws:

IOException

startFullAsync

public void startFullAsync(long timerMs,
 String replaceTo,
 Runnable completedCallback,
 Runnable checkDeleteCompletedCallback)
                    throws IOException

Throws:

IOException

startFullAsync

private void startFullAsync(long timerMs,
 String replaceRootPath,
 String replaceTo,
 Runnable completedCallback,
 Runnable checkDeleteCompletedCallback)
                     throws IOException

Throws:

IOException

startFullSyncForDelete

private void startFullSyncForDelete(Integer filePartDataTable,
 long timerMs,
 String replaceTo,
 String replaceRootPath,
 Runnable completedCallback)
                             throws IOException

Throws:

IOException

getScanDeleteFilter

private CacheArrayFilter getScanDeleteFilter(RemoteFile rootDir,
 Integer filePartDataTable,
 long timerMs,
 String replaceTo,
 String replaceRootPath,
 Runnable completedCallback)

startFullAsyncThread

private void startFullAsyncThread(long timerMs,
 String replaceRootPath,
 String replaceTo,
 Runnable completedCallback)

getFullAsyncFilter

private CacheArrayFilter getFullAsyncFilter(DiskFile the,
 long timerMs,
 String replaceRootPath,
 String replaceTo,
 Runnable completedCallback)

setCopyStructureOnly

public void setCopyStructureOnly(boolean copyStructureOnly)

isCopyStructureOnly

public boolean isCopyStructureOnly()

isViEditSwp

private boolean isViEditSwp(String fileName)

copyAttrs

protected static DiskFile copyAttrs(DiskFile source,
 boolean _copyStructureOnly,
 File _syncRoot)

getParentFile

public File getParentFile()

checkSyncPathAvailable

protected boolean checkSyncPathAvailable(String path)

addQueuePathMapping

protected static boolean addQueuePathMapping(String path)

checkQueuePathMapping

public static boolean checkQueuePathMapping()

removeQueuePathMapping

protected static void removeQueuePathMapping(String path)

getQueuePathMapping

public static Map<String,Long> getQueuePathMapping()

debugLog

private static void debugLog(String point,
 RemoteFile rf,
 CacheArrayFilter filter)