Examples of org.apache.jackrabbit.core.data.AsyncUploadCache

org.apache.jackrabbit.core.data.AsyncUploadCache
This class holds all in progress uploads. This class contains two data structures, one is {@link #asyncUploadMap} which is {@link Map}of file path vs lastModified of upload. The second {@link #toBeDeleted} is{@link Set} of upload which is marked for delete, while it is alreadyin progress. Before starting an asynchronous upload, it requires to invoke {@link #add(String)} to add entry to {@link #asyncUploadMap}. After asynchronous upload completes, it requires to invoke {@link #remove(String,AsyncUploadCacheResult)} to remove entry from{@link #asyncUploadMap} Any modification to this class are immediatelypersisted to local file system. {@link #asyncUploadMap} is persisted to /{@link homeDir}/ {@link #PENDIND_UPLOAD_FILE}. {@link #toBeDeleted} ispersisted to / {@link homeDir}/ {@link #TO_BE_DELETED_UPLOAD_FILE}. The / {@link homeDir} refer to ${rep.home}.

    /**
     * Test to validate store retrieve in cache.
     */
    public void testStoreRetrieve() {
        try {
            AsyncUploadCache pendingFiles = new AsyncUploadCache();
            pendingFiles.init(TARGET_DIR, CACHE_DIR, 100);
            pendingFiles.reset();
            LocalCache cache = new LocalCache(CACHE_DIR, TEMP_DIR, 400, 0.95,
                0.70, pendingFiles);
            Random random = new Random(12345);
            byte[] data = new byte[100];
            Map<String, byte[]> byteMap = new HashMap<String, byte[]>();

View Full Code Here

     * Test to verify cache's purging if cache current size exceeds
     * cachePurgeTrigFactor * size.
     */
    public void testAutoPurge() {
        try {
            AsyncUploadCache pendingFiles = new AsyncUploadCache();
            pendingFiles.init(TARGET_DIR, CACHE_DIR, 100);
            pendingFiles.reset();
            LocalCache cache = new LocalCache(CACHE_DIR, TEMP_DIR, 400, 0.95,
                0.70, pendingFiles);
            Random random = new Random(12345);
            byte[] data = new byte[100];
            Map<String, byte[]> byteMap = new HashMap<String, byte[]>();

View Full Code Here

     * Test to verify cache's purging if cache current size exceeds
     * cachePurgeTrigFactor * size.
     */
    public void testAutoPurgeWithPendingUpload() {
        try {
            AsyncUploadCache pendingFiles = new AsyncUploadCache();
            pendingFiles.init(TARGET_DIR, CACHE_DIR, 100);
            pendingFiles.reset();
            LocalCache cache = new LocalCache(CACHE_DIR, TEMP_DIR, 400, 0.95,
                0.70, pendingFiles);
            Random random = new Random(12345);
            byte[] data = new byte[125];
            Map<String, byte[]> byteMap = new HashMap<String, byte[]>();

View Full Code Here

        // FIXME: JCR-3806
        if (true) {
            return;
        }
        try {
            AsyncUploadCache pendingFiles = new AsyncUploadCache();
            pendingFiles.init(TARGET_DIR, CACHE_DIR, 100);
            pendingFiles.reset();
            LocalCache cache = new LocalCache(CACHE_DIR, TEMP_DIR, 400, 0.95,
                0.70, pendingFiles);
            Random random = new Random(12345);
            byte[] data = new byte[100];
            Map<String, byte[]> byteMap = new HashMap<String, byte[]>();

View Full Code Here

        // FIXME: JCR-3806
        if (true) {
            return;
        }
        try {
            AsyncUploadCache pendingFiles = new AsyncUploadCache();
            pendingFiles.init(TARGET_DIR, CACHE_DIR, 100);
            pendingFiles.reset();
            LocalCache cache = new LocalCache(CACHE_DIR, TEMP_DIR, 400, 0.95,
                0.70, pendingFiles);
            Random random = new Random(12345);
            byte[] data = new byte[100];
            Map<String, byte[]> byteMap = new HashMap<String, byte[]>();

View Full Code Here

        // FIXME: JCR-3806
        if (true) {
            return;
        }
        try {
            AsyncUploadCache pendingFiles = new AsyncUploadCache();
            pendingFiles.init(TARGET_DIR, CACHE_DIR, 100);
            pendingFiles.reset();
            LocalCache cache = new LocalCache(CACHE_DIR, TEMP_DIR, 400, 0.95,
                0.70, pendingFiles);
            Random random = new Random(12345);
            byte[] data = new byte[125];
            Map<String, byte[]> byteMap = new HashMap<String, byte[]>();

View Full Code Here

TOP

Related Classes of org.apache.jackrabbit.core.data.AsyncUploadCache

org.apache.jackrabbit.core.data.TestLocalCache

java.io.File

java.io.IOException

java.io.InputStream

java.io.ObjectOutputStream

java.io.ObjectInput

java.io.BufferedOutputStream

java.io.FileInputStream

java.io.FileOutputStream

java.io.ObjectInputStream

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.