Class UnicastHeader

java.lang.Object
org.jgroups.Header
org.jgroups.protocols.UnicastHeader
All Implemented Interfaces:
Constructable<Header>, SizeStreamable, Streamable
public class UnicastHeader extends Header
Header for subclasses of ReliableUnicast, e.g. UNICAST4.
Since:
5.4
Author:
Bela Ban

  • Field Details

  • Constructor Details

    • UnicastHeader

      public UnicastHeader()

    • UnicastHeader

      protected UnicastHeader(byte type)

    • UnicastHeader

      protected UnicastHeader(byte type, long seqno)

    • UnicastHeader

      protected UnicastHeader(byte type, long seqno, short conn_id, boolean first)

  • Method Details

    • getMagicId

      public short getMagicId()
      Description copied from class: Header
      Returns the magic-ID. If defined in jg-magic-map.xml, the IDs need to be the same
      Specified by:
      getMagicId in class Header

    • create

      public Supplier<? extends Header> create()
      Description copied from interface: Constructable
      Creates an instance of the class implementing this interface
      Returns:
      Supplier

    • createDataHeader

      public static UnicastHeader createDataHeader(long seqno, short conn_id, boolean first)

    • createAckHeader

      public static UnicastHeader createAckHeader(long seqno, short conn_id, int timestamp)

    • createSendFirstSeqnoHeader

      public static UnicastHeader createSendFirstSeqnoHeader(int timestamp)

    • createXmitReqHeader

      public static UnicastHeader createXmitReqHeader()

    • createCloseHeader

      public static UnicastHeader createCloseHeader(short conn_id)

    • type

      public byte type()

    • seqno

      public long seqno()

    • connId

      public short connId()

    • connId

      public UnicastHeader connId(short c)

    • first

      public boolean first()

    • timestamp

      public int timestamp()

    • timestamp

      public UnicastHeader timestamp(int ts)

    • toString

      public String toString()
      Overrides:
      toString in class Header

    • type2Str

      public static String type2Str(byte t)

    • serializedSize

      public final int serializedSize()
      Description copied from interface: SizeStreamable
      Returns the size (in bytes) of the marshalled object

    • copy

      public UnicastHeader copy()

    • writeTo

      public void writeTo(DataOutput out) throws IOException
      The following types and fields are serialized: 
      | DATA | seqno | conn_id | first |
| ACK  | seqno | timestamp |
| SEND_FIRST_SEQNO | timestamp |
| CLOSE | conn_id |
      Throws:
      IOException

    • readFrom

      public void readFrom(DataInput in) throws IOException
      Description copied from interface: Streamable
      Read the state of the current object (including superclasses) from instream Note that the input stream must not be closed
      Throws:
      IOException