joinGroup() — netty Function Reference

Architecture documentation for the joinGroup() function in LinuxSocket.java from the netty codebase.

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ joinGroup() — netty Function Reference

Dependency Diagram

graph TD
  01b16067_2cfe_5641_e182_eca4f3e10eec["joinGroup()"]
  d4234a66_3b23_bb74_6392_7b4eca8428c6["LinuxSocket"]
  01b16067_2cfe_5641_e182_eca4f3e10eec -->|defined in| d4234a66_3b23_bb74_6392_7b4eca8428c6
  b446cd77_a66d_2b48_c4aa_168c21b8b70c["joinSsmGroup()"]
  01b16067_2cfe_5641_e182_eca4f3e10eec -->|calls| b446cd77_a66d_2b48_c4aa_168c21b8b70c
  cd5cde44_97e9_e3ba_70b6_c79a1ebeaadd["interfaceIndex()"]
  01b16067_2cfe_5641_e182_eca4f3e10eec -->|calls| cd5cde44_97e9_e3ba_70b6_c79a1ebeaadd
  style 01b16067_2cfe_5641_e182_eca4f3e10eec fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-epoll/src/main/java/io/netty/channel/epoll/LinuxSocket.java lines 121–135

    void joinGroup(InetAddress group, NetworkInterface netInterface, InetAddress source) throws IOException {
        final NativeInetAddress g = NativeInetAddress.newInstance(group);
        final boolean isIpv6 = group instanceof Inet6Address;
        final NativeInetAddress i = NativeInetAddress.newInstance(deriveInetAddress(netInterface, isIpv6));
        if (source != null) {
            if (source.getClass() != group.getClass()) {
                throw new IllegalArgumentException("Source address is different type to group");
            }
            final NativeInetAddress s = NativeInetAddress.newInstance(source);
            joinSsmGroup(intValue(), ipv6 && isIpv6, g.address(), i.address(),
                    g.scopeId(), interfaceIndex(netInterface), s.address());
        } else {
            joinGroup(intValue(), ipv6 && isIpv6, g.address(), i.address(), g.scopeId(), interfaceIndex(netInterface));
        }
    }