Merge branch 'hb/stdlib/fix_dets/OTP-11709'

* hb/stdlib/fix_dets/OTP-11709:
  stdlib: Fix a Dets bug where files were deleted
  stdlib: Fix a Dets bug with leaking file descriptors

1 files changed, 52 insertions, 23 deletions

diff --git a/lib/stdlib/test/dets_SUITE.erl b/lib/stdlib/test/dets_SUITE.erl
index 059d553b00..00a5da42ad 100644
--- a/lib/stdlib/test/dets_SUITE.erl
+++ b/lib/stdlib/test/dets_SUITE.erl
@@ -1,7 +1,7 @@
 %%
 %% %CopyrightBegin%
 %% 
-%% Copyright Ericsson AB 1996-2013. All Rights Reserved.
+%% Copyright Ericsson AB 1996-2014. All Rights Reserved.
 %% 
 %% The contents of this file are subject to the Erlang Public License,
 %% Version 1.1, (the "License"); you may not use this file except in
@@ -52,7 +52,7 @@
          simultaneous_open/1, insert_new/1, repair_continuation/1,
          otp_5487/1, otp_6206/1, otp_6359/1, otp_4738/1, otp_7146/1,
          otp_8070/1, otp_8856/1, otp_8898/1, otp_8899/1, otp_8903/1,
-         otp_8923/1, otp_9282/1, otp_11245/1]).
+         otp_8923/1, otp_9282/1, otp_11245/1, otp_11709/1]).
 
 -export([dets_dirty_loop/0]).
 
@@ -109,7 +109,7 @@ all() ->
 	many_clients, otp_4906, otp_5402, simultaneous_open,
 	insert_new, repair_continuation, otp_5487, otp_6206,
 	otp_6359, otp_4738, otp_7146, otp_8070, otp_8856, otp_8898,
-	otp_8899, otp_8903, otp_8923, otp_9282, otp_11245
+	otp_8899, otp_8903, otp_8923, otp_9282, otp_11245, otp_11709
     ].
 
 groups() -> 
@@ -772,9 +772,9 @@ open_1(Config, V) ->
     crash(Fname, TypePos),
     {error, {invalid_type_code,Fname}} = dets:open_file(Fname),
     truncate(Fname, HeadSize - 10),
-    {error, {tooshort,Fname}} = dets:open_file(Fname),
-    {ok, TabRef} = dets:open_file(TabRef, [{file,Fname},{version,V}]),
-    ok = dets:close(TabRef),
+    {error,{not_a_dets_file,Fname}} = dets:open_file(Fname),
+    {error,{not_a_dets_file,Fname}} =
+        dets:open_file(TabRef, [{file,Fname},{version,V}]),
     file:delete(Fname),
 
     {error,{file_error,{foo,bar},_}} = dets:is_dets_file({foo,bar}),
@@ -967,10 +967,12 @@ fast_init_table(Config) ->
     {'EXIT', _} =
 	(catch dets:init_table(TabRef, fun(foo) -> bar end, {format,bchunk})),
     dets:close(TabRef),
+    file:delete(Fname),
     {ok, _} = dets:open_file(TabRef, Args),
     {'EXIT', _} = (catch dets:init_table(TabRef, fun() -> foo end,
 					       {format,bchunk})),
     dets:close(TabRef),
+    file:delete(Fname),
     {ok, _} = dets:open_file(TabRef, Args),
     {'EXIT', {badarg, _}} =
 	(catch dets:init_table(TabRef, nofun, {format,bchunk})),
@@ -979,10 +981,12 @@ fast_init_table(Config) ->
     away = (catch dets:init_table(TabRef, fun(_) -> throw(away) end,
 					{format,bchunk})),
     dets:close(TabRef),
+    file:delete(Fname),
     {ok, _} = dets:open_file(TabRef, Args),
     {error, {init_fun, fopp}} =
 	dets:init_table(TabRef, fun(read) -> fopp end, {format,bchunk}),
     dets:close(TabRef),
+    file:delete(Fname),
     {ok, _} = dets:open_file(TabRef, Args),
     dets:safe_fixtable(TabRef, true),
     {error, {fixed_table, TabRef}} =
@@ -1389,23 +1393,6 @@ repair(Config, V) ->
     {ok, TabRef} = dets:open_file(TabRef, [{file,Fname},{version,V}]),
     ok = ins(TabRef, 100),
     ok = dets:close(TabRef),
-    truncate(Fname, HeadSize - 10),
-    %% a new file is created ('tooshort')
-    {ok, TabRef} = dets:open_file(TabRef,
-                                  [{file,Fname},{version,V},
-                                   {min_no_slots,1000},
-                                   {max_no_slots,1000000}]),
-    case dets:info(TabRef, no_slots) of
-	undefined -> ok;
-	{Min1,Slot1,Max1} ->
-	    true = Min1 =< Slot1, true = Slot1 =< Max1,
-	    true = 1000 < Min1, true = 1000+256 > Min1,
-	    true = 1000000 < Max1, true = (1 bsl 20)+256 > Max1
-    end,
-    0 = dets:info(TabRef, size),
-    no_keys_test(TabRef),
-    _ = histogram(TabRef, silent),
-    ok = dets:close(TabRef),
     file:delete(Fname),
 
     %% version bump (v8)
@@ -3920,6 +3907,48 @@ otp_11245(Config) when is_list(Config) ->
     file:delete(File),
     ok.
 
+otp_11709(doc) ->
+    ["OTP-11709. Bugfixes."];
+otp_11709(suite) ->
+    [];
+otp_11709(Config) when is_list(Config) ->
+    Short = <<"foo">>,
+    Long = <<"a sufficiently long text">>,
+
+    %% Bug: leaking file descriptor
+    P0 = pps(),
+    File = filename(otp_11709, Config),
+    ok = file:write_file(File, Long),
+    false = dets:is_dets_file(File),
+    check_pps(P0),
+
+    %% Bug: deleting file
+    Args = [[{access, A}, {repair, R}] ||
+               A <- [read, read_write],
+               R <- [true, false, force]],
+    Fun1 = fun(S, As) ->
+                   P1 = pps(),
+                   ok = file:write_file(File, S),
+                   {error,{not_a_dets_file,File}} = dets:open_file(File, As),
+                   {ok, S} = file:read_file(File),
+                   check_pps(P1)
+           end,
+    Fun2 = fun(S) ->
+                   _ = [Fun1(S, As) || As <- Args],
+                   ok
+           end,
+    ok = Fun2(Long),  % no change here
+    ok = Fun2(Short), % mimic the behaviour for longer files
+
+    %% open_file/1
+    ok = file:write_file(File, Long),
+    {error,{not_a_dets_file,File}} = dets:open_file(File), % no change
+    ok = file:write_file(File, Short),
+    {error,{not_a_dets_file,File}} = dets:open_file(File), % mimic
+
+    _ = file:delete(File),
+    ok.
+
 %%
 %% Parts common to several test cases
 %%