raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Added comments and removed inverted logic

Browse source
This commit is contained in:
Viktor Klang 2010-09-09 14:27:48 +02:00
parent 81d9bff997
commit 51dfc02aa2
1 changed files with 7 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-actor/src/main/scala/actor/ActorRegistry.scala
View file

@ -164,10 +164,11 @@ class Index[K <: AnyRef,V <: AnyRef : Manifest] {
//Returns whether it needs to be retried or not
def tryPut(set: JSet[V], v: V): Boolean = {
set.synchronized {
if (!set.isEmpty) {
if (set.isEmpty) true //IF the set is empty then it has been removed, so signal retry
else { //Else add the value to the set and signal that retry is not needed
set add v
false
} else true
}
}
}
@ -214,13 +215,13 @@ class Index[K <: AnyRef,V <: AnyRef : Manifest] {
val set = container get key
if (set ne null) {
set.synchronized {
if (set.remove(value)) {
if (set.isEmpty)
container.remove(key,emptySet)
if (set.remove(value)) { //If we can remove the value
if (set.isEmpty) //and the set becomes empty
container.remove(key,emptySet) //We try to remove the key if it's mapped to an empty set
}
}
}
}
def clear = container.clear
def clear = { foreach(remove _) }
}