org.apache.giraph.comm.netty.handler

Class WorkerRequestReservedMap

java.lang.Object

org.apache.giraph.comm.netty.handler.WorkerRequestReservedMap

public class WorkerRequestReservedMap
extends Object

Provides a thread-safe map for checking worker and request id pairs

Constructor Summary

Constructors

Constructor and Description
WorkerRequestReservedMap(org.apache.hadoop.conf.Configuration conf) Constructor

Method Summary

Modifier and Type	Method and Description
boolean	reserveRequest(Integer workerId, long requestId) Reserve the request (before the request starts to insure that it is only executed once).

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerRequestReservedMap

public WorkerRequestReservedMap(org.apache.hadoop.conf.Configuration conf)

Constructor

Parameters:

conf - Configuration

Method Detail

reserveRequest

public boolean reserveRequest(Integer workerId,
                              long requestId)

Reserve the request (before the request starts to insure that it is only executed once). We are assuming no failure on the server.

Parameters:

workerId - workerId of the request

requestId - Request id

Returns:

True if the reserving succeeded, false otherwise