1 files changed, 110 insertions, 0 deletions
diff --git a/target_explorer/plugins/org.eclipse.tcf.te.filesystem.core/src/org/eclipse/tcf/te/tcf/filesystem/core/internal/operations/OpTargetFileDigest.java b/target_explorer/plugins/org.eclipse.tcf.te.filesystem.core/src/org/eclipse/tcf/te/tcf/filesystem/core/internal/operations/OpTargetFileDigest.java
new file mode 100644
index 000000000..328acbd3a
--- /dev/null
+++ b/target_explorer/plugins/org.eclipse.tcf.te.filesystem.core/src/org/eclipse/tcf/te/tcf/filesystem/core/internal/operations/OpTargetFileDigest.java
@@ -0,0 +1,110 @@
+/*******************************************************************************
+ * Copyright (c) 2012 Wind River Systems, Inc. and others. All rights reserved.
+ * This program and the accompanying materials are made available under the terms
+ * of the Eclipse Public License v1.0 which accompanies this distribution, and is
+ * available at http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Wind River Systems - initial API and implementation
+ *******************************************************************************/
+package org.eclipse.tcf.te.tcf.filesystem.core.internal.operations;
+
+import java.io.BufferedInputStream;
+import java.io.IOException;
+import java.lang.reflect.InvocationTargetException;
+import java.net.URL;
+import java.security.DigestInputStream;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+import org.eclipse.core.runtime.IProgressMonitor;
+import org.eclipse.tcf.te.tcf.filesystem.core.interfaces.IOperation;
+import org.eclipse.tcf.te.tcf.filesystem.core.model.FSTreeNode;
+
+/**
+ * The operation that computes the digest of the cache file in the background.
+ */
+public class OpTargetFileDigest implements IOperation {
+	// The digest of which is going to be computed.
+	FSTreeNode node;
+	// The computing result
+	byte[] digest;
+
+	/**
+	 * Create an operation to compute the digest of its target file.
+	 * 
+	 * @param node The file system node.
+	 */
+	public OpTargetFileDigest(FSTreeNode node) {
+	    this.node = node;
+    }
+	/*
+	 * (non-Javadoc)
+	 * @see org.eclipse.tcf.te.tcf.filesystem.core.interfaces.IOperation#run(org.eclipse.core.runtime.IProgressMonitor)
+	 */
+	@Override
+	public void run(IProgressMonitor monitor) throws InvocationTargetException, InterruptedException {
+		BufferedInputStream input = null;
+		try {
+			long totalSize = node.attr.size;
+			int chunk_size = (int) totalSize / 100;
+			int percentRead = 0;
+			long bytesRead = 0;
+			URL url = node.getLocationURL();
+			MessageDigest digest = MessageDigest.getInstance(MD_ALG);
+			input = new BufferedInputStream(new DigestInputStream(url.openStream(), digest));
+			// The buffer used to download the file.
+			byte[] data = new byte[OpStreamOp.DEFAULT_CHUNK_SIZE];
+			int length;
+			while ((length = input.read(data)) >= 0){
+				bytesRead += length;
+				if (chunk_size != 0) {
+					int percent = (int) bytesRead / chunk_size;
+					if (percent != percentRead) { // Update the progress.
+						monitor.worked(percent - percentRead);
+						percentRead = percent; // Remember the percentage.
+					}
+				}
+			}
+			this.digest = digest.digest();
+		}
+        catch (NoSuchAlgorithmException e) {
+			throw new InvocationTargetException(e);
+        }
+        catch (IOException e) {
+			throw new InvocationTargetException(e);
+        }
+		finally {
+			if (input != null) {
+				try {input.close();} catch (Exception e) {}
+			}
+		}
+	}
+	
+	/**
+	 * Get the computing result.
+	 * 
+	 * @return The message digest of this cache file.
+	 */
+	public byte[] getDigest() {
+		return digest;
+	}
+
+	/*
+	 * (non-Javadoc)
+	 * @see org.eclipse.tcf.te.tcf.filesystem.core.interfaces.IOperation#getName()
+	 */
+	@Override
+	public String getName() {
+		return "Update target digest"; //$NON-NLS-1$
+	}
+
+	/*
+	 * (non-Javadoc)
+	 * @see org.eclipse.tcf.te.tcf.filesystem.core.interfaces.IOperation#getTotalWork()
+	 */
+	@Override
+	public int getTotalWork() {
+		return 100;
+	}
+}