class CorpseRemovalActor extends RemoverActor
- Source
- CorpseRemovalActor.scala
- Alphabetic
- By Inheritance
- CorpseRemovalActor
- RemoverActor
- SupportActor
- Actor
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new CorpseRemovalActor()
Type Members
- type Receive = PartialFunction[Any, Unit]
- Definition Classes
- Actor
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def ClearAll(): Unit
No entries in the first pool.
No entries in the first pool.
- Definition Classes
- RemoverActor → SupportActor
- def ClearSpecific(targets: List[PlanetSideGameObject], zone: Zone): Unit
Remove specific entries from the first pool.
Remove specific entries from the first pool.
- Definition Classes
- RemoverActor → SupportActor
- def ClearanceTest(entry: Entry): Boolean
Performed to determine when an entry can be shifted off from the second list.
Performed to determine when an entry can be shifted off from the second list. Override.
- entry
the entry
- Definition Classes
- CorpseRemovalActor → RemoverActor
- def DeletionTask(entry: Entry): TaskBundle
The specific action that is necessary to complete the removal process.
The specific action that is necessary to complete the removal process. Override.
- entry
the entry
- Definition Classes
- CorpseRemovalActor → RemoverActor
- See also
GUIDTask
- def FinalTask(entry: Entry): TaskBundle
- Definition Classes
- RemoverActor
- def FirstJob(entry: Entry): Unit
Performed when the entry is shifted from the first list to the second list.
Performed when the entry is shifted from the first list to the second list. Override.
- entry
the entry
- Definition Classes
- CorpseRemovalActor → RemoverActor
- final val FirstStandardDuration: FiniteDuration
Default time for entries waiting in the first list.
Default time for entries waiting in the first list. Override.
- returns
the time as a
FiniteDurationobject (to be later transformed into nanoseconds)
- Definition Classes
- CorpseRemovalActor → RemoverActor
- def HurryAll(): Unit
Expedite all entries from the first pool into the second.
Expedite all entries from the first pool into the second.
- Definition Classes
- RemoverActor → SupportActor
- def HurrySpecific(targets: List[PlanetSideGameObject], zone: Zone): Unit
Expedite some entries from the first pool into the second.
Expedite some entries from the first pool into the second.
- targets
a list of objects to pick
- zone
the zone in which these objects must be discovered; all targets must be in this zone, with the assumption that this is the zone where they were registered
- Definition Classes
- RemoverActor → SupportActor
- def InclusionTest(entry: Entry): Boolean
Determine whether or not the resulting entry is valid for this process.
Determine whether or not the resulting entry is valid for this process. The primary purpose of this function should be to determine if the appropriate type of object is being submitted. Override.
- entry
the entry
- returns
true, if it can be processed;false, otherwise
- Definition Classes
- CorpseRemovalActor → SupportActor
- def InitialJob(entry: Entry): Unit
Performed when the entry is initially added to the first list.
Performed when the entry is initially added to the first list. Override.
- entry
the entry
- Definition Classes
- CorpseRemovalActor → RemoverActor
- def PartitionTargetsFromList(list: List[Entry], targets: List[Entry], zone: Zone, comparator: SimilarityComparator[Entry] = sameEntryComparator): (List[Entry], List[Entry])
- Definition Classes
- SupportActor
- def RetimeFirstTask(now: Long = System.nanoTime): Unit
Common function to reset the first task's delayed execution.
Common function to reset the first task's delayed execution. Cancels the scheduled timer and will only restart the timer if there is at least one entry in the first pool.
- now
the time (in nanoseconds); defaults to the current time (in nanoseconds)
- Definition Classes
- RemoverActor
- def SecondJob(entry: Entry): Unit
- Definition Classes
- RemoverActor
- final val SecondStandardDuration: FiniteDuration
Default time for entries waiting in the second list.
Default time for entries waiting in the second list. Override.
- returns
the time as a
FiniteDurationobject (to be later transformed into nanoseconds)
- Definition Classes
- CorpseRemovalActor → RemoverActor
- def aroundPostRestart(reason: Throwable): Unit
- Attributes
- protected[akka]
- Definition Classes
- Actor
- Annotations
- @InternalApi()
- def aroundPostStop(): Unit
- Attributes
- protected[akka]
- Definition Classes
- Actor
- Annotations
- @InternalApi()
- def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit
- Attributes
- protected[akka]
- Definition Classes
- Actor
- Annotations
- @InternalApi()
- def aroundPreStart(): Unit
- Attributes
- protected[akka]
- Definition Classes
- Actor
- Annotations
- @InternalApi()
- def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit
- Attributes
- protected[akka]
- Definition Classes
- Actor
- Annotations
- @InternalApi()
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- implicit val context: ActorContext
- Definition Classes
- Actor
- def debug(msg: String): Unit
- Definition Classes
- SupportActor
- def entryManagementBehaviors: Receive
- Definition Classes
- SupportActor
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- var firstHeap: List[Entry]
The first pool of objects waiting to be processed for removal.
The first pool of objects waiting to be processed for removal.
- Definition Classes
- RemoverActor
- var firstTask: Cancellable
The timer that checks whether entries in the first pool are still eligible for that pool.
The timer that checks whether entries in the first pool are still eligible for that pool.
- Definition Classes
- RemoverActor
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def info(msg: String): Unit
- Definition Classes
- SupportActor
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def postRestart(reason: Throwable): Unit
- Definition Classes
- Actor
- Annotations
- @throws(classOf[java.lang.Exception])
- def postStop(): Unit
Sufficiently clean up the current contents of these waiting removal jobs.
Sufficiently clean up the current contents of these waiting removal jobs. Cancel all timers, rush all entries in the lists through their individual steps, then empty the lists. This is an improved
HurryAll, but still faster since it also railroads entries through the second queue as well.- Definition Classes
- RemoverActor → Actor
- def preRestart(reason: Throwable, message: Option[Any]): Unit
- Definition Classes
- Actor
- Annotations
- @throws(classOf[java.lang.Exception])
- def preStart(): Unit
- Definition Classes
- Actor
- Annotations
- @throws(classOf[java.lang.Exception])
- def receive: Receive
- Definition Classes
- RemoverActor → Actor
- val sameEntryComparator: SimilarityComparator[Entry]
- Definition Classes
- RemoverActor → SupportActor
- var secondHeap: List[Entry]
The second pool of objects waiting to be processed for removal.
The second pool of objects waiting to be processed for removal.
- Definition Classes
- RemoverActor
- var secondTask: Cancellable
The timer that checks whether entries in the second pool are still eligible for that pool.
The timer that checks whether entries in the second pool are still eligible for that pool.
- Definition Classes
- RemoverActor
- implicit final val self: ActorRef
- Definition Classes
- Actor
- final def sender(): ActorRef
- Definition Classes
- Actor
- def supervisorStrategy: SupervisorStrategy
- Definition Classes
- Actor
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def trace(msg: String): Unit
- Definition Classes
- SupportActor
- def unhandled(message: Any): Unit
- Definition Classes
- Actor
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()