StatsWriterImplpublic class StatsWriterImpl extends XUXmlWriter
| Fields Summary |
|---|
| com.aelitis.azureus.core.AzureusCore | core |
| Methods Summary |
|---|
| protected void | write(java.lang.String file_name)
try{
setOutputStream( new FileOutputStream( file_name ));
writeSupport();
}finally{
closeOutputStream();
}
| | protected void | write(java.io.OutputStream os)
try{
setOutputStream( os );
writeSupport();
}finally{
flushOutputStream();
}
| | protected void | writeRawCookedAverageTag(java.lang.String tag, long raw)
writeLineRaw( "<" + tag + ">");
try{
indent();
writeTag( "TEXT", DisplayFormatters.formatByteCountToKiBEtcPerSec( raw ));
writeTag( "RAW", raw);
}finally{
exdent();
}
writeLineRaw( "</" + tag + ">");
| | protected void | writeRawCookedTag(java.lang.String tag, long raw)
writeLineRaw( "<" + tag + ">");
try{
indent();
writeTag( "TEXT", DisplayFormatters.formatByteCountToKiBEtc( raw ));
writeTag( "RAW", raw);
}finally{
exdent();
}
writeLineRaw( "</" + tag + ">");
| | protected void | writeSupport()
writeLineRaw( "<?xml version=\"1.0\" encoding=\"UTF-8\"?>" );
boolean export_peer_stats = COConfigurationManager.getBooleanParameter("Stats Export Peer Details");
String xsl = COConfigurationManager.getStringParameter( "Stats XSL File" );
if ( xsl.length() > 0 ){
writeLineRaw( "<?xml-stylesheet type=\"text/xsl\" href=\"" + xsl + "\"?>" );
}
writeLineRaw( "<STATS>");
GlobalManager global = core.getGlobalManager();
try{
indent();
writeTag( "AZUREUS_VERSION", Constants.AZUREUS_VERSION );
writeLineRaw( "<GLOBAL>" );
try{
indent();
GlobalManagerStats gm_stats = global.getStats();
writeRawCookedAverageTag( "DOWNLOAD_SPEED", gm_stats.getDataReceiveRate() + gm_stats.getProtocolReceiveRate() );
writeRawCookedAverageTag( "UPLOAD_SPEED", gm_stats.getDataSendRate() + gm_stats.getProtocolSendRate() );
}finally{
exdent();
}
writeLineRaw( "</GLOBAL>" );
writeLineRaw( "<DOWNLOADS>");
try{
indent();
List _dms = global.getDownloadManagers();
DownloadManager[] dms = new DownloadManager[_dms.size()];
// sort by position, downloads then seeders
_dms.toArray( dms );
Arrays.sort(
dms,
new Comparator()
{
public int
compare(
Object o1,
Object o2)
{
DownloadManager d1 = (DownloadManager)o1;
DownloadManager d2 = (DownloadManager)o2;
int d1_index = d1.getPosition();
int d2_index = d2.getPosition();
if ( d1.isDownloadComplete(false) ){
d1_index += 1000000;
}
if ( d2.isDownloadComplete(false) ){
d2_index += 1000000;
}
return( d1_index - d2_index );
}
});
for (int i=0;i<dms.length;i++){
DownloadManager dm = (DownloadManager)dms[i];
DownloadManagerStats dm_stats = dm.getStats();
writeLineRaw( "<DOWNLOAD>");
try{
indent();
writeLineRaw( "<TORRENT>" );
// torrent can be null if broken torrent!
TOTorrent torrent = dm.getTorrent();
try{
indent();
writeTag( "NAME", dm.getDisplayName());
writeTag( "TORRENT_FILE", dm.getTorrentFileName());
if ( torrent != null ){
writeTag( "HASH", TorrentUtils.nicePrintTorrentHash(torrent, true));
writeRawCookedTag( "SIZE", torrent.getSize());
writeTag( "PIECE_LENGTH", torrent.getPieceLength());
writeTag( "PIECE_COUNT", torrent.getNumberOfPieces());
writeTag( "FILE_COUNT", torrent.getFiles().length );
writeTag( "COMMENT", dm.getTorrentComment());
writeTag( "CREATED_BY", dm.getTorrentCreatedBy());
writeTag( "CREATION_DATE", torrent.getCreationDate());
}
}finally{
exdent();
}
writeLineRaw( "</TORRENT>");
writeTag( "DOWNLOAD_STATUS", DisplayFormatters.formatDownloadStatusDefaultLocale( dm));
writeTag( "DOWNLOAD_DIR", dm.getSaveLocation().toString());
if ( torrent != null ){
if ( torrent.isSimpleTorrent()){
writeTag( "TARGET_FILE", dm.getSaveLocation().toString());
}else{
writeTag( "TARGET_DIR", dm.getSaveLocation().toString());
}
}
writeTag( "TRACKER_STATUS", dm.getTrackerStatus());
writeTag( "COMPLETED", dm_stats.getCompleted());
writeRawCookedTag( "DOWNLOADED", dm_stats.getTotalDataBytesReceived());
writeRawCookedTag( "UPLOADED", dm_stats.getTotalDataBytesSent());
writeRawCookedTag( "DISCARDED", dm_stats.getDiscarded());
writeRawCookedAverageTag( "DOWNLOAD_SPEED", dm_stats.getDataReceiveRate());
writeRawCookedAverageTag( "UPLOAD_SPEED", dm_stats.getDataSendRate());
writeRawCookedAverageTag( "TOTAL_SPEED", dm_stats.getTotalAverage());
writeTag( "ELAPSED", dm_stats.getElapsedTime());
writeTag( "ETA", DisplayFormatters.formatETA(dm_stats.getETA()));
writeTag( "HASH_FAILS", dm_stats.getHashFailCount());
writeTag( "SHARE_RATIO", dm_stats.getShareRatio());
writeTag( "TOTAL_SEEDS", dm.getNbSeeds());
writeTag( "TOTAL_LEECHERS", dm.getNbPeers());
if ( export_peer_stats ){
try{
writeLineRaw( "<PEERS>");
indent();
PEPeerManager pm = dm.getPeerManager();
if ( pm != null ){
List peers = pm.getPeers();
for (int j=0;j<peers.size();j++){
PEPeer peer = (PEPeer)peers.get(j);
PEPeerStats peer_stats = peer.getStats();
byte[] id = peer.getId();
if ( id == null ){
continue;
}
try{
String peer_id = PeerClassifier.getPrintablePeerID( id );
peer_id = escapeXML(peer_id);
String type = escapeXML( peer.getClient());
writeLineRaw( "<PEER hex_id=\"" + ByteFormatter.encodeString( id ) + "\" printable_id=\""+ peer_id + "\" type=\"" + type + "\">");
indent();
writeTag( "IP", peer.getIp());
writeTag( "IS_SEED", peer.isSeed());
writeRawCookedTag( "DOWNLOADED", peer_stats.getTotalDataBytesReceived());
writeRawCookedTag( "UPLOADED", peer_stats.getTotalDataBytesSent());
writeRawCookedAverageTag( "DOWNLOAD_SPEED", peer_stats.getDataReceiveRate());
writeRawCookedAverageTag( "UPLOAD_SPEED", peer_stats.getDataSendRate());
}catch( Throwable e ){
Debug.printStackTrace( e );
}finally{
exdent();
writeLineRaw( "</PEER>");
}
}
}
}finally{
exdent();
writeLineRaw( "</PEERS>");
}
}
}finally{
exdent();
}
writeLineRaw( "</DOWNLOAD>");
}
}finally{
exdent();
}
writeLineRaw( "</DOWNLOADS>" );
}finally{
exdent();
}
writeLineRaw( "</STATS>");
|
|
