updatemonitor.java

这是一个基于java编写的torrent的P2P源码

/*
 * Created on 7 mai 2004
 * Created by Olivier Chalouhi
 * 
 * Copyright (C) 2004, 2005, 2006 Aelitis SAS, All rights Reserved
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details ( see the LICENSE file ).
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * 
 * AELITIS, SAS au capital de 46,603.30 euros,
 * 8 Allee Lenotre, La Grille Royale, 78600 Le Mesnil le Roi, France.
 */
package org.gudy.azureus2.ui.swt.update;


import org.eclipse.swt.SWT;

import org.gudy.azureus2.core3.config.COConfigurationManager;
import org.gudy.azureus2.core3.internat.MessageText;
import org.gudy.azureus2.core3.logging.LogEvent;
import org.gudy.azureus2.core3.logging.LogIDs;
import org.gudy.azureus2.core3.logging.Logger;
import org.gudy.azureus2.core3.util.*;
import org.gudy.azureus2.ui.swt.MessageBoxWindow;
import org.gudy.azureus2.ui.swt.Utils;
import org.gudy.azureus2.ui.swt.mainwindow.SWTThread;
import org.gudy.azureus2.update.CoreUpdateChecker;

import com.aelitis.azureus.core.AzureusCore;
import com.aelitis.azureus.ui.UIFunctions;
import com.aelitis.azureus.ui.UIFunctionsManager;

import org.gudy.azureus2.plugins.update.*;

/**
 * @author Olivier Chalouhi
 *
 */
public class 
UpdateMonitor 
	implements UpdateCheckInstanceListener 
{
	private static final LogIDs LOGID = LogIDs.GUI;
	public static final long AUTO_UPDATE_CHECK_PERIOD = 23*60*60*1000;  // 23 hours

	protected static UpdateMonitor		singleton;
	
	protected static AEMonitor			class_mon 	= new AEMonitor( "UpdateMonitor:class" );
	
	
	public static UpdateMonitor
	getSingleton(
		AzureusCore		core )
	{
		try{
			class_mon.enter();
		
			if ( singleton == null ){
				
				singleton = new UpdateMonitor( core );
			}
			
			return( singleton );
			
		}finally{
			
			class_mon.exit();
		}
	}

	protected AzureusCore			azureus_core;
	protected UpdateWindow 			current_update_window;
	protected UpdateCheckInstance	current_update_instance;
	
	  		
	
	protected 
	UpdateMonitor(
		AzureusCore				_azureus_core )
	{
		azureus_core	= _azureus_core;
		
	  	UpdateManager um = azureus_core.getPluginManager().getDefaultPluginInterface().getUpdateManager(); 

	  	um.addListener(
	  		new UpdateManagerListener()
			{
	  			public void
				checkInstanceCreated(
					UpdateCheckInstance	instance )
	  			{
	  				instance.addListener( UpdateMonitor.this );
	  			}
			});
	  	
	  	um.addVerificationListener(
	  			new UpdateManagerVerificationListener()
	  			{
	  				public boolean
	  				acceptUnVerifiedUpdate(
	  					final Update		update )
	  				{
						final boolean	accept[]	 = {false};
						
						Utils.execSWTThread(
								new Runnable()
								{
									public void
									run()
									{
										accept[0] = MessageBoxWindow.open( 
											"UpdateMonitor.messagebox.accept.unverified",
											SWT.YES | SWT.NO,
											SWT.NULL,
											false,
											SWTThread.getInstance().getDisplay(),
											MessageBoxWindow.ICON_WARNING,
											MessageText.getString( "UpdateMonitor.messagebox.accept.unverified.title" ),
											MessageText.getString( 
													"UpdateMonitor.messagebox.accept.unverified.text", 
													new String[]{ update.getName()})) == SWT.YES;
										
									}
								},
								false );	
							
						return( accept[0] );
	  				}
	  				
	  				public void
	  				verificationFailed(
	  					final Update		update,
	  					final Throwable		cause )
	  				{
	  					final String	cause_str = Debug.getNestedExceptionMessage( cause );
	  					
						Utils.execSWTThread(
								new Runnable()
								{
									public void
									run()
									{
										Utils.openMessageBox(Utils.findAnyShell(),
											SWT.OK,
											"UpdateMonitor.messagebox.verification.failed",
											new String[]{ update.getName(), cause_str });
									}
								});
	  				}
	  			});
	  	
	    SimpleTimer.addPeriodicEvent( 
	    		"UpdateMon:autocheck",
	            AUTO_UPDATE_CHECK_PERIOD,
	            new TimerEventPerformer()
	            {
	            	public void
					perform(
						TimerEvent  ev )
					{
	            		performAutoCheck(false);
					}
	            });
	      
	    	// wait a bit before starting check to give rest of AZ time to initialise 
	    
		new DelayedEvent(
				"UpdateMon:wait",
				2500,
				new AERunnable()
				{
					public void
					runSupport()
					{
						performAutoCheck(true);
					}
				});
	}
  
	protected void
	performAutoCheck(
		final boolean		start_of_day )
	{
		boolean check_at_start	= false;
		boolean check_periodic	= false;
		boolean bOldSWT = SWT.getVersion() < 3139;
	
			// no update checks for java web start
		
		if ( !SystemProperties.isJavaWebStartInstance()){
					
			// force check when SWT is really old
			check_at_start	= COConfigurationManager.getBooleanParameter( "update.start", true ) || bOldSWT;
			check_periodic	= COConfigurationManager.getBooleanParameter( "update.periodic", true );
		}
		
			// periodic -> check at start as well
		
		check_at_start = check_at_start || check_periodic;
		
		if (	( check_at_start && start_of_day) ||
				( check_periodic && !start_of_day )){
			
			performCheck(bOldSWT, true, null);	// this will implicitly do usage stats
			
		}else{

			new DelayedEvent(
					"UpdateMon:wait2",
					5000,
					new AERunnable()
					{
						public void
						runSupport()
						{
							if ( start_of_day ){
						  	UIFunctions uiFunctions = UIFunctionsManager.getUIFunctions();
						  	if (uiFunctions != null) {
						  		uiFunctions.setStatusText("");
						  	}
							}

							CoreUpdateChecker.doUsageStats();
						}
					});
		}
	}

	public void
	performCheck(
		final boolean 						bForce, 
		final boolean						automatic,
		final UpdateCheckInstanceListener 	l )
	{
		if ( SystemProperties.isJavaWebStartInstance()){
			
				// just in case we get here somehome!
			if (Logger.isEnabled())
				Logger.log(new LogEvent(LOGID,
						"skipping update check as java web start"));
			
			return;
		}

			// kill any existing update window
		
	    if ( current_update_window != null && ! current_update_window.isDisposed()){
	    	
	      SWTThread.getInstance().getDisplay().syncExec(
	      		new AERunnable() 
				{
	      			public void 
					runSupport() 
	      			{               
	      				current_update_window.dispose();
	      			}
	      		});
	    }
	    
	    if ( current_update_instance != null ){
	    	
	    	current_update_instance.cancel();
	    }
	    
	  	UIFunctions uiFunctions = UIFunctionsManager.getUIFunctions();
	  	if (uiFunctions != null) {
	  		// XXX What kind of format is this!?
	  		uiFunctions.setStatusText("MainWindow.status.checking ...");
	  	}
	    
	    	// take this off this GUI thread in case it blocks for a while
	    
	   AEThread t = 
		   	new AEThread( "UpdateMonitor:kickoff")
				{
			    	public void
					runSupport()
			    	{
			    		UpdateManager um = azureus_core.getPluginManager().getDefaultPluginInterface().getUpdateManager(); 
				
			    		current_update_instance = 
			    			um.createUpdateCheckInstance(
			    				bForce ? UpdateCheckInstance.UCI_INSTALL : UpdateCheckInstance.UCI_UPDATE,
			  					"update.instance.update" );
			  	
			    		if ( !automatic ){
			    			
			    			current_update_instance.setAutomatic( false );
			    		}
			    		
			    		if (l != null) {
			    			current_update_instance.addListener(l);
			    		}
			    		current_update_instance.start();
			    	}
				};
			
		t.setDaemon( true );
		
		t.start();
	}
	
	public void
	complete(
		UpdateCheckInstance		instance )
	{
			// we can get here for either update actions (triggered above) or for plugin
			// install actions (triggered by the plugin installer)
		
		boolean	update_action = instance.getType() == UpdateCheckInstance.UCI_UPDATE;
		
		UIFunctions uiFunctions = UIFunctionsManager.getUIFunctions();
		if (uiFunctions != null) {
			uiFunctions.setStatusText("");
		}
		
	    Update[] us = instance.getUpdates();
	   
	    boolean	show_window = false;
	    
	    	// updates with zero-length downloaders exist for admin purposes
	    	// and shoudn't cause the window to be shown if only they exist
	    
	    for (int i=0;i<us.length;i++){
	    	
	    	if (us[i].getDownloaders().length > 0 ){
	    		
	    		show_window	= true;
	    		
	    		break;
	    	}
	    }
	    
	    	// this controls whether or not the update window is displayed
	    	// note that we just don't show the window if this is set, we still do the
	    	// update check (as amongst other things we want ot know the latest
	    	// version of the core anyway	    
	    
    	if ( show_window ){
    		
    			// don't show another update if one's already there!
    		
    		UpdateWindow	this_window = null;
    		
    		if ( update_action ){
    			
    			if ( current_update_window == null || current_update_window.isDisposed()){
    			
    				this_window = current_update_window = new UpdateWindow( azureus_core, instance );
    			}
    		}else{

    				// always show an installer window
    			
    			this_window = new UpdateWindow( azureus_core, instance );
    		}
    		
    		if ( this_window != null ){
    			
	    		for( int i = 0 ;  i < us.length; i++ ){
				
	    			if ( us[i].getDownloaders().length > 0 ){
	    				
	    				this_window.addUpdate(us[i]);
	    			}
	    		}
	    		
	    		this_window.updateAdditionComplete();
	    		
    		}else{
    			if (Logger.isEnabled())
						Logger.log(new LogEvent(LOGID, LogEvent.LT_WARNING,
								"UpdateMonitor: user dialog already "
										+ "in progress, updates skipped"));

    		}
    	}else{
    		if (Logger.isEnabled())
					Logger.log(new LogEvent(LOGID, "UpdateMonitor: check instance "
							+ "resulted in no user-actionable updates"));

    	}
	} 
	
	public void
	cancelled(
		UpdateCheckInstance		instance )
	{
		UIFunctions uiFunctions = UIFunctionsManager.getUIFunctions();
		if (uiFunctions != null) {
			uiFunctions.setStatusText("");
		}
	}
}