jprdonnelly/tcommon-studio-se
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix Bug TDI-22891: optimize the code to reduce memory

Browse Source 
https://jira.talendforge.org/browse/TDI-22891

git-svn-id: http://talendforge.org/svn/tos/trunk@93762 f6f1c999-d317-4740-80b0-e6d1abc6f99e
This commit is contained in:
wliu
2012-11-14 07:24:52 +00:00
parent 170dd05b71
commit d42e5f2b49
1 changed files with 16 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
org.talend.librariesmanager/resources/java/routines/system/RunStat.java
View File

@@ -159,7 +159,7 @@ public class RunStat implements Runnable {
private boolean jobIsFinished = false;
private String str = ""; //$NON-NLS-1$
private StringBuffer str = new StringBuffer(); //$NON-NLS-1$
public void startThreadStat(String clientHost, int portStats) throws java.io.IOException, java.net.UnknownHostException {
if (!openSocket) {
@@ -263,19 +263,20 @@ public class RunStat implements Runnable {
// it is connection
int jobStat = sb.getJobStat();
if (jobStat == JOBDEFAULT) {
str = TYPE1_CONNECTION + "|" + rootPid + "|" + fatherPid + "|" + pid + "|" + sb.getConnectionId();
str.delete(0, str.length());
str = str.append(TYPE1_CONNECTION + "|" + rootPid + "|" + fatherPid + "|" + pid + "|").append(sb.getConnectionId());
// str = sb.getConnectionId();
if (sb.getState() == RunStat.CLEAR) {
str += "|" + "clear"; //$NON-NLS-1$ //$NON-NLS-2$
str.append( "|" + "clear"); //$NON-NLS-1$ //$NON-NLS-2$
} else {
if (sb.getExec() == null) {
str += "|" + sb.getNbLine() + "|" + (sb.getEndTime() - sb.getStartTime()); //$NON-NLS-1$ //$NON-NLS-2$
str.append("|").append(sb.getNbLine()).append("|").append(sb.getEndTime() - sb.getStartTime()); //$NON-NLS-1$ //$NON-NLS-2$
} else {
str += "|" + sb.getExec(); //$NON-NLS-1$
str.append("|").append(sb.getExec()); //$NON-NLS-1$
}
if (sb.getState() != RunStat.RUNNING) {
str += "|" + ((sb.getState() == RunStat.BEGIN) ? "start" : "stop"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
str.append("|" + ((sb.getState() == RunStat.BEGIN) ? "start" : "stop")); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
}
}
} else {
@@ -292,11 +293,11 @@ public class RunStat implements Runnable {
jobStatStr = jobName + "|" + "end job" + "|" + itemId + "|"
+ simpleDateFormat.format(new Date(sb.getEndTime()));
}
str = TYPE0_JOB + "|" + rootPid + "|" + fatherPid + "|" + pid + "|" + jobStatStr;
str.delete(0, str.length());
str.append( TYPE0_JOB + "|" + rootPid + "|" + fatherPid + "|" + pid + "|").append(jobStatStr);
}
// System.out.println(str);
pred.println(str); // envoi d'un message
pred.println(str.toString()); // envoi d'un message
}
keysList.clear();
@@ -365,10 +366,12 @@ public class RunStat implements Runnable {
public synchronized void updateStatOnConnection(String connectionId, int mode, String exec) {
StatBean bean;
String key = connectionId + "|" + mode;
StringBuffer key = new StringBuffer();
key.append(connectionId + "|" + mode);
if (connectionId.startsWith("iterate")) {
key = connectionId + "|" + mode + "|" + exec;
key.delete(0, key.length());
key.append(connectionId + "|" + mode + "|" + exec);
} else {
if (connectionId.contains(".")) {
String firstKey = null;
@@ -393,7 +396,7 @@ public class RunStat implements Runnable {
if (keysList.contains(key)) {
keysList.remove(key);
}
keysList.add(key);
keysList.add(key.toString());
// System.out.println(connectionId);
if (processStats.containsKey(key)) {
bean = processStats.get(key);
@@ -402,7 +405,7 @@ public class RunStat implements Runnable {
}
bean.setState(mode);
bean.setExec(exec);
processStats.put(key, bean);
processStats.put(key.toString(), bean);
// Set a maximum interval for each update of 250ms.
// since Iterate can be fast, we try to update the UI often.