vmario/docs
1
0
Fork 0
mirror of https://github.com/sismics/docs.git synced 2024-11-22 05:57:57 +01:00
Code Issues Packages Projects Releases Wiki Activity

add more log to debug processing indicator

Browse Source
This commit is contained in:
bgamard 2020-05-17 21:58:13 +02:00
parent 16fc058264
commit d9ad69c7ff
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs-core/src/main/java/com/sismics/docs/core/listener/async/FileProcessingAsyncListener.java
View File

@ -152,7 +152,7 @@ public class FileProcessingAsyncListener {
} catch (Exception e) { } catch (Exception e) {
log.error("Error extracting content from: " + file, e); log.error("Error extracting content from: " + file, e);
} }
log.info(MessageFormat.format("File content extracted in {0}ms", System.currentTimeMillis() - startTime)); log.info(MessageFormat.format("File content extracted in {0}ms: " + file.getId(), System.currentTimeMillis() - startTime));
// Save the file to database // Save the file to database
FileDao fileDao = new FileDao(); FileDao fileDao = new FileDao();

9
docs-core/src/main/java/com/sismics/docs/core/util/FileUtil.java
View File

@ -18,6 +18,8 @@ import com.sismics.util.context.ThreadLocalContext;
import com.sismics.util.io.InputStreamReaderThread; import com.sismics.util.io.InputStreamReaderThread;
import com.sismics.util.mime.MimeTypeUtil; import com.sismics.util.mime.MimeTypeUtil;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.crypto.Cipher; import javax.crypto.Cipher;
import javax.crypto.CipherInputStream; import javax.crypto.CipherInputStream;
@ -36,6 +38,11 @@ import java.util.*;
* @author bgamard * @author bgamard
*/ */
public class FileUtil { public class FileUtil {
/**
* Logger.
*/
private static final Logger log = LoggerFactory.getLogger(FileUtil.class);
/** /**
* File ID of files currently being processed. * File ID of files currently being processed.
*/ */
@ -211,6 +218,7 @@ public class FileUtil {
*/ */
public static void startProcessingFile(String fileId) { public static void startProcessingFile(String fileId) {
processingFileSet.add(fileId); processingFileSet.add(fileId);
log.info("Processing started for file: " + fileId);
} }
/** /**
@ -220,6 +228,7 @@ public class FileUtil {
*/ */
public static void endProcessingFile(String fileId) { public static void endProcessingFile(String fileId) {
processingFileSet.remove(fileId); processingFileSet.remove(fileId);
log.info("Processing ended for file: " + fileId);
} }
/** /**