Class/Object

it.unibo.scafi.distrib.actor.p2p.PlatformDevices

DeviceActor

Related Docs: object DeviceActor | package PlatformDevices

Permalink

class DeviceActor extends Platform.P2pBaseDeviceActor with Platform.MissingCodeManagementBehavior with Platform.ObservableDeviceActor

Specializes a ComputationDeviceActor to work in a decentralized, peer-to-peer manner. In particular, it needs to propagate each computed state to its neighbors.

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DeviceActor
  2. ObservableDeviceActor
  3. ObservableActorBehavior
  4. MissingCodeManagementBehavior
  5. P2pBaseDeviceActor
  6. P2pNbrManagementBehavior
  7. DynamicComputationDeviceActor
  8. DynamicDeviceLifecycleBehavior
  9. PeriodicBehavior
  10. LifecycleBehavior
  11. ComputationDeviceActor
  12. BaseNbrManagementBehavior
  13. ActuatorManagementBehavior
  14. SensorManagementBehavior
  15. SensingBehavior
  16. BasicActorBehavior
  17. BaseDeviceActor
  18. Actor
  19. AnyRef
  20. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DeviceActor(selfId: Platform.UID, aggregateExecutor: Option[Platform.ProgramContract], execScope: Platform.ExecScope)

    Permalink

Type Members

  1. type Receive = PartialFunction[Any, Unit]

    Permalink
    Definition Classes
    Actor

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. def actuatorManagementBehavior: Receive

    Permalink
    Definition Classes
    ActuatorManagementBehavior
  5. val actuators: Map[Platform.LSensorName, (Any) ⇒ Unit]

    Permalink
    Definition Classes
    ActuatorManagementBehavior
  6. def afterJob(): Unit

    Permalink
  7. var aggregateExecutor: Option[Platform.ProgramContract]

    Permalink
    Definition Classes
    DeviceActorComputationDeviceActor
  8. def aroundPostRestart(reason: Throwable): Unit

    Permalink
    Attributes
    protected[akka]
    Definition Classes
    Actor
    Annotations
    @InternalApi()
  9. def aroundPostStop(): Unit

    Permalink
    Attributes
    protected[akka]
    Definition Classes
    Actor
    Annotations
    @InternalApi()
  10. def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

    Permalink
    Attributes
    protected[akka]
    Definition Classes
    Actor
    Annotations
    @InternalApi()
  11. def aroundPreStart(): Unit

    Permalink
    Attributes
    protected[akka]
    Definition Classes
    Actor
    Annotations
    @InternalApi()
  12. def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

    Permalink
    Attributes
    protected[akka]
    Definition Classes
    Actor
    Annotations
    @InternalApi()
  13. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  14. def beforeJob(): Unit

    Permalink
    Definition Classes
    ComputationDeviceActor
  15. val classloader: CustomClassLoader

    Permalink
  16. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @throws( ... )
  17. def commandManagementBehavior: Receive

    Permalink
  18. def compute(ctx: Platform.ComputationContext): Platform.ComputationExport

    Permalink
    Definition Classes
    ComputationDeviceActor
  19. implicit val context: ActorContext

    Permalink
    Definition Classes
    Actor
  20. def currentStateMessage: Any

    Permalink
    Definition Classes
    ObservableActorBehavior
  21. def doJob(): Unit

    Permalink
    Definition Classes
    ComputationDeviceActor
  22. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  23. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  24. var execScope: Platform.ExecScope

    Permalink
  25. def executeActuators(value: Any): Unit

    Permalink
    Definition Classes
    ActuatorManagementBehavior
  26. var first: Boolean

    Permalink
  27. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate()
  28. def handleLifecycle(): Unit

    Permalink
  29. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate()
  30. val initialDelay: Option[FiniteDuration]

    Permalink
  31. def inputManagementBehavior: Receive

    Permalink
  32. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  33. var lastExport: Option[Platform.ComputationExport]

    Permalink
    Definition Classes
    ComputationDeviceActor
  34. def lifecyclePostStop(): Unit

    Permalink
  35. def lifecyclePreStart(): Unit

    Permalink
  36. val localSensors: Map[Platform.LSensorName, () ⇒ Any]

    Permalink
    Definition Classes
    SensorManagementBehavior
  37. val logger: LoggingAdapter

    Permalink
    Definition Classes
    BasicActorBehavior
  38. def mergeNeighborInfo(idn: Platform.UID, info: Platform.NbrInfo): Unit

    Permalink
    Definition Classes
    BaseNbrManagementBehavior
  39. val mobilityExt: CodeMobilityExtensionImpl

    Permalink
  40. val nbrSensorValues: Map[Platform.NSensorName, Map[Platform.UID, Any]]

    Permalink
    Definition Classes
    SensingBehavior
  41. var nbrs: Map[Platform.UID, Platform.NbrInfo]

    Permalink
    Definition Classes
    BaseNbrManagementBehavior
  42. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  43. def neighbourhoodManagementBehavior: Receive

    Permalink
    Definition Classes
    P2pNbrManagementBehavior
  44. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate()
  45. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate()
  46. def notifyObservers(msg: Any): Unit

    Permalink
    Definition Classes
    ObservableActorBehavior
  47. def notifyObservers(): Unit

    Permalink
    Definition Classes
    ObservableActorBehavior
  48. def observerAdded(ref: ActorRef): Unit

    Permalink
  49. val observers: Set[ActorRef]

    Permalink
    Definition Classes
    ObservableActorBehavior
  50. def observersManagementBehavior: Receive

    Permalink
    Definition Classes
    ObservableActorBehavior
  51. def periodicBehaviorPreStart(): Unit

    Permalink
    Definition Classes
    PeriodicBehavior
  52. def postRestart(reason: Throwable): Unit

    Permalink
    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  53. def postStop(): Unit

    Permalink
    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  54. def preRestart(reason: Throwable, message: Option[Any]): Unit

    Permalink
    Definition Classes
    Actor
    Annotations
    @throws( classOf[java.lang.Exception] )
  55. def preStart(): Unit

    Permalink
    Definition Classes
    DynamicComputationDeviceActorComputationDeviceActor → Actor
  56. def propagateExportToNeighbors(export: Platform.ComputationExport): Unit

    Permalink
    Definition Classes
    ComputationDeviceActor
  57. def propagateMsgToNeighbors(msg: Any): Unit

    Permalink
  58. def queryManagementBehavior: Receive

    Permalink
    Definition Classes
    BasicActorBehavior
  59. def receive: Receive

    Permalink
    Definition Classes
    ObservableDeviceActorBasicActorBehavior → Actor
  60. def removeNeighbor(idn: Platform.UID): Unit

    Permalink
  61. def replaceNeighborhood(neighbors: Map[Platform.UID, (Option[ActorRef], Option[String])]): Unit

    Permalink
    Definition Classes
    P2pNbrManagementBehavior
  62. var rounds: Int

    Permalink
    Definition Classes
    ComputationDeviceActor
  63. def scheduleNextWorkingCycle(): Unit

    Permalink
    Definition Classes
    PeriodicBehavior
  64. def scheduleNextWorkingCycle(delay: FiniteDuration, msg: Any = GoOn): Unit

    Permalink
    Definition Classes
    LifecycleBehavior
  65. implicit final val self: ActorRef

    Permalink
    Definition Classes
    Actor
  66. val selfId: Platform.UID

    Permalink
    Definition Classes
    DeviceActorBaseDeviceActor
  67. final def sender(): ActorRef

    Permalink
    Definition Classes
    Actor
  68. def sensingBehavior: Receive

    Permalink
    Definition Classes
    SensingBehavior
  69. def sensorManagementBehavior: Receive

    Permalink
    Definition Classes
    SensorManagementBehavior
  70. val sensorValues: Map[Platform.LSensorName, Any]

    Permalink
    Definition Classes
    SensingBehavior
  71. def setActuator(name: Platform.LSensorName, consumer: (Any) ⇒ Unit): Unit

    Permalink
    Definition Classes
    ActuatorManagementBehavior
  72. def setLocalSensor(name: Platform.LSensorName, provider: () ⇒ Any): Unit

    Permalink
    Definition Classes
    SensorManagementBehavior
  73. def setLocalSensorValue(name: Platform.LSensorName, value: Any): Unit

    Permalink
    Definition Classes
    ObservableDeviceActorSensingBehavior
  74. def setNbrSensorValue(name: Platform.NSensorName, map: Map[Platform.UID, Any]): Unit

    Permalink
    Definition Classes
    SensingBehavior
  75. def supervisorStrategy: SupervisorStrategy

    Permalink
    Definition Classes
    Actor
  76. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  77. var tick: Option[Cancellable]

    Permalink
  78. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  79. def unhandled(message: Any): Unit

    Permalink
    Definition Classes
    Actor
  80. def updateNeighborhood(neighbors: Set[Platform.UID], clear: Boolean = false): Unit

    Permalink
  81. def updateNeighborsState(nexps: Map[Platform.UID, Option[Platform.ComputationExport]], clear: Boolean = false): Unit

    Permalink
  82. def updateSensorValues(): Unit

    Permalink
    Definition Classes
    ComputationDeviceActor
  83. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  84. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  85. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  86. var workInterval: FiniteDuration

    Permalink
  87. def workingBehavior: Receive

    Permalink

Deprecated Value Members

  1. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @Deprecated @deprecated @throws( classOf[java.lang.Throwable] )
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from ObservableActorBehavior

Inherited from PeriodicBehavior

Inherited from LifecycleBehavior

Inherited from Platform.SensingBehavior

Inherited from BasicActorBehavior

Inherited from Platform.BaseDeviceActor

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Ungrouped