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

minor reformatting

Browse source
This commit is contained in:
Jonas Boner 2009-03-12 21:18:53 +01:00
parent 4a798881e6
commit e048d92d09
1 changed files with 12 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

17
kernel/src/main/scala/ActiveObject.scala
View file

@ -90,12 +90,16 @@ class ActiveObjectProxy(val intf: Class[_], val target: Class[_], val timeout: I
private[akka] val server = new GenericServerContainer(target.getName, () => dispatcher) private[akka] val server = new GenericServerContainer(target.getName, () => dispatcher)
server.setTimeout(timeout) server.setTimeout(timeout)
def invoke(proxy: AnyRef, m: Method, args: Array[AnyRef]): AnyRef = invoke(Invocation(m, args, targetInstance)) def invoke(proxy: AnyRef, m: Method, args: Array[AnyRef]): AnyRef =
invoke(Invocation(m, args, targetInstance))
def invoke(invocation: Invocation): AnyRef = { def invoke(invocation: Invocation): AnyRef = {
if (invocation.method.isAnnotationPresent(oneway)) server ! invocation if (invocation.method.isAnnotationPresent(oneway)) server ! invocation
else { else {
val result: ErrRef[AnyRef] = server !!! (invocation, ErrRef({ throw new ActiveObjectInvocationTimeoutException("proxy invocation timed out after " + timeout + " milliseconds") })) val result: ErrRef[AnyRef] = server !!! (invocation, ErrRef({
throw new ActiveObjectInvocationTimeoutException(
"proxy invocation timed out after " + timeout + " milliseconds")
}))
result() result()
} }
} }
@ -107,11 +111,12 @@ class ActiveObjectProxy(val intf: Class[_], val target: Class[_], val timeout: I
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a> * @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
*/ */
case class Invocation(val method: Method, val args: Array[Object], val target: AnyRef) { case class Invocation(val method: Method, val args: Array[Object], val target: AnyRef) {
method.setAccessible(true); method.setAccessible(true)
def invoke: AnyRef = method.invoke(target, args:_*) def invoke: AnyRef = method.invoke(target, args:_*)
override def toString: String = "Invocation [method: " + method.getName + ", args: " + argsToString(args) + ", target: " + target + "]" override def toString: String =
"Invocation [method: " + method.getName + ", args: " + argsToString(args) + ", target: " + target + "]"
override def hashCode(): Int = { override def hashCode(): Int = {
var result = HashCode.SEED var result = HashCode.SEED
@ -136,5 +141,7 @@ case class Invocation(val method: Method, val args: Array[Object], val target: A
a1.size == a2.size && a1.size == a2.size &&
a1.zip(a2).find(t => t._1 == t._2).isDefined) a1.zip(a2).find(t => t._1 == t._2).isDefined)
private def argsToString(array: Array[Object]): String = synchronized { array.foldLeft("(")(_ + " " + _) + ")" } private def argsToString(array: Array[Object]): String = synchronized {
array.foldLeft("(")(_ + " " + _) + ")"
}
} }