Retry three times, then bail out and return not found.

basho-labs · Sep 4, 2013 · c60fa22 · c60fa22
1 parent 48419ce
commit c60fa22
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/async_nif.hrl b/src/async_nif.hrl
@@ -22,7 +22,7 @@
 %% -------------------------------------------------------------------
 
 -define(ASYNC_NIF_CALL(Fun, Args),
-	F = fun(F) ->
+	F = fun(F, T) ->
 		    R = erlang:make_ref(),
 		    case erlang:apply(Fun, [R|Args]) of
 			{ok, {enqueued, PctBusy}} ->
@@ -43,9 +43,12 @@
 				    Reply
 			    end;
 			{error, eagain} ->
-			    F(F);
+			    case T of
+				3 -> not_found;
+				_ -> F(F, T + 1)
+			    end;
 			Other ->
 			    Other
 		    end
 	    end,
-	F(F)).
+	F(F, 1)).