gigablast/open-source-search-engine
1
0
Fork 0
mirror of https://github.com/gigablast/open-source-search-engine.git synced 2024-10-04 12:17:35 +03:00
Code Issues Projects Releases Wiki Activity

show index body parm

Browse Source
This commit is contained in:
mwells 2015-02-01 20:49:27 -07:00
parent 3a146dddc0
commit 784eb53727
2 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Parms.cpp
View File

@ -17714,7 +17714,7 @@ void Parms::init ( ) {
m->m_def = "1"; m->m_def = "1";
m->m_page = PAGE_SPIDER; m->m_page = PAGE_SPIDER;
m->m_obj = OBJ_COLL; m->m_obj = OBJ_COLL;
m->m_flags = PF_CLONE | PF_HIDDEN; m->m_flags = PF_CLONE ;//| PF_HIDDEN;
m++; m++;
m->m_cgi = "apiUrl"; m->m_cgi = "apiUrl";

18
UdpServer.cpp
View File

@ -2940,9 +2940,15 @@ bool UdpServer::readTimeoutPoll ( int64_t now ) {
// maybe QUICKPOLL(0) should at least send/read the udp ports? // maybe QUICKPOLL(0) should at least send/read the udp ports?
// //
// FOR NOW though since hosts do not go down that much // FOR NOW though since hosts do not go down that much
// let's also require that i has been 5 secs or more... // let's also require that it has been 5 secs or more...
// //
int32_t timeout = 5000;
// spider time requests typically have timeouts of 1 year!
// so we end up waiting for the host to come back online
// before the spider can proceed.
if ( slot->m_niceness ) timeout = slot->m_timeout;
// check it // check it
if ( slot->m_maxResends >= 0 && if ( slot->m_maxResends >= 0 &&
// if maxResends it 0, do not do ANY resend! just err out. // if maxResends it 0, do not do ANY resend! just err out.
@ -2951,7 +2957,9 @@ bool UdpServer::readTimeoutPoll ( int64_t now ) {
slot->m_sentBitsOn > slot->m_readAckBitsOn && slot->m_sentBitsOn > slot->m_readAckBitsOn &&
// fix too many timing out slot msgs when a host is // fix too many timing out slot msgs when a host is
// hogging the cpu on a niceness 0 thing... // hogging the cpu on a niceness 0 thing...
elapsed > 5000 && //elapsed > 5000 &&
// respect slot's timeout too!
elapsed > timeout &&
// only do this when sending a request // only do this when sending a request
slot->m_callback ) { slot->m_callback ) {
// should this be ENOACK or something? // should this be ENOACK or something?
@ -2960,8 +2968,10 @@ bool UdpServer::readTimeoutPoll ( int64_t now ) {
something = true; something = true;
// note it // note it
log("udp: Timing out slot (msgType=0x%"XINT32") " log("udp: Timing out slot (msgType=0x%"XINT32") "
"after %"INT32" resends. hostid=%"INT32" (elapsed=%"INT64")" , "after %"INT32" resends. hostid=%"INT32" "
(int32_t)slot->m_msgType, (int32_t)slot->m_resendCount , "(elapsed=%"INT64")" ,
(int32_t)slot->m_msgType,
(int32_t)slot->m_resendCount ,
slot->m_hostId,elapsed); slot->m_hostId,elapsed);
// keep going // keep going
continue; continue;