in src/main/scala/com/twitter/iago/server/MemcacheLikeTransport.scala [56:76]
override def sendRequest(request: ParrotRequest): Future[Rep] = {
val command = request.rawLine match {
case commandExtractor(command) => command
case _ =>
throw new IllegalArgumentException("could not parse command {%s}".format(request.rawLine))
}
log.debug("sending request: %s", command)
try {
val result = service(command)
val response = request.response.asInstanceOf[Promise[Rep]]
result proxyTo response
result
} catch {
case e: Throwable =>
log.error(e, "error executing request %s", command)
throw e
}
}