trait ProtocolUtils extends AnyRef
Provides basic functionality to the protocol that implements this trait.
The concrete protocol must provide an implementation for
process
, system
, and ProtocolUtils#dispatcher
.
It provides the ability to connect and the following fields:
me
is the identifier of the current process.N
is the total number of processes in the system.ALL
is the set of identifiers for all processes in the system (includingme
).neighbors
is the set of identifiers of all neighbor processes.
- Self Type
- ProtocolImpl
- Alphabetic
- By Inheritance
- ProtocolUtils
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from ProtocolUtils to any2stringadd[ProtocolUtils] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
-->(sender: Sender): Unit
Connects a new sender to this protocol.
Connects a new sender to this protocol.
- sender
the new sender to connect.
-
def
->[B](y: B): (ProtocolUtils, B)
- Implicit
- This member is added by an implicit conversion from ProtocolUtils to ArrowAssoc[ProtocolUtils] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
lazy val
ALL: Set[PID]
set of all processes in the system.
set of all processes in the system.
- Attributes
- protected[this]
-
lazy val
N: Int
total number of processes running in the system.
total number of processes running in the system.
- Attributes
- protected[this]
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
-
def
ensuring(cond: (ProtocolUtils) ⇒ Boolean, msg: ⇒ Any): ProtocolUtils
- Implicit
- This member is added by an implicit conversion from ProtocolUtils to Ensuring[ProtocolUtils] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (ProtocolUtils) ⇒ Boolean): ProtocolUtils
- Implicit
- This member is added by an implicit conversion from ProtocolUtils to Ensuring[ProtocolUtils] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): ProtocolUtils
- Implicit
- This member is added by an implicit conversion from ProtocolUtils to Ensuring[ProtocolUtils] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): ProtocolUtils
- Implicit
- This member is added by an implicit conversion from ProtocolUtils to Ensuring[ProtocolUtils] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from ProtocolUtils to StringFormat[ProtocolUtils] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
lazy val
me: PID
identifier of the process in which the protocol is running.
identifier of the process in which the protocol is running.
- Attributes
- protected[this]
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
lazy val
neighbors: Set[PID]
set of processes that are direct neighbors to the process in which this instance of the protocol runs.
set of processes that are direct neighbors to the process in which this instance of the protocol runs.
- Attributes
- protected[this]
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
receiver: Receiver
receiver to which this protocol delivers messages.
receiver to which this protocol delivers messages. Typically, this is the message dispatcher of the process.
- returns
receiver to which messages are delivered
-
def
receiver_=(receiver: Receiver): Unit
sets a new receiver to which this protocol will deliver messages.
sets a new receiver to which this protocol will deliver messages. Normally, there is no need for the application programmer to use this, as the receiver is automatically set to a meaningful default value.
- receiver
new receiver to which messages will be delivered
-
def
sender: Sender
target sender that will handle Sending#send operations for this protocol.
target sender that will handle Sending#send operations for this protocol.
- returns
target sender
- def senderOpt: Option[Sender]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
→[B](y: B): (ProtocolUtils, B)
- Implicit
- This member is added by an implicit conversion from ProtocolUtils to ArrowAssoc[ProtocolUtils] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc