in src/main/scala/com/twitter/iago/server/MemcacheTransport.scala [59:74]
private def set(args: Array[String], data: Option[String]): Option[Set] =
args match {
case a if a.length < 4 => None
case _ =>
val key = Buf.ByteArray.Owned(args(0).getBytes)
val flags = args(1).toInt
val expiry = Time.fromSeconds(args(2).toInt)
val byteCount = args(3).toInt
val bytes = data.getOrElse("").getBytes
if (bytes.length != byteCount) {
None
} else {
Some(Set(key, flags, expiry, Buf.ByteArray.Owned(bytes)))
}
}