Modifier and Type | Method and Description |
---|---|
void |
SystemEventsListener.peerJoined(PeerCard peer) |
void |
SystemEventsListener.peerLost(PeerCard peer) |
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
SimpleMessage.getReceivers()
To implement
|
Modifier and Type | Method and Description |
---|---|
PeerCard |
ControlBroker.getmyPeerCard()
This method returns the PeerCard of the current MW instance
|
Modifier and Type | Method and Description |
---|---|
Map<PeerCard,Map<String,Serializable>> |
ControlBroker.findMatchingPeers(Map<String,Serializable> filter,
int limit,
int timeout) |
Modifier and Type | Method and Description |
---|---|
void |
ControlBroker.addNewPeer(SpaceDescriptor spaceDescriptor,
PeerCard peer) |
void |
ControlBroker.join(PeerCard spaceCoordinator,
SpaceCard spaceCard) |
void |
ControlBroker.joinRequest(SpaceCard spaceCard,
PeerCard sender) |
void |
ControlBroker.leaveSpace(PeerCard spaceCoordinator,
SpaceCard spaceCard) |
void |
ControlBroker.newPeerAdded(SpaceCard spaceCard,
PeerCard peer) |
void |
ControlBroker.peerFound(PeerCard peer) |
void |
ControlBroker.peerLost(PeerCard sender) |
Map<String,Serializable> |
ControlBroker.requestPeerAttributes(List<String> attributes,
PeerCard target,
int limit,
int timeout) |
void |
ControlBroker.requestToInstallPart(byte[] partAsZip,
PeerCard target,
UAPPCard card)
This method allows to request the installation of an uApp part to a
target node
|
void |
ControlBroker.requestToUninstallPart(PeerCard target,
UAPPCard card)
This method allows to request the installation of an uApp part to a
target node
|
Modifier and Type | Method and Description |
---|---|
void |
ControlBroker.sendMessage(BrokerMessage msg,
List<PeerCard> receivers)
Send a message.
|
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
BrokerMessage.getReceivers() |
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
ConfigurationMessage.getReceivers() |
Modifier and Type | Method and Description |
---|---|
boolean |
ConfigurationMessage.isSentFrom(PeerCard sender) |
Constructor and Description |
---|
ConfigurationMessage(ConfigurationMessage.ConfigurationMessageType mType,
PeerCard sender,
String propagateSerialized)
Create a new Configuration Message.
|
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
ControlMessage.getReceivers()
To implement
|
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
DeployMessage.getReceivers()
To implement
|
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
DistributedMWMessage.getReceivers() |
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
SpaceMessage.getReceivers()
To implement
|
Modifier and Type | Method and Description |
---|---|
PeerCard |
AbstractBus.getPeerCard() |
static PeerCard |
AbstractBus.getPeerFromBusResourceURI(String uri) |
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
BusMessage.getReceivers() |
PeerCard |
BusMessage.getSender() |
Modifier and Type | Method and Description |
---|---|
void |
BusMessage.addReceiver(PeerCard pc) |
void |
BusMessage.addReceivers(PeerCard[] receivers) |
static BusMessage |
BusMessage.createP2PReply(String messageIDInReplyTo,
PeerCard receiver,
Object content,
AbstractBus creator)
Create a reply message to the message with the given ID, with the content
and receiver passed as a parameter.
|
boolean |
BusMessage.hasReceiver(PeerCard receiver) |
boolean |
BusMessage.sentBySamePeerAs(PeerCard peer) |
void |
BusMessage.setReceiver(PeerCard receiver)
If the given peer is not null, removes any existing receiver and adds the
given peer as the only receiver.
|
void |
BusMessage.setSender(PeerCard sender) |
static void |
BusMessage.setThisPeer(PeerCard peer) |
Modifier and Type | Method and Description |
---|---|
void |
BusMessage.setReceivers(List<PeerCard> receivers) |
Modifier and Type | Method and Description |
---|---|
void |
CommunicationConnector.multicast(ChannelMessage message,
List<PeerCard> receivers)
Send multicast message to a list of recipients in the same group
|
Modifier and Type | Method and Description |
---|---|
void |
JGroupsCommunicationConnector.multicast(ChannelMessage message,
List<PeerCard> receivers) |
Modifier and Type | Method and Description |
---|---|
PeerCard |
ChannelMessage.getSender() |
Modifier and Type | Method and Description |
---|---|
void |
ChannelMessage.setSender(PeerCard sender) |
Constructor and Description |
---|
ChannelMessage(PeerCard sender,
String content,
List channelNames) |
Modifier and Type | Method and Description |
---|---|
PeerCard |
DummySpaceManager.getMyPeerCard() |
Modifier and Type | Method and Description |
---|---|
Map<String,PeerCard> |
DummySpaceManager.getPeers() |
Modifier and Type | Method and Description |
---|---|
Map<String,Serializable> |
DummySpaceManager.getPeerAttributes(List<String> arg0,
PeerCard arg1) |
void |
DummyCommunicationModule.send(ChannelMessage arg0,
MessageListener arg1,
PeerCard arg2) |
void |
DummyCommunicationModule.send(ChannelMessage arg0,
PeerCard arg1) |
Modifier and Type | Method and Description |
---|---|
void |
DummyCommunicationModule.sendAll(ChannelMessage arg0,
List<PeerCard> arg1) |
void |
DummyCommunicationModule.sendAll(ChannelMessage arg0,
List<PeerCard> arg1,
MessageListener arg2) |
Constructor and Description |
---|
DummySpaceManager(PeerCard myCard) |
Modifier and Type | Method and Description |
---|---|
static Scope |
Scope.instanceScope(String id,
PeerCard peerCard) |
static Scope |
Scope.moduleScope(String id,
PeerCard pc,
ModuleContext mc) |
Constructor and Description |
---|
InstanceScope(String id,
PeerCard pc)
Constructor for an entity residing in the same node (this).
|
ModuleScope(String id,
PeerCard pc,
ModuleContext mc)
Constructor using default instance (this), and ModuleContext for module
Id.
|
Modifier and Type | Method and Description |
---|---|
PeerCard |
SpaceDescriptor.getDeployManager() |
Modifier and Type | Method and Description |
---|---|
void |
SpaceDescriptor.setDeployManager(PeerCard deployManager) |
Modifier and Type | Method and Description |
---|---|
PeerCard |
SpaceManager.getMyPeerCard()
This method returns the PeerCard of the current MW instance
|
PeerCard[] |
MatchingResult.getPeers() |
Modifier and Type | Method and Description |
---|---|
Map<PeerCard,List<Part>> |
UAPPPackage.getDeploy() |
Map<String,PeerCard> |
SpaceManager.getPeers()
This method return the list of neighborhood peers joined to the current
Space.
NOTE: The list does not contains the invoker |
Modifier and Type | Method and Description |
---|---|
InstallationResults |
InstallationResultsDetails.getDetailedResult(PeerCard peer,
Part part) |
Map<String,Serializable> |
MatchingResult.getPeerAttribute(PeerCard peer) |
Map<String,Serializable> |
SpaceManager.getPeerAttributes(List<String> attributes,
PeerCard target) |
void |
DistributedMWEventHandler.handleMessage(PeerCard sender,
DistributedMWMessage msg) |
void |
DeployManagerEventHandler.installationPartNotification(UAPPCard uappCard,
String partID,
PeerCard peer,
UAPPPartStatus partStatus)
Method called back in order to notifiy the result of a request to install
|
void |
SpaceEventHandler.joinRequest(SpaceCard spaceCard,
PeerCard sender)
This method allows the SpaceManager to manage a join request from a
remote peer.
|
void |
SpaceEventHandler.peerFound(PeerCard peer)
Method called when a peer joins the Space managed by the
SpaceManager
|
void |
SpaceListener.peerJoined(PeerCard peer)
Called when a peers joins the Space
|
void |
SpaceEventHandler.peerLost(PeerCard peer)
This method notifies to the coordinator that a peer wants to leave to the
Space
|
void |
SpaceListener.peerLost(PeerCard peer)
Called when a Peer leaves the Space
|
void |
InstallationResultsDetails.setDetailedResult(PeerCard peer,
Part part,
InstallationResults result) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceEventHandler.setListOfPeers(Map<String,PeerCard> peer)
This method allows to configure the set of peers that actually join the
Space managed or joined by this SpaceManager
|
Constructor and Description |
---|
UAPPPackage(String serviceId,
String id,
URI folder,
Map<PeerCard,List<Part>> layout) |
Modifier and Type | Method and Description |
---|---|
void |
DeployManagerImpl.installationPartNotification(UAPPCard card,
String partID,
PeerCard peer,
UAPPPartStatus status) |
void |
DeployManagerImpl.peerJoined(PeerCard peer) |
void |
DeployManagerImpl.peerLost(PeerCard peer) |
Modifier and Type | Method and Description |
---|---|
void |
DistributedBusMemberListener.busMemberAdded(PeerCard origin,
String busMemberID,
String busName,
BusMemberType memberType,
String label,
String comment)
Invoked when a new BusMember is registered in the bus.
|
void |
DistributedBusMemberListener.busMemberRemoved(PeerCard origin,
String busMemberID)
Invoked when an existing BusMember is unregistered from the bus.
|
void |
DistributedLogListener.log(PeerCard origin,
int logLevel,
String module,
String pkg,
String cls,
String method,
Object[] msgPart,
String t)
Log a new message.
|
void |
DistributedBusMemberListener.regParamsAdded(PeerCard origin,
String busMemberID,
Resource[] params)
Invoked when registration parameters of an existing BusMember are added.
|
void |
DistributedBusMemberListener.regParamsRemoved(PeerCard origin,
String busMemberID,
Resource[] params)
Invoked when registration parameters of an existing BusMember are
removed.
|
Modifier and Type | Method and Description |
---|---|
void |
DistributedBusMemberManager.addListener(DistributedBusMemberListener listener,
List<PeerCard> nodes)
Add a new listener.
|
void |
DistributedLogManager.addListener(DistributedLogListener listener,
List<PeerCard> nodes) |
void |
DistributedBusMemberManager.removeListener(DistributedBusMemberListener listener,
List<PeerCard> nodes)
Remove an existing listener.
|
void |
DistributedLogManager.removeListener(DistributedLogListener listener,
List<PeerCard> nodes) |
Modifier and Type | Field and Description |
---|---|
static PeerCard |
DistributedMWManagerImpl.myPeer |
Modifier and Type | Field and Description |
---|---|
protected HashMap<PeerCard,Set<T>> |
ListenerHandler.listeners
Remote nodes that we have subscribed to.
|
protected Set<PeerCard> |
ListenerHandler.subscribers
Remote peers that have subscribed to messages from this node.
|
Modifier and Type | Method and Description |
---|---|
List<PeerCard> |
MySpaceListener.getPeers()
Get all peers, including this peer.
|
Modifier and Type | Method and Description |
---|---|
void |
ListenerHandler.AddListenerHandler.handle(PeerCard sender,
Resource r) |
void |
ListenerHandler.RemoveListenerHandler.handle(PeerCard sender,
Resource r) |
void |
LogListenerHandler.LogListenerMessageHandler.handle(PeerCard sender,
Resource r) |
void |
BusMemberListenerHandler.BusMemberAddedMessageHandler.handle(PeerCard sender,
Resource r) |
void |
BusMemberListenerHandler.BusMemberRemovedMessageHandler.handle(PeerCard sender,
Resource r) |
void |
BusMemberListenerHandler.RegParamsAddedMessageHandler.handle(PeerCard sender,
Resource r) |
void |
BusMemberListenerHandler.RegParamsRemovedMessageHandler.handle(PeerCard sender,
Resource r) |
void |
ListenerHandler.peerJoined(PeerCard peer) |
void |
MySpaceListener.peerJoined(PeerCard peer) |
void |
ListenerHandler.peerLost(PeerCard peer) |
void |
MySpaceListener.peerLost(PeerCard peer) |
static void |
DistributedMWManagerImpl.sendMessage(Resource r,
PeerCard receiver) |
Modifier and Type | Method and Description |
---|---|
void |
DistributedMWManagerImpl.addListener(DistributedBusMemberListener listener,
List<PeerCard> nodes) |
void |
DistributedMWManagerImpl.addListener(DistributedLogListener listener,
List<PeerCard> nodes) |
void |
ListenerHandler.addListener(T listener,
List<PeerCard> nodes) |
void |
DistributedMWManagerImpl.removeListener(DistributedBusMemberListener listener,
List<PeerCard> nodes) |
void |
DistributedMWManagerImpl.removeListener(DistributedLogListener listener,
List<PeerCard> nodes) |
void |
ListenerHandler.removeListener(T listener,
List<PeerCard> nodes) |
static void |
DistributedMWManagerImpl.sendMessage(Resource r,
List<PeerCard> receivers) |
static void |
DistributedMWManagerImpl.sendMessage(Resource r,
Set<PeerCard> receivers) |
Modifier and Type | Method and Description |
---|---|
PeerCard |
SpaceManagerImpl.getMyPeerCard() |
PeerCard[] |
MatchingResultImpl.getPeers() |
Modifier and Type | Method and Description |
---|---|
Map<String,PeerCard> |
SpaceManagerImpl.getPeers() |
Modifier and Type | Method and Description |
---|---|
Map<String,Serializable> |
MatchingResultImpl.getPeerAttribute(PeerCard peer) |
Map<String,Serializable> |
SpaceManagerImpl.getPeerAttributes(List<String> attributes,
PeerCard target) |
void |
SpaceManagerImpl.joinRequest(SpaceCard spaceCard,
PeerCard peer) |
void |
SpaceManagerImpl.peerFound(PeerCard peer) |
void |
SpaceManagerImpl.peerLost(PeerCard peer) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceManagerImpl.setListOfPeers(Map<String,PeerCard> peers) |
Constructor and Description |
---|
MatchingResultImpl(Map<PeerCard,Map<String,Serializable>> data) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceModule.addPeer(SpaceDescriptor spaceDescriptor,
PeerCard peer)
This method allows to add a new Peer to the Space.
|
void |
SpaceModule.announceNewPeer(SpaceCard spaceCard,
PeerCard peerCard)
This method propagates the event of new PeerAdded to the whole Space
|
void |
SpaceModule.joinSpace(PeerCard spaceCoordinator,
SpaceCard spaceCard)
This method allows to join to an existing Space
|
void |
SpaceModule.leaveSpace(PeerCard spaceCoordinator,
SpaceCard spaceCard)
This method allows to leave a Space
|
void |
SpaceModule.messageFromSpace(SpaceMessage message,
PeerCard sender)
This method is called as soon as an SpaceMessage has been received
|
void |
CommunicationModule.send(ChannelMessage message,
MessageListener listener,
PeerCard receiver)
Unicast send
|
void |
CommunicationModule.send(ChannelMessage message,
PeerCard receiver)
Unicast send to the Space Coordinator for joining operation
|
Modifier and Type | Method and Description |
---|---|
void |
CommunicationModule.sendAll(ChannelMessage message,
List<PeerCard> receivers)
Multicast implementation of the send.
|
void |
CommunicationModule.sendAll(ChannelMessage message,
List<PeerCard> receivers,
MessageListener listener)
Multicast send
|
Modifier and Type | Method and Description |
---|---|
void |
CommunicationModuleImpl.send(ChannelMessage message,
MessageListener listener,
PeerCard receiver)
Unicast
|
void |
CommunicationModuleImpl.send(ChannelMessage message,
PeerCard receiver)
Unicast
|
Modifier and Type | Method and Description |
---|---|
void |
CommunicationModuleImpl.sendAll(ChannelMessage message,
List<PeerCard> recipients)
Multicast
|
void |
CommunicationModuleImpl.sendAll(ChannelMessage message,
List<PeerCard> receivers,
MessageListener listener)
Multicast
|
Constructor and Description |
---|
UnicastExecutor(ChannelMessage message,
CommunicationConnector communicationConnector,
PeerCard receiver,
List<MessageListener> listeners,
ModuleContext moduleContext) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceModuleImpl.addPeer(SpaceDescriptor spaceDescriptor,
PeerCard newPeer) |
void |
SpaceModuleImpl.announceNewPeer(SpaceCard spaceCard,
PeerCard peerCard) |
void |
SpaceModuleImpl.joinSpace(PeerCard spaceCoordinator,
SpaceCard spaceCard) |
void |
SpaceModuleImpl.leaveSpace(PeerCard spaceCoordinator,
SpaceCard spaceCard) |
void |
SpaceModuleImpl.messageFromSpace(SpaceMessage message,
PeerCard sender) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceBus.CallInjector.brokerCall(String callerID,
PeerCard receiver,
BusMessage call)
Can be used by
ServiceCallInjector to inject a
ServiceCall to the bus. |
ServiceResponse |
ServiceCaller.inject(ServiceCall call,
PeerCard receiver)
Can be used to inject a
ServiceCall to the bus. |
String |
ServiceCaller.sendCall(ServiceCall call,
PeerCard receiver) |
Modifier and Type | Field and Description |
---|---|
protected PeerCard |
ServiceStrategy.theCoordinator |
Modifier and Type | Method and Description |
---|---|
void |
ServiceBusImpl.CallInjectorImpl.brokerCall(String callerID,
PeerCard receiver,
BusMessage call) |
void |
ServiceStrategy.injectCall(String callerID,
BusMessage call,
PeerCard receiver) |
Modifier and Type | Method and Description |
---|---|
void |
UIStrategyHandler.peerLost(PeerCard peer) |
void |
UIStrategyCaller.peerLost(PeerCard peer)
Coordinator will abort all pending request of the lost peer
|
Modifier and Type | Method and Description |
---|---|
PeerCard |
CoordinatedStrategy.getCoordinator() |
PeerCard |
CoordinatedStrategy.CoordinatorAlreadyExistsException.getExistingCoordinator() |
Modifier and Type | Method and Description |
---|---|
void |
CoordinatedStrategy.peerJoined(PeerCard peer) |
void |
CoordinatedStrategy.peerLost(PeerCard peer) |
protected void |
CallBasedStrategy.placeAsynchronousRequest(PeerCard peer,
CallMessage<? extends CallBasedStrategy> callMessage)
Send an asynchronous request to memberID.
|
protected Object |
CallBasedStrategy.placeSynchronousRequest(PeerCard peer,
CallMessage<? extends CallBasedStrategy> callMessage)
Place a Synchronous request, The
CallMessage is sent and the
message is anotated as waiting for response, the calling thread will be
set in a waiting state until either a response to the message is
received, or the call is aborted . |
void |
CallBasedStrategy.sendAsynchronousResponse(PeerCard peer,
CallMessage<? extends CallBasedStrategy> response) |
protected void |
EventBasedStrategy.sendEventToRemoteBusMember(PeerCard[] members,
EventMessage content)
Helper method to send a Multicast Event.
|
protected void |
EventBasedStrategy.sendEventToRemoteBusMember(PeerCard member,
EventMessage content)
Helper method to send a Unicast Event.
|
void |
CoordinatedStrategy.CoordinatorAlreadyExistsException.setExistingCoordinator(PeerCard existingCoordinator) |
Modifier and Type | Field and Description |
---|---|
PeerCard |
MemberData.origin |
Modifier and Type | Method and Description |
---|---|
void |
BusMemberMonitor.busMemberAdded(PeerCard origin,
String busMemberID,
String busName,
BusMemberType memberType,
String label,
String comment) |
void |
BusMemberMonitor.busMemberRemoved(PeerCard origin,
String busMemberID) |
void |
BusMemberMonitor.regParamsAdded(PeerCard origin,
String busMemberID,
Resource[] params) |
void |
BusMemberMonitor.regParamsRemoved(PeerCard origin,
String busMemberID,
Resource[] params) |
Constructor and Description |
---|
MemberData(PeerCard origin,
String busMemberID,
String busName,
BusMemberType memberType,
String label,
String comment) |
Modifier and Type | Method and Description |
---|---|
PeerCard |
MySpaceListener.getMyPeerCard() |
Modifier and Type | Method and Description |
---|---|
void |
MySpaceListener.peerJoined(PeerCard peer) |
void |
MySpaceListener.peerLost(PeerCard peer) |
Modifier and Type | Method and Description |
---|---|
void |
BusMemberGui.add(PeerCard peer) |
void |
BusMemberGui.remove(PeerCard peer) |
void |
BusMemberPane.show(PeerCard peerCard) |
Modifier and Type | Method and Description |
---|---|
Map<String,Serializable> |
IInstaller.getPeerAttributes(List<String> attributes,
PeerCard target) |
Modifier and Type | Method and Description |
---|---|
Map<String,PeerCard> |
Installer.getPeers()
get peers in Space from the SpaceManager
|
Modifier and Type | Method and Description |
---|---|
Map<String,Serializable> |
Installer.getPeerAttributes(List<String> attributes,
PeerCard target) |
Modifier and Type | Method and Description |
---|---|
static List<PeerCard> |
DeploymentInfoController.getValidPeers(List<UAPPReqAtom> reqs,
String PartId) |
Copyright © 2018 universAAL Consortium. All rights reserved.