Review Kademlia assertions

[amule.git] / src / Statistics.cpp

//
// This file is part of the aMule Project.
//
// Copyright (c) 2003-2011 aMule Team ( admin@amule.org / http://www.amule.org )
// Copyright (c) 2002-2011 Merkur ( devs@emule-project.net / http://www.emule-project.net )
// Copyright (c) 2005-2011 Dévai Tamás ( gonosztopi@amule.org )
//
// Any parts of this program derived from the xMule, lMule or eMule project,
// or contributed by third-party developers are copyrighted by their
// respective authors.
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301, USA
//

#include "Statistics.h"         // Interface declarations

#include <protocol/ed2k/ClientSoftware.h>

#include <ec/cpp/ECTag.h>               // Needed for CECTag

#ifndef CLIENT_GUI
        #ifndef AMULE_DAEMON
                #include <common/Format.h>              // Needed for CFormat
        #endif
        #include "CFile.h"              // Needed for CFile access
        #include <common/Path.h>        // Needed for JoinPaths
        #include <wx/config.h>          // Needed for wxConfig
        #include "DataToText.h"         // Needed for GetSoftName()
        #include "ListenSocket.h"       // (tree, GetAverageConnections)
        #include "ServerList.h"         // Needed for CServerList (tree)
        #include <cmath>                // Needed for std::floor
        #include "updownclient.h"       // Needed for CUpDownClient
#else
        #include "GetTickCount.h"       // Needed for GetTickCount64()
        #include <ec/cpp/RemoteConnect.h>               // Needed for CRemoteConnect
#endif

#include "amule.h"              // Needed for theApp
#include <wx/intl.h>
#include "Logger.h"
#include "Preferences.h"        // Needed for thePrefs

#ifdef __BSD__
        // glibc -> bsd libc
        #define round rint
#else
        #define round(x) floor(x+0.5)
#endif /* __BSD__ */


#ifndef CLIENT_GUI

/*----- CPreciseRateCounter -----*/

void CPreciseRateCounter::CalculateRate(uint64_t now)
{
        wxMutexLocker lock(m_mutex);

        m_total += m_tmp_sum;
        m_byte_history.push_back(m_tmp_sum);
        m_tick_history.push_back(now);
        m_tmp_sum = 0;

        uint64_t timespan = now - m_tick_history.front();

        // Checking maximal timespan, but make sure not to remove
        // the extra node in m_tick_history.
        while (timespan > m_timespan && !m_byte_history.empty()) {
                m_total -= m_byte_history.front();
                m_byte_history.pop_front();
                m_tick_history.pop_front();
                timespan = now - m_tick_history.front();
        }

        // Count rate/average
        if (m_count_average) {
                if (!m_byte_history.empty()) {
                        m_rate = m_total / (double)m_byte_history.size();
                }
        } else {
                if (timespan > 0) {
                        m_rate = m_total / (timespan / 1000.0);
                }
        }

        if (m_rate > m_max_rate) {
                m_max_rate = m_rate;
        }
}


/*----- CStatTreeItemRateCounter -----*/

#ifndef AMULE_DAEMON
wxString CStatTreeItemRateCounter::GetDisplayString() const
{
        return CFormat(wxGetTranslation(m_label)) % CastItoSpeed(m_show_maxrate ? (uint32)m_max_rate : (uint32)m_rate);
}
#endif

void CStatTreeItemRateCounter::AddECValues(CECTag* tag) const
{
        CECTag value(EC_TAG_STAT_NODE_VALUE, m_show_maxrate ? (uint32)m_max_rate : (uint32)m_rate);
        value.AddTag(CECTag(EC_TAG_STAT_VALUE_TYPE, (uint8)EC_VALUE_SPEED));
        tag->AddTag(value);
}


/*----- CStatTreeItemPeakConnections -----*/

#ifndef AMULE_DAEMON
wxString CStatTreeItemPeakConnections::GetDisplayString() const
{
        return CFormat(wxGetTranslation(m_label)) % theStats::GetPeakConnections();
}
#endif

void CStatTreeItemPeakConnections::AddECValues(CECTag* tag) const
{
        tag->AddTag(CECTag(EC_TAG_STAT_NODE_VALUE, (uint64)theStats::GetPeakConnections()));
}


/*----- CStatistics -----*/

// Static variables

// Rate counters
CPreciseRateCounter*            CStatistics::s_upOverheadRate;
CPreciseRateCounter*            CStatistics::s_downOverheadRate;
CStatTreeItemRateCounter*       CStatistics::s_uploadrate;
CStatTreeItemRateCounter*       CStatistics::s_downloadrate;

#else /* CLIENT_GUI */

uint64  CStatistics::s_start_time;
uint64  CStatistics::s_statData[sdTotalItems];

#endif /* !CLIENT_GUI / CLIENT_GUI */

// Tree root
CStatTreeItemBase*              CStatistics::s_statTree;

#ifndef CLIENT_GUI
// Uptime
CStatTreeItemTimer*             CStatistics::s_uptime;

// Upload
CStatTreeItemUlDlCounter*       CStatistics::s_sessionUpload;
CStatTreeItemPacketTotals*      CStatistics::s_totalUpOverhead;
CStatTreeItemPackets*           CStatistics::s_fileReqUpOverhead;
CStatTreeItemPackets*           CStatistics::s_sourceXchgUpOverhead;
CStatTreeItemPackets*           CStatistics::s_serverUpOverhead;
CStatTreeItemPackets*           CStatistics::s_kadUpOverhead;
CStatTreeItemCounter*           CStatistics::s_cryptUpOverhead;
CStatTreeItemNativeCounter*     CStatistics::s_activeUploads;
CStatTreeItemNativeCounter*     CStatistics::s_waitingUploads;
CStatTreeItemCounter*           CStatistics::s_totalSuccUploads;
CStatTreeItemCounter*           CStatistics::s_totalFailedUploads;
CStatTreeItemCounter*           CStatistics::s_totalUploadTime;

// Download
CStatTreeItemUlDlCounter*       CStatistics::s_sessionDownload;
CStatTreeItemPacketTotals*      CStatistics::s_totalDownOverhead;
CStatTreeItemPackets*           CStatistics::s_fileReqDownOverhead;
CStatTreeItemPackets*           CStatistics::s_sourceXchgDownOverhead;
CStatTreeItemPackets*           CStatistics::s_serverDownOverhead;
CStatTreeItemPackets*           CStatistics::s_kadDownOverhead;
CStatTreeItemCounter*           CStatistics::s_cryptDownOverhead;
CStatTreeItemCounter*           CStatistics::s_foundSources;
CStatTreeItemNativeCounter*     CStatistics::s_activeDownloads;

// Connection
CStatTreeItemReconnects*        CStatistics::s_reconnects;
CStatTreeItemTimer*             CStatistics::s_sinceFirstTransfer;
CStatTreeItemTimer*             CStatistics::s_sinceConnected;
CStatTreeItemCounterMax*        CStatistics::s_activeConnections;
CStatTreeItemMaxConnLimitReached* CStatistics::s_limitReached;
CStatTreeItemSimple*            CStatistics::s_avgConnections;

// Clients
CStatTreeItemHiddenCounter*     CStatistics::s_clients;
CStatTreeItemCounter*           CStatistics::s_unknown;
//CStatTreeItem                 CStatistics::s_lowID;
//CStatTreeItem                 CStatistics::s_secIdentOnOff;
#ifdef __DEBUG__
CStatTreeItemNativeCounter*     CStatistics::s_hasSocket;
#endif
CStatTreeItemNativeCounter*     CStatistics::s_filtered;
CStatTreeItemNativeCounter*     CStatistics::s_banned;

// Servers
CStatTreeItemSimple*            CStatistics::s_workingServers;
CStatTreeItemSimple*            CStatistics::s_failedServers;
CStatTreeItemNativeCounter*     CStatistics::s_totalServers;
CStatTreeItemNativeCounter*     CStatistics::s_deletedServers;
CStatTreeItemNativeCounter*     CStatistics::s_filteredServers;
CStatTreeItemSimple*            CStatistics::s_usersOnWorking;
CStatTreeItemSimple*            CStatistics::s_filesOnWorking;
CStatTreeItemSimple*            CStatistics::s_totalUsers;
CStatTreeItemSimple*            CStatistics::s_totalFiles;
CStatTreeItemSimple*            CStatistics::s_serverOccupation;

// Shared files
CStatTreeItemCounter*           CStatistics::s_numberOfShared;
CStatTreeItemCounter*           CStatistics::s_sizeOfShare;

// Kad
uint64_t                        CStatistics::s_kadNodesTotal;
uint16_t                        CStatistics::s_kadNodesCur;

// Totals
uint64_t                        CStatistics::s_totalSent;
uint64_t                        CStatistics::s_totalReceived;

bool                            CStatistics::s_statsNeedSave;


CStatistics::CStatistics()
        : m_graphRunningAvgDown(thePrefs::GetStatsAverageMinutes() * 60 * 1000, true),
          m_graphRunningAvgUp(thePrefs::GetStatsAverageMinutes() * 60 * 1000, true),
          m_graphRunningAvgKad(thePrefs::GetStatsAverageMinutes() * 60 * 1000, true)
{
        uint64 start_time = GetTickCount64();

        // Init graphs

        average_minutes = thePrefs::GetStatsAverageMinutes();

        HR hr = {0.0, 0.0, 0.0, 0.0, 0.0, 0, 0, 0, 0, 0};
        hrInit = hr;
        nHistRanges = 7;        // =ceil(log(max_update_delay)/log(2))
        nPointsPerRange = GetPointsPerRange();
        bitsHistClockMask = (1 << (nHistRanges-1)) - 1;
        aposRecycle = new listPOS[nHistRanges];
        listPOS *ppos = aposRecycle+nHistRanges-1;
        for (int i=nHistRanges; i>0; --i) {  // permanently allocated history list
                listHR.push_back(hr);
                *ppos-- = --listHR.end();
                for (int j=nPointsPerRange; j>1; --j)
                        listHR.push_back(hr);
        }

        // Init rate counters outside the tree

        s_upOverheadRate = new CPreciseRateCounter(5000);
        s_downOverheadRate = new CPreciseRateCounter(5000);

        // Init Tree

        InitStatsTree();
        s_uptime->SetStartTime(start_time);

        // Load saved statistics
        Load();
        s_statsNeedSave = false;
}


CStatistics::~CStatistics()
{
        // clearing listHR frees the memory occupied by the nodes
        listHR.clear();
        delete [] aposRecycle;

        delete s_statTree;

        // delete items not in the tree
        delete s_totalUploadTime;

        // delete rate counters outside the tree
        delete s_upOverheadRate;
        delete s_downOverheadRate;
}


uint64_t ReadUInt64FromCfg(wxConfigBase* cfg, const wxString& key)
{
        wxString buffer;

        cfg->Read(key, &buffer, wxT("0"));

        uint64 tmp = 0;
        for (unsigned int i = 0; i < buffer.Length(); ++i) {
                if ((buffer[i] >= wxChar('0')) &&(buffer[i] <= wxChar('9'))) {
                        tmp = tmp * 10 + (buffer[i] - wxChar('0'));
                } else {
                        tmp = 0;
                        break;
                }
        }

        return tmp;
}

void CStatistics::Load()
{
        CFile f;

        s_totalSent = 0;
        s_totalReceived = 0;
        try {
                CPath path(JoinPaths(thePrefs::GetConfigDir(), wxT("statistics.dat")));
                if (path.FileExists() && f.Open(path)) {
                        uint8_t version = f.ReadUInt8();
                        if (version == 0) {
                                s_totalSent = f.ReadUInt64();
                                s_totalReceived = f.ReadUInt64();
                        }
                }
        } catch (const CSafeIOException& e) {
                AddLogLineN(e.what());
        }

        // Load old values from config
        bool cfgChanged = false;
        wxConfigBase* cfg = wxConfigBase::Get();
        if (cfg->HasEntry(wxT("/Statistics/TotalUploadedBytes"))) {
                s_totalSent += ReadUInt64FromCfg(cfg, wxT("/Statistics/TotalUploadedBytes"));
                cfg->DeleteEntry(wxT("/Statistics/TotalUploadedBytes"));
                cfgChanged = true;
        }
        if (cfg->HasEntry(wxT("/Statistics/TotalDownloadedBytes"))) {
                s_totalReceived += ReadUInt64FromCfg(cfg, wxT("/Statistics/TotalDownloadedBytes"));
                cfg->DeleteEntry(wxT("/Statistics/TotalDownloadedBytes"));
                cfgChanged = true;
        }
        if (cfgChanged) {
                cfg->Flush();
                s_statsNeedSave = s_totalSent > 0 || s_totalReceived > 0;
                Save();
        }
}


void CStatistics::Save()
{
        if (s_statsNeedSave) {
                CFile f;

                if (f.Open(JoinPaths(thePrefs::GetConfigDir(), wxT("statistics.dat")), CFile::write)) {
                        f.WriteUInt8(0);        /* version */
                        f.WriteUInt64(s_totalSent);
                        f.WriteUInt64(s_totalReceived);
                }
                s_statsNeedSave = false;
        }
}

void CStatistics::CalculateRates()
{
        uint64_t now = GetTickCount64();
        s_downOverheadRate->CalculateRate(now);
        s_upOverheadRate->CalculateRate(now);
        s_downloadrate->CalculateRate(now);
        s_uploadrate->CalculateRate(now);
}



/* ------------------------------- GRAPHS ---------------------------- */

/*
History List

  The basic idea here is that we want to keep as much history as we can without paying
a high price in terms of memory space.  Because we keep the history for display purposes,
we can take advantage of the fact that when the period shown in the graphs is long
then each pixel represents a long period.  So as the most recent history we keep one
window full of points at a resolution of 1 second, the next window full at 2 seconds,
the next at 4 seconds and so on, up to the maximum desired.  This way there is always
at least one sample point per pixel for any update delay set by the user, and the
memory required grows with the *log* of the total time period covered.
  The history is kept in a doubly-linked list, with the most recent snapshot at the tail.
The number of nodes in the list is fixed, and there are no calls to RemoveHead() and
AddTail() which would add overhead and contribute to memory fragmentation.  Instead,
every second when a new point gets recorded, one of the existing nodes is recycled;
it is disjoined from its present place, put at the tail of the list, and then gets
filled with new data.   [Emilio Sandoz]
  This unfortunately does not work with stl classes, as none of them supports moving
a node to another place, so we have to erase and re-add nodes.
*/

void CStatistics::RecordHistory()
{       // First we query and compute some values, then we store them in the history list

        // A few comments about the use of double and float in computations:
        // Even on a hi-res screen our graphs will have 10 bits of resolution at most,
        // so the 24 bits resolution of a float on 32 bit Intel processors is more than
        // enough for all displayed values.  Rate computations however, and especially
        // running average computations, use differences (delta bytes/ delta time), and
        // for long uptimes the difference between two timestamps can lose too much
        // accuracy because the large mantissa causes less significant bits to be dropped
        // (same for the difference between two cumulative byte counts).  [We don't store
        // these values as integers because they will be used in floating point calculations,
        // and we want to perform the conversion only once).  Therefore timestamps and
        // Kbyte counts are stored in the history as doubles, while computed values use
        // float (to save space and execution time).

/*
        Store values; first determine the node to be recycled (using the bits in iClock)

    oldest records ----------------- listHR ------------------ youngest records

        O-[Range 2^n sec]-O- ... -O-[Range 4 sec]-O-[Range 2 sec]-O-[Range 1 sec]-O
        |                 |       |               |               > every 2 secs -^
        |                 |  ...  |                >--------------- every 4 secs -^
        |                 |       >------------------------ recycle every 8 secs -^
        |                 |                                                 ...
        |                 >-the node at this position is recycled every 2^n secs -^
        >-------------------(ditto for the oldest node at the head of the list) --^
        ^                                                         ^
    aposRecycle[nHistRanges-1]               ...              aposRecycle[0]  Tail
*/
        listPOS         *ppos;
        static int      iClock;
        int             iClockPrev = iClock++;
        int             bits = (iClockPrev^iClock) & iClock;  // identify the highest changed bit
        if (bits <= bitsHistClockMask) {
                ppos = aposRecycle;
                while ((bits /= 2) != 0)  // count to the highest bit that was just toggled to 1
                        ++ppos;
                // recycle one node and jump over the next to move it to the next higher range
                listHR.push_back(**ppos);
                *ppos = ++listHR.erase(*ppos);
        } else {
                ppos = aposRecycle+nHistRanges-1;
                // recycle the node at the head; there is no higher range to move nodes into
                listHR.push_back(**ppos);
                *ppos = listHR.erase(*ppos);
        }

        // now save the latest data point in this node
        listPOS phr = --listHR.end();
        phr->kBytesSent = GetSessionSentBytes() / 1024.0;
        phr->kBytesReceived = GetSessionReceivedBytes() / 1024.0;
        phr->kBpsUpCur = GetUploadRate() / 1024.0;
        phr->kBpsDownCur = GetDownloadRate() / 1024.0;
        phr->cntUploads = GetActiveUploadsCount();
        phr->cntConnections = GetActiveConnections();
        phr->cntDownloads = GetDownloadingSources();
        phr->sTimestamp = GetUptimeMillis() / 1000.0;

        s_kadNodesTotal += s_kadNodesCur;
        phr->kadNodesTotal = s_kadNodesTotal;
        phr->kadNodesCur = s_kadNodesCur;
}


unsigned CStatistics::GetHistory(       // Assemble arrays of sample points for a graph
        unsigned cntPoints,             // number of sample points to assemble
        double sStep,                   // time difference between sample points
        double sFinal,                  // latest allowed timestamp
        const std::vector<float *> &ppf,// an array of pointers to arrays of floats for the result
        StatsGraphType which_graph)     // the graph which will receive the points
{
        if (sStep==0.0 || cntPoints==0) {
                return(0);
        }

        float *pf1 = ppf[0];
        float *pf2 = ppf[1];
        float *pf3 = ppf[2];
        unsigned cntFilled = 0;
        listRPOS pos = listHR.rbegin();

        // start of list should be an integer multiple of the sampling period for samples
        // to be consistent when the graphs are resized horizontally
        double  sTarget;
        if (sFinal >= 0.0) {
                sTarget = sFinal;
        } else {
                sTarget = sStep==1.0 ?
                        pos->sTimestamp :
                        std::floor(pos->sTimestamp/sStep) * sStep;
        }

        HR **ahr = NULL, **pphr = NULL;
        bool bRateGraph = (which_graph != GRAPH_CONN);  // rate graph or connections graph?
        if (bRateGraph) {
                ahr = new HR* [cntPoints];
                pphr = ahr;
        }

        while (pos != listHR.rend()) {
                if (pos->sTimestamp > sTarget) {
                        ++pos;
                        continue;
                }
                if (bRateGraph) {               // assemble an array of pointers for ComputeAverages
                        *pphr++ = &(*pos);
                } else {                        // or build the arrays if possible
                        *pf1++ = (float)pos->cntUploads;
                        *pf2++ = (float)pos->cntConnections;
                        *pf3++ = (float)pos->cntDownloads;
                }
                if (++cntFilled  == cntPoints) {        // enough points
                        break;
                }
                if (pos->sTimestamp == 0.0) {           // reached beginning of uptime
                        break;
                }
                if ((sTarget -= sStep) <= 0.0) {        // don't overshoot the beginning
                        if (bRateGraph) {
                                *pphr++ = &hrInit;
                        } else {
                                *pf1++ = *pf2++ = *pf3++ = 0.0;
                        }
                        ++cntFilled;
                        break;
                }
        }

        if (bRateGraph) {
                if  (cntFilled > 0) {
                        ComputeAverages(pphr, pos, cntFilled, sStep, ppf, which_graph);
                }
                delete[] ahr;
        }

        return cntFilled;
}


unsigned CStatistics::GetHistoryForWeb(  // Assemble arrays of sample points for the webserver
        unsigned cntPoints,             // maximum number of sample points to assemble
        double sStep,                   // time difference between sample points
        double *sStart,                 // earliest allowed timestamp
        uint32 **graphData)             // a pointer to a pointer that will point to the graph data array
{
        if (*sStart < 0.0) {
                *sStart = 0.0;
        }
        if (sStep==0.0 || cntPoints==0)
                return(0);
        unsigned        cntFilled = 0;
        listRPOS        pos = listHR.rbegin();
        double          LastTimeStamp = pos->sTimestamp;
        double          sTarget = LastTimeStamp;

        HR      **pphr = new HR *[cntPoints];

        while (pos != listHR.rend()) {
                if (pos->sTimestamp > sTarget) {
                        ++pos;  // find next history record
                        continue;
                }
                pphr[cntFilled] = &(*pos);
                if (++cntFilled  == cntPoints)          // enough points
                        break;
                if (pos->sTimestamp <= *sStart)         // reached beginning of requested time
                        break;
                if ((sTarget -= sStep) <= 0.0) {        // don't overshoot the beginning
                        pphr[cntFilled++] = NULL;
                        break;
                }
        }

        if (cntFilled) {
                *graphData = new uint32 [4 * cntFilled];
                if (*graphData) {
                        for (unsigned int i = 0; i < cntFilled; i++) {
                                HR *phr = pphr[cntFilled - i - 1];
                                if (phr) {
                                        (*graphData)[4 * i    ] = ENDIAN_HTONL((uint32)(phr->kBpsDownCur * 1024.0));
                                        (*graphData)[4 * i + 1] = ENDIAN_HTONL((uint32)(phr->kBpsUpCur * 1024.0));
                                        (*graphData)[4 * i + 2] = ENDIAN_HTONL((uint32)phr->cntConnections);
                                        (*graphData)[4 * i + 3] = ENDIAN_HTONL((uint32)phr->kadNodesCur);
                                } else {
                                        (*graphData)[4 * i] = (*graphData)[4 * i + 1] = 0;
                                        (*graphData)[4 * i + 2] = (*graphData)[4 * i + 3] = 0;
                                }
                        }
                }
        } else {
                *graphData = NULL;
        }

        delete [] pphr;

        *sStart = LastTimeStamp;

        return cntFilled;
}


void CStatistics::ComputeAverages(
        HR              **pphr,         // pointer to (end of) array of assembled history records
        listRPOS        pos,            // position in history list from which to backtrack
        unsigned        cntFilled,      // number of points in the sample data
        double          sStep,          // time difference between two samples
        const std::vector<float *> &ppf,// an array of pointers to arrays of floats with sample data
        StatsGraphType  which_graph)    // the graph which will receive the points
{
        double          sTarget, kValueRun;
        uint64          avgTime = average_minutes * 60;
        unsigned        nBtPoints = (unsigned)(avgTime / sStep);

        CPreciseRateCounter* runningAvg = NULL;
        switch (which_graph) {
                case GRAPH_DOWN:        runningAvg = &m_graphRunningAvgDown;    break;
                case GRAPH_UP:          runningAvg = &m_graphRunningAvgUp;              break;
                case GRAPH_KAD:         runningAvg = &m_graphRunningAvgKad;             break;
                default:
                        wxCHECK_RET(false, wxT("ComputeAverages called with unsupported graph type."));
        }

        runningAvg->m_timespan = avgTime * 1000;
        runningAvg->m_tick_history.clear();
        runningAvg->m_byte_history.clear();
        runningAvg->m_total = 0;
        runningAvg->m_tmp_sum = 0;

        if (pos == listHR.rend()) {
                sTarget = 0.0;
        } else {
                sTarget = std::max(0.0, pos->sTimestamp - sStep);
        }

        while (nBtPoints--) {
                while (pos != listHR.rend() && pos->sTimestamp > sTarget) ++pos;        // find next history record
                if (pos != listHR.rend()) {
                        runningAvg->m_tick_history.push_front((uint64)(pos->sTimestamp * 1000.0));

                        uint32 value = 0;
                        switch (which_graph) {
                        case GRAPH_DOWN:
                                value = (uint32)(pos->kBpsDownCur * 1024.0);
                                break;
                        case GRAPH_UP:
                                value = (uint32)(pos->kBpsUpCur * 1024.0);
                                break;
                        case GRAPH_KAD:
                                value = (uint32)(pos->kadNodesCur * 1024.0);
                                break;
                        default:
                                wxCHECK_RET(false, wxT("ComputeAverages called with unsupported graph type."));
                        }

                        runningAvg->m_byte_history.push_front(value);
                        runningAvg->m_total += value;
                } else {
                        break;
                }
                if ((sTarget -= sStep) < 0.0) {
                        break;
                }
        };

        // now compute averages in returned arrays, starting with the earliest values
        float *pf1 = ppf[0] + cntFilled - 1;    // holds session avg
        float *pf2 = ppf[1] + cntFilled - 1;    // holds running avg
        float *pf3 = ppf[2] + cntFilled - 1;    // holds current rate

        for (int cnt=cntFilled; cnt>0; cnt--, pf1--, pf2--, pf3--) {
                HR *phr = *(--pphr);
                if (which_graph == GRAPH_DOWN) {
                        kValueRun = phr->kBytesReceived;
                        *pf3 = phr->kBpsDownCur;
                } else if (which_graph == GRAPH_UP) {
                        kValueRun = phr->kBytesSent;
                        *pf3 = phr->kBpsUpCur;
                } else {
                        kValueRun = phr->kadNodesTotal;
                        *pf3 = phr->kadNodesCur;
                }

                *pf1 = kValueRun / phr->sTimestamp;
                (*runningAvg) += (uint32)(*pf3 * 1024.0);
                runningAvg->CalculateRate((uint64)(phr->sTimestamp * 1000.0));
                *pf2 = (float)(runningAvg->GetRate() / 1024.0);
        }
}


GraphUpdateInfo CStatistics::GetPointsForUpdate()
{
        GraphUpdateInfo update;
        listPOS phr = --listHR.end();
        update.timestamp = (double) phr->sTimestamp;

        m_graphRunningAvgDown += (uint32)(phr->kBpsDownCur * 1024.0);
        m_graphRunningAvgUp += (uint32)(phr->kBpsUpCur * 1024.0);
        // Note: kadNodesCur is multiplied by 1024 since the value is done
        // in other places, so we simply follow suit here to avoid trouble.
        m_graphRunningAvgKad += (uint32)(phr->kadNodesCur * 1024.0);
        m_graphRunningAvgDown.CalculateRate((uint64)(phr->sTimestamp * 1000.0));
        m_graphRunningAvgUp.CalculateRate((uint64)(phr->sTimestamp * 1000.0));
        m_graphRunningAvgKad.CalculateRate((uint64)(phr->sTimestamp * 1000.0));

        update.downloads[0] = phr->kBytesReceived / phr->sTimestamp;
        update.downloads[1] = m_graphRunningAvgDown.GetRate() / 1024.0;
        update.downloads[2] = phr->kBpsDownCur;

        update.uploads[0] = phr->kBytesSent / phr->sTimestamp;
        update.uploads[1] = m_graphRunningAvgUp.GetRate() / 1024.0;
        update.uploads[2] = phr->kBpsUpCur;

        update.connections[0] = (float)phr->cntUploads;
        update.connections[1] = (float)phr->cntConnections;
        update.connections[2] = (float)phr->cntDownloads;

        update.kadnodes[0] = phr->kadNodesTotal / phr->sTimestamp;
        update.kadnodes[1] = m_graphRunningAvgKad.GetRate() / 1024.0;
        update.kadnodes[2] = phr->kadNodesCur;

        return update;
}


/* ------------------------------- TREE ---------------------------- */

void CStatistics::InitStatsTree()
{
        s_statTree = new CStatTreeItemBase(wxTRANSLATE("Statistics"));

        CStatTreeItemBase* tmpRoot1;
        CStatTreeItemBase* tmpRoot2;

        s_uptime = static_cast<CStatTreeItemTimer*>(s_statTree->AddChild(new CStatTreeItemTimer(wxTRANSLATE("Uptime: %s"))));

        tmpRoot1 = s_statTree->AddChild(new CStatTreeItemBase(wxTRANSLATE("Transfer"), stSortChildren));

        tmpRoot2 = tmpRoot1->AddChild(new CStatTreeItemBase(wxTRANSLATE("Uploads")), 2);
        s_sessionUpload = static_cast<CStatTreeItemUlDlCounter*>(tmpRoot2->AddChild(new CStatTreeItemUlDlCounter(wxTRANSLATE("Uploaded Data (Session (Total)): %s"), theStats::GetTotalSentBytes, stSortChildren | stSortByValue)));
        // Children will be added on-the-fly
        s_totalUpOverhead = static_cast<CStatTreeItemPacketTotals*>(tmpRoot2->AddChild(new CStatTreeItemPacketTotals(wxTRANSLATE("Total Overhead (Packets): %s"))));
        s_fileReqUpOverhead = static_cast<CStatTreeItemPackets*>(tmpRoot2->AddChild(new CStatTreeItemPackets(wxTRANSLATE("File Request Overhead (Packets): %s"))));
        s_totalUpOverhead->AddPacketCounter(s_fileReqUpOverhead);
        s_sourceXchgUpOverhead = static_cast<CStatTreeItemPackets*>(tmpRoot2->AddChild(new CStatTreeItemPackets(wxTRANSLATE("Source Exchange Overhead (Packets): %s"))));
        s_totalUpOverhead->AddPacketCounter(s_sourceXchgUpOverhead);
        s_serverUpOverhead = static_cast<CStatTreeItemPackets*>(tmpRoot2->AddChild(new CStatTreeItemPackets(wxTRANSLATE("Server Overhead (Packets): %s"))));
        s_totalUpOverhead->AddPacketCounter(s_serverUpOverhead);
        s_kadUpOverhead = static_cast<CStatTreeItemPackets*>(tmpRoot2->AddChild(new CStatTreeItemPackets(wxTRANSLATE("Kad Overhead (Packets): %s"))));
        s_totalUpOverhead->AddPacketCounter(s_kadUpOverhead);
        s_cryptUpOverhead = static_cast<CStatTreeItemCounter*>(tmpRoot2->AddChild(new CStatTreeItemCounter(wxTRANSLATE("Crypt overhead (UDP): %s"))));
        s_cryptUpOverhead->SetDisplayMode(dmBytes);
        s_activeUploads = static_cast<CStatTreeItemNativeCounter*>(tmpRoot2->AddChild(new CStatTreeItemNativeCounter(wxTRANSLATE("Active Uploads: %s"))));
        s_waitingUploads = static_cast<CStatTreeItemNativeCounter*>(tmpRoot2->AddChild(new CStatTreeItemNativeCounter(wxTRANSLATE("Waiting Uploads: %s"))));
        s_totalSuccUploads = static_cast<CStatTreeItemCounter*>(tmpRoot2->AddChild(new CStatTreeItemCounter(wxTRANSLATE("Total successful upload sessions: %s"))));
        s_totalFailedUploads = static_cast<CStatTreeItemCounter*>(tmpRoot2->AddChild(new CStatTreeItemCounter(wxTRANSLATE("Total failed upload sessions: %s"))));
        s_totalUploadTime = new CStatTreeItemCounter(wxEmptyString);
        tmpRoot2->AddChild(new CStatTreeItemAverage(wxTRANSLATE("Average upload time: %s"), s_totalUploadTime, s_totalSuccUploads, dmTime));

        tmpRoot2 = tmpRoot1->AddChild(new CStatTreeItemBase(wxTRANSLATE("Downloads")), 1);
        s_sessionDownload = static_cast<CStatTreeItemUlDlCounter*>(tmpRoot2->AddChild(new CStatTreeItemUlDlCounter(wxTRANSLATE("Downloaded Data (Session (Total)): %s"), theStats::GetTotalReceivedBytes, stSortChildren | stSortByValue)));
        // Children will be added on-the-fly
        s_totalDownOverhead = static_cast<CStatTreeItemPacketTotals*>(tmpRoot2->AddChild(new CStatTreeItemPacketTotals(wxTRANSLATE("Total Overhead (Packets): %s"))));
        s_fileReqDownOverhead = static_cast<CStatTreeItemPackets*>(tmpRoot2->AddChild(new CStatTreeItemPackets(wxTRANSLATE("File Request Overhead (Packets): %s"))));
        s_totalDownOverhead->AddPacketCounter(s_fileReqDownOverhead);
        s_sourceXchgDownOverhead = static_cast<CStatTreeItemPackets*>(tmpRoot2->AddChild(new CStatTreeItemPackets(wxTRANSLATE("Source Exchange Overhead (Packets): %s"))));
        s_totalDownOverhead->AddPacketCounter(s_sourceXchgDownOverhead);
        s_serverDownOverhead = static_cast<CStatTreeItemPackets*>(tmpRoot2->AddChild(new CStatTreeItemPackets(wxTRANSLATE("Server Overhead (Packets): %s"))));
        s_totalDownOverhead->AddPacketCounter(s_serverDownOverhead);
        s_kadDownOverhead = static_cast<CStatTreeItemPackets*>(tmpRoot2->AddChild(new CStatTreeItemPackets(wxTRANSLATE("Kad Overhead (Packets): %s"))));
        s_totalDownOverhead->AddPacketCounter(s_kadDownOverhead);
        s_cryptDownOverhead = static_cast<CStatTreeItemCounter*>(tmpRoot2->AddChild(new CStatTreeItemCounter(wxTRANSLATE("Crypt overhead (UDP): %s"))));
        s_cryptDownOverhead->SetDisplayMode(dmBytes);
        s_foundSources = static_cast<CStatTreeItemCounter*>(tmpRoot2->AddChild(new CStatTreeItemCounter(wxTRANSLATE("Found Sources: %s"), stSortChildren | stSortByValue)));
        s_activeDownloads = static_cast<CStatTreeItemNativeCounter*>(tmpRoot2->AddChild(new CStatTreeItemNativeCounter(wxTRANSLATE("Active Downloads (chunks): %s"))));

        tmpRoot1->AddChild(new CStatTreeItemRatio(wxTRANSLATE("Session UL:DL Ratio (Total): %s"), s_sessionUpload, s_sessionDownload, theStats::GetTotalSentBytes, theStats::GetTotalReceivedBytes), 3);

        tmpRoot1 = s_statTree->AddChild(new CStatTreeItemBase(wxTRANSLATE("Connection")));
        tmpRoot1->AddChild(new CStatTreeItemAverageSpeed(wxTRANSLATE("Average download rate (Session): %s"), s_sessionDownload, s_uptime));
        tmpRoot1->AddChild(new CStatTreeItemAverageSpeed(wxTRANSLATE("Average upload rate (Session): %s"), s_sessionUpload, s_uptime));
        s_downloadrate = static_cast<CStatTreeItemRateCounter*>(tmpRoot1->AddChild(new CStatTreeItemRateCounter(wxTRANSLATE("Max download rate (Session): %s"), true, 30000)));
        s_uploadrate = static_cast<CStatTreeItemRateCounter*>(tmpRoot1->AddChild(new CStatTreeItemRateCounter(wxTRANSLATE("Max upload rate (Session): %s"), true, 30000)));
        s_reconnects = static_cast<CStatTreeItemReconnects*>(tmpRoot1->AddChild(new CStatTreeItemReconnects(wxTRANSLATE("Reconnects: %i"))));
        s_sinceFirstTransfer = static_cast<CStatTreeItemTimer*>(tmpRoot1->AddChild(new CStatTreeItemTimer(wxTRANSLATE("Time Since First Transfer: %s"), stHideIfZero)));
        s_sinceConnected = static_cast<CStatTreeItemTimer*>(tmpRoot1->AddChild(new CStatTreeItemTimer(wxTRANSLATE("Connected To Server Since: %s"))));
        s_activeConnections = static_cast<CStatTreeItemCounterMax*>(tmpRoot1->AddChild(new CStatTreeItemCounterMax(wxTRANSLATE("Active Connections (estimate): %i"))));
        s_limitReached = static_cast<CStatTreeItemMaxConnLimitReached*>(tmpRoot1->AddChild(new CStatTreeItemMaxConnLimitReached(wxTRANSLATE("Max Connection Limit Reached: %s"))));
        s_avgConnections = static_cast<CStatTreeItemSimple*>(tmpRoot1->AddChild(new CStatTreeItemSimple(wxTRANSLATE("Average Connections (estimate): %g"))));
        s_avgConnections->SetValue(0.0);
        tmpRoot1->AddChild(new CStatTreeItemPeakConnections(wxTRANSLATE("Peak Connections (estimate): %i")));

        s_clients = static_cast<CStatTreeItemHiddenCounter*>(s_statTree->AddChild(new CStatTreeItemHiddenCounter(wxTRANSLATE("Clients"), stSortChildren | stSortByValue)));
        s_unknown = static_cast<CStatTreeItemCounter*>(s_clients->AddChild(new CStatTreeItemCounter(wxTRANSLATE("Unknown: %s")), 6));
        //s_lowID = static_cast<CStatTreeItem*>(s_clients->AddChild(new CStatTreeItem(wxTRANSLATE("LowID: %u (%.2f%% Total %.2f%% Known)")), 5));
        //s_secIdentOnOff = static_cast<CStatTreeItem*>(s_clients->AddChild(new CStatTreeItem(wxTRANSLATE("SecIdent On/Off: %u (%.2f%%) : %u (%.2f%%)")), 4));
#ifdef __DEBUG__
        s_hasSocket = static_cast<CStatTreeItemNativeCounter*>(s_clients->AddChild(new CStatTreeItemNativeCounter(wxT("HasSocket: %s")), 3));
#endif
        s_filtered = static_cast<CStatTreeItemNativeCounter*>(s_clients->AddChild(new CStatTreeItemNativeCounter(wxTRANSLATE("Filtered: %s")), 2));
        s_banned = static_cast<CStatTreeItemNativeCounter*>(s_clients->AddChild(new CStatTreeItemNativeCounter(wxTRANSLATE("Banned: %s")), 1));
        s_clients->AddChild(new CStatTreeItemTotalClients(wxTRANSLATE("Total: %i Known: %i"), s_clients, s_unknown), 0x80000000);

        // TODO: Use counters?
        tmpRoot1 = s_statTree->AddChild(new CStatTreeItemBase(wxTRANSLATE("Servers")));
        s_workingServers = static_cast<CStatTreeItemSimple*>(tmpRoot1->AddChild(new CStatTreeItemSimple(wxTRANSLATE("Working Servers: %i"))));
        s_failedServers = static_cast<CStatTreeItemSimple*>(tmpRoot1->AddChild(new CStatTreeItemSimple(wxTRANSLATE("Failed Servers: %i"))));
        s_totalServers = static_cast<CStatTreeItemNativeCounter*>(tmpRoot1->AddChild(new CStatTreeItemNativeCounter(wxTRANSLATE("Total: %s"))));
        s_deletedServers = static_cast<CStatTreeItemNativeCounter*>(tmpRoot1->AddChild(new CStatTreeItemNativeCounter(wxTRANSLATE("Deleted Servers: %s"))));
        s_filteredServers = static_cast<CStatTreeItemNativeCounter*>(tmpRoot1->AddChild(new CStatTreeItemNativeCounter(wxTRANSLATE("Filtered Servers: %s"))));
        s_usersOnWorking = static_cast<CStatTreeItemSimple*>(tmpRoot1->AddChild(new CStatTreeItemSimple(wxTRANSLATE("Users on Working Servers: %llu"))));
        s_filesOnWorking = static_cast<CStatTreeItemSimple*>(tmpRoot1->AddChild(new CStatTreeItemSimple(wxTRANSLATE("Files on Working Servers: %llu"))));
        s_totalUsers = static_cast<CStatTreeItemSimple*>(tmpRoot1->AddChild(new CStatTreeItemSimple(wxTRANSLATE("Total Users: %llu"))));
        s_totalFiles = static_cast<CStatTreeItemSimple*>(tmpRoot1->AddChild(new CStatTreeItemSimple(wxTRANSLATE("Total Files: %llu"))));
        s_serverOccupation = static_cast<CStatTreeItemSimple*>(tmpRoot1->AddChild(new CStatTreeItemSimple(wxTRANSLATE("Server Occupation: %.2f%%"))));
        s_serverOccupation->SetValue(0.0);

        tmpRoot1 = s_statTree->AddChild(new CStatTreeItemBase(wxTRANSLATE("Shared Files")));
        s_numberOfShared = static_cast<CStatTreeItemCounter*>(tmpRoot1->AddChild(new CStatTreeItemCounter(wxTRANSLATE("Number of Shared Files: %s"))));
        s_sizeOfShare = static_cast<CStatTreeItemCounter*>(tmpRoot1->AddChild(new CStatTreeItemCounter(wxTRANSLATE("Total size of Shared Files: %s"))));
        s_sizeOfShare->SetDisplayMode(dmBytes);
        tmpRoot1->AddChild(new CStatTreeItemAverage(wxTRANSLATE("Average file size: %s"), s_sizeOfShare, s_numberOfShared, dmBytes));
}


void CStatistics::UpdateStatsTree()
{
        // get sort orders right
        s_sessionUpload->ReSortChildren();
        s_sessionDownload->ReSortChildren();
        s_clients->ReSortChildren();
        s_foundSources->ReSortChildren();
        // TODO: sort OS_Info subtrees.

        s_avgConnections->SetValue(theApp->listensocket->GetAverageConnections());

        // get serverstats
        // TODO: make these realtime, too
        uint32 servfail;
        uint32 servuser;
        uint32 servfile;
        uint32 servtuser;
        uint32 servtfile;
        float servocc;
        theApp->serverlist->GetStatus(servfail, servuser, servfile, servtuser, servtfile, servocc);
        s_workingServers->SetValue((uint64)((*s_totalServers)-servfail));
        s_failedServers->SetValue((uint64)servfail);
        s_usersOnWorking->SetValue((uint64)servuser);
        s_filesOnWorking->SetValue((uint64)servfile);
        s_totalUsers->SetValue((uint64)servtuser);
        s_totalFiles->SetValue((uint64)servtfile);
        s_serverOccupation->SetValue(servocc);
}


void CStatistics::AddSourceOrigin(unsigned origin)
{
        CStatTreeItemCounter* counter = static_cast<CStatTreeItemCounter*>(s_foundSources->GetChildById(0x0100 + origin));
        if (counter) {
                ++(*counter);
        } else {
                counter = new CStatTreeItemCounter(OriginToText(origin) + wxT(": %s"), stHideIfZero | stShowPercent);
                ++(*counter);
                s_foundSources->AddChild(counter, 0x0100 + origin);
        }
}

void CStatistics::RemoveSourceOrigin(unsigned origin)
{
        CStatTreeItemCounter* counter = static_cast<CStatTreeItemCounter*>(s_foundSources->GetChildById(0x0100 + origin));
        wxASSERT(counter);
        --(*counter);
}

uint32 GetSoftID(uint8 SoftType)
{
        // prevent appearing multiple tree entries with the same name
        // this should be kept in sync with GetSoftName().
        switch (SoftType) {
                case SO_OLDEMULE:
                        return 0x0100 + SO_EMULE;
                case SO_NEW_SHAREAZA:
                case SO_NEW2_SHAREAZA:
                        return 0x0100 + SO_SHAREAZA;
                case SO_NEW2_MLDONKEY:
                        return 0x0100 + SO_NEW_MLDONKEY;
                default:
                        return 0x0100 + SoftType;
        }
}

void CStatistics::AddDownloadFromSoft(uint8 SoftType, uint32 bytes)
{
        AddReceivedBytes(bytes);

        uint32 id = GetSoftID(SoftType);

        if (s_sessionDownload->HasChildWithId(id)) {
                (*static_cast<CStatTreeItemCounter*>(s_sessionDownload->GetChildById(id))) += bytes;
        } else {
                CStatTreeItemCounter* tmp = new CStatTreeItemCounter(GetSoftName(SoftType) + wxT(": %s"));
                tmp->SetDisplayMode(dmBytes);
                (*tmp) += bytes;
                s_sessionDownload->AddChild(tmp, id);
        }
}

void CStatistics::AddUploadToSoft(uint8 SoftType, uint32 bytes)
{
        uint32 id = GetSoftID(SoftType);

        if (s_sessionUpload->HasChildWithId(id)) {
                (*static_cast<CStatTreeItemCounter*>(s_sessionUpload->GetChildById(id))) += bytes;
        } else {
                CStatTreeItemCounter* tmp = new CStatTreeItemCounter(GetSoftName(SoftType) + wxT(": %s"));
                tmp->SetDisplayMode(dmBytes);
                (*tmp) += bytes;
                s_sessionUpload->AddChild(tmp, id);
        }
}

inline bool SupportsOSInfo(unsigned clientSoft)
{
        return (clientSoft == SO_AMULE) || (clientSoft == SO_HYDRANODE) || (clientSoft == SO_NEW2_MLDONKEY);
}

// Do some random black magic to strings to get a relatively unique number for them.
uint32 GetIdFromString(const wxString& str)
{
        uint32 id = 0;
        for (unsigned i = 0; i < str.Length(); ++i) {
                unsigned old_id = id;
                id += (uint32)str.GetChar(i);
                id <<= 2;
                id ^= old_id;
                id -= old_id;
        }
        return (((id >> 1) + id) | 0x00000100) & 0x7fffffff;
}

void CStatistics::AddKnownClient(CUpDownClient *pClient)
{
        ++(*s_clients);

        uint32 clientSoft = pClient->GetClientSoft();
        uint32 id = GetSoftID(clientSoft);

        CStatTreeItemCounter *client;

        if (s_clients->HasChildWithId(id)) {
                client = static_cast<CStatTreeItemCounter*>(s_clients->GetChildById(id));
                ++(*client);
        } else {
                uint32 flags = stSortChildren | stShowPercent | stHideIfZero;
                if (!SupportsOSInfo(clientSoft)) {
                        flags |= stCapChildren;
                }
                client = new CStatTreeItemCounter(GetSoftName(clientSoft) + wxT(": %s"), flags);
                ++(*client);
                s_clients->AddChild(client, id);
                if (SupportsOSInfo(clientSoft)) {
                        client->AddChild(new CStatTreeItemBase(wxTRANSLATE("Version"), stSortChildren | stCapChildren), 2);
                        client->AddChild(new CStatTreeItemBase(wxTRANSLATE("Operating System"), stSortChildren | stSortByValue), 1);
                }
        }

        CStatTreeItemBase *versionRoot = SupportsOSInfo(clientSoft) ? client->GetChildById(2) : client;
        uint32 clientVersion = pClient->GetVersion();

        if (versionRoot->HasChildWithId(clientVersion)) {
                CStatTreeItemCounter *version = static_cast<CStatTreeItemCounter*>(versionRoot->GetChildById(clientVersion));
                ++(*version);
        } else {
                const wxString& versionStr = pClient->GetVersionString();
                CStatTreeItemCounter *version = new CStatTreeItemCounter((versionStr.IsEmpty() ? wxString(wxTRANSLATE("Unknown")) : versionStr) + wxT(": %s"), stShowPercent | stHideIfZero);
                ++(*version);
                versionRoot->AddChild(version, clientVersion, SupportsOSInfo(clientSoft));
        }

        if (SupportsOSInfo(clientSoft)) {
                const wxString& OSInfo = pClient->GetClientOSInfo();
                uint32 OS_ID = OSInfo.IsEmpty() ? 0 : GetIdFromString(OSInfo);
                CStatTreeItemBase* OSRoot = client->GetChildById(1);
                CStatTreeItemCounter* OSNode = static_cast<CStatTreeItemCounter*>(OSRoot->GetChildById(OS_ID));
                if (OSNode) {
                        ++(*OSNode);
                } else {
                        OSNode = new CStatTreeItemCounter((OS_ID ? OSInfo : wxString(wxTRANSLATE("Not Received"))) + wxT(": %s"), stShowPercent | stHideIfZero);
                        ++(*OSNode);
                        OSRoot->AddChild(OSNode, OS_ID, true);
                }
        }
}

void CStatistics::RemoveKnownClient(uint32 clientSoft, uint32 clientVersion, const wxString& OSInfo)
{
        --(*s_clients);

        uint32 id = GetSoftID(clientSoft);

        CStatTreeItemCounter *client = static_cast<CStatTreeItemCounter*>(s_clients->GetChildById(id));
        wxASSERT(client);
        --(*client);

        CStatTreeItemBase *versionRoot = SupportsOSInfo(clientSoft) ? client->GetChildById(2) : client;

        CStatTreeItemCounter *version = static_cast<CStatTreeItemCounter*>(versionRoot->GetChildById(clientVersion));
        wxASSERT(version);
        --(*version);

        if (SupportsOSInfo(clientSoft)) {
                uint32 OS_ID = OSInfo.IsEmpty() ? 0 : GetIdFromString(OSInfo);
                CStatTreeItemCounter* OSNode = static_cast<CStatTreeItemCounter*>(client->GetChildById(1)->GetChildById(OS_ID));
                wxASSERT(OSNode);
                --(*OSNode);
        }
}

#else /* CLIENT_GUI */

CStatistics::CStatistics(CRemoteConnect &conn)
        : m_conn(conn)
{
        s_start_time = GetTickCount64();

        // Init Tree
        s_statTree = new CStatTreeItemBase(_("Statistics"), 0);

        // Clear stat data container
        for (int i = 0; i < sdTotalItems; ++i) {
                s_statData[i] = 0;
        }
}


CStatistics::~CStatistics()
{
        delete s_statTree;
}


void CStatistics::UpdateStats(const CECPacket* stats)
{
        s_statData[sdUpload] = stats->GetTagByNameSafe(EC_TAG_STATS_UL_SPEED)->GetInt();
        s_statData[sdUpOverhead] = stats->GetTagByNameSafe(EC_TAG_STATS_UP_OVERHEAD)->GetInt();
        s_statData[sdDownload] = stats->GetTagByNameSafe(EC_TAG_STATS_DL_SPEED)->GetInt();
        s_statData[sdDownOverhead] = stats->GetTagByNameSafe(EC_TAG_STATS_DOWN_OVERHEAD)->GetInt();
        s_statData[sdWaitingClients] = stats->GetTagByNameSafe(EC_TAG_STATS_UL_QUEUE_LEN)->GetInt();
        s_statData[sdBannedClients] = stats->GetTagByNameSafe(EC_TAG_STATS_BANNED_COUNT)->GetInt();
        s_statData[sdED2KUsers] = stats->GetTagByNameSafe(EC_TAG_STATS_ED2K_USERS)->GetInt();
        s_statData[sdKadUsers] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_USERS)->GetInt();
        s_statData[sdED2KFiles] = stats->GetTagByNameSafe(EC_TAG_STATS_ED2K_FILES)->GetInt();
        s_statData[sdKadFiles] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_FILES)->GetInt();
        s_statData[sdKadFirewalledUDP] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_FIREWALLED_UDP)->GetInt();
        s_statData[sdKadIndexedSources] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_INDEXED_SOURCES)->GetInt();
        s_statData[sdKadIndexedKeywords] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_INDEXED_KEYWORDS)->GetInt();
        s_statData[sdKadIndexedNotes] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_INDEXED_NOTES)->GetInt();
        s_statData[sdKadIndexedLoad] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_INDEXED_LOAD)->GetInt();
        s_statData[sdKadIPAdress] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_IP_ADRESS)->GetInt();
        s_statData[sdKadNodes] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_NODES)->GetInt();
        s_statData[sdBuddyStatus] = stats->GetTagByNameSafe(EC_TAG_STATS_BUDDY_STATUS)->GetInt();
        s_statData[sdBuddyIP] = stats->GetTagByNameSafe(EC_TAG_STATS_BUDDY_IP)->GetInt();
        s_statData[sdBuddyPort] = stats->GetTagByNameSafe(EC_TAG_STATS_BUDDY_PORT)->GetInt();
        s_statData[sdKadInLanMode] = stats->GetTagByNameSafe(EC_TAG_STATS_KAD_IN_LAN_MODE)->GetInt();
        s_statData[sdTotalSentBytes] = stats->GetTagByNameSafe(EC_TAG_STATS_TOTAL_SENT_BYTES)->GetInt();
        s_statData[sdTotalReceivedBytes] = stats->GetTagByNameSafe(EC_TAG_STATS_TOTAL_RECEIVED_BYTES)->GetInt();
        s_statData[sdSharedFileCount] = stats->GetTagByNameSafe(EC_TAG_STATS_SHARED_FILE_COUNT)->GetInt();

        const CECTag * LoggerTag = stats->GetTagByName(EC_TAG_STATS_LOGGER_MESSAGE);
        if (LoggerTag) {
                for (CECTag::const_iterator it = LoggerTag->begin(); it != LoggerTag->end(); ++it) {
                        theApp->AddRemoteLogLine(it->GetStringData());
                }
        }
}


void CStatistics::UpdateStatsTree()
{}


void CStatistics::RebuildStatTreeRemote(const CECTag * tag)
{
        delete s_statTree;
        s_statTree = new CStatTreeItemBase(tag);
}


uint64 CStatistics::GetUptimeMillis()
{
        return GetTickCount64() - s_start_time;
}


uint64 CStatistics::GetUptimeSeconds()
{
        return (GetTickCount64() - s_start_time) / 1000;
}

#endif /* !CLIENT_GUI */

// File_checked_for_headers