transferobserver.java

peeranha42是jxta的 p2p程序核心

package de.uni_bremen.informatik.p2p.plugins.filesharing.control;

import de.uni_bremen.informatik.p2p.plugins.filesharing.data.DownloadJob;

/**
 * @author Lars Kordes
 */
public class TransferObserver extends Thread {
	private DownloadJob dj = null;
	
	public TransferObserver(DownloadJob arg1) {
		dj = arg1;
	}
	
	public void run() {
		long time = System.currentTimeMillis();
		long progress = dj.getProgress();
		while(true) {
			try {
				sleep(1000);
			} catch (InterruptedException e) {
			}
			long sec = (System.currentTimeMillis()-time)*1000;
			long bytes = (dj.progress - progress)*1024;
			dj.setDownloadRate(bytes/sec);
			
			time = System.currentTimeMillis();
			progress = dj.getProgress();
		}
	}
}