Package kr.ac.konkuk.ccslab.cm.manager

Class CMCommManager

java.lang.Object

kr.ac.konkuk.ccslab.cm.manager.CMCommManager

public class CMCommManager
extends Object

Constructor Summary

Constructors

Constructor	Description
CMCommManager()

Method Summary

Modifier and Type	Method	Description
static SocketChannel	addBlockSocketChannel(int nChKey, String strTarget, CMInfo cmInfo)
static List<String>	getLocalIPList()
static MembershipKey	joinMulticastGroup(DatagramChannel dc, String addr)
static double	measureInputThroughput(String target, CMInfo cmInfo)
static double	measureOutputThroughput(String target, CMInfo cmInfo)
static SelectableChannel	openBlockChannel(int channelType, String address, int port, CMInfo cmInfo)
static SelectableChannel	openNonBlockChannel(int channelType, String address, int port, CMInfo cmInfo)
static boolean	removeBlockSocketChannel(int nChKey, String strTarget, CMInfo cmInfo)
static int	sendMessage(ByteBuffer buf, DatagramChannel dc, String addr, int port)
static int	sendMessage(ByteBuffer buf, SocketChannel sc)
static CMByteReceiver	startReceivingMessage(CMInfo cmInfo)
static CMByteSender	startSendingMessage(CMInfo cmInfo)
static void	terminate(CMInfo cmInfo)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CMCommManager

public CMCommManager()

Method Details

terminate

public static void terminate(CMInfo cmInfo)

getLocalIPList

public static List<String> getLocalIPList()

openNonBlockChannel

public static SelectableChannel openNonBlockChannel(int channelType,
 String address,
 int port,
 CMInfo cmInfo)
                                             throws IOException

Throws:

IOException

openBlockChannel

public static SelectableChannel openBlockChannel(int channelType,
 String address,
 int port,
 CMInfo cmInfo)
                                          throws IOException

Throws:

IOException

addBlockSocketChannel

public static SocketChannel addBlockSocketChannel(int nChKey,
 String strTarget,
 CMInfo cmInfo)

removeBlockSocketChannel

public static boolean removeBlockSocketChannel(int nChKey,
 String strTarget,
 CMInfo cmInfo)

joinMulticastGroup

public static MembershipKey joinMulticastGroup(DatagramChannel dc,
 String addr)

startReceivingMessage

public static CMByteReceiver startReceivingMessage(CMInfo cmInfo)

startSendingMessage

public static CMByteSender startSendingMessage(CMInfo cmInfo)

sendMessage

public static int sendMessage(ByteBuffer buf,
 SocketChannel sc)

sendMessage

public static int sendMessage(ByteBuffer buf,
 DatagramChannel dc,
 String addr,
 int port)

measureInputThroughput

public static double measureInputThroughput(String target,
 CMInfo cmInfo)

measureOutputThroughput

public static double measureOutputThroughput(String target,
 CMInfo cmInfo)