various fixes, bump to 0.05

organization := "com.paulasmuth"

version := "0.0.3"

version := "0.0.5"

mainClass in (Compile, run) := Some("com.fnordmetric.enterprise.FnordMetric")

object FnordMetric {

  val VERSION = "v0.0.3"

  val VERSION = "v0.0.5"

  val CONFIG  = HashMap[Symbol,String]()

  // adds a new (time, value) tuple to be written to the swap file

  // but does not write it yet. this method is not thread safe!

  def put(time: Long, value: Double) : Unit = {

  def put(time: Long, value: Double) : Unit = this.synchronized {

    val bvalue = java.lang.Double.doubleToLongBits(value)

    if (buffer.remaining < BLOCK_SIZE)

  // fluhes the queued writes from the buffer to disk. this method

  // is not thread safe!

  def flush : Unit = {

  def flush : Unit = this.synchronized {

    last_flush = FnordMetric.now

    if (buffer.position < BLOCK_SIZE)

      return

    file.synchronized {

      file.seek(write_pos)

      file.write(buffer.array, 0, buffer.position)

      // we need to seek before every read as calls to load_chunk don't

      // have to be synchronized with writes

      file.synchronized {

      val nxt_read = file.synchronized {

        file.seek(position - chunk_size)

        read_pos += file.read(chunk.array, read_pos,

        file.read(chunk.array, read_pos,

          chunk_size - read_pos - 1)

      }

      if (nxt_read >= 0)

        read_pos += nxt_read

      else

        // this should never happen

        FnordMetric.error("end of file reached while reading " + file_name, false)

    }

    read_pos = chunk_size - BLOCK_SIZE

  }

  override def exceptionCaught(ctx: ChannelHandlerContext, e: ExceptionEvent) {

    FnordMetric.error("[TCP] Exception: " + e.getCause, false)

    FnordMetric.exception(e.getCause, false)

    e.getChannel.close()

  }

  val buffer = new Array[Byte](buffer_size)

  val packet = new DatagramPacket(buffer, buffer_size)

  FnordMetric.log("Listening on tcp://0.0.0.0:" + port)

  FnordMetric.log("Listening on udp://0.0.0.0:" + port)

  while (true) {

    sock.receive(packet)