hermes-agent/n8n-openai-adapter
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Simplify acquiring lock on Code.require_file

Browse Source
This commit is contained in:
José Valim
2019-03-14 21:55:46 +01:00
parent 88338bb99b
commit 018df4fbfd
2 changed files with 7 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/elixir/src/elixir_code_server.erl
+7 -7
View File
@@ -45,12 +45,12 @@ handle_call({acquire, Path}, From, Config) ->
case maps:find(Path, Current) of
{ok, true} ->
{reply, required, Config};
{ok, {Ref, List}} when is_list(List), is_reference(Ref) ->
Queued = maps:put(Path, {Ref, [From | List]}, Current),
{reply, {queued, Ref}, Config#elixir_code_server{required=Queued}};
{ok, Queued} when is_list(Queued) ->
Required = maps:put(Path, [From | Queued], Current),
{noreply, Config#elixir_code_server{required=Required}};
error ->
Queued = maps:put(Path, {make_ref(), []}, Current),
{reply, proceed, Config#elixir_code_server{required=Queued}}
Required = maps:put(Path, [], Current),
{reply, proceed, Config#elixir_code_server{required=Required}}
end;
handle_call(required, _From, Config) ->
@@ -99,8 +99,8 @@ handle_cast({required, Path}, Config) ->
case maps:find(Path, Current) of
{ok, true} ->
{noreply, Config};
{ok, {Ref, List}} when is_list(List), is_reference(Ref) ->
_ = [Pid ! {elixir_code_server, Ref, required} || {Pid, _Tag} <- lists:reverse(List)],
{ok, Queued} ->
_ = [gen_server:reply(From, required) || From <- lists:reverse(Queued)],
Done = maps:put(Path, true, Current),
{noreply, Config#elixir_code_server{required=Done}};
error ->