inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-24 17:32:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Build of bm-remote executable jar.

Browse Source 
Some tweaks to the verbose reporting of the bm-remote client.


git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@6793 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Derek Hulley
2007-09-15 20:12:40 +00:00
parent 66a82b5781
commit de179a659b
2 changed files with 35 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
source/java/org/alfresco/repo/model/filefolder/loader/AbstractLoaderThread.java
View File

@@ -46,7 +46,12 @@ public abstract class AbstractLoaderThread extends Thread
protected final int testLoadDepth;
private AtomicBoolean mustStop;
Random random;
private Random random;
// Statistics
private int statCount;
private double statTotalMs;
private double statAverageMs;
public AbstractLoaderThread(
LoaderSession session,
@@ -65,6 +70,10 @@ public abstract class AbstractLoaderThread extends Thread
this.mustStop = new AtomicBoolean(false);
this.random = new Random();
this.statCount = 0;
this.statTotalMs = 0.0D;
this.statAverageMs = 0.0D;
}
/**
@@ -95,11 +104,15 @@ public abstract class AbstractLoaderThread extends Thread
int nodeIndex = random.nextInt(nodeCount);
NodeRef workingRootNodeRef = session.getWorkingRootNodeRefs().get(nodeIndex);
long startTime = System.currentTimeMillis();
long startTime = System.nanoTime();
String msg = doLoading(serverProxy, workingRootNodeRef);
long endTime = System.currentTimeMillis();
long endTime = System.nanoTime();
// Record stats
updateStats(startTime, endTime);
// Dump the specifics of the load
logVerbose(startTime, endTime, msg);
// Have we done this enough?
testCount++;
@@ -126,9 +139,25 @@ public abstract class AbstractLoaderThread extends Thread
}
}
private void dumpLoadSpecifics(long startTime, long endTime, String msg)
private synchronized void updateStats(long startTime, long endTime)
{
statCount++;
// Calculate the delta in milliseconds
double delta = ((double)(endTime - startTime) / 1000.0);
// Now recalculate the average
statTotalMs += delta;
statAverageMs = (statTotalMs / (double)statCount);
}
private void logVerbose(long startTime, long endTime, String msg)
{
double delta = ((double)(endTime - startTime) / 1000.0);
StringBuilder sb = new StringBuilder();
sb.append(loaderName).append(", ")
.append(String.format("%5.1d", (int)delta)).append(", ")
.append(msg);
session.logVerbose(sb.toString());
}
/**