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
|
package com.github.jodersky.flow
import java.io.IOException
import scala.util.Failure
import scala.util.Success
import scala.util.Try
import com.github.jodersky.flow.internal.InternalSerial
import Serial.Open
import Serial.OpenFailed
import akka.actor.Actor
import akka.actor.ActorLogging
import akka.actor.OneForOneStrategy
import akka.actor.Props
import akka.actor.SupervisorStrategy.Escalate
import akka.actor.SupervisorStrategy.Stop
import akka.actor.actorRef2Scala
class SerialManager extends Actor with ActorLogging {
import SerialManager._
import context._
override val supervisorStrategy =
OneForOneStrategy() {
case _: IOException => Stop
case _: Exception => Escalate
}
def receive = {
case Open(handler, port, baud, cs, tsb, parity) => Try { InternalSerial.open(port, baud, cs, tsb, parity.id) } match {
case Failure(t) => {
log.debug(s"failed to open low serial port at ${port}, baud ${baud}, reason: " + t.getMessage())
handler ! OpenFailed(port, t)
}
case Success(serial) => {
log.debug(s"opened low-level serial port at ${port}, baud ${baud}")
context.actorOf(Props(classOf[SerialOperator], handler, serial), name = escapePortString(port))
}
}
}
}
object SerialManager {
private def escapePortString(port: String) = port collect {
case '/' => '-'
case c => c
}
}
|
