org.apache.giraph.comm.netty.handler

Class RequestInfo

java.lang.Object

org.apache.giraph.comm.netty.handler.RequestInfo

public class RequestInfo
extends Object

Help track requests throughout the system

Constructor Summary

Constructors

Constructor and Description
RequestInfo(InetSocketAddress destinationAddress, WritableRequest request) Constructor.

Method Summary

Modifier and Type	Method and Description
InetSocketAddress	getDestinationAddress()
long	getElapsedMsecs() Get the elapsed millseconds since the request started.
long	getElapsedNanos() Get the elapsed nanoseconds since the request started.
WritableRequest	getRequest()
long	getStartedMsecs() Get the started msecs.
io.netty.channel.ChannelFuture	getWriteFuture()
void	setWriteFuture(io.netty.channel.ChannelFuture writeFuture)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestInfo

public RequestInfo(InetSocketAddress destinationAddress,
                   WritableRequest request)

Constructor.

Parameters:

destinationAddress - Destination of the request

request - Request that is sent

Method Detail

getDestinationAddress

public InetSocketAddress getDestinationAddress()

getStartedMsecs

public long getStartedMsecs()

Get the started msecs.

Returns:

Started msecs

getElapsedNanos

public long getElapsedNanos()

Get the elapsed nanoseconds since the request started.

Returns:

Nanoseconds since the request was started

getElapsedMsecs

public long getElapsedMsecs()

Get the elapsed millseconds since the request started.

Returns:

Milliseconds since the request was started

getRequest

public WritableRequest getRequest()

setWriteFuture

public void setWriteFuture(io.netty.channel.ChannelFuture writeFuture)

getWriteFuture

public io.netty.channel.ChannelFuture getWriteFuture()

toString

public String toString()

Overrides:

toString in class Object