Merged akka-utils and akka-java-utils into akka-core

akka-core/src/main/scala/util/Helpers.scala

@@ -0,0 +1,67 @@
+/**
+ * Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
+ */
+
+package se.scalablesolutions.akka.util
+
+import java.security.MessageDigest
+import java.util.concurrent.locks.ReentrantReadWriteLock
+
+class SystemFailure(cause: Throwable) extends RuntimeException(cause)
+
+/**
+ * @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
+ */
+object Helpers extends Logging {
+
+  implicit def null2Option[T](t: T): Option[T] = if (t != null) Some(t) else None
+
+  def intToBytes(value: Int): Array[Byte] = {
+    val bytes = new Array[Byte](4)
+    bytes(0) = (value >>> 24).asInstanceOf[Byte]
+    bytes(1) = (value >>> 16).asInstanceOf[Byte]
+    bytes(2) = (value >>> 8).asInstanceOf[Byte]
+    bytes(3) = value.asInstanceOf[Byte]
+    bytes
+  }
+
+  def getMD5For(s: String) = {
+    val digest = MessageDigest.getInstance("MD5")
+    digest.update(s.getBytes("ASCII"))
+    val bytes = digest.digest
+
+    val sb = new StringBuilder
+    val hex = "0123456789ABCDEF"
+    bytes.foreach(b => {
+      val n = b.asInstanceOf[Int]
+      sb.append(hex.charAt((n & 0xF) >> 4)).append(hex.charAt(n & 0xF))
+    })
+    sb.toString
+  }
+
+ // ================================================
+  class ReadWriteLock {
+    private val rwl = new ReentrantReadWriteLock
+    private val readLock = rwl.readLock
+    private val writeLock = rwl.writeLock
+
+    def withWriteLock[T](body: => T): T = {
+      writeLock.lock
+      try {
+        body
+      } finally {
+        writeLock.unlock
+      }
+    }
+
+    def withReadLock[T](body: => T): T = {
+      readLock.lock
+      try {
+        body
+      } finally {
+        readLock.unlock
+      }
+    }
+  }
+}
+