Mirrors/privacore-open-source-search-engine
1
0
Fork 1
mirror of https://github.com/privacore/open-source-search-engine.git synced 2025-01-22 02:18:42 -05:00
Code Issues Packages Projects Releases Wiki Activity
master
privacore-open-source-searc.../PageHosts.cpp
Ivan Skytte Jørgensen beeddcf35d Got rid of gb-include.h
2018-07-26 17:29:51 +02:00

900 lines
24 KiB
C++
Raw Permalink Blame History

#include "TcpSocket.h"
#include "HttpServer.h"
#include "HttpRequest.h"
#include "Pages.h"
#include "Hostdb.h"
#include "HostFlags.h"
#include "sort.h"
#include "Conf.h"
#include "ip.h"
#include "GbUtil.h"
#include "hash.h"
static int defaultSort ( const void *i1, const void *i2 );
static int splitTimeSort ( const void *i1, const void *i2 );
static int flagSort ( const void *i1, const void *i2 );
static int resendsSort ( const void *i1, const void *i2 );
static int errorsSort ( const void *i1, const void *i2 );
static int tryagainSort ( const void *i1, const void *i2 );
static int dgramsToSort ( const void *i1, const void *i2 );
static int dgramsFromSort ( const void *i1, const void *i2 );
// . returns false if blocked, true otherwise
// . sets errno on error
// . make a web page displaying the config of this host
// . call g_httpServer.sendDynamicPage() to send it
bool sendPageHosts ( TcpSocket *s , HttpRequest *r ) {
// don't allow pages bigger than 128k in cache
//char *p = buf;
//char *pend = buf + 64*1024;
StackBuf<64*1024> sb;
// XML OR JSON
char format = r->getReplyFormat();
// if ( format == FORMAT_XML || format == FORMAT_JSON )
// return sendPageHostsInXmlOrJson( s , r );
// check for a sort request
int32_t sort = r->getLong ( "sort", -1 );
// sort by hostid with dead on top by default
if ( sort == -1 ) sort = 16;
const char *coll = r->getString ( "c" );
//char *pwd = r->getString ( "pwd" );
// check for setnote command
int32_t setnote = r->getLong("setnote", 0);
int32_t setsparenote = r->getLong("setsparenote", 0);
// check for replace host command
int32_t replaceHost = r->getLong("replacehost", 0);
// set note...
if ( setnote == 1 ) {
// get the host id to change
int32_t host = r->getLong("host", -1);
if ( host == -1 ) goto skipReplaceHost;
// get the note to set
int32_t noteLen;
const char *note = r->getString("note", &noteLen, "", 0);
// set the note
g_hostdb.setNote(host, note, noteLen);
}
// set spare note...
if ( setsparenote == 1 ) {
// get the host id to change
int32_t spare = r->getLong("spare", -1);
if ( spare == -1 ) goto skipReplaceHost;
// get the note to set
int32_t noteLen;
const char *note = r->getString("note", &noteLen, "", 0);
// set the note
g_hostdb.setSpareNote(spare, note, noteLen);
}
// replace host...
if ( replaceHost == 1 ) {
// get the host ids to swap
int32_t rhost = r->getLong("rhost", -1);
int32_t rspare = r->getLong("rspare", -1);
if ( rhost == -1 || rspare == -1 )
goto skipReplaceHost;
// replace
g_hostdb.replaceHost(rhost, rspare);
}
skipReplaceHost:
int32_t refreshRate = r->getLong("rr", 0);
if(refreshRate > 0 && format == FORMAT_HTML )
sb.safePrintf("<META HTTP-EQUIV=\"refresh\" "
"content=\"%" PRId32"\"\\>",
refreshRate);
// print standard header
// char *pp = sb.getBuf();
// char *ppend = sb.getBufEnd();
// if ( pp ) {
if ( format == FORMAT_HTML ) g_pages.printAdminTop ( &sb , s , r );
// sb.incrementLength ( pp - sb.getBuf() );
// }
const char *colspan = "30";
//char *shotcol = "";
char shotcol[1024];
shotcol[0] = '\0';
const char *cs = coll;
if ( ! cs ) cs = "";
if ( g_conf.m_useShotgun && format == FORMAT_HTML ) {
colspan = "31";
//shotcol = "<td><b>ip2</b></td>";
sprintf ( shotcol, "<td><a href=\"/admin/hosts?c=%s"
"&sort=2\">"
"<b>ping2</b></td></a>",
cs);
}
// print host table
if ( format == FORMAT_HTML )
sb.safePrintf (
"<table %s>"
"<tr><td colspan=%s><center>"
"<b>Hosts "
"(<a href=\"/admin/hosts?c=%s&sort=%" PRId32"&resetstats=1\">"
"reset)</a></b>"
"</td></tr>"
"<tr bgcolor=#%s>"
"<td></td>"
"<td><a href=\"/admin/hosts?c=%s&sort=0\">"
"<b>hostId</b></a></td>"
"<td><b>host ip</b></td>"
"<td><b>shard</b></td>"
"<td><b>mirror</b></td>" // mirror # within the shard
"<td><b>http port</b></td>"
"<td><b>GB version</b></td>"
"<td><a href=\"/admin/hosts?c=%s&sort=3\">"
"<b>dgrams resent</b></a></td>"
"<td><b>try agains recvd</b></td>"
"<td><a href=\"/admin/hosts?c=%s&sort=13\">"
"<b>avg split time</b></a></td>"
"<td><b>splits done</b></a></td>"
"<td><a href=\"/admin/hosts?c=%s&sort=12\">"
"<b>status</b></a></td>"
"<td><b>docs indexed</a></td>"
"%s"
"<td><b>note</b></td>",
TABLE_STYLE ,
colspan ,
cs, sort,
DARK_BLUE ,
cs,
cs,
cs,
cs,
shotcol );
// loop through each host we know and print it's stats
int32_t nh = g_hostdb.getNumHosts();
// should we reset resends, errorsRecvd and ETRYAGAINS recvd?
if ( r->getLong("resetstats",0) ) {
for ( int32_t i = 0 ; i < nh ; i++ ) {
// get the ith host (hostId)
Host *h = g_hostdb.getHost ( i );
h->m_totalResends = 0;
h->m_errorReplies = 0;
h->m_etryagains = 0;
h->m_dgramsTo = 0;
h->m_dgramsFrom = 0;
h->m_splitTimes = 0;
h->m_splitsDone = 0;
}
}
// sort hosts if needed
int32_t hostSort [ MAX_HOSTS ];
for ( int32_t i = 0 ; i < nh ; i++ )
hostSort [ i ] = i;
switch ( sort ) {
case 3: gbsort ( hostSort, nh, sizeof(int32_t), resendsSort ); break;
case 4: gbsort ( hostSort, nh, sizeof(int32_t), errorsSort ); break;
case 5: gbsort ( hostSort, nh, sizeof(int32_t), tryagainSort ); break;
case 6: gbsort ( hostSort, nh, sizeof(int32_t), dgramsToSort ); break;
case 7: gbsort ( hostSort, nh, sizeof(int32_t), dgramsFromSort ); break;
//case 8:
case 12:gbsort ( hostSort, nh, sizeof(int32_t), flagSort ); break;
case 13:gbsort ( hostSort, nh, sizeof(int32_t), splitTimeSort ); break;
//case 15:
case 16:gbsort ( hostSort, nh, sizeof(int32_t), defaultSort ); break;
}
if ( format == FORMAT_XML ) {
sb.safePrintf("<response>\n");
sb.safePrintf("\t<statusCode>0</statusCode>\n");
sb.safePrintf("\t<statusMsg>Success</statusMsg>\n");
}
if ( format == FORMAT_JSON ) {
sb.safePrintf("{\"response\":{\n");
sb.safePrintf("\t\"statusCode\":0,\n");
sb.safePrintf("\t\"statusMsg\":\"Success\",\n");
}
// compute majority gb version so we can highlight bad out of sync
// gb versions in red below
int32_t majorityHash32 = 0;
int32_t lastCount = 0;
// get majority gb version
for ( int32_t si = 0 ; si < nh ; si++ ) {
int32_t i = hostSort[si];
// get the ith host (hostId)
Host *h = g_hostdb.getHost ( i );
const char *vbuf = h->m_runtimeInformation.m_gbVersionStr;
int32_t vhash32 = hash32n ( vbuf );
if ( vhash32 == majorityHash32 ) lastCount++;
else lastCount--;
if ( lastCount < 0 ) majorityHash32 = vhash32;
}
if(format==FORMAT_JSON)
sb.safePrintf("\t\"hosts\": [\n");
g_hostdb.setOurFlags();
g_hostdb.setOurTotalDocsIndexed();
for ( int32_t si = 0 ; si < nh ; si++ ) {
int32_t i = hostSort[si];
// get the ith host (hostId)
Host *h = g_hostdb.getHost ( i );
const char *vbuf = h->m_runtimeInformation.m_gbVersionStr;
// get hash
int32_t vhash32 = hash32n ( vbuf );
const char *vbuf1 = "";
const char *vbuf2 = "";
if ( vhash32 != majorityHash32 ) {
vbuf1 = "<font color=red><b>";
vbuf2 = "</font></b>";
}
//int32_t switchGroup = 0;
//if ( g_hostdb.m_indexSplits > 1 )
// switchGroup = h->m_group%g_hostdb.m_indexSplits;
// host can have 2 ip addresses, get the one most
// similar to that of the requester
int32_t eip = g_hostdb.getBestIp ( h );
char ipbuf3[64];
iptoa(eip,ipbuf3);
// split time, don't divide by zero!
int32_t splitTime = 0;
if ( h->m_splitsDone )
splitTime = h->m_splitTimes / h->m_splitsDone;
//char flagString[32];
StackBuf<64> fb;
if(h->m_runtimeInformation.m_valid) {
// does its hosts.conf file disagree with ours?
if ( h->isHostsConfCRCKnown() && !h->hasSameHostsConfCRC() ) {
if(format == FORMAT_HTML)
fb.safePrintf("<font color=red><b title=\"Hosts.conf in disagreement with ours.\">H</b></font>");
else
fb.safePrintf("Hosts.conf in disagreement with ours");
}
int32_t flags = h->m_runtimeInformation.m_flags;
// recovery mode? reocvered from coring?
if ((flags & PFLAG_RECOVERYMODE)&& format == FORMAT_HTML ) {
fb.safePrintf("<b title=\"Recovered from core"
"\">x</b>");
}
if ((flags & PFLAG_RECOVERYMODE)&& format != FORMAT_HTML )
fb.safePrintf("Recovered from core");
// rebalancing?
if ( (flags & PFLAG_REBALANCING)&& format == FORMAT_HTML )
fb.safePrintf("<b title=\"Currently "
"rebalancing\">R</b>");
if ( (flags & PFLAG_REBALANCING)&& format != FORMAT_HTML )
fb.safePrintf("Currently rebalancing");
// has recs that should be in another shard? indicates
// we need to rebalance or there is a bad hosts.conf
if ((flags & PFLAG_FOREIGNRECS) && format == FORMAT_HTML )
fb.safePrintf("<font color=red><b title=\"Foreign "
"data "
"detected. Needs rebalance.\">F"
"</b></font>");
if ((flags & PFLAG_FOREIGNRECS) && format != FORMAT_HTML )
fb.safePrintf("Foreign data detected. "
"Needs rebalance.");
// if it has spiders going on say "S" with # as the superscript
if ((flags & PFLAG_HASSPIDERS) && format == FORMAT_HTML )
fb.safePrintf ( "<span title=\"Spidering\">S</span>");
if ((flags & PFLAG_HASSPIDERS) && format != FORMAT_HTML )
fb.safePrintf ( "Spidering");
// say "M" if merging
if ( (flags & PFLAG_MERGING) && format == FORMAT_HTML )
fb.safePrintf ( "<span title=\"Merging\">M</span>");
if ( (flags & PFLAG_MERGING) && format != FORMAT_HTML )
fb.safePrintf ( "Merging");
// say "D" if dumping
if ( (flags & PFLAG_DUMPING) && format == FORMAT_HTML )
fb.safePrintf ( "<span title=\"Dumping\">D</span>");
if ( (flags & PFLAG_DUMPING) && format != FORMAT_HTML )
fb.safePrintf ( "Dumping");
// say "y" if doing the daily merge
if ( !(flags & PFLAG_MERGEMODE0) )
fb.safePrintf ( "y");
if(format == FORMAT_HTML) {
if(!h->m_spiderEnabled)
fb.safePrintf("<span title=\"Spider Disabled\" style=\"text-decoration:line-through;\">S</span>");
if(!h->m_queryEnabled)
fb.safePrintf("<span title=\"Query Disabled\" style=\"text-decoration:line-through;\">Q</span>");
}
} else {
fb.safePrintf("??");
}
if ( fb.length() == 0 && format == FORMAT_HTML )
fb.safePrintf("&nbsp;");
fb.nullTerm();
const char *bg = g_hostdb.isDead(h) ? "ffa6a6" : LIGHT_BLUE;
//
// BEGIN XML OUTPUT
//
if ( format == FORMAT_XML ) {
sb.safePrintf("\t<host>\n"
"\t\t<name><![CDATA["
);
cdataEncode(&sb, h->m_hostname);
sb.safePrintf("]]></name>\n");
sb.safePrintf("\t\t<shard>%" PRId32"</shard>\n",
(int32_t)h->m_shardNum);
sb.safePrintf("\t\t<mirror>%" PRId32"</mirror>\n",
h->m_stripe);
char ipbuf[16];
sb.safePrintf("\t\t<ip1>%s</ip1>\n",
iptoa(h->m_ip,ipbuf));
sb.safePrintf("\t\t<ip2>%s</ip2>\n",
iptoa(h->m_ipShotgun,ipbuf));
sb.safePrintf("\t\t<httpPort>%" PRId32"</httpPort>\n",
(int32_t)h->getInternalHttpPort());
sb.safePrintf("\t\t<udpPort>%" PRId32"</udpPort>\n",
(int32_t)h->m_port);
sb.safePrintf("\t\t<dnsPort>%" PRId32"</dnsPort>\n",
(int32_t)h->m_dnsClientPort);
sb.safePrintf("\t\t<gbVersion>%s</gbVersion>\n",vbuf);
sb.safePrintf("\t\t<resends>%" PRId32"</resends>\n",
h->m_totalResends.load());
sb.safePrintf("\t\t<errorTryAgains>%" PRId32
"</errorTryAgains>\n",
h->m_etryagains.load());
/*
sb.safePrintf("\t\t<dgramsTo>%" PRId64"</dgramsTo>\n",
h->m_dgramsTo);
sb.safePrintf("\t\t<dgramsFrom>%" PRId64"</dgramsFrom>\n",
h->m_dgramsFrom);
*/
sb.safePrintf("\t\t<splitTime>%" PRId32"</splitTime>\n",
splitTime);
sb.safePrintf("\t\t<splitsDone>%" PRId32"</splitsDone>\n",
h->m_splitsDone);
sb.safePrintf("\t\t<status><![CDATA[%s]]></status>\n",
fb.getBufStart());
sb.safePrintf("\t\t<docsIndexed>%" PRId32
"</docsIndexed>\n",
h->m_runtimeInformation.m_totalDocsIndexed);
sb.safePrintf("\t\t<note>%s</note>\n",
h->m_note );
sb.safePrintf("\t\t<spider>%" PRId32"</spider>\n",
(int32_t)h->m_spiderEnabled );
sb.safePrintf("\t\t<query>%" PRId32"</query>\n",
(int32_t)h->m_queryEnabled );
sb.safePrintf("\t</host>\n");
continue;
}
//
// END XML OUTPUT
//
//
// BEGIN JSON OUTPUT
//
if ( format == FORMAT_JSON ) {
sb.safePrintf("\t\t\t{\n");
sb.safePrintf("\t\t\t\t\"name\":\"%s\",\n",h->m_hostname);
sb.safePrintf("\t\t\t\t\"shard\":%" PRId32",\n",
(int32_t)h->m_shardNum);
sb.safePrintf("\t\t\t\t\"mirror\":%" PRId32",\n", h->m_stripe);
char ipbuf[16];
sb.safePrintf("\t\t\t\t\"ip1\":\"%s\",\n",iptoa(h->m_ip,ipbuf));
sb.safePrintf("\t\t\t\t\"ip2\":\"%s\",\n",iptoa(h->m_ipShotgun,ipbuf));
sb.safePrintf("\t\t\t\t\"httpPort\":%" PRId32",\n",
(int32_t)h->getInternalHttpPort());
sb.safePrintf("\t\t\t\t\"udpPort\":%" PRId32",\n",
(int32_t)h->m_port);
sb.safePrintf("\t\t\t\t\"dnsPort\":%" PRId32",\n",
(int32_t)h->m_dnsClientPort);
sb.safePrintf("\t\t\t\t\"gbVersion\":\"%s\",\n",vbuf);
sb.safePrintf("\t\t\t\t\"resends\":%" PRId32",\n",
h->m_totalResends.load());
/*
sb.safePrintf("\t\t\t\t\"errorReplies\":%" PRId32",\n",
h->m_errorReplies);
*/
sb.safePrintf("\t\t\t\t\"errorTryAgains\":%" PRId32",\n",
h->m_etryagains.load());
/*
sb.safePrintf("\t\t\t\t\"dgramsTo\":%" PRId64",\n",
h->m_dgramsTo);
sb.safePrintf("\t\t\t\t\"dgramsFrom\":%" PRId64",\n",
h->m_dgramsFrom);
*/
sb.safePrintf("\t\t\t\t\"splitTime\":%" PRId32",\n",
splitTime);
sb.safePrintf("\t\t\t\t\"splitsDone\":%" PRId32",\n",
h->m_splitsDone);
sb.safePrintf("\t\t\t\t\"status\":\"%s\",\n",
fb.getBufStart());
sb.safePrintf("\t\t\t\t\"docsIndexed\":%" PRId32",\n",
h->m_runtimeInformation.m_totalDocsIndexed);
sb.safePrintf("\t\t\t\t\"note\":\"%s\",\n",
h->m_note );
sb.safePrintf("\t\t\t\t\"spider\":\"%" PRId32"\",\n",
(int32_t)h->m_spiderEnabled );
sb.safePrintf("\t\t\t\t\"query\":\"%" PRId32"\"\n",
(int32_t)h->m_queryEnabled );
sb.safePrintf("\t\t\t}");
if(si+1 < nh)
sb.safePrintf(",");
sb.safePrintf("\n");
continue;
}
//
// END JSON OUTPUT
//
sb.safePrintf (
"<tr bgcolor=#%s>"
"<td>%s</td>"
"<td><a href=\"http://%s:%d/admin/hosts?"
""
"c=%s"
"&sort=%" PRId32"\">%" PRId32"</a></td>"
"<td>%s</td>" // hostname
"<td>%" PRId32"</td>" // group
"<td>%" PRId32"</td>" // stripe
"<td>%d</td>" // http port
// gb version
"<td><nobr>%s%s%s</nobr></td>"
// resends
"<td>%" PRId32"</td>"
// etryagains
"<td>%" PRId32"</td>"
// split time
"<td>%" PRId32"</td>"
// splits done
"<td>%" PRId32"</td>"
// flags
"<td>%s</td>"
// docs indexed
"<td>%" PRId32"</td>"
//note
"<td nowrap=1>%s</td>"
"</tr>",
bg,
(h==g_hostdb.getMyHost() ? "&Rightarrow;" : "&nbsp;"),
ipbuf3, h->getInternalHttpPort(),
cs, sort,
i,
h->m_hostname,
(int32_t)h->m_shardNum,
h->m_stripe,
h->getInternalHttpPort(),
vbuf1,
vbuf,
vbuf2,
h->m_totalResends.load(),
h->m_etryagains.load(),
splitTime,
h->m_splitsDone,
fb.getBufStart(),
h->m_runtimeInformation.m_totalDocsIndexed,
h->m_note );
}
if ( format == FORMAT_XML ) {
sb.safePrintf("</response>\n");
return g_httpServer.sendDynamicPage ( s ,
sb.getBufStart(),
sb.length() ,
0,
false,
"text/xml");
}
if ( format == FORMAT_JSON ) {
sb.safePrintf("\t\t]");
sb.safePrintf("\n}");
sb.safePrintf("}");
return g_httpServer.sendDynamicPage ( s ,
sb.getBufStart(),
sb.length() ,
0,
false,
"application/json");
}
// end the table now
sb.safePrintf ( "</table><br>\n" );
if( g_hostdb.m_numSpareHosts ) {
// print spare hosts table
sb.safePrintf("<table %s>"
"<tr class=hdrow><td colspan=10><center>"
"<b>Spares</b>"
"</td></tr>"
"<tr bgcolor=#%s>"
"<td><b>spareId</td>"
"<td><b>host name</td>"
"<td><b>ip1</td>"
"<td><b>ip2</td>"
"<td><b>http port</td>"
"<td><b>note</td>",
TABLE_STYLE,
DARK_BLUE);
for ( int32_t i = 0; i < g_hostdb.m_numSpareHosts; i++ ) {
// get the ith host (hostId)
Host *h = g_hostdb.getSpare ( i );
char ipbuf1[64];
char ipbuf2[64];
iptoa(h->m_ip,ipbuf1);
iptoa(h->m_ipShotgun,ipbuf2);
// print it
sb.safePrintf("<tr bgcolor=#%s>"
"<td>%" PRId32"</td>"
"<td>%s</td>"
"<td>%s</td>"
"<td>%s</td>"
"<td>%d</td>"
"<td>%s</td>"
"</tr>",
LIGHT_BLUE,
i,
h->m_hostname,
ipbuf1,
ipbuf2,
h->getInternalHttpPort(),
h->m_note);
}
sb.safePrintf ( "</table><br>" );
}
sb.safePrintf(
"<style>"
".poo { background-color:#%s;}\n"
"</style>\n" ,
LIGHT_BLUE );
// print help table
sb.safePrintf (
"<table %s>"
"<tr class=hdrow><td colspan=10><center>"
"<b>Key</b>"
"</td></tr>"
"<tr class=poo>"
"<td>host ip</td>"
"<td>The primary IP address of the host."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>shard</td>"
"<td>"
"The index is split into shards. Which shard does this "
"host serve?"
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>mirror</td>"
"<td>"
"A shard can be mirrored multiple times for "
"data redundancy."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>dgrams resent</td>"
"<td>How many datagrams have had to be resent to a host "
"because it was not ACKed quick enough or because it was "
"fully ACKed but the entire request was resent in case "
"the host was reset."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>try agains recvd</td>"
"<td>How many ETRYAGAIN errors "
"were received in response to a "
"request to add data. Usually because the host's memory "
"is full and it is dumping its data to disk. This number "
"can be high if the host if failing to dump the data "
"to disk because of some malfunction, and it can therefore "
"bottleneck the entire cluster."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>avg split time</td>"
"<td>Average time this host took to compute the docids "
"for a query. Useful for guaging the slowness of a host "
"compare to other hosts."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>splits done</td>"
"<td>Number of queries this host completed. Used in "
"computation of the <i>avg split time</i>."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>status</td>"
"<td>Status flags for the host. See key below."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>docs indexed</td>"
"<td>Number of documents this host has indexed over all "
"collections. All hosts should have close to the same "
"number in a well-sharded situation."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>M (status flag)</td>"
"<td>Indicates host is merging files on disk."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>D (status flag)</td>"
"<td>Indicates host is dumping data to disk."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>S (status flag)</td>"
"<td>Indicates host has outstanding spiders."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>y (status flag)</td>"
"<td>Indicates host is performing the daily merge."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>R (status flag)</td>"
"<td>Indicates host is performing a rebalance operation."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>F (status flag)</td>"
"<td>Indicates host has foreign records and requires "
"a rebalance operation."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>x (status flag)</td>"
"<td>Indicates host has abruptly exited due to a fatal "
"error (cored) and "
"restarted itself. The exponent is how many times it has "
"done this. If no exponent, it only did it once."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>C (status flag)</td>"
"<td>Indicates # of corrupted disk reads."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td>K (status flag)</td>"
"<td>Indicates # of sockets closed from hitting limit."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td><nobr>O (status flag)</nobr></td>"
"<td>Indicates # of times we ran out of memory."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td><nobr>N (status flag)</nobr></td>"
"<td>Indicates host's clock is NOT in sync with host #0. "
"Gigablast should automatically sync on startup, "
"so this would be a problem "
"if it does not go away. Hosts need to have their clocks "
"in sync before they can add data to their index."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td><nobr>U (status flag)</nobr></td>"
"<td>Indicates the number of active UDP transactions "
"which are incoming requests. These will pile up if a "
"host can't handle them fast enough."
"</td>"
"</tr>\n"
"<tr class=poo>"
"<td><nobr>T (status flag)</nobr></td>"
"<td>Indicates the number of active TCP transactions "
"which are either outgoing or incoming requests."
"</td>"
"</tr>\n"
,
TABLE_STYLE
);
sb.safePrintf ( "</table><br></form><br>" );
// . send this page
// . encapsulates in html header and tail
// . make a Mime
return g_httpServer.sendDynamicPage ( s , (char*) sb.getBufStart() ,
sb.length() );
}
int defaultSort ( const void *i1, const void *i2 ) {
Host *h1 = g_hostdb.getHost ( *(int32_t*)i1 );
Host *h2 = g_hostdb.getHost ( *(int32_t*)i2 );
if ( g_hostdb.isDead(h1) && ! g_hostdb.isDead(h2) ) return -1;
if ( g_hostdb.isDead(h2) && ! g_hostdb.isDead(h1) ) return 1;
if ( h1->m_hostId < h2->m_hostId ) return -1;
return 1;
}
int splitTimeSort ( const void *i1, const void *i2 ) {
Host *h1 = g_hostdb.getHost ( *(int32_t*)i1 );
Host *h2 = g_hostdb.getHost ( *(int32_t*)i2 );
int32_t t1 = 0;
int32_t t2 = 0;
if ( h1->m_splitsDone > 0 ) t1 = h1->m_splitTimes / h1->m_splitsDone;
if ( h2->m_splitsDone > 0 ) t2 = h2->m_splitTimes / h2->m_splitsDone;
if ( t1 > t2 ) return -1;
if ( t1 < t2 ) return 1;
return 0;
}
int flagSort ( const void *i1, const void *i2 ) {
Host *h1 = g_hostdb.getHost ( *(int32_t*)i1 );
Host *h2 = g_hostdb.getHost ( *(int32_t*)i2 );
if ( h1->m_runtimeInformation.m_flags > h2->m_runtimeInformation.m_flags ) return -1;
if ( h1->m_runtimeInformation.m_flags < h2->m_runtimeInformation.m_flags ) return 1;
return 0;
}
int resendsSort ( const void *i1, const void *i2 ) {
Host *h1 = g_hostdb.getHost ( *(int32_t*)i1 );
Host *h2 = g_hostdb.getHost ( *(int32_t*)i2 );
if ( h1->m_totalResends > h2->m_totalResends )
return -1;
if ( h1->m_totalResends < h2->m_totalResends )
return 1;
return 0;
}
int errorsSort ( const void *i1, const void *i2 ) {
Host *h1 = g_hostdb.getHost ( *(int32_t*)i1 );
Host *h2 = g_hostdb.getHost ( *(int32_t*)i2 );
if ( h1->m_errorReplies > h2->m_errorReplies ) return -1;
if ( h1->m_errorReplies < h2->m_errorReplies ) return 1;
return 0;
}
int tryagainSort ( const void *i1, const void *i2 ) {
Host *h1 = g_hostdb.getHost ( *(int32_t*)i1 );
Host *h2 = g_hostdb.getHost ( *(int32_t*)i2 );
if ( h1->m_etryagains>h2->m_etryagains)return -1;
if ( h1->m_etryagains<h2->m_etryagains)return 1;
return 0;
}
int dgramsToSort ( const void *i1, const void *i2 ) {
Host *h1 = g_hostdb.getHost ( *(int32_t*)i1 );
Host *h2 = g_hostdb.getHost ( *(int32_t*)i2 );
if ( h1->m_dgramsTo > h2->m_dgramsTo ) return -1;
if ( h1->m_dgramsTo < h2->m_dgramsTo ) return 1;
return 0;
}
int dgramsFromSort ( const void *i1, const void *i2 ) {
Host *h1 = g_hostdb.getHost ( *(int32_t*)i1 );
Host *h2 = g_hostdb.getHost ( *(int32_t*)i2 );
if ( h1->m_dgramsFrom > h2->m_dgramsFrom ) return -1;
if ( h1->m_dgramsFrom < h2->m_dgramsFrom ) return 1;
return 0;
}
Reference in New Issue View Git Blame Copy Permalink