| | |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | */ |
| | | package org.opends.server.plugins.profiler; |
| | | import org.opends.messages.Message; |
| | | |
| | | |
| | | |
| | |
| | | import org.opends.server.types.ConfigChangeResult; |
| | | import org.opends.server.types.DirectoryConfig; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.types.ErrorLogCategory; |
| | | import org.opends.server.types.ErrorLogSeverity; |
| | | import org.opends.server.types.ResultCode; |
| | | import org.opends.server.util.TimeThread; |
| | | |
| | | import org.opends.server.types.DebugLogLevel; |
| | | import static org.opends.server.loggers.ErrorLogger.*; |
| | | import static org.opends.server.loggers.debug.DebugLogger.*; |
| | | import org.opends.server.loggers.debug.DebugTracer; |
| | | import static org.opends.server.messages.MessageHandler.*; |
| | | import static org.opends.server.messages.PluginMessages.*; |
| | | import org.opends.server.loggers.ErrorLogger; |
| | | import static org.opends.messages.PluginMessages.*; |
| | | |
| | | import static org.opends.server.util.StaticUtils.*; |
| | | |
| | | |
| | |
| | | // Make sure that this plugin is only registered as a startup plugin. |
| | | if (pluginTypes.isEmpty()) |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_NO_PLUGIN_TYPES; |
| | | String message = getMessage(msgID, String.valueOf(configEntryDN)); |
| | | throw new ConfigException(msgID, message); |
| | | Message message = ERR_PLUGIN_PROFILER_NO_PLUGIN_TYPES.get( |
| | | String.valueOf(configEntryDN)); |
| | | throw new ConfigException(message); |
| | | } |
| | | else |
| | | { |
| | |
| | | { |
| | | if (t != PluginType.STARTUP) |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_INVALID_PLUGIN_TYPE; |
| | | String message = getMessage(msgID, String.valueOf(configEntryDN), |
| | | String.valueOf(t)); |
| | | throw new ConfigException(msgID, message); |
| | | Message message = ERR_PLUGIN_PROFILER_INVALID_PLUGIN_TYPE.get( |
| | | String.valueOf(configEntryDN), String.valueOf(t)); |
| | | throw new ConfigException(message); |
| | | } |
| | | } |
| | | } |
| | |
| | | File profileDirectory = getFileForPath(configuration.getProfileDirectory()); |
| | | if (! (profileDirectory.exists() && profileDirectory.isDirectory())) |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_INVALID_PROFILE_DIR; |
| | | String message = getMessage(msgID, profileDirectory.getAbsolutePath(), |
| | | String.valueOf(configEntryDN)); |
| | | throw new ConfigException(msgID, message); |
| | | Message message = WARN_PLUGIN_PROFILER_INVALID_PROFILE_DIR.get( |
| | | profileDirectory.getAbsolutePath(), String.valueOf(configEntryDN)); |
| | | throw new ConfigException(message); |
| | | } |
| | | } |
| | | |
| | |
| | | TRACER.debugCaught(DebugLogLevel.ERROR, e); |
| | | } |
| | | |
| | | int msgID = MSGID_PLUGIN_PROFILER_CANNOT_WRITE_PROFILE_DATA; |
| | | String message = getMessage(msgID, String.valueOf(configEntryDN), |
| | | filename, |
| | | stackTraceToSingleLineString(e)); |
| | | logError(ErrorLogCategory.PLUGIN, ErrorLogSeverity.SEVERE_ERROR, |
| | | message, msgID); |
| | | Message message = ERR_PLUGIN_PROFILER_CANNOT_WRITE_PROFILE_DATA. |
| | | get(String.valueOf(configEntryDN), filename, |
| | | stackTraceToSingleLineString(e)); |
| | | ErrorLogger.logError(message); |
| | | } |
| | | } |
| | | } |
| | |
| | | */ |
| | | @Override() |
| | | public boolean isConfigurationAcceptable(PluginCfg configuration, |
| | | List<String> unacceptableReasons) |
| | | List<Message> unacceptableReasons) |
| | | { |
| | | ProfilerPluginCfg config = (ProfilerPluginCfg) configuration; |
| | | return isConfigurationChangeAcceptable(config, unacceptableReasons); |
| | |
| | | */ |
| | | public boolean isConfigurationChangeAcceptable( |
| | | ProfilerPluginCfg configuration, |
| | | List<String> unacceptableReasons) |
| | | List<Message> unacceptableReasons) |
| | | { |
| | | boolean configAcceptable = true; |
| | | DN cfgEntryDN = configuration.dn(); |
| | |
| | | // Make sure that the plugin is only registered as a startup plugin. |
| | | if (configuration.getPluginType().isEmpty()) |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_NO_PLUGIN_TYPES; |
| | | String message = getMessage(msgID, String.valueOf(cfgEntryDN)); |
| | | Message message = ERR_PLUGIN_PROFILER_NO_PLUGIN_TYPES.get( |
| | | String.valueOf(cfgEntryDN)); |
| | | unacceptableReasons.add(message); |
| | | configAcceptable = false; |
| | | } |
| | |
| | | { |
| | | if (t != PluginCfgDefn.PluginType.STARTUP) |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_INVALID_PLUGIN_TYPE; |
| | | String message = getMessage(msgID, String.valueOf(cfgEntryDN), |
| | | Message message = ERR_PLUGIN_PROFILER_INVALID_PLUGIN_TYPE.get( |
| | | String.valueOf(cfgEntryDN), |
| | | String.valueOf(t)); |
| | | unacceptableReasons.add(message); |
| | | configAcceptable = false; |
| | |
| | | File profileDirectory = getFileForPath(configuration.getProfileDirectory()); |
| | | if (! (profileDirectory.exists() && profileDirectory.isDirectory())) |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_INVALID_PROFILE_DIR; |
| | | unacceptableReasons.add(getMessage(msgID, |
| | | profileDirectory.getAbsolutePath(), |
| | | String.valueOf(cfgEntryDN))); |
| | | unacceptableReasons.add(WARN_PLUGIN_PROFILER_INVALID_PROFILE_DIR.get( |
| | | profileDirectory.getAbsolutePath(), |
| | | String.valueOf(cfgEntryDN))); |
| | | configAcceptable = false; |
| | | } |
| | | |
| | |
| | | { |
| | | ResultCode resultCode = ResultCode.SUCCESS; |
| | | boolean adminActionRequired = false; |
| | | ArrayList<String> messages = new ArrayList<String>(); |
| | | ArrayList<Message> messages = new ArrayList<Message>(); |
| | | |
| | | currentConfig = configuration; |
| | | |
| | |
| | | new ProfilerThread(configuration.getProfileSampleInterval()); |
| | | profilerThread.start(); |
| | | |
| | | int msgID = MSGID_PLUGIN_PROFILER_STARTED_PROFILING; |
| | | messages.add(getMessage(msgID, String.valueOf(configEntryDN))); |
| | | messages.add(INFO_PLUGIN_PROFILER_STARTED_PROFILING.get( |
| | | String.valueOf(configEntryDN))); |
| | | } |
| | | else |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_ALREADY_PROFILING; |
| | | messages.add(getMessage(msgID, String.valueOf(configEntryDN))); |
| | | messages.add(INFO_PLUGIN_PROFILER_ALREADY_PROFILING.get( |
| | | String.valueOf(configEntryDN))); |
| | | } |
| | | } |
| | | break; |
| | |
| | | { |
| | | if (profilerThread == null) |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_NOT_RUNNING; |
| | | messages.add(getMessage(msgID, String.valueOf(configEntryDN))); |
| | | messages.add(INFO_PLUGIN_PROFILER_NOT_RUNNING.get( |
| | | String.valueOf(configEntryDN))); |
| | | } |
| | | else |
| | | { |
| | | profilerThread.stopProfiling(); |
| | | |
| | | int msgID = MSGID_PLUGIN_PROFILER_STOPPED_PROFILING; |
| | | messages.add(getMessage(msgID, String.valueOf(configEntryDN))); |
| | | messages.add(INFO_PLUGIN_PROFILER_STOPPED_PROFILING.get( |
| | | String.valueOf(configEntryDN))); |
| | | |
| | | String filename = |
| | | getFileForPath( |
| | |
| | | { |
| | | profilerThread.writeCaptureData(filename); |
| | | |
| | | msgID = MSGID_PLUGIN_PROFILER_WROTE_PROFILE_DATA; |
| | | messages.add(getMessage(msgID, String.valueOf(configEntryDN), |
| | | filename)); |
| | | messages.add(INFO_PLUGIN_PROFILER_WROTE_PROFILE_DATA.get( |
| | | String.valueOf(configEntryDN), |
| | | filename)); |
| | | } |
| | | catch (Exception e) |
| | | { |
| | |
| | | TRACER.debugCaught(DebugLogLevel.ERROR, e); |
| | | } |
| | | |
| | | msgID = MSGID_PLUGIN_PROFILER_CANNOT_WRITE_PROFILE_DATA; |
| | | messages.add(getMessage(msgID, String.valueOf(configEntryDN), |
| | | filename, |
| | | stackTraceToSingleLineString(e))); |
| | | messages.add(ERR_PLUGIN_PROFILER_CANNOT_WRITE_PROFILE_DATA.get( |
| | | String.valueOf(configEntryDN), |
| | | filename, |
| | | stackTraceToSingleLineString(e))); |
| | | |
| | | resultCode = DirectoryConfig.getServerErrorResultCode(); |
| | | } |
| | |
| | | { |
| | | if (profilerThread == null) |
| | | { |
| | | int msgID = MSGID_PLUGIN_PROFILER_NOT_RUNNING; |
| | | messages.add(getMessage(msgID, String.valueOf(configEntryDN))); |
| | | messages.add(INFO_PLUGIN_PROFILER_NOT_RUNNING.get( |
| | | String.valueOf(configEntryDN))); |
| | | } |
| | | else |
| | | { |
| | | profilerThread.stopProfiling(); |
| | | |
| | | int msgID = MSGID_PLUGIN_PROFILER_STOPPED_PROFILING; |
| | | messages.add(getMessage(msgID, String.valueOf(configEntryDN))); |
| | | messages.add(INFO_PLUGIN_PROFILER_STOPPED_PROFILING.get( |
| | | String.valueOf(configEntryDN))); |
| | | |
| | | profilerThread = null; |
| | | } |