* Request properties: *
* See the {@link ChainSawHandler} for generating standard format * log files. * * @author Stephen Uhler * @version @(#)LogHandler.java 2.3 */ public class LogHandler implements Handler { public Handler handler; // the handler to log public String props; // a substitutable string for props public String headers; // a substitutable string for headers public String format; // substitute misc stuff public String title; // title the output file String handlerName; // the name of the handler public int flush; // log flush interval public File file; int count = 0; // count flushing interval DataOutputStream log; // where to log the output to public boolean init(Server server, String prefix) { props = server.props.getProperty(prefix + "props", ""); title = server.props.getProperty(prefix + "title"); headers = server.props.getProperty(prefix + "headers", ""); format = server.props.getProperty(prefix + "format", "%u;%t:%d:%b"); handlerName = server.props.getProperty(prefix + "handler"); handler=ChainHandler.initHandler(server, prefix, handlerName); String logFile = server.props.getProperty(prefix + "logFile", server.hostName + "-" + server.listen.getLocalPort() + ".log"); try { flush = Integer.parseInt( server.props.getProperty(prefix + "flush", "25")); } catch (NumberFormatException e) {} try { file = new File(logFile); log = new DataOutputStream(new BufferedOutputStream( new FileOutputStream(logFile, true))); if (title != null) { log.writeBytes(title + "\n"); } } catch (IOException e) { server.log(Server.LOG_WARNING, prefix, e.toString()); return false; } return (handler != null); } /** * Dispatch the request to the handler. Log information if * dispatched handler returns true. */ public boolean respond(Request request) throws IOException { if (!handler.respond(request)) { return false; } long duration = System.currentTimeMillis() - request.startMillis; String msg = subst(request, format, duration) + Format.subst(request.props, props) + Format.subst(request.headers, headers) + "\n"; /* * Write to the log file. If there's a problem, try to open * the file again. */ if (!file.exists()) { log.flush(); request.log(Server.LOG_WARNING, "Log file went away!"); log = new DataOutputStream(new BufferedOutputStream( new FileOutputStream(file))); if (title != null) { log.writeBytes(title + "\n"); } count = 0; } log.writeBytes(msg); request.log(Server.LOG_DIAGNOSTIC, msg); if (count++ >= flush) { log.flush(); count = 0; } return true; } /** * Compute built-in strings by mapping %n's to values */ static boolean format(Request request, char c, StringBuffer buff, long duration) { switch(c) { case 'u': // URL buff.append(request.url); break; case 't': // timestamp buff.append(request.startMillis); break; case 'd': // service time (ms) buff.append(duration); break; case 's': // result status buff.append(request.getStatus()); break; case 'b': // bytes written buff.append(request.out.bytesWritten); break; case 'i': // client ip address buff.append(request.getSocket().getInetAddress().getHostAddress()); break; case 'r': // socket reuse count buff.append(request.getReuseCount()); break; case 'T': // active threads buff.append(Thread.activeCount()); break; case 'M': // memory utilization long currentMem = Runtime.getRuntime().freeMemory(); long totalMem = Runtime.getRuntime().totalMemory(); buff.append(currentMem * 100 /totalMem); break; case 'm': // method buff.append(request.method); break; case 'q': // query string buff.append(request.query); break; case 'v': // protocol version (10 or 11) buff.append(request.version); break; case '%': // insert a % buff.append("%"); break; default: return false; } return true; } /** * Format a string. * Replace %X constructs. */ public static String subst(Request request, String format, long duration) { int i = format.indexOf('%'); if (i < 0) { return format; } int len = format.length(); StringBuffer result = new StringBuffer(format.substring(0, i)); for ( ; i < len; i++) { try { char ch = format.charAt(i); if (ch == '%') { i++; format(request, format.charAt(i), result, duration); } else { result.append(ch); } } catch (IndexOutOfBoundsException e) { /* Ignore malformed "%" sequences */ } catch (NullPointerException e) { /* Ignore non-existent properties or array */ } } return result.toString(); } }