mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-10-08 14:51:49 +00:00
84841e063f
125788 rmunteanu: Merged 5.1.N (5.1.2) to 5.2.N (5.2.1)
125606 rmunteanu: Merged 5.1.1 (5.1.1) to 5.1.N (5.1.2)
125515 slanglois: MNT-16155 Update source headers - add new Copyrights for Java and JSP source files + automatic check in the build
git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@127810 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
113 lines
3.8 KiB
Java
113 lines
3.8 KiB
Java
/*
|
|
* #%L
|
|
* Alfresco Repository
|
|
* %%
|
|
* Copyright (C) 2005 - 2016 Alfresco Software Limited
|
|
* %%
|
|
* This file is part of the Alfresco software.
|
|
* If the software was purchased under a paid Alfresco license, the terms of
|
|
* the paid license agreement will prevail. Otherwise, the software is
|
|
* provided under the following open source license terms:
|
|
*
|
|
* Alfresco is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Lesser General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* Alfresco 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 Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
|
|
* #L%
|
|
*/
|
|
package org.alfresco.repo.action;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.Collections;
|
|
import java.util.List;
|
|
import java.util.UUID;
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
|
|
import org.alfresco.service.cmr.action.Action;
|
|
|
|
/**
|
|
* Responsible for monitoring running actions and accumulating statistics on actions that have been run.
|
|
*
|
|
* @author Alex Miller
|
|
*/
|
|
public class ActionServiceMonitor
|
|
{
|
|
private ConcurrentHashMap<UUID, RunningAction> runningActions = new ConcurrentHashMap<UUID, RunningAction>();
|
|
private ConcurrentHashMap<String, ActionStatistics> actionStatistics = new ConcurrentHashMap<String, ActionStatistics>();
|
|
|
|
/**
|
|
* Called by the {@link ActionServiceImpl} when an action is started.
|
|
*
|
|
* Adds the action to the list of currently running actions.
|
|
*
|
|
* @param action The action being started
|
|
* @return A {@link RunningAction} object used to track the status of the running action.
|
|
*/
|
|
public RunningAction actionStarted(Action action)
|
|
{
|
|
RunningAction runningAction = new RunningAction(action);
|
|
|
|
this.runningActions.put(runningAction.getId(), runningAction);
|
|
|
|
return runningAction;
|
|
}
|
|
|
|
/**
|
|
* Called by the {@link ActionServiceImpl} when sn action completes.
|
|
*
|
|
* Removes the actions from the list of currently running actions, and updated the accumulated statistics for that action.
|
|
*
|
|
* @param action The {@link RunningAction} object returned by actionStatred.
|
|
*/
|
|
public void actionCompleted(RunningAction action)
|
|
{
|
|
runningActions.remove(action.getId());
|
|
updateActionStatisitcis(action);
|
|
}
|
|
|
|
private void updateActionStatisitcis(RunningAction action)
|
|
{
|
|
String actionName = action.getActionName();
|
|
ActionStatistics actionStats = actionStatistics.get(actionName);
|
|
if (actionStats == null)
|
|
{
|
|
actionStatistics.putIfAbsent(actionName, new ActionStatistics(actionName));
|
|
actionStats = actionStatistics.get(actionName);
|
|
}
|
|
|
|
actionStats.addAction(action);
|
|
}
|
|
|
|
/**
|
|
* @return The list of currently running actions.
|
|
*/
|
|
public List<RunningAction> getRunningActions()
|
|
{
|
|
return Collections.unmodifiableList(new ArrayList<RunningAction>(runningActions.values()));
|
|
}
|
|
|
|
/**
|
|
* @return a count of the currently running actions
|
|
*/
|
|
public int getRunningActionCount()
|
|
{
|
|
return runningActions.size();
|
|
}
|
|
|
|
/**
|
|
* @return a list of the accumulated action statistics.
|
|
*/
|
|
public List<ActionStatistics> getActionStatisitcs()
|
|
{
|
|
return Collections.unmodifiableList(new ArrayList<ActionStatistics>(actionStatistics.values()));
|
|
}
|
|
}
|