PluginInitializerpublic class PluginInitializer extends Object implements AEDiagnosticsEvidenceGenerator, org.gudy.azureus2.core3.global.GlobalManagerListener
Fields Summary |
---|
private static final LogIDs | LOGID | public static final String | INTERNAL_PLUGIN_ID | private String[] | builtin_plugins | private static String[] | default_version_details | private static PluginInitializer | singleton | private static AEMonitor | class_mon | private static List | registration_queue | private AzureusCoreOperation | core_operation | private AzureusCore | azureus_core | private PluginInterfaceImpl | default_plugin | private PluginManager | plugin_manager | private ClassLoader | root_class_loader | private List | loaded_pi_list | private static boolean | loading_builtin | private List | plugins | private List | plugin_interfaces | private Thread | init_thread | private boolean | initialisation_complete |
Constructors Summary |
---|
protected PluginInitializer(AzureusCore _azureus_core, AzureusCoreOperation _core_operation)
azureus_core = _azureus_core;
AEDiagnostics.addEvidenceGenerator( this );
azureus_core.addLifecycleListener(
new AzureusCoreLifecycleAdapter()
{
public void
componentCreated(
AzureusCore core,
AzureusCoreComponent comp )
{
if ( comp instanceof GlobalManager ){
GlobalManager gm = (GlobalManager)comp;
gm.addListener( PluginInitializer.this );
}
}
});
core_operation = _core_operation;
UpdateManagerImpl.getSingleton( azureus_core ); // initialise the update manager
plugin_manager = PluginManagerImpl.getSingleton( this );
UpdaterUtils.checkBootstrapPlugins();
|
Methods Summary |
---|
public void | destroyInitiated()
for (int i=0;i<plugin_interfaces.size();i++){
((PluginInterfaceImpl)plugin_interfaces.get(i)).closedownInitiated();
}
if ( default_plugin != null ){
default_plugin.closedownInitiated();
}
| public void | destroyed()
for (int i=0;i<plugin_interfaces.size();i++){
((PluginInterfaceImpl)plugin_interfaces.get(i)).closedownComplete();
}
if ( default_plugin != null ){
default_plugin.closedownComplete();
}
| public void | downloadManagerAdded(org.gudy.azureus2.core3.download.DownloadManager dm)
| public void | downloadManagerRemoved(org.gudy.azureus2.core3.download.DownloadManager dm)
| public static void | fireEvent(int type)
singleton.fireEventSupport(type, null);
| public static void | fireEvent(int type, java.lang.Object value)
singleton.fireEventSupport(type, value);
| protected void | fireEventSupport(int type, java.lang.Object value)
PluginEvent ev =
new PluginEvent()
{
public int
getType()
{
return( type );
}
public Object
getValue()
{
return( value );
}
};
for (int i=0;i<plugin_interfaces.size();i++){
try{
((PluginInterfaceImpl)plugin_interfaces.get(i)).firePluginEvent(ev);
}catch(Throwable e ){
Debug.printStackTrace(e);
}
}
if ( default_plugin != null ){
default_plugin.firePluginEvent(ev);
}
| public void | generate(IndentWriter writer)
writer.println( "Plugins" );
try{
writer.indent();
for (int i=0;i<plugin_interfaces.size();i++){
PluginInterfaceImpl pi = (PluginInterfaceImpl)plugin_interfaces.get(i);
pi.generateEvidence( writer );
}
}finally{
writer.exdent();
}
| protected AzureusCore | getAzureusCore()
return( azureus_core );
| public static PluginInterface | getDefaultInterface()
return( singleton.getDefaultInterfaceSupport());
| protected PluginInterface | getDefaultInterfaceSupport()
if ( default_plugin == null ){
default_plugin =
new PluginInterfaceImpl(
new Plugin()
{
public void
initialize(
PluginInterface pi)
{
}
},
this,
getClass(),
getClass().getClassLoader(),
"default",
new Properties(),
null,
INTERNAL_PLUGIN_ID,
null );
}
return( default_plugin );
| protected org.gudy.azureus2.core3.global.GlobalManager | getGlobalManager()
return( azureus_core.getGlobalManager() );
| protected PluginInterfaceImpl | getPluginFromClass(java.lang.Class cla)
return( getPluginFromClass( cla.getName()));
| protected PluginInterfaceImpl | getPluginFromClass(java.lang.String class_name)
for (int i=0;i<plugin_interfaces.size();i++){
PluginInterfaceImpl pi = (PluginInterfaceImpl)plugin_interfaces.get(i);
if ( pi.getPlugin().getClass().getName().equals( class_name )){
return( pi );
}
}
// fall back to the loaded but not-yet-initialised list
for (int i=0;i<loaded_pi_list.size();i++){
List l = (List)loaded_pi_list.get(i);
for (int j=0;j<l.size();j++){
PluginInterfaceImpl pi = (PluginInterfaceImpl)l.get(j);
if ( pi.getPlugin().getClass().getName().equals( class_name )){
return( pi );
}
}
}
return( null );
| public static java.util.List | getPluginInterfaces()
return singleton.getPluginInterfacesSupport();
| protected java.util.List | getPluginInterfacesSupport()
return plugin_interfaces;
| protected PluginManager | getPluginManager()
return( plugin_manager );
| public PluginInterface[] | getPlugins()
List pis = getPluginInterfacesSupport();
PluginInterface[] res = new PluginInterface[pis.size()];
pis.toArray(res);
return( res );
| private void | getRootClassLoader()
// first do explicit plugins
File user_dir = FileUtil.getUserFile("shared");
getRootClassLoader( user_dir );
File app_dir = FileUtil.getApplicationFile("shared");
if ( !user_dir.equals( app_dir )){
getRootClassLoader( app_dir );
}
| private void | getRootClassLoader(java.io.File dir)
dir = new File( dir, "lib" );
if ( dir.exists() && dir.isDirectory()){
File[] files = dir.listFiles();
if ( files != null ){
files = PluginLauncherImpl.getHighestJarVersions( files, new String[]{ null }, new String[]{ null }, false );
for (int i=0;i<files.length;i++){
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Share class loader extended by " + files[i].toString()));
root_class_loader =
PluginLauncherImpl.addFileToClassPath(
PluginInitializer.class.getClassLoader(),
root_class_loader, files[i] );
}
}
}
| public static org.gudy.azureus2.pluginsimpl.local.PluginInitializer | getSingleton(AzureusCore azureus_core, AzureusCoreOperation core_operation)
try{
class_mon.enter();
if ( singleton == null ){
singleton = new PluginInitializer( azureus_core, core_operation );
}
return( singleton );
}finally{
class_mon.exit();
}
| public void | initialisationComplete()
initialisation_complete = true;
UIManagerImpl.initialisationComplete();
for (int i=0;i<plugin_interfaces.size();i++){
((PluginInterfaceImpl)plugin_interfaces.get(i)).initialisationComplete();
}
if ( default_plugin != null ){
default_plugin.initialisationComplete();
}
| private void | initialisePlugin(java.util.List l)
PluginException last_load_failure = null;
for (int i=0;i<l.size();i++){
PluginInterfaceImpl plugin_interface = (PluginInterfaceImpl)l.get(i);
if (plugin_interface.isDisabled()) {
plugin_interfaces.add( plugin_interface );
continue;
}
Plugin plugin = plugin_interface.getPlugin();
if (plugin_interface.isOperational())
continue;
Throwable load_failure = null;
try{
UtilitiesImpl.setPluginThreadContext( plugin_interface );
plugin.initialize(plugin_interface);
if (!(plugin instanceof FailedPlugin)){
plugin_interface.setOperational( true );
}
}catch( Throwable e ){
load_failure = e;
}
plugins.add( plugin );
plugin_interfaces.add( plugin_interface );
if ( load_failure != null ){
Debug.printStackTrace( load_failure );
String msg = "Error initializing plugin '" + plugin_interface.getPluginName() + "'";
Logger.log(new LogAlert(LogAlert.UNREPEATABLE, msg, load_failure));
System.out.println( msg + " : " + load_failure);
last_load_failure = new PluginException( msg, load_failure );
}
}
if ( last_load_failure != null ){
throw( last_load_failure );
}
| public void | initialisePlugins()
try{
init_thread = Thread.currentThread();
for (int i = 0; i < loaded_pi_list.size(); i++) {
try {
List l = (List) loaded_pi_list.get(i);
if (l.size() > 0) {
PluginInterfaceImpl plugin_interface = (PluginInterfaceImpl) l.get(0);
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Initializing plugin '"
+ plugin_interface.getPluginName() + "'"));
if (core_operation != null) {
core_operation.reportCurrentTask(MessageText
.getString("splash.plugin.init")
+ plugin_interface.getPluginName());
}
initialisePlugin(l);
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Initialization of plugin '"
+ plugin_interface.getPluginName() + "' complete"));
}
} catch (PluginException e) {
// already handled
} finally {
if (core_operation != null) {
core_operation.reportPercent((100 * (i + 1)) / loaded_pi_list.size());
}
}
}
// some plugins try and steal the logger stdout redirects.
// re-establish them if needed
Logger.doRedirects();
// now do built in ones
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Initializing built-in plugins"));
PluginManagerDefaults def = PluginManager.getDefaults();
for (int i = 0; i < builtin_plugins.length; i++) {
if (def.isDefaultPluginEnabled(builtin_plugins[i][0])) {
String id = builtin_plugins[i][2];
String key = builtin_plugins[i][3];
try {
Class cla = root_class_loader.loadClass(
builtin_plugins[i][1]);
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Initializing built-in plugin '"
+ builtin_plugins[i][2] + "'" ));
initializePluginFromClass(cla, id, key);
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, LogEvent.LT_WARNING,
"Initialization of built in plugin '" + builtin_plugins[i][2] + "' complete"));
} catch (Throwable e) {
try {
// replace it with a "broken" plugin instance
initializePluginFromClass(FailedPlugin.class, id, key);
} catch (Throwable f) {
}
if (builtin_plugins[i][4].equalsIgnoreCase("true")) {
Debug.printStackTrace(e);
Logger.log(new LogAlert(LogAlert.UNREPEATABLE,
"Initialization of built in plugin '" + builtin_plugins[i][2]
+ "' fails", e));
}
}
} else {
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, LogEvent.LT_WARNING,
"Built-in plugin '" + builtin_plugins[i][2] + "' is disabled"));
}
}
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID,
"Initializing dynamically registered plugins"));
for (int i = 0; i < registration_queue.size(); i++) {
try {
Object entry = registration_queue.get(i);
if (entry instanceof Class) {
Class cla = (Class) entry;
singleton.initializePluginFromClass(cla, INTERNAL_PLUGIN_ID, cla
.getName());
} else {
Object[] x = (Object[]) entry;
Plugin plugin = (Plugin) x[0];
singleton.initializePluginFromInstance(plugin, (String) x[1], plugin
.getClass().getName());
}
} catch (PluginException e) {
}
}
registration_queue.clear();
}finally{
init_thread = null;
}
| protected void | initializePluginFromClass(java.lang.Class plugin_class, java.lang.String plugin_id, java.lang.String plugin_config_key)
if ( plugin_class != FailedPlugin.class && getPluginFromClass( plugin_class ) != null ){
Logger.log(new LogAlert(LogAlert.UNREPEATABLE, LogAlert.AT_WARNING,
"Error loading '" + plugin_id + "', plugin class '"
+ plugin_class.getName() + "' is already loaded"));
return;
}
if( core_operation != null ){
String plugin_name;
if ( plugin_config_key.length() == 0 ){
plugin_name = plugin_class.getName();
int pos = plugin_name.lastIndexOf(".");
if ( pos != -1 ){
plugin_name = plugin_name.substring( pos+1 );
}
}else{
plugin_name = plugin_config_key;
}
core_operation.reportCurrentTask(MessageText.getString("splash.plugin.init") + plugin_name );
}
try{
Plugin plugin = (Plugin) plugin_class.newInstance();
PluginInterfaceImpl plugin_interface =
new PluginInterfaceImpl(
plugin,
this,
plugin_class,
plugin_class.getClassLoader(),
plugin_config_key,
new Properties(),
"",
plugin_id,
null );
UtilitiesImpl.setPluginThreadContext( plugin_interface );
try{
Method load_method = plugin_class.getMethod( "load", new Class[]{ PluginInterface.class });
load_method.invoke( plugin, new Object[]{ plugin_interface });
}catch( NoSuchMethodException e ){
}catch( Throwable e ){
Debug.printStackTrace( e );
Logger.log(new LogAlert(LogAlert.UNREPEATABLE,
"Load of built in plugin '" + plugin_id + "' fails", e));
}
plugin.initialize(plugin_interface);
if (!(plugin instanceof FailedPlugin)){
plugin_interface.setOperational( true );
}
plugins.add( plugin );
plugin_interfaces.add( plugin_interface );
}catch(Throwable e){
Debug.printStackTrace( e );
String msg = "Error loading internal plugin '" + plugin_class.getName() + "'";
Logger.log(new LogAlert(LogAlert.UNREPEATABLE, msg, e));
System.out.println(msg + " : " + e);
throw( new PluginException( msg, e ));
}
| protected void | initializePluginFromInstance(Plugin plugin, java.lang.String plugin_id, java.lang.String plugin_config_key)
try{
PluginInterfaceImpl plugin_interface =
new PluginInterfaceImpl(
plugin,
this,
plugin.getClass(),
plugin.getClass().getClassLoader(),
plugin_config_key,
new Properties(),
"",
plugin_id,
null );
UtilitiesImpl.setPluginThreadContext( plugin_interface );
plugin.initialize(plugin_interface);
if (!(plugin instanceof FailedPlugin)){
plugin_interface.setOperational( true );
}
plugins.add( plugin );
plugin_interfaces.add( plugin_interface );
}catch(Throwable e){
Debug.printStackTrace( e );
String msg = "Error loading internal plugin '" + plugin.getClass().getName() + "'";
Logger.log(new LogAlert(LogAlert.UNREPEATABLE, msg, e));
System.out.println(msg + " : " + e);
throw( new PluginException( msg, e ));
}
| protected boolean | isInitialisationComplete()
return( initialisation_complete );
| protected boolean | isInitialisationThread()
return( Thread.currentThread() == init_thread );
| protected static boolean | isLoadingBuiltin()
return( loading_builtin );
| private java.util.List | loadPluginFromDir(java.io.File directory, boolean bSkipAlreadyLoaded)
List loaded_pis = new ArrayList();
ClassLoader plugin_class_loader = root_class_loader;
if( !directory.isDirectory()){
return( loaded_pis );
}
String pluginName = directory.getName();
File[] pluginContents = directory.listFiles();
if ( pluginContents == null || pluginContents.length == 0){
return( loaded_pis );
}
// first sanity check - dir must include either a plugin.properties or
// at least one .jar file
boolean looks_like_plugin = false;
for (int i=0;i<pluginContents.length;i++){
String name = pluginContents[i].getName().toLowerCase();
if ( name.endsWith( ".jar") || name.equals( "plugin.properties" )){
looks_like_plugin = true;
break;
}
}
if ( !looks_like_plugin ){
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, LogEvent.LT_WARNING,
"Plugin directory '" + directory + "' has no plugin.properties "
+ "or .jar files, skipping"));
return( loaded_pis );
}
// take only the highest version numbers of jars that look versioned
String[] plugin_version = {null};
String[] plugin_id = {null};
pluginContents = PluginLauncherImpl.getHighestJarVersions( pluginContents, plugin_version, plugin_id, true );
for( int i = 0 ; i < pluginContents.length ; i++){
File jar_file = pluginContents[i];
// migration hack for i18nAZ_1.0.jar
if ( pluginContents.length > 1 ){
String name = jar_file.getName();
if ( name.startsWith( "i18nPlugin_" )){
// non-versioned version still there, rename it
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "renaming '" + name
+ "' to conform with versioning system"));
jar_file.renameTo( new File( jar_file.getParent(), "i18nAZ_0.1.jar " ));
continue;
}
}
plugin_class_loader = PluginLauncherImpl.addFileToClassPath( root_class_loader, plugin_class_loader, jar_file);
}
String plugin_class_string = null;
try {
Properties props = new Properties();
File properties_file = new File(directory.toString() + File.separator + "plugin.properties");
try {
// if properties file exists on its own then override any properties file
// potentially held within a jar
if ( properties_file.exists()){
FileInputStream fis = null;
try{
fis = new FileInputStream( properties_file );
props.load( fis );
}finally{
if ( fis != null ){
fis.close();
}
}
}else{
if ( plugin_class_loader instanceof URLClassLoader ){
URLClassLoader current = (URLClassLoader)plugin_class_loader;
URL url = current.findResource("plugin.properties");
if ( url != null ){
URLConnection connection = url.openConnection();
InputStream is = connection.getInputStream();
props.load(is);
}else{
throw( new Exception( "failed to load plugin.properties from jars"));
}
}else{
throw( new Exception( "failed to load plugin.properties from dir or jars"));
}
}
}catch( Throwable e ){
Debug.printStackTrace( e );
String msg = "Can't read 'plugin.properties' for plugin '" + pluginName + "': file may be missing";
Logger.log(new LogAlert(LogAlert.UNREPEATABLE, LogAlert.AT_ERROR, msg));
System.out.println( msg );
throw( new PluginException( msg, e ));
}
plugin_class_string = (String)props.get( "plugin.class");
if ( plugin_class_string == null ){
plugin_class_string = (String)props.get( "plugin.classes");
if ( plugin_class_string == null ){
// set so we don't bork later will npe
plugin_class_string = "";
}
}
String plugin_name_string = (String)props.get( "plugin.name");
if ( plugin_name_string == null ){
plugin_name_string = (String)props.get( "plugin.names");
}
int pos1 = 0;
int pos2 = 0;
while(true){
int p1 = plugin_class_string.indexOf( ";", pos1 );
String plugin_class;
if ( p1 == -1 ){
plugin_class = plugin_class_string.substring(pos1).trim();
}else{
plugin_class = plugin_class_string.substring(pos1,p1).trim();
pos1 = p1+1;
}
PluginInterfaceImpl existing_pi = getPluginFromClass( plugin_class );
if ( existing_pi != null ){
if (bSkipAlreadyLoaded) {
break;
}
// allow user dir entries to override app dir entries without warning
File this_parent = directory.getParentFile();
File existing_parent = null;
if ( existing_pi.getInitializerKey() instanceof File ){
existing_parent = ((File)existing_pi.getInitializerKey()).getParentFile();
}
if ( this_parent.equals( FileUtil.getApplicationFile("plugins")) &&
existing_parent != null &&
existing_parent.equals( FileUtil.getUserFile( "plugins" ))){
// skip this overridden plugin
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Plugin '" + plugin_name_string
+ "/" + plugin_class
+ ": shared version overridden by user-specific one"));
return( new ArrayList());
}else{
Logger.log(new LogAlert(LogAlert.UNREPEATABLE, LogAlert.AT_WARNING,
"Error loading '" + plugin_name_string + "', plugin class '"
+ plugin_class + "' is already loaded"));
}
}else{
String plugin_name = null;
if ( plugin_name_string != null ){
int p2 = plugin_name_string.indexOf( ";", pos2 );
if ( p2 == -1 ){
plugin_name = plugin_name_string.substring(pos2).trim();
}else{
plugin_name = plugin_name_string.substring(pos2,p2).trim();
pos2 = p2+1;
}
}
Properties new_props = (Properties)props.clone();
for (int j=0;j<default_version_details.length;j++){
if ( plugin_class.equals( default_version_details[j][0] )){
if ( new_props.get( "plugin.id") == null ){
new_props.put( "plugin.id", default_version_details[j][1]);
}
if ( plugin_name == null ){
plugin_name = default_version_details[j][2];
}
if ( new_props.get( "plugin.version") == null ){
// no explicit version. If we've derived one then use that, otherwise defaults
if ( plugin_version[0] != null ){
new_props.put( "plugin.version", plugin_version[0]);
}else{
new_props.put( "plugin.version", default_version_details[j][3]);
}
}
}
}
new_props.put( "plugin.class", plugin_class );
if ( plugin_name != null ){
new_props.put( "plugin.name", plugin_name );
}
// System.out.println( "loading plugin '" + plugin_class + "' using cl " + classLoader);
// if the plugin load fails we still need to generate a plugin entry
// as this drives the upgrade process
Throwable load_failure = null;
String pid = plugin_id[0]==null?directory.getName():plugin_id[0];
Plugin plugin = PluginLauncherImpl.getPreloadedPlugin( plugin_class );
if ( plugin == null ){
try{
Class c = plugin_class_loader.loadClass(plugin_class);
plugin = (Plugin) c.newInstance();
}catch (java.lang.UnsupportedClassVersionError e) {
plugin = new FailedPlugin(plugin_name,directory.getAbsolutePath());
// shorten stack trace
load_failure = new UnsupportedClassVersionError(e.getMessage());
}catch( Throwable e ){
if ( e instanceof ClassNotFoundException &&
props.getProperty( "plugin.install_if_missing", "no" ).equalsIgnoreCase( "yes" )){
// don't report the failure
}else{
load_failure = e;
}
plugin = new FailedPlugin(plugin_name,directory.getAbsolutePath());
}
}else{
plugin_class_loader = plugin.getClass().getClassLoader();
}
MessageText.integratePluginMessages((String)props.get("plugin.langfile"),plugin_class_loader);
PluginInterfaceImpl plugin_interface =
new PluginInterfaceImpl(
plugin,
this,
directory,
plugin_class_loader,
directory.getName(), // key for config values
new_props,
directory.getAbsolutePath(),
pid,
plugin_version[0] );
// Must use getPluginID() instead of pid, because they may differ
boolean bEnabled = COConfigurationManager
.getBooleanParameter("PluginInfo."
+ plugin_interface.getPluginID() + ".enabled", true);
plugin_interface.setDisabled(!bEnabled);
try{
Method load_method = plugin.getClass().getMethod( "load", new Class[]{ PluginInterface.class });
load_method.invoke( plugin, new Object[]{ plugin_interface });
}catch( NoSuchMethodException e ){
}catch( Throwable e ){
load_failure = e;
}
loaded_pis.add( plugin_interface );
if ( load_failure != null ){
// don't complain about our internal one
if ( !pid.equals(UpdaterUpdateChecker.getPluginID())){
String msg = "Error loading plugin '" + pluginName + "' / '" + plugin_class_string + "'";
Logger.log(new LogAlert(LogAlert.UNREPEATABLE, msg, load_failure));
System.out.println( msg + " : " + load_failure);
}
}
}
if ( p1 == -1 ){
break;
}
}
return( loaded_pis );
}catch(Throwable e) {
if ( e instanceof PluginException ){
throw((PluginException)e);
}
Debug.printStackTrace( e );
String msg = "Error loading plugin '" + pluginName + "' / '" + plugin_class_string + "'";
Logger.log(new LogAlert(LogAlert.UNREPEATABLE, msg, e));
System.out.println( msg + " : " + e);
throw( new PluginException( msg, e ));
}
| public java.util.List | loadPlugins(AzureusCore core, boolean bSkipAlreadyLoaded)
List pluginLoaded = new ArrayList();
PluginManagerImpl.setStartDetails( core );
getRootClassLoader();
// first do explicit plugins
File user_dir = FileUtil.getUserFile("plugins");
File app_dir = FileUtil.getApplicationFile("plugins");
int user_plugins = 0;
int app_plugins = 0;
if ( user_dir.exists() && user_dir.isDirectory()){
user_plugins = user_dir.listFiles().length;
}
if ( app_dir.exists() && app_dir.isDirectory()){
app_plugins = app_dir.listFiles().length;
}
// user ones first so they override app ones if present
pluginLoaded.addAll(loadPluginsFromDir(user_dir, 0, user_plugins
+ app_plugins, bSkipAlreadyLoaded));
if ( !user_dir.equals( app_dir )){
pluginLoaded.addAll(loadPluginsFromDir(app_dir, user_plugins,
user_plugins + app_plugins, bSkipAlreadyLoaded));
}
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Loading built-in plugins"));
if (core_operation != null) {
core_operation.reportCurrentTask(MessageText.getString("splash.plugin")
+ MessageText.getString("ConfigView.pluginlist.column.type.builtIn"));
}
PluginManagerDefaults def = PluginManager.getDefaults();
for (int i=0;i<builtin_plugins.length;i++){
if ( def.isDefaultPluginEnabled( builtin_plugins[i][0])){
try{
loading_builtin = true;
// lazyness here, for builtin we use static load method with default plugin interface
// if we need to improve on this then we'll have to move to a system more akin to
// the dir-loaded plugins
Class cla = root_class_loader.loadClass( builtin_plugins[i][1]);
Method load_method = cla.getMethod( "load", new Class[]{ PluginInterface.class });
load_method.invoke( null, new Object[]{ getDefaultInterfaceSupport() });
Logger.log(new LogEvent(LOGID, LogEvent.LT_WARNING,
"Built-in plugin '" + builtin_plugins[i][0] + "' ok"));
}catch( NoSuchMethodException e ){
}catch( Throwable e ){
if ( builtin_plugins[i][4].equalsIgnoreCase("true" )){
Debug.printStackTrace( e );
Logger.log(new LogAlert(LogAlert.UNREPEATABLE,
"Load of built in plugin '" + builtin_plugins[i][2] + "' fails", e));
}
}finally{
loading_builtin = false;
}
}else{
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, LogEvent.LT_WARNING,
"Built-in plugin '" + builtin_plugins[i][2] + "' is disabled"));
}
}
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Loading dynamically registered plugins"));
for (int i=0;i<registration_queue.size();i++){
Object entry = registration_queue.get(i);
Class cla;
String id;
if ( entry instanceof Class ){
cla = (Class)entry;
id = cla.getName();
}else{
Object[] x = (Object[])entry;
Plugin plugin = (Plugin)x[0];
cla = plugin.getClass();
id = (String)x[1];
}
try{
// lazyness here, for dynamic we use static load method with default plugin interface
// if we need to improve on this then we'll have to move to a system more akin to
// the dir-loaded plugins
Method load_method = cla.getMethod( "load", new Class[]{ PluginInterface.class });
load_method.invoke( null, new Object[]{ getDefaultInterfaceSupport() });
}catch( NoSuchMethodException e ){
}catch( Throwable e ){
Debug.printStackTrace( e );
Logger.log(new LogAlert(LogAlert.UNREPEATABLE,
"Load of dynamic plugin '" + id + "' fails", e));
}
}
return pluginLoaded;
| private java.util.List | loadPluginsFromDir(java.io.File pluginDirectory, int plugin_offset, int plugin_total, boolean bSkipAlreadyLoaded)
List dirLoadedPIs = new ArrayList();
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Plugin Directory is " + pluginDirectory));
if ( !pluginDirectory.exists() ){
FileUtil.mkdirs(pluginDirectory);
}
if( pluginDirectory.isDirectory()){
File[] pluginsDirectory = pluginDirectory.listFiles();
for(int i = 0 ; i < pluginsDirectory.length ; i++) {
if( pluginsDirectory[i].getName().equals( "CVS" ) ) {
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Skipping plugin "
+ pluginsDirectory[i].getName()));
continue;
}
if (Logger.isEnabled())
Logger.log(new LogEvent(LOGID, "Loading plugin "
+ pluginsDirectory[i].getName()));
if(core_operation != null) {
core_operation.reportCurrentTask(MessageText.getString("splash.plugin") + pluginsDirectory[i].getName());
}
try{
List loaded_pis = loadPluginFromDir(pluginsDirectory[i], bSkipAlreadyLoaded);
// save details for later initialisation
loaded_pi_list.add( loaded_pis );
dirLoadedPIs.addAll( loaded_pis );
}catch( PluginException e ){
// already handled
}
if( core_operation != null ){
core_operation.reportPercent( (100 * (i + plugin_offset)) / plugin_total );
}
}
}
return dirLoadedPIs;
| protected static void | queueRegistration(java.lang.Class _class)
try{
class_mon.enter();
if ( singleton == null ){
registration_queue.add( _class );
}else{
try{
singleton.initializePluginFromClass( _class, INTERNAL_PLUGIN_ID, _class.getName());
}catch(PluginException e ){
}
}
}finally{
class_mon.exit();
}
| protected static void | queueRegistration(Plugin plugin, java.lang.String id)
try{
class_mon.enter();
if ( singleton == null ){
registration_queue.add( new Object[]{ plugin, id });
}else{
try{
singleton.initializePluginFromInstance( plugin, id, plugin.getClass().getName());
}catch(PluginException e ){
}
}
}finally{
class_mon.exit();
}
| protected void | reloadPlugin(PluginInterfaceImpl pi)
unloadPlugin( pi );
Object key = pi.getInitializerKey();
String config_key = pi.getPluginConfigKey();
if ( key instanceof File ){
List pis = loadPluginFromDir( (File)key, false );
initialisePlugin( pis );
}else{
initializePluginFromClass( (Class) key, pi.getPluginID(), config_key );
}
| public void | seedingStatusChanged(boolean seeding_only_mode)
/*nothing*/
| protected void | unloadPlugin(PluginInterfaceImpl pi)
plugins.remove( pi.getPlugin());
plugin_interfaces.remove( pi );
pi.unloadSupport();
for (int i=0;i<loaded_pi_list.size();i++){
List l = (List)loaded_pi_list.get(i);
if ( l.remove(pi)){
if ( l.size() == 0 ){
loaded_pi_list.remove(i);
}
return;
}
}
|
|