1 | if (stacktree.peek() instanceof Connector) {↵ | | |
|
2 | stacktree.push(threadinfo);↵ | | |
|
3 | connector.setThreadInfo(threadinfo);↵ | | |
|
4 | if (attributes != null) {↵ | | |
|
5 | for (int idx = 0; idx < attributes.getLength(); idx++) {↵ | | 1 | for (int idx = 0; idx < attributes.getLength(); idx++) {↵
|
6 | String attr = attributes.getQName(idx);↵ | | 2 | String attr = attributes.getQName(idx);↵
|
7 | if (attr.equals(Constants.MAXTHREADS)) {↵ | | 3 | if (attr.equals(Constants.MAXTIME)) {↵
|
8 | threadinfo.setMaxThreads(parseInt(attributes.getValue(idx)));↵ | | 4 | requestinfo.setMaxTime(parseInt(attributes.getValue(idx)));↵
|
9 | } else if (attr.equals(Constants.MINSPARETHREADS)) {↵ | | 5 | } else if (attr.equals(Constants.PROCESSINGTIME)) {↵
|
10 | threadinfo.setMinSpareThreads(parseInt(attributes.getValue(idx)));↵ | | 6 | requestinfo.setProcessingTime(parseInt(attributes.getValue(idx)));↵
|
11 | } else if (attr.equals(Constants.MAXSPARETHREADS)) {↵ | | 7 | } else if (attr.equals(Constants.REQUESTCOUNT)) {↵
|
12 | threadinfo.setMaxSpareThreads(parseInt(attributes.getValue(idx)));↵ | | 8 | requestinfo.setRequestCount(parseInt(attributes.getValue(idx)));↵
|
13 | } else if (attr.equals(Constants.CURRENTTHREADCOUNT)) {↵ | | 9 | } else if (attr.equals(Constants.ERRORCOUNT)) {↵
|
14 | threadinfo.setCurrentThreadCount(parseInt(attributes.getValue(idx)));↵ | | 10 | requestinfo.setErrorCount(parseInt(attributes.getValue(idx)));↵
|
15 | } else if (attr.equals(Constants.CURRENTBUSYTHREADS)) {↵ | | 11 | } else if (attr.equals(Constants.BYTESRECEIVED)) {↵
|
16 | threadinfo.setCurrentThreadsBusy(parseInt(attributes.getValue(idx)));↵ | | 12 | requestinfo.setBytesReceived(parseLong(attributes.getValue(idx)));↵
|
17 | }↵ | | 13 | }↵
|
18 | }↵ | | 14 | else if (attr.equals(Constants.BYTESSENT)) {↵
|
| | | 15 | requestinfo.setBytesSent(parseLong(attributes.getValue(idx)));↵
|
19 | }↵ | | 16 | }↵
|
20 | } | | 17 | }
|