diff options
Diffstat (limited to 'kamon-system/src/main/scala/kamon/system')
24 files changed, 140 insertions, 0 deletions
diff --git a/kamon-system/src/main/scala/kamon/system/System.scala b/kamon-system/src/main/scala/kamon/system/System.scala new file mode 100644 index 00000000..a6c468ef --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/System.scala @@ -0,0 +1,36 @@ +/* + * ========================================================================================= + * Copyright © 2013-2014 the kamon project <http://kamon.io/> + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file + * except in compliance with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the + * License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, + * either express or implied. See the License for the specific language governing permissions + * and limitations under the License. + * ========================================================================================= + */ + +package kamon.system + +import akka.actor.{ ExtendedActorSystem, Extension, ExtensionIdProvider, ExtensionId } +import kamon.Kamon +import akka.event.Logging + +object System extends ExtensionId[SystemExtension] with ExtensionIdProvider { + override def lookup(): ExtensionId[_ <: Extension] = System + override def createExtension(system: ExtendedActorSystem): SystemExtension = new SystemExtension(system) +} + +class SystemExtension(private val system: ExtendedActorSystem) extends Kamon.Extension { + val log = Logging(system, classOf[SystemExtension]) + log.info("Starting the Kamon(System) extension") + + private val config = system.settings.config.getConfig("kamon.system") + + val defaultDispatcher = system.dispatchers.lookup(config.getString("dispatcher")) +} + diff --git a/kamon-system/src/main/scala/kamon/system/native/SigarLoader.scala b/kamon-system/src/main/scala/kamon/system/native/SigarLoader.scala new file mode 100644 index 00000000..511a8ffc --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/SigarLoader.scala @@ -0,0 +1,82 @@ +package kamon.system.native + +import org.hyperic.sigar.Sigar +import org.hyperic.sigar.SigarProxy +import java.io._ +import scalax.io.JavaConverters._ +import scalax.io._ + +import Resource._ + +import scalax.file.Path +import java.util +import scala.collection.JavaConversions._ + +object SigarLoader { + val Version = "1.6.4" + val JavaLibraryPath = "java.library.path" + val TmpDir = "java.io.tmpdir" + val IndexFile = "/kamon/system/native/index" + val UsrPathField = "usr_paths" + + def init: SigarProxy = init(new File(System.getProperty(TmpDir))) + + private def init(baseTmp: File): SigarProxy = { + val tmpDir = createTmpDir(baseTmp) + for (lib ← loadIndex) copy(lib, tmpDir) + + attachToLibraryPath(tmpDir) + + try { + val sigar = new Sigar + sigar.getPid + sigar + } catch { + case t: Throwable ⇒ + throw new RuntimeException("Failed to load sigar", t) + } + } + + private val usrPathField = { + val usrPathField = classOf[ClassLoader].getDeclaredField(UsrPathField) + usrPathField.setAccessible(true) + usrPathField + } + + private def attachToLibraryPath(dir: File): Unit = { + val dirAbsolute = dir.getAbsolutePath + System.setProperty(JavaLibraryPath, newLibraryPath(dirAbsolute)) + var paths = usrPathField.get(null).asInstanceOf[Array[String]] + if (paths == null) paths = new Array[String](0) + for (path ← paths) if (path == dirAbsolute) return + val newPaths = util.Arrays.copyOf(paths, paths.length + 1) + newPaths(newPaths.length - 1) = dirAbsolute + usrPathField.set(null, newPaths) + } + + private def newLibraryPath(dirAbsolutePath: String): String = { + Option(System.getProperty(JavaLibraryPath)).fold(dirAbsolutePath)(oldValue ⇒ s"$dirAbsolutePath${File.pathSeparator}$oldValue") + } + + private def copy(lib: String, tmpDir: File) { + val dest: Path = Path(new File(tmpDir, lib)) + if (dest.exists) return + val currentFile = Resource.fromInputStream(classOf[Loader].getResourceAsStream("" + lib)) + currentFile.acquireFor(current ⇒ dest.doCopyFrom(current.asInput)) + } + + private def createTmpDir(baseTmp: File): File = { + val path = Path(new File(baseTmp, s"sigar-$Version")) + path.createDirectory(failIfExists = false) + path.jfile + } + + private def loadIndex: util.List[String] = { + val libs = new util.ArrayList[String] + val input = fromInputStream(classOf[Loader].getResourceAsStream(IndexFile)) + input.lines().foreach(libs.add) + libs + } +} + +class Loader
\ No newline at end of file diff --git a/kamon-system/src/main/scala/kamon/system/native/index b/kamon-system/src/main/scala/kamon/system/native/index new file mode 100644 index 00000000..ebc7f952 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/index @@ -0,0 +1,22 @@ +libsigar-amd64-freebsd-6.so +libsigar-amd64-linux.so +libsigar-amd64-solaris.so +libsigar-ia64-hpux-11.sl +libsigar-ia64-linux.so +libsigar-pa-hpux-11.sl +libsigar-ppc64-aix-5.so +libsigar-ppc64-linux.so +libsigar-ppc-aix-5.so +libsigar-ppc-linux.so +libsigar-s390x-linux.so +libsigar-sparc64-solaris.so +libsigar-sparc-solaris.so +libsigar-universal64-macosx.dylib +libsigar-universal-macosx.dylib +libsigar-x86-freebsd-5.so +libsigar-x86-freebsd-6.so +libsigar-x86-linux.so +libsigar-x86-solaris.so +sigar-amd64-winnt.dll +sigar-x86-winnt.dll + diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-freebsd-6.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-freebsd-6.so Binary files differnew file mode 100644 index 00000000..3e94f0d2 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-freebsd-6.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-linux.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-linux.so Binary files differnew file mode 100644 index 00000000..5a2e4c24 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-linux.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-solaris.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-solaris.so Binary files differnew file mode 100644 index 00000000..6396482a --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-amd64-solaris.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-ia64-hpux-11.sl b/kamon-system/src/main/scala/kamon/system/native/libsigar-ia64-hpux-11.sl Binary files differnew file mode 100644 index 00000000..d92ea4a9 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-ia64-hpux-11.sl diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-ia64-linux.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-ia64-linux.so Binary files differnew file mode 100644 index 00000000..2bd2fc8e --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-ia64-linux.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-pa-hpux-11.sl b/kamon-system/src/main/scala/kamon/system/native/libsigar-pa-hpux-11.sl Binary files differnew file mode 100644 index 00000000..0dfd8a11 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-pa-hpux-11.sl diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc-aix-5.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc-aix-5.so Binary files differnew file mode 100644 index 00000000..7d4b5199 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc-aix-5.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc-linux.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc-linux.so Binary files differnew file mode 100644 index 00000000..4394b1b0 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc-linux.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc64-aix-5.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc64-aix-5.so Binary files differnew file mode 100644 index 00000000..35fd8288 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc64-aix-5.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc64-linux.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc64-linux.so Binary files differnew file mode 100644 index 00000000..a1ba2529 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-ppc64-linux.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-s390x-linux.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-s390x-linux.so Binary files differnew file mode 100644 index 00000000..c275f4ac --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-s390x-linux.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-sparc-solaris.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-sparc-solaris.so Binary files differnew file mode 100644 index 00000000..aa847d2b --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-sparc-solaris.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-sparc64-solaris.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-sparc64-solaris.so Binary files differnew file mode 100644 index 00000000..6c4fe809 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-sparc64-solaris.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-universal-macosx.dylib b/kamon-system/src/main/scala/kamon/system/native/libsigar-universal-macosx.dylib Binary files differnew file mode 100644 index 00000000..27ab1071 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-universal-macosx.dylib diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-universal64-macosx.dylib b/kamon-system/src/main/scala/kamon/system/native/libsigar-universal64-macosx.dylib Binary files differnew file mode 100644 index 00000000..0c721fec --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-universal64-macosx.dylib diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-freebsd-5.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-freebsd-5.so Binary files differnew file mode 100644 index 00000000..8c50c611 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-freebsd-5.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-freebsd-6.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-freebsd-6.so Binary files differnew file mode 100644 index 00000000..f0800274 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-freebsd-6.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-linux.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-linux.so Binary files differnew file mode 100644 index 00000000..a0b64edd --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-linux.so diff --git a/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-solaris.so b/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-solaris.so Binary files differnew file mode 100644 index 00000000..c6452e56 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/libsigar-x86-solaris.so diff --git a/kamon-system/src/main/scala/kamon/system/native/sigar-amd64-winnt.dll b/kamon-system/src/main/scala/kamon/system/native/sigar-amd64-winnt.dll Binary files differnew file mode 100644 index 00000000..1ec8a035 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/sigar-amd64-winnt.dll diff --git a/kamon-system/src/main/scala/kamon/system/native/sigar-x86-winnt.dll b/kamon-system/src/main/scala/kamon/system/native/sigar-x86-winnt.dll Binary files differnew file mode 100644 index 00000000..6afdc016 --- /dev/null +++ b/kamon-system/src/main/scala/kamon/system/native/sigar-x86-winnt.dll |