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