|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.proactive.p2p.service.P2PAcquaintanceManager
Updating the group of exportAcquaintances of the P2P service.
Field Summary |
Fields inherited from interface org.objectweb.proactive.p2p.service.util.P2PConstants |
HIDE_P2PNODE_MONITORING, MAX_NODE, P2P_NODE_NAME, PROPERPY_XML_PATH, PROPERTY_ACQUISITION, PROPERTY_EXPLORING_MSG, PROPERTY_LOAD_BAL, PROPERTY_LOOKUP_FREQ, PROPERTY_MSG_MEMORY, PROPERTY_MULTI_PROC_NODES, PROPERTY_NO_SHARING, PROPERTY_NOA, PROPERTY_NODES_ACQUISITION_T0, PROPERTY_PORT, PROPERTY_TTL, PROPERTY_TTU, SHARED_NODE_NAME, VN_NAME |
Constructor Summary | |
P2PAcquaintanceManager()
The empty constructor for activating. |
|
P2PAcquaintanceManager(P2PService localService)
Construct a new P2PAcquaintanceManager . |
Method Summary | |
void |
add(P2PService peer)
Add a peer in the group of acquaintancesActived. |
void |
chooseNneighborsAndSendTheBalanceRequest(int n,
P2PService sender,
double ranking)
|
void |
chooseNneighborsAndStealTheirWork(int n,
double ranking,
java.lang.String myNodeAddress)
|
BooleanMutableWrapper |
contains(P2PService service)
Returns true if this collection contains the specified element. |
P2PService |
getActiveGroup()
|
void |
initActivity(Body body)
Initializes the activity of the active object. |
void |
remove(P2PService peer)
|
void |
runActivity(Body body)
Runs the activity of the active object. |
IntMutableWrapper |
size()
Returns the number of elements in this group. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public P2PAcquaintanceManager()
public P2PAcquaintanceManager(P2PService localService)
P2PAcquaintanceManager
.
localService
- a reference to the local P2P service.Method Detail |
public void initActivity(Body body)
InitActive
initActivity
in interface InitActive
body
- the body of the active object being initializedInitActive.initActivity(org.objectweb.proactive.Body)
public void runActivity(Body body)
RunActive
runActivity
in interface RunActive
body
- the body of the active object being startedRunActive.runActivity(org.objectweb.proactive.Body)
public P2PService getActiveGroup()
public void add(P2PService peer)
peer
- the peer to add.public void remove(P2PService peer)
public IntMutableWrapper size()
public BooleanMutableWrapper contains(P2PService service)
service
- element whose presence in this collection is to be tested.
public void chooseNneighborsAndSendTheBalanceRequest(int n, P2PService sender, double ranking)
n
- number of neighbors which receive the balance requestsender
- who sends the requestranking
- the ranking of the callerpublic void chooseNneighborsAndStealTheirWork(int n, double ranking, java.lang.String myNodeAddress)
n
- number of neighbors which receive the balance requestranking
- who sends the requestmyNodeAddress
- the ranking of the caller
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |