swapfile mutex via flock (6e94f548) · Commits · github_fork / Clip

fnordmetric-enterprise/src/FnordMetric.scala

+24 −3

Original line number	Diff line number	Diff line
		@@ -11,6 +11,9 @@ import java.util.Locale
		import java.util.Date
		import java.text.DateFormat
		import java.io.File
		import java.io.RandomAccessFile
		import java.nio.channels.FileChannel
		import java.nio.channels.FileLock
		import scala.collection.mutable.HashMap

		object FnordMetric {
		@@ -23,12 +26,15 @@ object FnordMetric {
		'http_threads -> "4",
		'websocket_threads -> "4",
		'tcp_threads -> "4",
		'udp_threads -> "4"
		'udp_threads -> "4",
		'swap_prefix -> "/tmp/fnordmetric"
		)

		var debug = false
		var verbose = false

		var flock : FileLock = null

		def main(args: Array[String]) : Unit = {
		var n = 0

		@@ -86,6 +92,13 @@ object FnordMetric {
		def boot = try {
		FnordMetric.log("Booting...")

		flock = new RandomAccessFile(
		new File(FnordMetric.CONFIG('swap_prefix), "server.lck"),
		"rw").getChannel.tryLock

		if (flock == null)
		error("cannot aquire server.lck", true)

		val tcp_server = if (CONFIG contains 'tcp_port)
		new TCPServer(
		CONFIG('tcp_port).toInt,
		@@ -136,7 +149,7 @@ object FnordMetric {
		log("[ERROR] " + msg)

		if (fatal)
		System.exit(1)
		exit(1)
		}


		@@ -152,7 +165,15 @@ object FnordMetric {
		log_debug(line.toString)

		if (fatal)
		System.exit(1)
		exit(1)
		}


		def exit(code: Int) = {
		if (flock != null)
		flock.release

		System.exit(code)
		}

		}

0 → 100644

+18 −0

Original line number	Diff line number	Diff line
		// FnordMetric Enterprise
		// (c) 2011-2013 Paul Asmuth <paul@paulasmuth.com>
		//
		// Licensed under the MIT License (the "License"); you may not use this
		// file except in compliance with the License. You may obtain a copy of
		// the License at: http://opensource.org/licenses/MIT

		package com.fnordmetric.enterprise

		import java.io.File

		class SwapFile() {

		val file = new File(FnordMetric.CONFIG('swap_prefix),
		"fnord.txt")

		}