From e5c8298beee5dde90ca98cc4707faac4bf0e2f0c Mon Sep 17 00:00:00 2001 From: Vitaly Takmazov Date: Thu, 7 Jul 2016 15:13:47 +0300 Subject: reorganize project --- src/main/java/com/juick/xmpp/s2s/CleaningUp.java | 107 ----------------------- 1 file changed, 107 deletions(-) delete mode 100644 src/main/java/com/juick/xmpp/s2s/CleaningUp.java (limited to 'src/main/java/com/juick/xmpp/s2s/CleaningUp.java') diff --git a/src/main/java/com/juick/xmpp/s2s/CleaningUp.java b/src/main/java/com/juick/xmpp/s2s/CleaningUp.java deleted file mode 100644 index 14d97ed8..00000000 --- a/src/main/java/com/juick/xmpp/s2s/CleaningUp.java +++ /dev/null @@ -1,107 +0,0 @@ -package com.juick.xmpp.s2s; - -import java.io.FileNotFoundException; -import java.io.PrintWriter; -import java.io.UnsupportedEncodingException; -import java.util.Iterator; - -/** - * - * @author ugnich - */ -public class CleaningUp implements Runnable { - XMPPComponent xmpp; - - public CleaningUp(XMPPComponent xmpp) { - this.xmpp = xmpp; - } - - @Override - public void run() { - while (true) { - try { - PrintWriter statsFile = new PrintWriter(xmpp.STATSFILE, "UTF-8"); - statsFile.write("

Threads: " + Thread.activeCount() + "

"); - statsFile.write("

Out (" + xmpp.outConnections.size() + ")

"); - - long now = System.currentTimeMillis(); - - synchronized (xmpp.outConnections) { - for (Iterator i = xmpp.outConnections.iterator(); i.hasNext();) { - ConnectionOut c = i.next(); - int inactive = (int) ((double) (now - c.tsLocalData) / 1000.0); - if (inactive > 900) { - c.closeConnection(); - i.remove(); - } else { - statsFile.write(" "); - statsFile.write(" \n"); - statsFile.write(" \n"); - statsFile.write(" \n"); - statsFile.write(" \n"); - statsFile.write(" \n"); - statsFile.write(" "); - } - } - } - - statsFile.write("
tosidinactiveout packetsout bytes
" + c.to + "" + c.streamID + "" + inactive + "" + c.packetsLocal + "" + c.bytesLocal + "

In (" + xmpp.inConnections.size() + ")

"); - - synchronized (xmpp.inConnections) { - for (Iterator i = xmpp.inConnections.iterator(); i.hasNext();) { - ConnectionIn c = i.next(); - int inactive = (int) ((double) (now - c.tsRemoteData) / 1000.0); - if (inactive > 900) { - c.closeConnection(); - i.remove(); - } else { - statsFile.write(" "); - if (c.from.isEmpty()) { - statsFile.write(" \n"); - } else if (c.from.size() == 1) { - statsFile.write(" \n"); - } else { - String out = " \n"); - } - statsFile.write(" \n"); - statsFile.write(" \n"); - statsFile.write(" \n"); - statsFile.write(" "); - } - } - } - - statsFile.write("
fromsidinactivein packets
 " + c.from.get(0) + ""; - for (int n = 0; n < c.from.size(); n++) { - if (n > 0) { - out += "
"; - } - out += c.from.get(n); - } - statsFile.write(out + "		" + c.streamID + "" + inactive + "" + c.packetsRemote + "

Cache (" + xmpp.outCache.size() + ")

"); - - synchronized (xmpp.outCache) { - for (Iterator i = xmpp.outCache.iterator(); i.hasNext();) { - CacheEntry c = i.next(); - int inactive = (int) ((double) (now - c.tsCreated) / 1000.0); - if (inactive > 600) { - i.remove(); - } else { - statsFile.write(""); - } - } - } - - statsFile.write("
hostlivesize
" + c.hostname + "" + inactive + "" + c.xml.length() + "
"); - statsFile.close(); - - try { - Thread.sleep(10000); - } catch (InterruptedException e) { - } - } catch (FileNotFoundException e) { - } catch (UnsupportedEncodingException e) { - } - } - } -} -- cgit v1.2.3