KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > coyote > RequestGroupInfo


1 /*
2  * Licensed to the Apache Software Foundation (ASF) under one or more
3  * contributor license agreements. See the NOTICE file distributed with
4  * this work for additional information regarding copyright ownership.
5  * The ASF licenses this file to You under the Apache License, Version 2.0
6  * (the "License"); you may not use this file except in compliance with
7  * the License. You may obtain a copy of the License at
8  *
9  * http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  */
17
18 package org.apache.coyote;
19
20 import java.util.ArrayList JavaDoc;
21
22 /** This can be moved to top level ( eventually with a better name ).
23  * It is currently used only as a JMX artifact, to agregate the data
24  * collected from each RequestProcessor thread.
25  */
26 public class RequestGroupInfo {
27     ArrayList JavaDoc processors=new ArrayList JavaDoc();
28     private long deadMaxTime = 0;
29     private long deadProcessingTime = 0;
30     private int deadRequestCount = 0;
31     private int deadErrorCount = 0;
32     private long deadBytesReceived = 0;
33     private long deadBytesSent = 0;
34
35     public synchronized void addRequestProcessor( RequestInfo rp ) {
36         processors.add( rp );
37     }
38
39     public synchronized void removeRequestProcessor( RequestInfo rp ) {
40         if( rp != null ) {
41             if( deadMaxTime < rp.getMaxTime() )
42                 deadMaxTime = rp.getMaxTime();
43             deadProcessingTime += rp.getProcessingTime();
44             deadRequestCount += rp.getRequestCount();
45             deadErrorCount += rp.getErrorCount();
46             deadBytesReceived += rp.getBytesReceived();
47             deadBytesSent += rp.getBytesSent();
48
49             processors.remove( rp );
50         }
51     }
52
53     public synchronized long getMaxTime() {
54         long maxTime=deadMaxTime;
55         for( int i=0; i<processors.size(); i++ ) {
56             RequestInfo rp=(RequestInfo)processors.get( i );
57             if( maxTime < rp.getMaxTime() ) maxTime=rp.getMaxTime();
58         }
59         return maxTime;
60     }
61
62     // Used to reset the times
63 public synchronized void setMaxTime(long maxTime) {
64         deadMaxTime = maxTime;
65         for( int i=0; i<processors.size(); i++ ) {
66             RequestInfo rp=(RequestInfo)processors.get( i );
67             rp.setMaxTime(maxTime);
68         }
69     }
70
71     public synchronized long getProcessingTime() {
72         long time=deadProcessingTime;
73         for( int i=0; i<processors.size(); i++ ) {
74             RequestInfo rp=(RequestInfo)processors.get( i );
75             time += rp.getProcessingTime();
76         }
77         return time;
78     }
79
80     public synchronized void setProcessingTime(long totalTime) {
81         deadProcessingTime = totalTime;
82         for( int i=0; i<processors.size(); i++ ) {
83             RequestInfo rp=(RequestInfo)processors.get( i );
84             rp.setProcessingTime( totalTime );
85         }
86     }
87
88     public synchronized int getRequestCount() {
89         int requestCount=deadRequestCount;
90         for( int i=0; i<processors.size(); i++ ) {
91             RequestInfo rp=(RequestInfo)processors.get( i );
92             requestCount += rp.getRequestCount();
93         }
94         return requestCount;
95     }
96
97     public synchronized void setRequestCount(int requestCount) {
98         deadRequestCount = requestCount;
99         for( int i=0; i<processors.size(); i++ ) {
100             RequestInfo rp=(RequestInfo)processors.get( i );
101             rp.setRequestCount( requestCount );
102         }
103     }
104
105     public synchronized int getErrorCount() {
106         int requestCount=deadErrorCount;
107         for( int i=0; i<processors.size(); i++ ) {
108             RequestInfo rp=(RequestInfo)processors.get( i );
109             requestCount += rp.getErrorCount();
110         }
111         return requestCount;
112     }
113
114     public synchronized void setErrorCount(int errorCount) {
115         deadErrorCount = errorCount;
116         for( int i=0; i<processors.size(); i++ ) {
117             RequestInfo rp=(RequestInfo)processors.get( i );
118             rp.setErrorCount( errorCount);
119         }
120     }
121
122     public synchronized long getBytesReceived() {
123         long bytes=deadBytesReceived;
124         for( int i=0; i<processors.size(); i++ ) {
125             RequestInfo rp=(RequestInfo)processors.get( i );
126             bytes += rp.getBytesReceived();
127         }
128         return bytes;
129     }
130
131     public synchronized void setBytesReceived(long bytesReceived) {
132         deadBytesReceived = bytesReceived;
133         for( int i=0; i<processors.size(); i++ ) {
134             RequestInfo rp=(RequestInfo)processors.get( i );
135             rp.setBytesReceived( bytesReceived );
136         }
137     }
138
139     public synchronized long getBytesSent() {
140         long bytes=deadBytesSent;
141         for( int i=0; i<processors.size(); i++ ) {
142             RequestInfo rp=(RequestInfo)processors.get( i );
143             bytes += rp.getBytesSent();
144         }
145         return bytes;
146     }
147
148     public synchronized void setBytesSent(long bytesSent) {
149         deadBytesSent = bytesSent;
150         for( int i=0; i<processors.size(); i++ ) {
151             RequestInfo rp=(RequestInfo)processors.get( i );
152             rp.setBytesSent( bytesSent );
153         }
154     }
155
156     public void resetCounters() {
157         this.setBytesReceived(0);
158         this.setBytesSent(0);
159         this.setRequestCount(0);
160         this.setProcessingTime(0);
161         this.setMaxTime(0);
162         this.setErrorCount(0);
163     }
164 }
165
Popular Tags