Solved possible deadlock because of PostgreSqlConnection.SetRangeInHash isolation level solution.

Author: Vytautas Kasparavičius

src/Hangfire.PostgreSql/Hangfire.PostgreSql.csproj

@@ -14,9 +14,10 @@
     <PackageReleaseNotes>https://github.com/frankhommers/Hangfire.PostgreSql/releases</PackageReleaseNotes>
     <PackageProjectUrl>http://hmm.rs/Hangfire.PostgreSql</PackageProjectUrl>
     <PackageLicenseUrl>https://raw.github.com/frankhommers/Hangfire.PostgreSql/master/LICENSE.md</PackageLicenseUrl>
-    <Version>1.4.8</Version>
-    <FileVersion>1.4.8.0</FileVersion>
-    <AssemblyVersion>1.4.8.0</AssemblyVersion>
+    <Version>1.4.8.1</Version>
+    <FileVersion>1.4.8.1</FileVersion>
+    <AssemblyVersion>1.4.8.1</AssemblyVersion>
+    <GeneratePackageOnBuild>True</GeneratePackageOnBuild>
   </PropertyGroup>
 
   <ItemGroup>
@@ -25,7 +26,7 @@
 
   <ItemGroup>
     <PackageReference Include="Dapper" Version="1.50.2" />
-    <PackageReference Include="Hangfire.Core" Version="1.6.12" />
+    <PackageReference Include="Hangfire.Core" Version="1.6.14" />
     <PackageReference Include="Newtonsoft.Json" Version="10.0.2" />
     <PackageReference Include="Npgsql" Version="3.2.2" />
   </ItemGroup>

src/Hangfire.PostgreSql/PostgreSqlConnection.cs

@@ -22,6 +22,7 @@
 using System;
 using System.Collections.Generic;
 using System.Data;
+using System.Diagnostics;
 using System.Globalization;
 using System.Linq;
 using System.Threading;
@@ -325,6 +326,7 @@ SELECT 1
 );
 ";
 			var execute = true;
+			var executionTimer = Stopwatch.StartNew();
 			while (execute)
 			{
 				try
@@ -344,6 +346,9 @@ SELECT 1
 					if (!exception.SqlState.Equals("40001"))
 						throw;
 				}
+
+				if(executionTimer.Elapsed > _options.TransactionSynchronisationTimeout)
+					throw new TimeoutException("SetRangeInHash experienced timeout while trying to execute transaction");
 			}
 		}
 

src/Hangfire.PostgreSql/PostgreSqlStorageOptions.cs

@@ -28,21 +28,23 @@ public class PostgreSqlStorageOptions
         private TimeSpan _queuePollInterval;
         private TimeSpan _invisibilityTimeout;
         private TimeSpan _distributedLockTimeout;
+        private TimeSpan _transactionSerializationTimeout;
 
         public PostgreSqlStorageOptions()
         {
             QueuePollInterval = TimeSpan.FromSeconds(15);
             InvisibilityTimeout = TimeSpan.FromMinutes(30);
             DistributedLockTimeout = TimeSpan.FromMinutes(10);
+	        TransactionSynchronisationTimeout = TimeSpan.FromMilliseconds(500);
             SchemaName = "hangfire";
             UseNativeDatabaseTransactions = true;
             PrepareSchemaIfNecessary = true;
         }
 
         public TimeSpan QueuePollInterval
         {
-            get { return _queuePollInterval; }
-            set
+            get => _queuePollInterval;
+	        set
             {
                 ThrowIfValueIsNotPositive(value, nameof(QueuePollInterval));
                 _queuePollInterval = value;
@@ -51,8 +53,8 @@ public TimeSpan QueuePollInterval
 
         public TimeSpan InvisibilityTimeout
         {
-            get { return _invisibilityTimeout; }
-            set
+            get => _invisibilityTimeout;
+	        set
             {
                 ThrowIfValueIsNotPositive(value, nameof(InvisibilityTimeout));
                 _invisibilityTimeout = value;
@@ -61,14 +63,24 @@ public TimeSpan InvisibilityTimeout
 
         public TimeSpan DistributedLockTimeout
         {
-            get { return _distributedLockTimeout; }
-            set
+            get => _distributedLockTimeout;
+	        set
             {
                 ThrowIfValueIsNotPositive(value, nameof(DistributedLockTimeout));
                 _distributedLockTimeout = value;
             }
         }
 
+	    public TimeSpan TransactionSynchronisationTimeout
+	    {
+			get => _transactionSerializationTimeout;
+		    set
+		    {
+			    ThrowIfValueIsNotPositive(value, nameof(TransactionSynchronisationTimeout));
+			    _transactionSerializationTimeout = value;
+		    }
+		}
+
         public bool UseNativeDatabaseTransactions { get; set; }
         public bool PrepareSchemaIfNecessary { get; set; }
         public string SchemaName { get; set; }