From a74178bc6bcd61f379c882e9de980c0463acd63d Mon Sep 17 00:00:00 2001 From: Sebastian Burckhardt Date: Mon, 18 Mar 2024 09:48:09 -0700 Subject: [PATCH] loosen azure storage semaphores (#365) --- .../StorageLayer/Faster/AzureBlobs/BlobManager.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/DurableTask.Netherite/StorageLayer/Faster/AzureBlobs/BlobManager.cs b/src/DurableTask.Netherite/StorageLayer/Faster/AzureBlobs/BlobManager.cs index cf7a2a78..2ca24780 100644 --- a/src/DurableTask.Netherite/StorageLayer/Faster/AzureBlobs/BlobManager.cs +++ b/src/DurableTask.Netherite/StorageLayer/Faster/AzureBlobs/BlobManager.cs @@ -72,8 +72,8 @@ partial class BlobManager : ICheckpointManager, ILogCommitManager public IPartitionErrorHandler PartitionErrorHandler { get; private set; } - internal static SemaphoreSlim AsynchronousStorageReadMaxConcurrency = new SemaphoreSlim(Math.Min(100, Environment.ProcessorCount * 10)); - internal static SemaphoreSlim AsynchronousStorageWriteMaxConcurrency = new SemaphoreSlim(Math.Min(50, Environment.ProcessorCount * 7)); + internal static SemaphoreSlim AsynchronousStorageReadMaxConcurrency = new SemaphoreSlim(Math.Min(100, Environment.ProcessorCount * 20)); + internal static SemaphoreSlim AsynchronousStorageWriteMaxConcurrency = new SemaphoreSlim(Math.Min(50, Environment.ProcessorCount * 10)); internal volatile int LeaseUsers;