Package org.jgroups.tests

Class Probe.TcpRequester

java.lang.Object

org.jgroups.tests.Probe.Requester

org.jgroups.tests.Probe.TcpRequester

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

Probe

protected class Probe.TcpRequester
extends Probe.Requester

Field Summary

Fields

Modifier and Type	Field	Description
protected java.io.InputStream	in
protected java.io.OutputStream	out
protected java.net.Socket	sock

Fields inherited from class org.jgroups.tests.Probe.Requester

dest, on_rsp, ON_RSP, passcode, request

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TcpRequester(java.net.SocketAddress dest, java.lang.String request, java.lang.String passcode, java.util.function.Consumer<ByteArray> on_rsp)

Method Summary

Modifier and Type	Method	Description
protected ByteArray	fetchResponse()
protected boolean	isRunning()
protected <T extends Probe.Requester> T	sendRequest(byte[] request)
protected <T extends Probe.Requester> T	start(java.net.InetAddress bind_addr, long timeout, int ttl)
protected <T extends Probe.Requester> T	stop()

Methods inherited from class org.jgroups.tests.Probe.Requester

createRequest, run, setResponseHandler

Methods inherited from class java.lang.Object

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

Field Detail

sock

protected java.net.Socket sock

in

protected java.io.InputStream in

out

protected java.io.OutputStream out

Constructor Detail

TcpRequester

protected TcpRequester(java.net.SocketAddress dest,
                       java.lang.String request,
                       java.lang.String passcode,
                       java.util.function.Consumer<ByteArray> on_rsp)

Method Detail

start

protected <T extends Probe.Requester> T start(java.net.InetAddress bind_addr,
                                              long timeout,
                                              int ttl)
                                       throws java.io.IOException

Specified by:

start in class Probe.Requester

Throws:

java.io.IOException

stop

protected <T extends Probe.Requester> T stop()

Specified by:

stop in class Probe.Requester

isRunning

protected boolean isRunning()

Specified by:

isRunning in class Probe.Requester

sendRequest

protected <T extends Probe.Requester> T sendRequest(byte[] request)
                                             throws java.io.IOException

Specified by:

sendRequest in class Probe.Requester

Throws:

java.io.IOException

fetchResponse

protected ByteArray fetchResponse()

Specified by:

fetchResponse in class Probe.Requester