org.apache.hadoop.hbase.ipc

Interface PriorityFunction

All Known Implementing Classes:

MasterRpcServices, RSRpcServices

@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"})
 @InterfaceStability.Evolving
public interface PriorityFunction

Function to figure priority of incoming request.

Method Summary

Modifier and Type	Method and Description
long	getDeadline(RPCProtos.RequestHeader header, Message param) Returns the deadline of the specified request.
int	getPriority(RPCProtos.RequestHeader header, Message param) Returns the 'priority type' of the specified request.

Method Detail

getPriority

int getPriority(RPCProtos.RequestHeader header,
                Message param)

Returns the 'priority type' of the specified request. The returned value is mainly used to select the dispatch queue.

Parameters:

header -

param -

Returns:

Priority of this request.

getDeadline

long getDeadline(RPCProtos.RequestHeader header,
                 Message param)

Returns the deadline of the specified request. The returned value is used to sort the dispatch queue.

Parameters:

header -

param -

Returns:

Deadline of this request. 0 now, otherwise msec of 'delay'