File 0952-observer-Reading-invalid-port-socket-optio... of Package erlang

Overview Repositories Revisions Requests Users Attributes Meta

File 0952-observer-Reading-invalid-port-socket-options.patch of Package erlang (Revision 5e61acd9f1d3331a475517e09a34188a)

Currently displaying revision 5e61acd9f1d3331a475517e09a34188a , Show latest

From ff80ff54467cd21e2f8abb713b66df6de773a169 Mon Sep 17 00:00:00 2001
From: Micael Karlberg <bmk@erlang.org>
Date: Wed, 30 Mar 2022 14:44:51 +0200
Subject: [PATCH 1/5] [observer] Reading invalid port socket options

Reading port socket options is now done "individually".
This means that if one option is invalid its simply skipped,
and we continue with the rest.

OTP-18012
---
 lib/runtime_tools/src/observer_backend.erl | 47 +++++++++++++++++-----
 1 file changed, 38 insertions(+), 9 deletions(-)

diff --git a/lib/runtime_tools/src/observer_backend.erl b/lib/runtime_tools/src/observer_backend.erl
index ecbba3d0d8..1bdfb6fb9b 100644
--- a/lib/runtime_tools/src/observer_backend.erl
+++ b/lib/runtime_tools/src/observer_backend.erl
@@ -205,15 +205,7 @@ inet_port_extra({_,Type},Port) when Type =:= "udp_inet";
                 [{local_address,LAddr}];
             {error, _} -> []
         end ++
-        case inet:getopts(Port,
-                          [active, broadcast, buffer, bind_to_device,
-                           delay_send, deliver, dontroute, exit_on_close,
-                           header, high_msgq_watermark, high_watermark,
-                           ipv6_v6only, keepalive, linger, low_msgq_watermark,
-                           low_watermark, mode, netns, nodelay, packet,
-                           packet_size, priority, read_packets, recbuf,
-                           reuseaddr, send_timeout, send_timeout_close,
-                           show_econnreset, sndbuf, tos, tclass]) of
+        case get_sock_opts(Port) of
             {ok, Opts} -> [{options, Opts}];
             {error, _} -> []
         end,
@@ -221,6 +213,44 @@ inet_port_extra({_,Type},Port) when Type =:= "udp_inet";
 inet_port_extra(_,_) ->
     [].
 
+sock_opts() ->
+    [active, broadcast, buffer, bind_to_device,
+     delay_send, deliver, dontroute, exit_on_close,
+     header, high_msgq_watermark, high_watermark,
+     ipv6_v6only, keepalive, linger, low_msgq_watermark,
+     low_watermark, mode, netns, nodelay, packet,
+     packet_size, priority, read_packets, recbuf,
+     reuseaddr, send_timeout, send_timeout_close,
+     show_econnreset, sndbuf, tos, tclass].
+
+get_sock_opts(Port) ->
+    get_sock_opts(Port, sock_opts()).
+
+get_sock_opts(Port, Opts) ->
+    get_sock_opts(Port, Opts, []).
+
+%% The reason we are doing it this way, is because if there
+%% is an issue with one of the options, we should just skip
+%% that option and continue with the next.
+%% Better to have some options then none.
+get_sock_opts(_Port, [], Acc) ->
+    {ok, lists:reverse(Acc)};
+get_sock_opts(Port, [Opt|Opts], Acc) ->
+    case inet:getopts(Port, [Opt]) of
+        {ok, [Res]} ->
+            get_sock_opts(Port, Opts, [Res|Acc]);
+        {ok, []} -> % No value?
+            get_sock_opts(Port, Opts, Acc);
+        {error, einval} ->
+            get_sock_opts(Port, Opts, Acc);
+
+        %% If the option is "invalid", the reason would be 'einval',
+        %% so this error must be something else => fail
+        {error, _} = ERROR ->
+            ERROR
+    end.
+
+
 get_table_list(ets, Opts) ->
     HideUnread = proplists:get_value(unread_hidden, Opts, true),
     HideSys = proplists:get_value(sys_hidden, Opts, true),
-- 
2.34.1

Places

File 0952-observer-Reading-invalid-port-socket-options.patch of Package erlang (Revision 5e61acd9f1d3331a475517e09a34188a)

Places