File gen_rpc-2.1.0-message_queue_data-off_heap.patch of Package gen_rpc

Overview Repositories Revisions Requests Users Attributes Meta

File gen_rpc-2.1.0-message_queue_data-off_heap.patch of Package gen_rpc

diff -Ndurp gen_rpc-2.1.0/rebar.config gen_rpc-2.1.0-message_queue_data-off_heap/rebar.config
--- gen_rpc-2.1.0/rebar.config	2016-10-07 13:17:44.000000000 +0300
+++ gen_rpc-2.1.0-message_queue_data-off_heap/rebar.config	2018-12-30 03:17:24.733919812 +0200
@@ -12,6 +12,7 @@
 ]}.
 
 {erl_opts, [debug_info,
+    {platform_define, "^(19|2)", 'HAVE_MQD_process_flag'},
     {warn_format, 1},
     bin_opt_info,
     inline_list_funcs,
diff -Ndurp gen_rpc-2.1.0/src/gen_rpc_helper.erl gen_rpc-2.1.0-message_queue_data-off_heap/src/gen_rpc_helper.erl
--- gen_rpc-2.1.0/src/gen_rpc_helper.erl	2016-10-07 13:17:44.000000000 +0300
+++ gen_rpc-2.1.0-message_queue_data-off_heap/src/gen_rpc_helper.erl	2018-12-30 03:11:41.558202987 +0200
@@ -73,12 +73,14 @@ host_from_node(Node) when is_atom(Node)
     Host.
 
 %% Set optimal process flags
+-ifdef(HAVE_MQD_process_flag).
+-define(OPTIMAL_PROCESS_FLAGS, [{trap_exit, true}, {priority, high}, {message_queue_data, off_heap}]).
+-else.
+-define(OPTIMAL_PROCESS_FLAGS, [{trap_exit, true}, {priority, high}]).
+-endif.
 -spec set_optimal_process_flags() -> ok.
 set_optimal_process_flags() ->
-    _ = erlang:process_flag(trap_exit, true),
-    _ = erlang:process_flag(priority, high),
-    _ = erlang:process_flag(message_queue_data, off_heap),
-    ok.
+    lists:foreach(fun({F, V}) -> erlang:process_flag(F, V) end, ?OPTIMAL_PROCESS_FLAGS).
 
 %% Return an atom to identify gen_rpc processes
 %%

Places

File gen_rpc-2.1.0-message_queue_data-off_heap.patch of Package gen_rpc

Places