Method Detail

• addLidMessage

  void addLidMessage​(GS_VID_T lid,
                     M writable)

• addGidMessages

  void addGidMessages​(Iterator<GS_VID_T> gids,
                      Iterator<M> writables)

• addGidMessage

  void addGidMessage​(GS_VID_T gid,
                     M writable)

  For messages bound with gid, first get lid.

  Parameters:

  gid - global id

  writable - msg

• swap

  void swap​(MessageStore<I,​M,​GS_VID_T> other)

• clearAll

  void clearAll()

• anyMessageReceived

  boolean anyMessageReceived()

  Check whether any messages received.

• messageAvailable

  boolean messageAvailable​(GS_VID_T lid)

  Check for lid, any messages available.

  Parameters:

  lid - lid.

  Returns:

  true if has message

• messageAvailable

  boolean messageAvailable​(Long lid)

• getMessages

  Iterable<M> getMessages​(GS_VID_T lid)

• getMessages

  Iterable<M> getMessages​(Long lid)

• digest

  void digest​(FFIByteVector vector)

  For a bytestream provided by FFIByteVector, read from it and digest its content.

  Parameters:

  vector -

• digestByteBuffer

  void digestByteBuffer​(io.netty.buffer.ByteBuf buf,
                        boolean fromSelf)