anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added the close of metrics files

Browse Source
This commit is contained in:
selva.andre
2012-08-30 17:06:10 +02:00
parent 1b683328e0
commit ecaf50a1a8
2 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
benchmarking/src/main/java/org/dna/mqtt/bechnmark/ConsumerFuture.java
+3 -2
View File
@@ -104,8 +104,9 @@ public class ConsumerFuture implements Runnable {
m_benchMarkOut.close();
try {
FileWriter fw = new FileWriter(BENCHMARK_FILE);
fw.write(m_baos.toString());
FileOutputStream fw = new FileOutputStream(BENCHMARK_FILE);
fw.write(m_baos.toByteArray());
fw.close();
} catch (IOException e) {
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
}
benchmarking/src/main/java/org/dna/mqtt/bechnmark/Producer.java
+9 -6
View File
@@ -22,12 +22,12 @@ public class Producer implements Runnable {
public static final int PUB_LOOP = 100000;
private static int m_starIndex;
private static int m_len;
private int m_starIndex;
private int m_len;
private long m_startMillis;
private static final String BENCHMARK_FILE = "producer_bechmark.txt";
private static final String BENCHMARK_FILE = "producer_bechmark_%s.txt";
private PrintWriter m_benchMarkOut;
private ByteArrayOutputStream m_baos = new ByteArrayOutputStream(1024 * 1024);
private ByteArrayOutputStream m_baos = new ByteArrayOutputStream(1024 * 1024 * 2);
public Producer(String clientID, int start, int len) {
m_clientID = clientID;
@@ -60,6 +60,7 @@ public class Producer implements Runnable {
long time = System.currentTimeMillis() - m_startMillis;
LOG.info(String.format("Producer %s connected in %d ms", Thread.currentThread().getName(), time));
LOG.info("Starting from index " + m_starIndex + " up to " + (m_starIndex + m_len));
m_startMillis = System.currentTimeMillis();
for (int i = m_starIndex; i < m_starIndex + m_len; i++) {
try {
@@ -88,11 +89,13 @@ public class Producer implements Runnable {
time = System.currentTimeMillis() - m_startMillis;
LOG.info(String.format("Producer %s disconnected in %d ms", Thread.currentThread().getName(), time));
m_benchMarkOut.flush();
m_benchMarkOut.close();
try {
FileWriter fw = new FileWriter(BENCHMARK_FILE);
fw.write(m_baos.toString());
FileOutputStream fw = new FileOutputStream(String.format(BENCHMARK_FILE, m_clientID));
fw.write(m_baos.toByteArray());
fw.close();
} catch (IOException e) {
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
}