com.fr.third.jgroups.tests.perf

类 UdpPerf

java.lang.Object

com.fr.third.jgroups.tests.perf.UdpPerf

public class UdpPerf
extends java.lang.Object

Dynamic tool to measure multicast performance of JGroups; every member sends N messages and we measure how long it takes for all receivers to receive them. MPerf is dynamic because it doesn't accept any configuration parameters (besides the channel config file and name); all configuration is done at runtime, and will be broadcast to all cluster members.

从以下版本开始:

3.1

作者:

Bela Ban (belaban@yahoo.com)

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	UdpPerf.Receiver
protected class	UdpPerf.Sender

字段概要

字段

限定符和类型	字段和说明
protected long	last_interval
protected int	log_interval
protected boolean	looping
protected java.net.MulticastSocket	mcast_sock
protected int	msg_size
protected int	num_msgs
protected int	num_threads
protected int	receive_log_interval
protected UdpPerf.Receiver	receiver
protected java.net.SocketAddress	sock_addr
protected java.util.concurrent.atomic.AtomicLong	total_received_msgs Maintains stats per sender, will be sent to perf originator when all messages have been received

构造器概要

构造器

构造器和说明
UdpPerf()

方法概要

方法

限定符和类型	方法和说明
protected void	handleData()
protected void	loop()
static void	main(java.lang.String[] args)
protected void	send(byte[] payload)
protected void	sendMessages()
void	start()
void	stop()

从类继承的方法 java.lang.Object

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

字段详细资料

mcast_sock

protected java.net.MulticastSocket mcast_sock

sock_addr

protected java.net.SocketAddress sock_addr

receiver

protected UdpPerf.Receiver receiver

num_msgs

protected int num_msgs

msg_size

protected int msg_size

num_threads

protected int num_threads

log_interval

protected int log_interval

receive_log_interval

protected int receive_log_interval

total_received_msgs

protected final java.util.concurrent.atomic.AtomicLong total_received_msgs

Maintains stats per sender, will be sent to perf originator when all messages have been received

looping

protected boolean looping

last_interval

protected long last_interval

构造器详细资料

UdpPerf

public UdpPerf()

方法详细资料

start

public void start()
           throws java.lang.Exception

抛出:

java.lang.Exception

loop

protected void loop()

send

protected void send(byte[] payload)
             throws java.lang.Exception

抛出:

java.lang.Exception

stop

public void stop()

handleData

protected void handleData()

sendMessages

protected void sendMessages()

main

public static void main(java.lang.String[] args)