liblttng-ust-jul/org/lttng/ust/jul/LTTngAgent.java

   1 /*
   2  * Copyright (C) 2013 - David Goulet <dgoulet@efficios.com>
   3  *
   4  * This library is free software; you can redistribute it and/or modify it
   5  * under the terms of the GNU Lesser General Public License, version 2.1 only,
   6  * as published by the Free Software Foundation.
   7  *
   8  * This library is distributed in the hope that it will be useful, but WITHOUT
   9  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  10  * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License
  11  * for more details.
  12  *
  13  * You should have received a copy of the GNU Lesser General Public License
  14  * along with this library; if not, write to the Free Software Foundation,
  15  * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  16  */
  17
  18 package org.lttng.ust.jul;
  19
  20 import java.io.IOException;
  21 import java.io.InputStream;
  22 import java.io.BufferedReader;
  23 import java.io.FileReader;
  24 import java.util.concurrent.Semaphore;
  25 import java.util.concurrent.TimeUnit;
  26 import java.util.logging.FileHandler;
  27 import java.util.logging.Handler;
  28 import java.util.logging.Level;
  29 import java.util.logging.Logger;
  30 import java.util.logging.LogManager;
  31 import java.util.Enumeration;
  32
  33 public class LTTngAgent {
  34         private static LogManager logManager;
  35
  36         /* Possible that we have to threads handling two sessiond. */
  37         private static LTTngLogHandler lttngHandlerRoot;
  38         private static LTTngLogHandler lttngHandlerUser;
  39         private static LTTngThread lttngThreadRoot;
  40         private static LTTngThread lttngThreadUser;
  41         private static Thread sessiondThRoot;
  42         private static Thread sessiondThUser;
  43
  44         /* Singleton agent object. */
  45         private static LTTngAgent curAgent = null;
  46
  47         /* Indicate if this object has been initialized. */
  48         private static boolean initialized = false;
  49
  50         private static Semaphore registerSem;
  51         private final static int semTimeout = 3; /* Seconds */
  52
  53         /*
  54          * Default value to connect to session daemon. Port number is dynamically
  55          * fetched from the port file that is created by a running session daemon.
  56          */
  57         private static final String sessiondAddr = "127.0.0.1";
  58
  59         /*
  60          * Constructor is private. This is a singleton and a reference should be
  61          * acquired using getLTTngAgent().
  62          */
  63         private LTTngAgent() throws IOException {
  64                 this.logManager = LogManager.getLogManager();
  65                 this.lttngHandlerUser = new LTTngLogHandler(this.logManager);
  66                 this.lttngHandlerRoot = new LTTngLogHandler(this.logManager);
  67                 this.lttngHandlerRoot.is_root = 1;
  68                 this.registerSem = new Semaphore(0, true);
  69         }
  70
  71         private void removeHandlers() throws SecurityException, IOException {
  72                 String loggerName;
  73                 Logger logger;
  74
  75                 Enumeration list = this.logManager.getLoggerNames();
  76                 while (list.hasMoreElements()) {
  77                         loggerName = list.nextElement().toString();
  78                         /* Somehow there is always an empty string at the end. */
  79                         if (loggerName == "") {
  80                                 continue;
  81                         }
  82
  83                         logger = this.logManager.getLogger(loggerName);
  84                         logger.removeHandler(this.lttngHandlerUser);
  85                         logger.removeHandler(this.lttngHandlerRoot);
  86                 }
  87         }
  88
  89         private int getUID() throws IOException {
  90                 int uid;
  91                 byte b[] = new byte[4];
  92                 String userName = System.getProperty("user.name");
  93                 String command = "id -u " + userName;
  94                 Process child = Runtime.getRuntime().exec(command);
  95                 InputStream in = child.getInputStream();
  96
  97                 in.read(b);
  98                 uid = Integer.parseInt(new String(b).trim(), 10);
  99                 in.close();
 100
 101                 return uid;
 102         }
 103
 104         /*
 105          * Public getter to acquire a reference to this singleton object.
 106          */
 107         public static synchronized LTTngAgent getLTTngAgent() throws IOException {
 108                 if (curAgent == null) {
 109                         curAgent = new LTTngAgent();
 110                         curAgent.init();
 111                 }
 112
 113                 return curAgent;
 114         }
 115
 116         /*
 117          * Initialize LTTngAgent. This will attach the log handler to all Logger
 118          * returned by the logManager.
 119          */
 120         private synchronized void init() throws SecurityException, IOException {
 121                 int nr_acquires = 0;
 122
 123                 if (this.initialized) {
 124                         return;
 125                 }
 126
 127                 /* Handle user session daemon if any. */
 128                 this.lttngThreadUser = new LTTngThread(this.sessiondAddr,
 129                                 this.lttngHandlerUser, this.registerSem);
 130                 this.sessiondThUser = new Thread(lttngThreadUser);
 131                 this.sessiondThUser.start();
 132                 /* Wait for registration done of per-user sessiond */
 133                 nr_acquires++;
 134
 135                 /* Handle root session daemon. */
 136                 this.lttngThreadRoot = new LTTngThread(this.sessiondAddr,
 137                                 this.lttngHandlerRoot, this.registerSem);
 138                 this.sessiondThRoot = new Thread(lttngThreadRoot);
 139                 this.sessiondThRoot.start();
 140                 /* Wait for registration done of system-wide sessiond */
 141                 nr_acquires++;
 142
 143                 /* Wait for each registration to end. */
 144                 try {
 145                         this.registerSem.tryAcquire(nr_acquires, semTimeout,
 146                                         TimeUnit.SECONDS);
 147                 } catch (InterruptedException e) {
 148                         e.printStackTrace();
 149                 }
 150
 151                 this.initialized = true;
 152         }
 153
 154         public void dispose() throws IOException {
 155                 this.lttngThreadUser.dispose();
 156                 if (this.lttngThreadRoot != null) {
 157                         this.lttngThreadRoot.dispose();
 158                 }
 159
 160                 /* Make sure there is no more LTTng handler attach to logger(s). */
 161                 this.removeHandlers();
 162
 163                 try {
 164                         this.sessiondThUser.join();
 165                         if (this.sessiondThRoot != null) {
 166                                 this.sessiondThRoot.join();
 167                         }
 168                 } catch (InterruptedException e) {
 169                         e.printStackTrace();
 170                 }
 171         }
 172 }