Author: jflesch
Date: 2006-07-20 18:32:48 +0000 (Thu, 20 Jul 2006)
New Revision: 9674
Added:
trunk/apps/Thaw/src/thaw/plugins/StatusBar.java
Log:
I've forgotten status bar plugin ...
Added: trunk/apps/Thaw/src/thaw/plugins/StatusBar.java
===================================================================
--- trunk/apps/Thaw/src/thaw/plugins/StatusBar.java 2006-07-20 18:31:47 UTC
(rev 9673)
+++ trunk/apps/Thaw/src/thaw/plugins/StatusBar.java 2006-07-20 18:32:48 UTC
(rev 9674)
@@ -0,0 +1,126 @@
+package thaw.plugins;
+
+import java.util.Vector;
+import java.util.Iterator;
+
+import thaw.i18n.I18n;
+import thaw.core.*;
+import thaw.fcp.*;
+
+public class StatusBar implements Runnable, Plugin {
+ public final static int INTERVAL = 3000; /* in ms */
+ public final static String SEPARATOR = " ";
+
+ private Core core;
+ private boolean running;
+ private Thread refresher;
+
+
+ public boolean run(Core core) {
+ this.core = core;
+
+ running = true;
+ refresher = new Thread(this);
+
+ refresher.start();
+
+ return true;
+ }
+
+ public void run() {
+ while(running) {
+
+ try {
+ Thread.sleep(INTERVAL);
+ } catch(java.lang.InterruptedException e) {
+ // pfff :P
+ }
+
+ updateStatusBar();
+
+ }
+
+ }
+
+ public void updateStatusBar() {
+ int progressDone = 0;
+ int progressTotal = 0;
+
+ int finished = 0;
+ int failed = 0;
+ int running = 0;
+ int pending = 0;
+ int total = 0;
+
+ try {
+ Vector runningQueue =
core.getQueueManager().getRunningQueue();
+
+ for(Iterator it = runningQueue.iterator();
+ it.hasNext(); ) {
+ FCPTransferQuery query =
(FCPTransferQuery)it.next();
+
+ if(query.isRunning()) {
+ running++;
+ progressTotal += 100;
+ progressDone += query.getProgression();
+ }
+
+ if(query.isFinished() && query.isSuccessful()) {
+ finished++;
+ progressTotal += 100;
+ progressDone += 100;
+ }
+
+ if(query.isFinished() && !query.isSuccessful())
{
+ failed++;
+ }
+ }
+
+ Vector[] pendingQueues =
core.getQueueManager().getPendingQueues();
+
+ for(int i =0 ; i < pendingQueues.length; i++) {
+
+ progressTotal += pendingQueues[i].size() * 100;
+ pending += pendingQueues[i].size();
+
+ }
+
+ } catch(java.util.ConcurrentModificationException e) {
+ Logger.notice(this, "Collision !");
+
core.getMainWindow().setStatus(core.getMainWindow().getStatus()+"*");
+ return;
+ }
+
+ total = finished + failed + running + pending;
+
+ core.getMainWindow().setStatus("Thaw "+Main.VERSION
+ + SEPARATOR +
I18n.getMessage("thaw.plugin.statistics.globalProgression") + " "
+ + Integer.toString(progressDone)
+ "/" + Integer.toString(progressTotal)
+ + SEPARATOR +
I18n.getMessage("thaw.plugin.statistics.finished")+ " "
+ + Integer.toString(finished) +
"/" + Integer.toString(total)
+ + SEPARATOR +
I18n.getMessage("thaw.plugin.statistics.failed") + " "
+ + Integer.toString(failed) + "/"
+ Integer.toString(total)
+ + SEPARATOR +
I18n.getMessage("thaw.plugin.statistics.running") + " "
+ + Integer.toString(running) +
"/" + Integer.toString(total)
+ + SEPARATOR +
I18n.getMessage("thaw.plugin.statistics.pending") + " "
+ + Integer.toString(pending) +
"/" + Integer.toString(total)
+ );
+
+ }
+
+
+ public boolean stop() {
+ running = false;
+
+ core.getMainWindow().setStatus("Thaw "+Main.VERSION);
+
+ return true;
+ }
+
+
+ public String getNameForUser() {
+ return I18n.getMessage("thaw.plugin.statistics.statistics");
+ }
+
+
+}
