Package org.jgroups.protocols

Class MPING

  • All Implemented Interfaces:
    java.lang.Runnable, Lifecycle
    public class MPING
extends PING
implements java.lang.Runnable
    Uses its own IP multicast socket to send and receive discovery requests/responses. Can be used in conjuntion with a non-UDP transport, e.g. TCP.
    The discovery is asymmetric: discovery requests are broadcast via the multicast socket, and received via the multicast socket by everyone in the group. However, the discovery responses are sent back via the regular transport (e.g. TCP) to the sender (discovery request contains sender's regular address, e.g. 192.168.0.2:7800).
    Author:
    Bela Ban

    • Field Detail

      • bind_addr

        protected java.net.InetAddress bind_addr

      • bind_interface_str

        protected java.lang.String bind_interface_str

      • ip_ttl

        protected int ip_ttl

      • mcast_addr

        protected java.net.InetAddress mcast_addr

      • mcast_port

        protected int mcast_port

      • receive_on_all_interfaces

        protected boolean receive_on_all_interfaces

      • receive_interfaces

        protected java.util.List<java.net.NetworkInterface> receive_interfaces
        List of interfaces to receive multicasts on. The multicast receive socket will listen on all of these interfaces. This is a comma-separated list of IP addresses or interface names. E.g. "192.168.5.1,eth1,127.0.0.1". Duplicates are discarded; we only bind to an interface once. If this property is set, it overrides receive_on_all_interfaces.

      • send_on_all_interfaces

        protected boolean send_on_all_interfaces
        If true, the transport should use all available interfaces to send multicast messages. This means the same multicast message is sent N times, so use with care

      • send_interfaces

        protected java.util.List<java.net.NetworkInterface> send_interfaces
        List of interfaces to send multicasts on. The multicast send socket will send the same multicast message on all of these interfaces. This is a comma-separated list of IP addresses or interface names. E.g. "192.168.5.1,eth1,127.0.0.1". Duplicates are discarded. If this property is set, it override send_on_all_interfaces.

      • mcast_receive_sock

        protected java.net.MulticastSocket mcast_receive_sock

      • mcast_send_sock

        protected java.net.MulticastSocket mcast_send_sock

      • mcast_send_sockets

        protected java.net.MulticastSocket[] mcast_send_sockets

      • receiver

        protected volatile java.lang.Thread receiver

    • Constructor Detail

      • MPING

        public MPING()

    • Method Detail

      • getBindAddr

        public java.net.InetAddress getBindAddr()

      • setBindAddr

        public MPING setBindAddr​(java.net.InetAddress b)

      • getReceiveInterfaces

        public java.util.List<java.net.NetworkInterface> getReceiveInterfaces()

      • getSendInterfaces

        public java.util.List<java.net.NetworkInterface> getSendInterfaces()

      • isReceiveOnAllInterfaces

        public boolean isReceiveOnAllInterfaces()

      • isSendOnAllInterfaces

        public boolean isSendOnAllInterfaces()

      • getTTL

        public int getTTL()

      • setTTL

        public MPING setTTL​(int ip_ttl)

      • getMcastAddr

        public java.net.InetAddress getMcastAddr()

      • mcastAddress

        public MPING mcastAddress​(java.net.InetAddress a)

      • setMcastAddr

        public MPING setMcastAddr​(java.net.InetAddress a)

      • getMcastPort

        public int getMcastPort()

      • setMcastPort

        public MPING setMcastPort​(int p)

      • setMulticastAddress

        public MPING setMulticastAddress​(java.lang.String a)
                          throws java.net.UnknownHostException
        Throws:
        java.net.UnknownHostException

      • up

        public java.lang.Object up​(Event evt)
        Description copied from class: Protocol
        An event was received from the protocol below. Usually the current protocol will want to examine the event type and - depending on its type - perform some computation (e.g. removing headers from a MSG event type, or updating the internal membership list when receiving a VIEW_CHANGE event). Finally, the event is either a) discarded, or b) an event is sent down the stack using down_prot.down() or c) the event (or another event) is sent up the stack using up_prot.up().
        Overrides:
        up in class Discovery

      • init

        public void init()
          throws java.lang.Exception
        Description copied from class: Protocol
        Called after a protocol has been created and before the protocol is started. Attributes are already set. Other protocols are not yet connected and events cannot yet be sent.
        Specified by:
        init in interface Lifecycle
        Overrides:
        init in class Discovery
        Throws:
        java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the the channel constructor will throw an exception

      • start

        public void start()
           throws java.lang.Exception
        Description copied from class: Protocol
        This method is called on a JChannel.connect(String); starts work. Protocols are connected ready to receive events. Will be called from bottom to top.
        Specified by:
        start in interface Lifecycle
        Overrides:
        start in class Discovery
        Throws:
        java.lang.Exception - Thrown if protocol cannot be started successfully. This will cause the ProtocolStack to fail, so JChannel.connect(String) will throw an exception

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable

      • createMulticastSocket

        protected java.net.MulticastSocket createMulticastSocket​(java.lang.String service_name,
                                                         int port)
                                                  throws java.lang.Exception
        Throws:
        java.lang.Exception

      • setInterface

        protected <T extends MPING> T setInterface​(java.net.InetAddress intf,
                                           java.net.MulticastSocket s)

      • bindToInterfaces

        protected void bindToInterfaces​(java.util.List<java.net.NetworkInterface> interfaces,
                                java.net.MulticastSocket s,
                                java.net.InetAddress mcast_addr)
                         throws java.io.IOException
        Throws:
        java.io.IOException

      • startReceiver

        protected void startReceiver()