Field Detail

• SIZE

  public static final int SIZE

• HASH_SHIFT

  public static final int HASH_SHIFT

Constructor Detail

• ParallelMessageManagerGen_cxx_0x5a835738

  public ParallelMessageManagerGen_cxx_0x5a835738​(long address)

Method Detail

• equals

  public boolean equals​(Object o)

  Overrides:

  equals in class Object

• hashCode

  public int hashCode()

  Overrides:

  hashCode in class Object

• toString

  public String toString()

  Overrides:

  toString in class Object

• finishARound

  public void finishARound()

  Specified by:

  finishARound in interface MessageManagerBase

• nativeFinishARound

  public static void nativeFinishARound​(long ptr)

• forceContinue

  public void forceContinue()

  Specified by:

  forceContinue in interface MessageManagerBase

• nativeForceContinue

  public static void nativeForceContinue​(long ptr)

• getMessageInBuffer

  public @com.alibaba.fastffi.FFINameAlias("GetMessageInBuffer") boolean getMessageInBuffer​(MessageInBuffer buf)

  Description copied from interface: ParallelMessageManager
  Retrieve a message archive.

  Specified by:

  getMessageInBuffer in interface ParallelMessageManager

  Parameters:

  buf - place to store the archive.

  Returns:

  true if got one.

• nativeGetMessageInBuffer

  public static @com.alibaba.fastffi.FFINameAlias("GetMessageInBuffer") boolean nativeGetMessageInBuffer​(long ptr,
                                                                                                         long buf0)

• getMsgSize

  public @com.alibaba.fastffi.FFINameAlias("GetMsgSize") long getMsgSize()

  Specified by:

  getMsgSize in interface MessageManagerBase

• nativeGetMsgSize

  public static @com.alibaba.fastffi.FFINameAlias("GetMsgSize") long nativeGetMsgSize​(long ptr)

• initChannels

  public void initChannels​(int channel_num)

  Description copied from interface: ParallelMessageManager
  Init the message manager which number of possible channels. Each channel will swap messages in parallel.

  Specified by:

  initChannels in interface ParallelMessageManager

  Parameters:

  channel_num - number of channels.

• nativeInitChannels

  public static void nativeInitChannels​(long ptr,
                                        int channel_num0)

• start

  public void start()

  Specified by:

  start in interface MessageManagerBase

• nativeStart

  public static void nativeStart​(long ptr)

• startARound

  public void startARound()

  Specified by:

  startARound in interface MessageManagerBase

• nativeStartARound

  public static void nativeStartARound​(long ptr)

• toTerminate

  public @com.alibaba.fastffi.FFINameAlias("ToTerminate") boolean toTerminate()

  Specified by:

  toTerminate in interface MessageManagerBase

• nativeToTerminate

  public static @com.alibaba.fastffi.FFINameAlias("ToTerminate") boolean nativeToTerminate​(long ptr)