Kiu/xenadmin
1
0
Fork 0
mirror of https://github.com/xcp-ng/xenadmin.git synced 2025-01-20 07:19:18 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

[CA-112327] Fixed Bug in BatchingMigrateVirtualDiskManager class

Browse Source
This commit is contained in:
Gabor Apati-Nagy 2013-11-04 12:35:12 +00:00
parent 71985da65b
commit 19409f8e20
2 changed files with 9 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
XenModel/Actions/ParallelAction.cs
View File

@ -44,15 +44,7 @@ namespace XenAdmin.Actions
/// </summary>
public class ParallelAction : MultipleAction
{
private int numberOfSimultaneousActions = 25;
/// <summary>
/// Number of actions to be run at the same time
/// </summary>
public int NumberOfSimultaneousActions
{
set { numberOfSimultaneousActions = value; }
}
private const int DEFAULT_MAX_NUMBER_OF_PARALLEL_ACTIONS = 25;
//Change parameter to increase the number of concurrent actions running
private readonly ProduceConsumerQueue _queuePC;
@ -60,7 +52,13 @@ namespace XenAdmin.Actions
public ParallelAction (IXenConnection connection, string title, string startDescription, string endDescription, List<AsyncAction> subActions)
: base(connection, title, startDescription, endDescription, subActions)
{
_queuePC = new ProduceConsumerQueue(subActions.Count < numberOfSimultaneousActions ? subActions.Count : numberOfSimultaneousActions);
_queuePC = new ProduceConsumerQueue(Math.Min(DEFAULT_MAX_NUMBER_OF_PARALLEL_ACTIONS, subActions.Count));
}
public ParallelAction(IXenConnection connection, string title, string startDescription, string endDescription, List<AsyncAction> subActions, int maxNumberOfParallelActions)
: base(connection, title, startDescription, endDescription, subActions)
{
_queuePC = new ProduceConsumerQueue(Math.Min(maxNumberOfParallelActions, subActions.Count));
}
protected override void RunSubActions(List<Exception> exceptions)

6
XenModel/Actions/VDI/BatchingMigrateVirtualDiskManager.cs
View File

@ -123,11 +123,7 @@ namespace XenAdmin.Actions
private ParallelAction CreateNewParallelAction(List<AsyncAction> batch)
{
return new ParallelAction(connection, CreatedActionTitle, CreatedActionStartDescription,
CreatedActionEndDescription, batch)
{
NumberOfSimultaneousActions = BATCH_SIZE
};
return new ParallelAction(connection, CreatedActionTitle, CreatedActionStartDescription, CreatedActionEndDescription, batch, BATCH_SIZE);
}
private List<AsyncAction> BatchAsVdiMigrate(List<VDI> vdis, SR sr)