blob: 7549bbf429c7f9a4fe7c28adeda0a51b4e668e5f (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
/* __ *\
** ________ ___ / / ___ Scala API **
** / __/ __// _ | / / / _ | (c) 2005-2013, LAMP/EPFL **
** __\ \/ /__/ __ |/ /__/ __ | http://scala-lang.org/ **
** /____/\___/_/ |_/____/_/ | | **
** |/ **
\* */
package scala.actors
package remote
import java.io.{ByteArrayInputStream, ByteArrayOutputStream,
ObjectInputStream, ObjectOutputStream, InputStream,
ObjectStreamClass}
/**
* @author Guy Oliver
*/
private[remote] class CustomObjectInputStream(in: InputStream, cl: ClassLoader)
extends ObjectInputStream(in) {
override def resolveClass(cd: ObjectStreamClass): Class[_] =
try {
cl.loadClass(cd.getName())
} catch {
case cnf: ClassNotFoundException =>
super.resolveClass(cd)
}
override def resolveProxyClass(interfaces: Array[String]): Class[_] =
try {
val ifaces = interfaces map { iface => cl.loadClass(iface) }
java.lang.reflect.Proxy.getProxyClass(cl, ifaces: _*)
} catch {
case e: ClassNotFoundException =>
super.resolveProxyClass(interfaces)
}
}
/**
* @author Philipp Haller
*/
@deprecated("Use the akka.actor package instead. For migration from the scala.actors package refer to the Actors Migration Guide.", "2.11.0")
class JavaSerializer(serv: Service, cl: ClassLoader) extends Serializer(serv) {
def serialize(o: AnyRef): Array[Byte] = {
val bos = new ByteArrayOutputStream()
val out = new ObjectOutputStream(bos)
out.writeObject(o)
out.flush()
bos.toByteArray()
}
def deserialize(bytes: Array[Byte]): AnyRef = {
val bis = new ByteArrayInputStream(bytes)
// use custom stream only if cl != null
val in = if (cl != null)
new CustomObjectInputStream(bis, cl)
else
new ObjectInputStream(bis)
in.readObject()
}
}
|
