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
Platform.ObservableDeviceActor, ObservableActorBehavior, Platform.MissingCodeManagementBehavior, Platform.P2pBaseDeviceActor, Platform.P2pNbrManagementBehavior, Platform.DynamicComputationDeviceActor, Platform.DynamicDeviceLifecycleBehavior, PeriodicBehavior, LifecycleBehavior, Platform.ComputationDeviceActor, Platform.BaseNbrManagementBehavior, Platform.ActuatorManagementBehavior, Platform.SensorManagementBehavior, Platform.SensingBehavior, BasicActorBehavior, Platform.BaseDeviceActor, Actor, AnyRef, Any
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
    Definition Classes
    ObservableDeviceActor → ComputationDeviceActor

  7. var aggregateExecutor: Option[Platform.ProgramContract]

    Permalink
    Definition Classes
    DeviceActor → ComputationDeviceActor

  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
    Definition Classes
    MissingCodeManagementBehavior

  16. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @throws( ... )

  17. def commandManagementBehavior: Receive

    Permalink
    Definition Classes
    MissingCodeManagementBehavior → BasicActorBehavior

  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
    Definition Classes
    DeviceActor → DynamicDeviceLifecycleBehavior

  25. def executeActuators(value: Any): Unit

    Permalink
    Definition Classes
    ActuatorManagementBehavior

  26. var first: Boolean

    Permalink
    Definition Classes
    DynamicDeviceLifecycleBehavior

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

    Permalink
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate()

  28. def handleLifecycle(): Unit

    Permalink
    Definition Classes
    DynamicDeviceLifecycleBehavior → PeriodicBehavior → LifecycleBehavior

  29. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate()

  30. val initialDelay: Option[FiniteDuration]

    Permalink
    Definition Classes
    DynamicDeviceLifecycleBehavior → PeriodicBehavior

  31. def inputManagementBehavior: Receive

    Permalink
    Definition Classes
    MissingCodeManagementBehavior → BasicActorBehavior

  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
    Definition Classes
    DynamicDeviceLifecycleBehavior → LifecycleBehavior

  35. def lifecyclePreStart(): Unit

    Permalink
    Definition Classes
    DynamicDeviceLifecycleBehavior → PeriodicBehavior → LifecycleBehavior

  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
    Definition Classes
    MissingCodeManagementBehavior

  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
    Definition Classes
    ObservableDeviceActor → ObservableActorBehavior

  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
    DynamicComputationDeviceActor → ComputationDeviceActor → Actor

  56. def propagateExportToNeighbors(export: Platform.ComputationExport): Unit

    Permalink
    Definition Classes
    ComputationDeviceActor

  57. def propagateMsgToNeighbors(msg: Any): Unit

    Permalink
    Definition Classes
    P2pBaseDeviceActor → ComputationDeviceActor

  58. def queryManagementBehavior: Receive

    Permalink
    Definition Classes
    BasicActorBehavior

  59. def receive: Receive

    Permalink
    Definition Classes
    ObservableDeviceActor → BasicActorBehavior → Actor

  60. def removeNeighbor(idn: Platform.UID): Unit

    Permalink
    Definition Classes
    ObservableDeviceActor → BaseNbrManagementBehavior

  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
    DeviceActor → BaseDeviceActor

  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
    ObservableDeviceActor → SensingBehavior

  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
    Definition Classes
    DynamicDeviceLifecycleBehavior

  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
    Definition Classes
    ObservableDeviceActor → BaseNbrManagementBehavior

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

    Permalink
    Definition Classes
    ObservableDeviceActor → BaseNbrManagementBehavior

  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
    Definition Classes
    DynamicDeviceLifecycleBehavior → PeriodicBehavior

  87. def workingBehavior: Receive

    Permalink
    Definition Classes
    ComputationDeviceActor → BasicActorBehavior

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 Platform.ObservableDeviceActor

Inherited from ObservableActorBehavior

Inherited from Platform.MissingCodeManagementBehavior

Inherited from Platform.P2pBaseDeviceActor

Inherited from Platform.P2pNbrManagementBehavior

Inherited from Platform.DynamicComputationDeviceActor

Inherited from Platform.DynamicDeviceLifecycleBehavior

Inherited from PeriodicBehavior

Inherited from LifecycleBehavior

Inherited from Platform.ComputationDeviceActor

Inherited from Platform.BaseNbrManagementBehavior

Inherited from Platform.ActuatorManagementBehavior

Inherited from Platform.SensorManagementBehavior

Inherited from Platform.SensingBehavior

Inherited from BasicActorBehavior

Inherited from Platform.BaseDeviceActor

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Ungrouped