Package com.alibaba.graphscope.parallel

Class ParallelMessageManagerGen_cxx_0x5a835738

java.lang.Object

com.alibaba.fastffi.FFIPointerImpl

com.alibaba.graphscope.parallel.ParallelMessageManagerGen_cxx_0x5a835738

All Implemented Interfaces:

com.alibaba.fastffi.FFIPointer, FFIType, MessageManagerBase, ParallelMessageManager, ParallelMessageManagerGen, Serializable

public class ParallelMessageManagerGen_cxx_0x5a835738
extends FFIPointerImpl
implements ParallelMessageManagerGen

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static int	HASH_SHIFT
static int	SIZE

Fields inherited from class com.alibaba.fastffi.FFIPointerImpl

address

Constructor Summary

Constructors

Constructor	Description
ParallelMessageManagerGen_cxx_0x5a835738(long address)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
void	finishARound()
void	forceContinue()
@com.alibaba.fastffi.FFINameAlias("GetMessageInBuffer") boolean	getMessageInBuffer(MessageInBuffer buf)	Retrieve a message archive.
@com.alibaba.fastffi.FFINameAlias("GetMsgSize") long	getMsgSize()
int	hashCode()
void	initChannels(int channel_num)	Init the message manager which number of possible channels.
static void	nativeFinishARound(long ptr)
static void	nativeForceContinue(long ptr)
static @com.alibaba.fastffi.FFINameAlias("GetMessageInBuffer") boolean	nativeGetMessageInBuffer(long ptr, long buf0)
static @com.alibaba.fastffi.FFINameAlias("GetMsgSize") long	nativeGetMsgSize(long ptr)
static void	nativeInitChannels(long ptr, int channel_num0)
static void	nativeStart(long ptr)
static void	nativeStartARound(long ptr)
static @com.alibaba.fastffi.FFINameAlias("ToTerminate") boolean	nativeToTerminate(long ptr)
void	start()
void	startARound()
String	toString()
@com.alibaba.fastffi.FFINameAlias("ToTerminate") boolean	toTerminate()

Methods inherited from class com.alibaba.fastffi.FFIPointerImpl

getAddress

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.alibaba.fastffi.FFIPointer

getAddress

Methods inherited from interface com.alibaba.graphscope.parallel.ParallelMessageManager

parallelProcess, sendMsgThroughEdges, sendMsgThroughIEdges, sendMsgThroughOEdges, syncStateOnOuterVertex, syncStateOnOuterVertexNoMsg

Methods inherited from interface com.alibaba.graphscope.parallel.ParallelMessageManagerGen

sendMsgThroughEdgesArrowProjected, sendMsgThroughEdgesImmutable, sendMsgThroughIEdgesArrowProjected, sendMsgThroughIEdgesImmutable, sendMsgThroughOEdgesArrowProjected, sendMsgThroughOEdgesImmutable, sendToFragment, syncStateOnOuterVertexArrowProjected, syncStateOnOuterVertexArrowProjectedNoMsg, syncStateOnOuterVertexImmutable, syncStateOnOuterVertexImmutableNoMsg

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)