From 8936b71f13b37559600afb5536ff7d7878b9ab0e Mon Sep 17 00:00:00 2001 From: Micael Karlberg Date: Tue, 10 Jul 2018 13:42:28 +0200 Subject: [socket-nif] Add support for socket (level ip) option multicast_loop Added support for the IP option MULTICAST_LOOP. OTP-14831 --- erts/preloaded/src/socket.erl | 127 ++++++++++++++++++++++++++++++++++++------ 1 file changed, 110 insertions(+), 17 deletions(-) (limited to 'erts/preloaded/src') diff --git a/erts/preloaded/src/socket.erl b/erts/preloaded/src/socket.erl index 278a3f17ad..d2ed733b3c 100644 --- a/erts/preloaded/src/socket.erl +++ b/erts/preloaded/src/socket.erl @@ -460,9 +460,9 @@ -define(SOCKET_OPT_LEVEL_UDP, 5). -define(SOCKET_OPT_LEVEL_SCTP, 6). --define(SOCKET_OPT_OTP_DEBUG, 0). --define(SOCKET_OPT_OTP_IOW, 1). --define(SOCKET_OPT_OTP_CTRL_PROC, 2). +-define(SOCKET_OPT_OTP_DEBUG, 1). +-define(SOCKET_OPT_OTP_IOW, 2). +-define(SOCKET_OPT_OTP_CTRL_PROC, 3). -define(SOCKET_OPT_SOCK_ACCEPTCONN, 1). %% -define(SOCKET_OPT_SOCK_ACCEPTFILTER, 2). @@ -497,22 +497,112 @@ %% -define(SOCKET_OPT_SOCK_TIMESTAMP, 31). -define(SOCKET_OPT_SOCK_TYPE, 32). --define(SOCKET_OPT_IP_RECVTOS, 25). --define(SOCKET_OPT_IP_ROUTER_ALERT, 28). --define(SOCKET_OPT_IP_TOS, 30). --define(SOCKET_OPT_IP_TTL, 32). - --define(SOCKET_OPT_IPV6_HOPLIMIT, 12). - --define(SOCKET_OPT_TCP_CONGESTION, 0). +%% -define(SOCKET_OPT_IP_ADD_MEMBERSHIP, 1). +%% -define(SOCKET_OPT_IP_ADD_SOURCE_MEMBERSHIP, 2). +%% -define(SOCKET_OPT_IP_BLOCK_SOURCE, 3). +%% -define(SOCKET_OPT_IP_DONT_FRAG, 4). +%% -define(SOCKET_OPT_IP_DROP_MEMBERSHIP, 5). +%% -define(SOCKET_OPT_IP_DROP_SOURCE_MEMBERSHIP, 6). +%% -define(SOCKET_OPT_IP_FREEBIND, 7). +%% -define(SOCKET_OPT_IP_HDRINCL, 8). +%% -define(SOCKET_OPT_IP_MINTTL, 9). +%% -define(SOCKET_OPT_IP_MSFILTER, 10). +%% -define(SOCKET_OPT_IP_MTU, 11). +%% -define(SOCKET_OPT_IP_MTU_DISCOVER, 12). +%% -define(SOCKET_OPT_IP_MULTICAST_ALL, 13). +%% -define(SOCKET_OPT_IP_MULTICAST_IF, 14). +-define(SOCKET_OPT_IP_MULTICAST_LOOP, 15). +%% -define(SOCKET_OPT_IP_MULTICAST_TTL, 16). +%% -define(SOCKET_OPT_IP_NODEFRAG, 17). +%% -define(SOCKET_OPT_IP_OPTIONS, 18). +%% -define(SOCKET_OPT_IP_PKTINFO, 19). +%% -define(SOCKET_OPT_IP_RECVERR, 20). +%% -define(SOCKET_OPT_IP_RECVIF, 21). +%% -define(SOCKET_OPT_IP_RECVDSTADDR, 22). +%% -define(SOCKET_OPT_IP_RECVOPTS, 23). +%% -define(SOCKET_OPT_IP_RECVORIGDSTADDR, 24). +-define(SOCKET_OPT_IP_RECVTOS, 25). +%% -define(SOCKET_OPT_IP_RECVTTL, 26). +%% -define(SOCKET_OPT_IP_RETOPTS, 27). +-define(SOCKET_OPT_IP_ROUTER_ALERT, 28). +%% -define(SOCKET_OPT_IP_SNDSRCADDR, 29). +-define(SOCKET_OPT_IP_TOS, 30). +%% -define(SOCKET_OPT_IP_TRANSPARENT, 31). +-define(SOCKET_OPT_IP_TTL, 32). +-define(SOCKET_OPT_IP_UNBLOCK_SOURCE, 33). + +%% -define(SOCKET_OPT_IPV6_ADDFORM, 1). +%% -define(SOCKET_OPT_IPV6_ADD_MEMBERSHIP, 2). +%% -define(SOCKET_OPT_IPV6_AUTHHDR, 3). +%% -define(SOCKET_OPT_IPV6_AUTH_LEVEL, 4). +%% -define(SOCKET_OPT_IPV6_CHECKSUM, 5). +%% -define(SOCKET_OPT_IPV6_DROP_MEMBERSHIP, 6). +%% -define(SOCKET_OPT_IPV6_DSTOPTS, 7). +%% -define(SOCKET_OPT_IPV6_ESP_TRANS_LEVEL, 8). +%% -define(SOCKET_OPT_IPV6_ESP_NETWORK_LEVEL, 9). +%% -define(SOCKET_OPT_IPV6_FAITH, 10). +%% -define(SOCKET_OPT_IPV6_FLOWINFO, 11). +-define(SOCKET_OPT_IPV6_HOPLIMIT, 12). +%% -define(SOCKET_OPT_IPV6_HOPOPTS, 13). +%% -define(SOCKET_OPT_IPV6_IPCOMP_LEVEL, 14). +%% -define(SOCKET_OPT_IPV6_JOIN_GROUP, 15). +%% -define(SOCKET_OPT_IPV6_LEAVE_GROUP, 16). +%% -define(SOCKET_OPT_IPV6_MTU, 17). +%% -define(SOCKET_OPT_IPV6_MTU_DISCOVER, 18). +%% -define(SOCKET_OPT_IPV6_MULTICAST_HOPS, 19). +%% -define(SOCKET_OPT_IPV6_MULTICAST_IF, 20). +%% -define(SOCKET_OPT_IPV6_MULTICAST_LOOP, 21). +%% -define(SOCKET_OPT_IPV6_PORTRANGE, 22). +%% -define(SOCKET_OPT_IPV6_PKTINFO, 23). +%% -define(SOCKET_OPT_IPV6_PKTOPTIONS, 24). +%% -define(SOCKET_OPT_IPV6_RECVERR, 25). +%% -define(SOCKET_OPT_IPV6_RECVPKTINFO, 26). +%% -define(SOCKET_OPT_IPV6_RECVTCLASS, 27). +%% -define(SOCKET_OPT_IPV6_ROUTER_ALERT, 28). +%% -define(SOCKET_OPT_IPV6_RTHDR, 29). +%% -define(SOCKET_OPT_IPV6_TCLASS, 30). +%% -define(SOCKET_OPT_IPV6_UNICAST_HOPS, 31). +%% -define(SOCKET_OPT_IPV6_USE_MIN_MTU, 32). +%% -define(SOCKET_OPT_IPV6_V6ONLY, 33). + +-define(SOCKET_OPT_TCP_CONGESTION, 1). -define(SOCKET_OPT_TCP_CORK, 2). -define(SOCKET_OPT_TCP_MAXSEG, 3). -define(SOCKET_OPT_TCP_NODELAY, 4). --define(SOCKET_OPT_UDP_CORK, 0). - --define(SOCKET_OPT_SCTP_AUTOCLOSE, 7). --define(SOCKET_OPT_SCTP_NODELAY, 22). +-define(SOCKET_OPT_UDP_CORK, 1). + +%% -define(SOCKET_OPT_SCTP_ADAPTION_LAYER, 1). +%% -define(SOCKET_OPT_SCTP_ASSOCINFO, 2). +%% -define(SOCKET_OPT_SCTP_AUTH_ACTIVE_KEY, 3). +%% -define(SOCKET_OPT_SCTP_AUTH_ASCONF, 4). +%% -define(SOCKET_OPT_SCTP_AUTH_CHUNK, 5). +%% -define(SOCKET_OPT_SCTP_AUTH_KEY, 6). +%% -define(SOCKET_OPT_SCTP_AUTH_DELETE_KEY, 7). +-define(SOCKET_OPT_SCTP_AUTOCLOSE, 8). +%% -define(SOCKET_OPT_SCTP_CONTEXT, 9). +%% -define(SOCKET_OPT_SCTP_DEFAULT_SEND_PARAMS, 10). +%% -define(SOCKET_OPT_SCTP_DELAYED_ACK_TIME, 11). +%% -define(SOCKET_OPT_SCTP_DISABLE_FRAGMENTS, 12). +%% -define(SOCKET_OPT_SCTP_HMAC_IDENT, 13). +%% -define(SOCKET_OPT_SCTP_EXPLICIT_EOR, 14). +%% -define(SOCKET_OPT_SCTP_FRAGMENT_INTERLEAVE, 15). +%% -define(SOCKET_OPT_SCTP_GET_PEER_ADDR_INFO, 16). +%% -define(SOCKET_OPT_SCTP_INITMSG, 17). +%% -define(SOCKET_OPT_SCTP_I_WANT_MAPPED_V4_ADDR, 18). +%% -define(SOCKET_OPT_SCTP_LOCAL_AUTH_CHUNKS, 19). +%% -define(SOCKET_OPT_SCTP_MAXSEG, 20). +%% -define(SOCKET_OPT_SCTP_MAXBURST, 21). +-define(SOCKET_OPT_SCTP_NODELAY, 22). +%% -define(SOCKET_OPT_SCTP_PARTIAL_DELIVERY_POINT, 23). +%% -define(SOCKET_OPT_SCTP_PEER_ADDR_PARAMS, 24). +%% -define(SOCKET_OPT_SCTP_PEER_AUTH_CHUNKS, 25). +%% -define(SOCKET_OPT_SCTP_PRIMARY_ADDR, 26). +%% -define(SOCKET_OPT_SCTP_RESET_STREAMS, 27). +%% -define(SOCKET_OPT_SCTP_RTOINFO, 28). +%% -define(SOCKET_OPT_SCTP_SET_PEER_PRIMARY_ADDR, 29). +%% -define(SOCKET_OPT_SCTP_STATUS, 30). +%% -define(SOCKET_OPT_SCTP_USE_EXT_RECVINFO, 31). -define(SOCKET_SHUTDOWN_HOW_READ, 0). -define(SOCKET_SHUTDOWN_HOW_WRITE, 1). @@ -1865,6 +1955,9 @@ enc_setopt_value(socket, sndbuf, V, _D, _T, _P) when is_integer(V) -> enc_setopt_value(socket = L, Opt, V, _D, _T, _P) -> not_supported({L, Opt, V}); +enc_setopt_value(ip, multicast_loop, V, _D, _T, _P) + when is_boolean(V) -> + V; enc_setopt_value(ip, recvtos, V, _D, _T, _P) when is_boolean(V) -> V; @@ -2157,8 +2250,8 @@ enc_sockopt_key(ip = L, multicast_all = Opt, _Dir, _D, _T, _P) -> not_supported({L, Opt}); enc_sockopt_key(ip = L, multicast_if = Opt, _Dir, _D, _T, _P) -> not_supported({L, Opt}); -enc_sockopt_key(ip = L, multicast_loop = Opt, _Dir, _D, _T, _P) -> - not_supported({L, Opt}); +enc_sockopt_key(ip = _L, multicast_loop = _Opt, _Dir, _D, _T, _P) -> + ?SOCKET_OPT_IP_MULTICAST_LOOP; enc_sockopt_key(ip = L, multicast_ttl = Opt, _Dir, _D, _T, _P) -> not_supported({L, Opt}); enc_sockopt_key(ip = L, nodefrag = Opt, _Dir, _D, raw = _T, _P) -> -- cgit v1.2.3