001: /*
002: * $Id: StatManager.java,v 1.3 2002/02/24 02:10:19 skavish Exp $
003: *
004: * ==========================================================================
005: *
006: * The JGenerator Software License, Version 1.0
007: *
008: * Copyright (c) 2000 Dmitry Skavish (skavish@usa.net). All rights reserved.
009: *
010: * Redistribution and use in source and binary forms, with or without
011: * modification, are permitted provided that the following conditions are met:
012: *
013: * 1. Redistributions of source code must retain the above copyright
014: * notice, this list of conditions and the following disclaimer.
015: *
016: * 2. Redistributions in binary form must reproduce the above copyright
017: * notice, this list of conditions and the following disclaimer in
018: * the documentation and/or other materials provided with the
019: * distribution.
020: *
021: * 3. The end-user documentation included with the redistribution, if
022: * any, must include the following acknowlegement:
023: * "This product includes software developed by Dmitry Skavish
024: * (skavish@usa.net, http://www.flashgap.com/)."
025: * Alternately, this acknowlegement may appear in the software itself,
026: * if and wherever such third-party acknowlegements normally appear.
027: *
028: * 4. The name "The JGenerator" must not be used to endorse or promote
029: * products derived from this software without prior written permission.
030: * For written permission, please contact skavish@usa.net.
031: *
032: * 5. Products derived from this software may not be called "The JGenerator"
033: * nor may "The JGenerator" appear in their names without prior written
034: * permission of Dmitry Skavish.
035: *
036: * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
037: * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
038: * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
039: * DISCLAIMED. IN NO EVENT SHALL DMITRY SKAVISH OR THE OTHER
040: * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
041: * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
042: * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
043: * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
044: * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
045: * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
046: * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
047: * SUCH DAMAGE.
048: *
049: */
050:
051: package org.openlaszlo.iv.flash.servlet;
052:
053: import java.io.*;
054: import java.net.*;
055: import java.util.*;
056:
057: import javax.servlet.*;
058: import javax.servlet.http.*;
059:
060: import org.openlaszlo.iv.flash.util.*;
061: import org.openlaszlo.iv.flash.cache.*;
062:
063: /**
064: * Generator servlet statistic
065: */
066: public class StatManager {
067:
068: static class StatDaemon extends Thread {
069: public StatDaemon() {
070: }
071:
072: public void run() {
073: for (;;) {
074: Date date = new Date(System.currentTimeMillis());
075: int day = date.getDay();
076: try {
077: Thread.sleep(1000 * 60); // sleep for 1 minute
078: } catch (InterruptedException e) {
079: continue;
080: }
081: long now = System.currentTimeMillis();
082: today.setEndTime(now);
083: save();
084: date = new Date(now);
085: if (day != date.getDay()) {
086: synchronized (StatManager.class) {
087: today = new StatUnit(now);
088: statistic.addElement(today);
089: }
090: }
091: }
092: }
093: }
094:
095: private static String statFileName;
096: private static StatUnit sinceStartup;
097: private static StatUnit today;
098: private static Vector statistic;
099: private static StatDaemon statDaemon;
100:
101: private static void save() {
102: try {
103: FileOutputStream out = new FileOutputStream(statFileName);
104: ObjectOutputStream p = new ObjectOutputStream(out);
105: p.writeObject(statistic);
106: p.flush();
107: out.close();
108: } catch (IOException e) {
109: Log.logRB(e);
110: }
111: }
112:
113: private synchronized static void load() {
114: try {
115: FileInputStream in = new FileInputStream(statFileName);
116: ObjectInputStream p = new ObjectInputStream(in);
117: statistic = (Vector) p.readObject();
118: p.close();
119: in.close();
120: } catch (FileNotFoundException e) {
121: statistic = new Vector();
122: } catch (Exception e) {
123: Log.logRB(e);
124: statistic = new Vector();
125: }
126: // find today's stat
127: today = null;
128: Date date = new Date(System.currentTimeMillis());
129: int tday = date.getDay();
130: for (int i = 0; i < statistic.size(); i++) {
131: StatUnit unit = (StatUnit) statistic.elementAt(i);
132: date = new Date(unit.getStartTime());
133: if (tday == date.getDay()) {
134: today = unit;
135: break;
136: }
137: }
138: if (today == null) {
139: today = new StatUnit(System.currentTimeMillis());
140: statistic.addElement(today);
141: }
142: }
143:
144: public static void init() {
145: sinceStartup = new StatUnit(System.currentTimeMillis());
146: statFileName = PropertyManager.getProperty(
147: "org.openlaszlo.iv.flash.statFileName", "logs/stat");
148: if (statFileName != null) {
149: File statFile = Util.getSysFile(statFileName);
150: statFileName = statFile.getAbsolutePath();
151: }
152: load();
153: statDaemon = new StatDaemon();
154: statDaemon.start();
155: }
156:
157: public static StatUnit getSinceStartup() {
158: return sinceStartup;
159: }
160:
161: public static Vector getStatistic() {
162: return statistic;
163: }
164:
165: /**
166: * Add statistic for the given request
167: */
168: public static void addRequest(String fileName, int size,
169: long processTime, long totalTime) {
170: sinceStartup.addRequest(fileName, size, processTime, totalTime);
171: today.addRequest(fileName, size, processTime, totalTime);
172: }
173: }
|