12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832 |
- // ECOin - Copyright (c) - 2014/2022 - GPLv3 - epsylon@riseup.net (https://03c8.net)
- #include "irc.h"
- #include "db.h"
- #include "net.h"
- #include "init.h"
- #include "strlcpy.h"
- #include "addrman.h"
- #include "ui_interface.h"
- #ifdef WIN32
- #include <string.h>
- #endif
- #ifdef USE_UPNP
- #include <miniupnpc/miniwget.h>
- #include <miniupnpc/miniupnpc.h>
- #include <miniupnpc/upnpcommands.h>
- #include <miniupnpc/upnperrors.h>
- #endif
- using namespace std;
- using namespace boost;
- static const int MAX_OUTBOUND_CONNECTIONS = 16;
- void ThreadMessageHandler2(void* parg);
- void ThreadSocketHandler2(void* parg);
- void ThreadOpenConnections2(void* parg);
- void ThreadOpenAddedConnections2(void* parg);
- #ifdef USE_UPNP
- void ThreadMapPort2(void* parg);
- #endif
- void ThreadDNSAddressSeed2(void* parg);
- bool OpenNetworkConnection(const CAddress& addrConnect, CSemaphoreGrant *grantOutbound = NULL, const char *strDest = NULL, bool fOneShot = false);
- struct LocalServiceInfo {
- int nScore;
- int nPort;
- };
- // Global state variables
- bool fClient = false;
- bool fDiscover = true;
- bool fUseUPnP = false;
- uint64 nLocalServices = (fClient ? 0 : NODE_NETWORK);
- static CCriticalSection cs_mapLocalHost;
- static map<CNetAddr, LocalServiceInfo> mapLocalHost;
- static bool vfReachable[NET_MAX] = {};
- static bool vfLimited[NET_MAX] = {};
- static CNode* pnodeLocalHost = NULL;
- CAddress addrSeenByPeer(CService("0.0.0.0", 0), nLocalServices);
- uint64 nLocalHostNonce = 0;
- boost::array<int, THREAD_MAX> vnThreadsRunning;
- static std::vector<SOCKET> vhListenSocket;
- CAddrMan addrman;
- vector<CNode*> vNodes;
- CCriticalSection cs_vNodes;
- map<CInv, CDataStream> mapRelay;
- deque<pair<int64, CInv> > vRelayExpiration;
- CCriticalSection cs_mapRelay;
- map<CInv, int64> mapAlreadyAskedFor;
- static deque<string> vOneShots;
- CCriticalSection cs_vOneShots;
- set<CNetAddr> setservAddNodeAddresses;
- CCriticalSection cs_setservAddNodeAddresses;
- static CSemaphore *semOutbound = NULL;
- void AddOneShot(string strDest)
- {
- LOCK(cs_vOneShots);
- vOneShots.push_back(strDest);
- }
- unsigned short GetListenPort()
- {
- return (unsigned short)(GetArg("-port", GetDefaultPort()));
- }
- void CNode::PushGetBlocks(CBlockIndex* pindexBegin, uint256 hashEnd)
- {
- // Filter out duplicate requests
- if (pindexBegin == pindexLastGetBlocksBegin && hashEnd == hashLastGetBlocksEnd)
- return;
- pindexLastGetBlocksBegin = pindexBegin;
- hashLastGetBlocksEnd = hashEnd;
- PushMessage("getblocks", CBlockLocator(pindexBegin), hashEnd);
- }
- bool GetLocal(CService& addr, const CNetAddr *paddrPeer)
- {
- if (fNoListen)
- return false;
- int nBestScore = -1;
- int nBestReachability = -1;
- {
- LOCK(cs_mapLocalHost);
- for (map<CNetAddr, LocalServiceInfo>::iterator it = mapLocalHost.begin(); it != mapLocalHost.end(); it++)
- {
- int nScore = (*it).second.nScore;
- int nReachability = (*it).first.GetReachabilityFrom(paddrPeer);
- if (nReachability > nBestReachability || (nReachability == nBestReachability && nScore > nBestScore))
- {
- addr = CService((*it).first, (*it).second.nPort);
- nBestReachability = nReachability;
- nBestScore = nScore;
- }
- }
- }
- return nBestScore >= 0;
- }
- CAddress GetLocalAddress(const CNetAddr *paddrPeer)
- {
- CAddress ret(CService("0.0.0.0",0),0);
- CService addr;
- if (GetLocal(addr, paddrPeer))
- {
- ret = CAddress(addr);
- ret.nServices = nLocalServices;
- ret.nTime = GetAdjustedTime();
- }
- return ret;
- }
- bool RecvLine(SOCKET hSocket, string& strLine)
- {
- strLine = "";
- while (true)
- {
- char c;
- int nBytes = recv(hSocket, &c, 1, 0);
- if (nBytes > 0)
- {
- if (c == '\n')
- continue;
- if (c == '\r')
- return true;
- strLine += c;
- if (strLine.size() >= 9000)
- return true;
- }
- else if (nBytes <= 0)
- {
- if (fShutdown)
- return false;
- if (nBytes < 0)
- {
- int nErr = WSAGetLastError();
- if (nErr == WSAEMSGSIZE)
- continue;
- if (nErr == WSAEWOULDBLOCK || nErr == WSAEINTR || nErr == WSAEINPROGRESS)
- {
- Sleep(10);
- continue;
- }
- }
- if (!strLine.empty())
- return true;
- if (nBytes == 0)
- {
- // socket closed
- printf("socket closed\n");
- return false;
- }
- else
- {
- // socket error
- int nErr = WSAGetLastError();
- printf("recv failed: %d\n", nErr);
- return false;
- }
- }
- }
- }
- void static AdvertizeLocal()
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodes)
- {
- if (pnode->fSuccessfullyConnected)
- {
- CAddress addrLocal = GetLocalAddress(&pnode->addr);
- if (addrLocal.IsRoutable() && (CService)addrLocal != (CService)pnode->addrLocal)
- {
- pnode->PushAddress(addrLocal);
- pnode->addrLocal = addrLocal;
- }
- }
- }
- }
- void SetReachable(enum Network net, bool fFlag)
- {
- LOCK(cs_mapLocalHost);
- vfReachable[net] = fFlag;
- if (net == NET_IPV6 && fFlag)
- vfReachable[NET_IPV4] = true;
- }
- bool AddLocal(const CService& addr, int nScore)
- {
- if (!addr.IsRoutable())
- return false;
- if (!fDiscover && nScore < LOCAL_MANUAL)
- return false;
- if (IsLimited(addr))
- return false;
- printf("AddLocal(%s,%i)\n", addr.ToString().c_str(), nScore);
- {
- LOCK(cs_mapLocalHost);
- bool fAlready = mapLocalHost.count(addr) > 0;
- LocalServiceInfo &info = mapLocalHost[addr];
- if (!fAlready || nScore >= info.nScore) {
- info.nScore = nScore + (fAlready ? 1 : 0);
- info.nPort = addr.GetPort();
- }
- SetReachable(addr.GetNetwork());
- }
- AdvertizeLocal();
- return true;
- }
- bool AddLocal(const CNetAddr &addr, int nScore)
- {
- return AddLocal(CService(addr, GetListenPort()), nScore);
- }
- void SetLimited(enum Network net, bool fLimited)
- {
- if (net == NET_UNROUTABLE)
- return;
- LOCK(cs_mapLocalHost);
- vfLimited[net] = fLimited;
- }
- bool IsLimited(enum Network net)
- {
- LOCK(cs_mapLocalHost);
- return vfLimited[net];
- }
- bool IsLimited(const CNetAddr &addr)
- {
- return IsLimited(addr.GetNetwork());
- }
- bool SeenLocal(const CService& addr)
- {
- {
- LOCK(cs_mapLocalHost);
- if (mapLocalHost.count(addr) == 0)
- return false;
- mapLocalHost[addr].nScore++;
- }
- AdvertizeLocal();
- return true;
- }
- bool IsLocal(const CService& addr)
- {
- LOCK(cs_mapLocalHost);
- return mapLocalHost.count(addr) > 0;
- }
- bool IsReachable(const CNetAddr& addr)
- {
- LOCK(cs_mapLocalHost);
- enum Network net = addr.GetNetwork();
- return vfReachable[net] && !vfLimited[net];
- }
- bool GetMyExternalIP2(const CService& addrConnect, const char* pszGet, const char* pszKeyword, CNetAddr& ipRet)
- {
- SOCKET hSocket;
- if (!ConnectSocket(addrConnect, hSocket))
- return error("GetMyExternalIP() : connection to %s failed", addrConnect.ToString().c_str());
- send(hSocket, pszGet, strlen(pszGet), MSG_NOSIGNAL);
- string strLine;
- while (RecvLine(hSocket, strLine))
- {
- if (strLine.empty()) // HTTP response is separated from headers by blank line
- {
- while (true)
- {
- if (!RecvLine(hSocket, strLine))
- {
- closesocket(hSocket);
- return false;
- }
- if (pszKeyword == NULL)
- break;
- if (strLine.find(pszKeyword) != string::npos)
- {
- strLine = strLine.substr(strLine.find(pszKeyword) + strlen(pszKeyword));
- break;
- }
- }
- closesocket(hSocket);
- if (strLine.find("<") != string::npos)
- strLine = strLine.substr(0, strLine.find("<"));
- strLine = strLine.substr(strspn(strLine.c_str(), " \t\n\r"));
- while (strLine.size() > 0 && isspace(strLine[strLine.size()-1]))
- strLine.resize(strLine.size()-1);
- CService addr(strLine,0,true);
- printf("GetMyExternalIP() received [%s] %s\n", strLine.c_str(), addr.ToString().c_str());
- if (!addr.IsValid() || !addr.IsRoutable())
- return false;
- ipRet.SetIP(addr);
- return true;
- }
- }
- closesocket(hSocket);
- return error("GetMyExternalIP() : connection closed");
- }
- bool GetMyExternalIP(CNetAddr& ipRet)
- {
- CService addrConnect;
- const char* pszGet;
- const char* pszKeyword;
- for (int nLookup = 0; nLookup <= 1; nLookup++)
- for (int nHost = 1; nHost <= 2; nHost++)
- {
- if (nHost == 1)
- {
- addrConnect = CService("131.186.113.70",80); // checkip.dyndns.org:80 (11/01/2021)
- if (nLookup == 1)
- {
- CService addrIP("checkip.dyndns.org", 80, true);
- if (addrIP.IsValid())
- addrConnect = addrIP;
- }
- pszGet = "GET / HTTP/1.1\r\n"
- "Host: checkip.dyndns.org\r\n"
- "User-Agent: Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.1)\r\n"
- "Connection: close\r\n"
- "\r\n";
- pszKeyword = "Address:";
- }
- else if (nHost == 2)
- {
- addrConnect = CService("104.18.59.232", 443); // www.showmyip.com:443 (11/01/2021)
- if (nLookup == 1)
- {
- CService addrIP("www.showmyip.com", 443, true);
- if (addrIP.IsValid())
- addrConnect = addrIP;
- }
- pszGet = "GET /simple/ HTTP/1.1\r\n"
- "Host: www.showmyip.com\r\n"
- "User-Agent: Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.1)\r\n"
- "Connection: close\r\n"
- "\r\n";
- pszKeyword = NULL; // Returns just IP address
- }
- if (GetMyExternalIP2(addrConnect, pszGet, pszKeyword, ipRet))
- return true;
- }
- return false;
- }
- void ThreadGetMyExternalIP(void* parg)
- {
- RenameThread("ecoin-ext-ip");
- CNetAddr addrLocalHost;
- if (GetMyExternalIP(addrLocalHost))
- {
- printf("GetMyExternalIP() returned %s\n", addrLocalHost.ToStringIP().c_str());
- AddLocal(addrLocalHost, LOCAL_HTTP);
- }
- }
- void AddressCurrentlyConnected(const CService& addr)
- {
- addrman.Connected(addr);
- }
- CNode* FindNode(const CNetAddr& ip)
- {
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodes)
- if ((CNetAddr)pnode->addr == ip)
- return (pnode);
- }
- return NULL;
- }
- CNode* FindNode(std::string addrName)
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodes)
- if (pnode->addrName == addrName)
- return (pnode);
- return NULL;
- }
- CNode* FindNode(const CService& addr)
- {
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodes)
- if ((CService)pnode->addr == addr)
- return (pnode);
- }
- return NULL;
- }
- CNode* ConnectNode(CAddress addrConnect, const char *pszDest, int64 nTimeout)
- {
- if (pszDest == NULL) {
- if (IsLocal(addrConnect))
- return NULL;
- CNode* pnode = FindNode((CService)addrConnect);
- if (pnode)
- {
- if (nTimeout != 0)
- pnode->AddRef(nTimeout);
- else
- pnode->AddRef();
- return pnode;
- }
- }
- printf("trying connection %s lastseen=%.1fhrs\n",
- pszDest ? pszDest : addrConnect.ToString().c_str(),
- pszDest ? 0 : (double)(GetAdjustedTime() - addrConnect.nTime)/3600.0);
- SOCKET hSocket;
- if (pszDest ? ConnectSocketByName(addrConnect, hSocket, pszDest, GetDefaultPort()) : ConnectSocket(addrConnect, hSocket))
- {
- addrman.Attempt(addrConnect);
- printf("connected %s\n", pszDest ? pszDest : addrConnect.ToString().c_str());
- #ifdef WIN32
- u_long nOne = 1;
- if (ioctlsocket(hSocket, FIONBIO, &nOne) == SOCKET_ERROR)
- printf("ConnectSocket() : ioctlsocket non-blocking setting failed, error %d\n", WSAGetLastError());
- #else
- if (fcntl(hSocket, F_SETFL, O_NONBLOCK) == SOCKET_ERROR)
- printf("ConnectSocket() : fcntl non-blocking setting failed, error %d\n", errno);
- #endif
- CNode* pnode = new CNode(hSocket, addrConnect, pszDest ? pszDest : "", false);
- if (nTimeout != 0)
- pnode->AddRef(nTimeout);
- else
- pnode->AddRef();
- {
- LOCK(cs_vNodes);
- vNodes.push_back(pnode);
- }
- pnode->nTimeConnected = GetTime();
- return pnode;
- }
- else
- {
- return NULL;
- }
- }
- void CNode::CloseSocketDisconnect()
- {
- fDisconnect = true;
- if (hSocket != INVALID_SOCKET)
- {
- printf("disconnecting node %s\n", addrName.c_str());
- closesocket(hSocket);
- hSocket = INVALID_SOCKET;
- vRecv.clear();
- }
- }
- void CNode::Cleanup()
- {
- }
- void CNode::PushVersion()
- {
- int64 nTime = (fInbound ? GetAdjustedTime() : GetTime());
- CAddress addrYou = (addr.IsRoutable() && !IsProxy(addr) ? addr : CAddress(CService("0.0.0.0",0)));
- CAddress addrMe = GetLocalAddress(&addr);
- RAND_bytes((unsigned char*)&nLocalHostNonce, sizeof(nLocalHostNonce));
- printf("send version message: version %d, blocks=%d, us=%s, them=%s, peer=%s\n", PROTOCOL_VERSION, nBestHeight, addrMe.ToString().c_str(), addrYou.ToString().c_str(), addr.ToString().c_str());
- PushMessage("version", PROTOCOL_VERSION, nLocalServices, nTime, addrYou, addrMe,
- nLocalHostNonce, FormatSubVersion(CLIENT_NAME, CLIENT_VERSION, std::vector<string>()), nBestHeight);
- }
- std::map<CNetAddr, int64> CNode::setBanned;
- CCriticalSection CNode::cs_setBanned;
- void CNode::ClearBanned()
- {
- setBanned.clear();
- }
- bool CNode::IsBanned(CNetAddr ip)
- {
- bool fResult = false;
- {
- LOCK(cs_setBanned);
- std::map<CNetAddr, int64>::iterator i = setBanned.find(ip);
- if (i != setBanned.end())
- {
- int64 t = (*i).second;
- if (GetTime() < t)
- fResult = true;
- }
- }
- return fResult;
- }
- bool CNode::Misbehaving(int howmuch)
- {
- if (addr.IsLocal())
- {
- printf("Warning: Local node %s misbehaving (delta: %d)!\n", addrName.c_str(), howmuch);
- return false;
- }
- nMisbehavior += howmuch;
- if (nMisbehavior >= GetArg("-banscore", 100))
- {
- int64 banTime = GetTime()+GetArg("-bantime", 60*60*24); // Default 24-hour ban
- printf("Misbehaving: %s (%d -> %d) DISCONNECTING\n", addr.ToString().c_str(), nMisbehavior-howmuch, nMisbehavior);
- {
- LOCK(cs_setBanned);
- if (setBanned[addr] < banTime)
- setBanned[addr] = banTime;
- }
- CloseSocketDisconnect();
- return true;
- } else
- printf("Misbehaving: %s (%d -> %d)\n", addr.ToString().c_str(), nMisbehavior-howmuch, nMisbehavior);
- return false;
- }
- #undef X
- #define X(name) stats.name = name
- void CNode::copyStats(CNodeStats &stats)
- {
- X(nServices);
- X(nLastSend);
- X(nLastRecv);
- X(nTimeConnected);
- X(addrName);
- X(nVersion);
- X(strSubVer);
- X(fInbound);
- X(nReleaseTime);
- X(nStartingHeight);
- X(nMisbehavior);
- }
- #undef X
- void ThreadSocketHandler(void* parg)
- {
- // Make this thread recognisable as the networking thread
- RenameThread("ecoin-net");
- try
- {
- vnThreadsRunning[THREAD_SOCKETHANDLER]++;
- ThreadSocketHandler2(parg);
- vnThreadsRunning[THREAD_SOCKETHANDLER]--;
- }
- catch (std::exception& e) {
- vnThreadsRunning[THREAD_SOCKETHANDLER]--;
- PrintException(&e, "ThreadSocketHandler()");
- } catch (...) {
- vnThreadsRunning[THREAD_SOCKETHANDLER]--;
- throw; // support pthread_cancel()
- }
- printf("ThreadSocketHandler exited\n");
- }
- void ThreadSocketHandler2(void* parg)
- {
- printf("ThreadSocketHandler started\n");
- list<CNode*> vNodesDisconnected;
- unsigned int nPrevNodeCount = 0;
- while (true)
- {
- {
- LOCK(cs_vNodes);
- vector<CNode*> vNodesCopy = vNodes;
- BOOST_FOREACH(CNode* pnode, vNodesCopy)
- {
- if (pnode->fDisconnect ||
- (pnode->GetRefCount() <= 0 && pnode->vRecv.empty() && pnode->vSend.empty()))
- {
- vNodes.erase(remove(vNodes.begin(), vNodes.end(), pnode), vNodes.end());
- // release outbound grant (if any)
- pnode->grantOutbound.Release();
- // close socket and cleanup
- pnode->CloseSocketDisconnect();
- pnode->Cleanup();
- // hold in disconnected pool until all refs are released
- pnode->nReleaseTime = max(pnode->nReleaseTime, GetTime() + 15 * 60);
- if (pnode->fNetworkNode || pnode->fInbound)
- pnode->Release();
- vNodesDisconnected.push_back(pnode);
- }
- }
- // Delete disconnected nodes
- list<CNode*> vNodesDisconnectedCopy = vNodesDisconnected;
- BOOST_FOREACH(CNode* pnode, vNodesDisconnectedCopy)
- {
- // wait until threads are done using it
- if (pnode->GetRefCount() <= 0)
- {
- bool fDelete = false;
- {
- TRY_LOCK(pnode->cs_vSend, lockSend);
- if (lockSend)
- {
- TRY_LOCK(pnode->cs_vRecv, lockRecv);
- if (lockRecv)
- {
- TRY_LOCK(pnode->cs_mapRequests, lockReq);
- if (lockReq)
- {
- TRY_LOCK(pnode->cs_inventory, lockInv);
- if (lockInv)
- fDelete = true;
- }
- }
- }
- }
- if (fDelete)
- {
- vNodesDisconnected.remove(pnode);
- delete pnode;
- }
- }
- }
- }
- if (vNodes.size() != nPrevNodeCount)
- {
- nPrevNodeCount = vNodes.size();
- uiInterface.NotifyNumConnectionsChanged(vNodes.size());
- }
- // Find which sockets have data to receive
- struct timeval timeout;
- timeout.tv_sec = 0;
- timeout.tv_usec = 50000; // frequency to poll pnode->vSend
- fd_set fdsetRecv;
- fd_set fdsetSend;
- fd_set fdsetError;
- FD_ZERO(&fdsetRecv);
- FD_ZERO(&fdsetSend);
- FD_ZERO(&fdsetError);
- SOCKET hSocketMax = 0;
- bool have_fds = false;
- BOOST_FOREACH(SOCKET hListenSocket, vhListenSocket) {
- FD_SET(hListenSocket, &fdsetRecv);
- hSocketMax = max(hSocketMax, hListenSocket);
- have_fds = true;
- }
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodes)
- {
- if (pnode->hSocket == INVALID_SOCKET)
- continue;
- FD_SET(pnode->hSocket, &fdsetRecv);
- FD_SET(pnode->hSocket, &fdsetError);
- hSocketMax = max(hSocketMax, pnode->hSocket);
- have_fds = true;
- {
- TRY_LOCK(pnode->cs_vSend, lockSend);
- if (lockSend && !pnode->vSend.empty())
- FD_SET(pnode->hSocket, &fdsetSend);
- }
- }
- }
- vnThreadsRunning[THREAD_SOCKETHANDLER]--;
- int nSelect = select(have_fds ? hSocketMax + 1 : 0,
- &fdsetRecv, &fdsetSend, &fdsetError, &timeout);
- vnThreadsRunning[THREAD_SOCKETHANDLER]++;
- if (fShutdown)
- return;
- if (nSelect == SOCKET_ERROR)
- {
- if (have_fds)
- {
- int nErr = WSAGetLastError();
- printf("socket select error %d\n", nErr);
- for (unsigned int i = 0; i <= hSocketMax; i++)
- FD_SET(i, &fdsetRecv);
- }
- FD_ZERO(&fdsetSend);
- FD_ZERO(&fdsetError);
- Sleep(timeout.tv_usec/1000);
- }
- // Accept new connections
- BOOST_FOREACH(SOCKET hListenSocket, vhListenSocket)
- if (hListenSocket != INVALID_SOCKET && FD_ISSET(hListenSocket, &fdsetRecv))
- {
- #ifdef USE_IPV6
- struct sockaddr_storage sockaddr;
- #else
- struct sockaddr sockaddr;
- #endif
- socklen_t len = sizeof(sockaddr);
- SOCKET hSocket = accept(hListenSocket, (struct sockaddr*)&sockaddr, &len);
- CAddress addr;
- int nInbound = 0;
- if (hSocket != INVALID_SOCKET)
- if (!addr.SetSockAddr((const struct sockaddr*)&sockaddr))
- printf("Warning: Unknown socket family\n");
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodes)
- if (pnode->fInbound)
- nInbound++;
- }
- if (hSocket == INVALID_SOCKET)
- {
- int nErr = WSAGetLastError();
- if (nErr != WSAEWOULDBLOCK)
- printf("socket error accept failed: %d\n", nErr);
- }
- else if (nInbound >= GetArg("-maxconnections", 125) - MAX_OUTBOUND_CONNECTIONS)
- {
- {
- LOCK(cs_setservAddNodeAddresses);
- if (!setservAddNodeAddresses.count(addr))
- closesocket(hSocket);
- }
- }
- else if (CNode::IsBanned(addr))
- {
- printf("connection from %s dropped (banned)\n", addr.ToString().c_str());
- closesocket(hSocket);
- }
- else
- {
- printf("accepted connection %s\n", addr.ToString().c_str());
- CNode* pnode = new CNode(hSocket, addr, "", true);
- pnode->AddRef();
- {
- LOCK(cs_vNodes);
- vNodes.push_back(pnode);
- }
- }
- }
- // Service each socket
- vector<CNode*> vNodesCopy;
- {
- LOCK(cs_vNodes);
- vNodesCopy = vNodes;
- BOOST_FOREACH(CNode* pnode, vNodesCopy)
- pnode->AddRef();
- }
- BOOST_FOREACH(CNode* pnode, vNodesCopy)
- {
- if (fShutdown)
- return;
- // Receive
- if (pnode->hSocket == INVALID_SOCKET)
- continue;
- if (FD_ISSET(pnode->hSocket, &fdsetRecv) || FD_ISSET(pnode->hSocket, &fdsetError))
- {
- TRY_LOCK(pnode->cs_vRecv, lockRecv);
- if (lockRecv)
- {
- CDataStream& vRecv = pnode->vRecv;
- unsigned int nPos = vRecv.size();
- if (nPos > ReceiveBufferSize()) {
- if (!pnode->fDisconnect)
- printf("socket recv flood control disconnect (%" PRIszu" bytes)\n", vRecv.size());
- pnode->CloseSocketDisconnect();
- }
- else {
- // typical socket buffer is 8K-64K
- char pchBuf[0x10000];
- int nBytes = recv(pnode->hSocket, pchBuf, sizeof(pchBuf), MSG_DONTWAIT);
- if (nBytes > 0)
- {
- vRecv.resize(nPos + nBytes);
- memcpy(&vRecv[nPos], pchBuf, nBytes);
- pnode->nLastRecv = GetTime();
- }
- else if (nBytes == 0)
- {
- // socket closed gracefully
- if (!pnode->fDisconnect)
- printf("socket closed\n");
- pnode->CloseSocketDisconnect();
- }
- else if (nBytes < 0)
- {
- // error
- int nErr = WSAGetLastError();
- if (nErr != WSAEWOULDBLOCK && nErr != WSAEMSGSIZE && nErr != WSAEINTR && nErr != WSAEINPROGRESS)
- {
- if (!pnode->fDisconnect)
- printf("socket recv error %d\n", nErr);
- pnode->CloseSocketDisconnect();
- }
- }
- }
- }
- }
- // Send
- if (pnode->hSocket == INVALID_SOCKET)
- continue;
- if (FD_ISSET(pnode->hSocket, &fdsetSend))
- {
- TRY_LOCK(pnode->cs_vSend, lockSend);
- if (lockSend)
- {
- CDataStream& vSend = pnode->vSend;
- if (!vSend.empty())
- {
- int nBytes = send(pnode->hSocket, &vSend[0], vSend.size(), MSG_NOSIGNAL | MSG_DONTWAIT);
- if (nBytes > 0)
- {
- vSend.erase(vSend.begin(), vSend.begin() + nBytes);
- pnode->nLastSend = GetTime();
- }
- else if (nBytes < 0)
- {
- // error
- int nErr = WSAGetLastError();
- if (nErr != WSAEWOULDBLOCK && nErr != WSAEMSGSIZE && nErr != WSAEINTR && nErr != WSAEINPROGRESS)
- {
- printf("socket send error %d\n", nErr);
- pnode->CloseSocketDisconnect();
- }
- }
- }
- }
- }
- // Inactivity checking
- if (pnode->vSend.empty())
- pnode->nLastSendEmpty = GetTime();
- if (GetTime() - pnode->nTimeConnected > 60)
- {
- if (pnode->nLastRecv == 0 || pnode->nLastSend == 0)
- {
- printf("socket no message in first 60 seconds, %d %d\n", pnode->nLastRecv != 0, pnode->nLastSend != 0);
- pnode->fDisconnect = true;
- }
- else if (GetTime() - pnode->nLastSend > 90*60 && GetTime() - pnode->nLastSendEmpty > 90*60)
- {
- printf("socket not sending\n");
- pnode->fDisconnect = true;
- }
- else if (GetTime() - pnode->nLastRecv > 90*60)
- {
- printf("socket inactivity timeout\n");
- pnode->fDisconnect = true;
- }
- }
- }
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodesCopy)
- pnode->Release();
- }
- Sleep(10);
- }
- }
- #ifdef USE_UPNP
- void ThreadMapPort(void* parg)
- {
- // Make this thread recognisable as the UPnP thread
- RenameThread("ecoin-UPnP");
- try
- {
- vnThreadsRunning[THREAD_UPNP]++;
- ThreadMapPort2(parg);
- vnThreadsRunning[THREAD_UPNP]--;
- }
- catch (std::exception& e) {
- vnThreadsRunning[THREAD_UPNP]--;
- PrintException(&e, "ThreadMapPort()");
- } catch (...) {
- vnThreadsRunning[THREAD_UPNP]--;
- PrintException(NULL, "ThreadMapPort()");
- }
- printf("ThreadMapPort exited\n");
- }
- void ThreadMapPort2(void* parg)
- {
- printf("ThreadMapPort started\n");
- std::string port = strprintf("%u", GetListenPort());
- const char * multicastif = 0;
- const char * minissdpdpath = 0;
- struct UPNPDev * devlist = 0;
- char lanaddr[64];
- #ifndef UPNPDISCOVER_SUCCESS
- // /* miniupnpc 1.5 */
- devlist = upnpDiscover(2000, multicastif, minissdpdpath, 0);
- #else
- // /* miniupnpc 1.9.20150730 */
- int error = 0;
- devlist = upnpDiscover(2000, multicastif, minissdpdpath, 0, 0, 2, &error);
- #endif
- struct UPNPUrls urls;
- struct IGDdatas data;
- int r;
- r = UPNP_GetValidIGD(devlist, &urls, &data, lanaddr, sizeof(lanaddr));
- if (r == 1)
- {
- if (fDiscover) {
- char externalIPAddress[40];
- r = UPNP_GetExternalIPAddress(urls.controlURL, data.first.servicetype, externalIPAddress);
- if(r != UPNPCOMMAND_SUCCESS)
- printf("UPnP: GetExternalIPAddress() returned %d\n", r);
- else
- {
- if(externalIPAddress[0])
- {
- printf("UPnP: ExternalIPAddress = %s\n", externalIPAddress);
- AddLocal(CNetAddr(externalIPAddress), LOCAL_UPNP);
- }
- else
- printf("UPnP: GetExternalIPAddress failed.\n");
- }
- }
- string strDesc = "Ecoin " + FormatFullVersion();
- #ifndef UPNPDISCOVER_SUCCESS
- r = UPNP_AddPortMapping(urls.controlURL, data.first.servicetype,
- port.c_str(), port.c_str(), lanaddr, strDesc.c_str(), "TCP", 0);
- #else
- r = UPNP_AddPortMapping(urls.controlURL, data.first.servicetype,
- port.c_str(), port.c_str(), lanaddr, strDesc.c_str(), "TCP", 0, "0");
- #endif
- if(r!=UPNPCOMMAND_SUCCESS)
- printf("AddPortMapping(%s, %s, %s) failed with code %d (%s)\n",
- port.c_str(), port.c_str(), lanaddr, r, strupnperror(r));
- else
- printf("UPnP Port Mapping successful.\n");
- int i = 1;
- while (true)
- {
- if (fShutdown || !fUseUPnP)
- {
- r = UPNP_DeletePortMapping(urls.controlURL, data.first.servicetype, port.c_str(), "TCP", 0);
- printf("UPNP_DeletePortMapping() returned : %d\n", r);
- freeUPNPDevlist(devlist); devlist = 0;
- FreeUPNPUrls(&urls);
- return;
- }
- if (i % 600 == 0) // Refresh every 20 minutes
- {
- #ifndef UPNPDISCOVER_SUCCESS
- r = UPNP_AddPortMapping(urls.controlURL, data.first.servicetype,
- port.c_str(), port.c_str(), lanaddr, strDesc.c_str(), "TCP", 0);
- #else
- r = UPNP_AddPortMapping(urls.controlURL, data.first.servicetype,
- port.c_str(), port.c_str(), lanaddr, strDesc.c_str(), "TCP", 0, "0");
- #endif
- if(r!=UPNPCOMMAND_SUCCESS)
- printf("AddPortMapping(%s, %s, %s) failed with code %d (%s)\n",
- port.c_str(), port.c_str(), lanaddr, r, strupnperror(r));
- else
- printf("UPnP Port Mapping successful.\n");;
- }
- Sleep(2000);
- i++;
- }
- } else {
- printf("No valid UPnP IGDs found\n");
- freeUPNPDevlist(devlist); devlist = 0;
- if (r != 0)
- FreeUPNPUrls(&urls);
- while (true)
- {
- if (fShutdown || !fUseUPnP)
- return;
- Sleep(2000);
- }
- }
- }
- void MapPort()
- {
- if (fUseUPnP && vnThreadsRunning[THREAD_UPNP] < 1)
- {
- if (!NewThread(ThreadMapPort, NULL))
- printf("Error: ThreadMapPort(ThreadMapPort) failed\n");
- }
- }
- #else
- void MapPort()
- {
- // Intentionally left blank.
- }
- #endif
- // DNS seeds
- static const char *strDNSSeed[][2] = {
- {"ecoinseed.03c8.net", "dnsecoin.03c8.net"},
- };
- void ThreadDNSAddressSeed(void* parg)
- {
- // Make this thread recognisable as the DNS seeding thread
- RenameThread("ecoin-dnsseed");
- try
- {
- vnThreadsRunning[THREAD_DNSSEED]++;
- ThreadDNSAddressSeed2(parg);
- vnThreadsRunning[THREAD_DNSSEED]--;
- }
- catch (std::exception& e) {
- vnThreadsRunning[THREAD_DNSSEED]--;
- PrintException(&e, "ThreadDNSAddressSeed()");
- } catch (...) {
- vnThreadsRunning[THREAD_DNSSEED]--;
- throw; // support pthread_cancel()
- }
- printf("ThreadDNSAddressSeed exited\n");
- }
- void ThreadDNSAddressSeed2(void* parg)
- {
- printf("ThreadDNSAddressSeed started\n");
- int found = 0;
- if (!fTestNet)
- {
- printf("Loading addresses from DNS seeds (could take a while)\n");
- for (unsigned int seed_idx = 0; seed_idx < ARRAYLEN(strDNSSeed); seed_idx++) {
- if (HaveNameProxy()) {
- AddOneShot(strDNSSeed[seed_idx][1]);
- } else {
- vector<CNetAddr> vaddr;
- vector<CAddress> vAdd;
- if (LookupHost(strDNSSeed[seed_idx][1], vaddr))
- {
- BOOST_FOREACH(CNetAddr& ip, vaddr)
- {
- int nOneDay = 24*3600;
- CAddress addr = CAddress(CService(ip, GetDefaultPort()));
- addr.nTime = GetTime() - 3*nOneDay - GetRand(4*nOneDay); // use a random age between 3 and 7 days old
- vAdd.push_back(addr);
- found++;
- }
- }
- addrman.Add(vAdd, CNetAddr(strDNSSeed[seed_idx][0], true));
- }
- }
- }
- printf("%d addresses found from DNS seeds\n", found);
- }
- unsigned int pnSeed[] =
- {
- 0x36CBF4AA, 0x36CBF41B,
- };
- void DumpAddresses()
- {
- int64 nStart = GetTimeMillis();
- CAddrDB adb;
- adb.Write(addrman);
- printf("Flushed %d addresses to peers.dat %" PRI64d"ms\n",
- addrman.size(), GetTimeMillis() - nStart);
- }
- void ThreadDumpAddress2(void* parg)
- {
- vnThreadsRunning[THREAD_DUMPADDRESS]++;
- while (!fShutdown)
- {
- DumpAddresses();
- vnThreadsRunning[THREAD_DUMPADDRESS]--;
- Sleep(600000);
- vnThreadsRunning[THREAD_DUMPADDRESS]++;
- }
- vnThreadsRunning[THREAD_DUMPADDRESS]--;
- }
- void ThreadDumpAddress(void* parg)
- {
- // Make this thread recognisable as the address dumping thread
- RenameThread("ecoin-adrdump");
- try
- {
- ThreadDumpAddress2(parg);
- }
- catch (std::exception& e) {
- PrintException(&e, "ThreadDumpAddress()");
- }
- printf("ThreadDumpAddress exited\n");
- }
- void ThreadOpenConnections(void* parg)
- {
- // Make this thread recognisable as the connection opening thread
- RenameThread("ecoin-opencon");
- try
- {
- vnThreadsRunning[THREAD_OPENCONNECTIONS]++;
- ThreadOpenConnections2(parg);
- vnThreadsRunning[THREAD_OPENCONNECTIONS]--;
- }
- catch (std::exception& e) {
- vnThreadsRunning[THREAD_OPENCONNECTIONS]--;
- PrintException(&e, "ThreadOpenConnections()");
- } catch (...) {
- vnThreadsRunning[THREAD_OPENCONNECTIONS]--;
- PrintException(NULL, "ThreadOpenConnections()");
- }
- printf("ThreadOpenConnections exited\n");
- }
- void static ProcessOneShot()
- {
- string strDest;
- {
- LOCK(cs_vOneShots);
- if (vOneShots.empty())
- return;
- strDest = vOneShots.front();
- vOneShots.pop_front();
- }
- CAddress addr;
- CSemaphoreGrant grant(*semOutbound, true);
- if (grant) {
- if (!OpenNetworkConnection(addr, &grant, strDest.c_str(), true))
- AddOneShot(strDest);
- }
- }
- void static ThreadStakeMinter(void* parg)
- {
- printf("ThreadStakeMinter started\n");
- CWallet* pwallet = (CWallet*)parg;
- try
- {
- vnThreadsRunning[THREAD_MINTER]++;
- StakeMiner(pwallet);
- vnThreadsRunning[THREAD_MINTER]--;
- }
- catch (std::exception& e) {
- vnThreadsRunning[THREAD_MINTER]--;
- PrintException(&e, "ThreadStakeMinter()");
- } catch (...) {
- vnThreadsRunning[THREAD_MINTER]--;
- PrintException(NULL, "ThreadStakeMinter()");
- }
- printf("ThreadStakeMinter exiting, %d threads remaining\n", vnThreadsRunning[THREAD_MINTER]);
- }
- void ThreadOpenConnections2(void* parg)
- {
- printf("ThreadOpenConnections started\n");
- // Connect to specific addresses
- if (mapArgs.count("-connect") && mapMultiArgs["-connect"].size() > 0)
- {
- for (int64 nLoop = 0;; nLoop++)
- {
- ProcessOneShot();
- BOOST_FOREACH(string strAddr, mapMultiArgs["-connect"])
- {
- CAddress addr;
- OpenNetworkConnection(addr, NULL, strAddr.c_str());
- for (int i = 0; i < 10 && i < nLoop; i++)
- {
- Sleep(500);
- if (fShutdown)
- return;
- }
- }
- Sleep(500);
- }
- }
- // Initiate network connections
- int64 nStart = GetTime();
- while (true)
- {
- ProcessOneShot();
- vnThreadsRunning[THREAD_OPENCONNECTIONS]--;
- Sleep(500);
- vnThreadsRunning[THREAD_OPENCONNECTIONS]++;
- if (fShutdown)
- return;
- vnThreadsRunning[THREAD_OPENCONNECTIONS]--;
- CSemaphoreGrant grant(*semOutbound);
- vnThreadsRunning[THREAD_OPENCONNECTIONS]++;
- if (fShutdown)
- return;
- // Add seed nodes if IRC isn't working
- if (addrman.size()==0 && (GetTime() - nStart > 60) && !fTestNet)
- {
- std::vector<CAddress> vAdd;
- for (unsigned int i = 0; i < ARRAYLEN(pnSeed); i++)
- {
- const int64 nOneWeek = 7*24*60*60;
- struct in_addr ip;
- memcpy(&ip, &pnSeed[i], sizeof(ip));
- CAddress addr(CService(ip, GetDefaultPort()));
- addr.nTime = GetTime()-GetRand(nOneWeek)-nOneWeek;
- vAdd.push_back(addr);
- }
- addrman.Add(vAdd, CNetAddr("127.0.0.1"));
- }
- CAddress addrConnect;
- int nOutbound = 0;
- set<vector<unsigned char> > setConnected;
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodes) {
- if (!pnode->fInbound) {
- setConnected.insert(pnode->addr.GetGroup());
- nOutbound++;
- }
- }
- }
- int64 nANow = GetAdjustedTime();
- int nTries = 0;
- while (true)
- {
- // use an nUnkBias between 10 (no outgoing connections) and 90 (8 outgoing connections)
- CAddress addr = addrman.Select(10 + min(nOutbound,8)*10);
- // if we selected an invalid address, restart
- if (!addr.IsValid() || setConnected.count(addr.GetGroup()) || IsLocal(addr))
- break;
- nTries++;
- if (nTries > 100)
- break;
- if (IsLimited(addr))
- continue;
- if (nANow - addr.nLastTry < 600 && nTries < 30)
- continue;
- if (addr.GetPort() != GetDefaultPort() && nTries < 50)
- continue;
- addrConnect = addr;
- break;
- }
- if (addrConnect.IsValid())
- OpenNetworkConnection(addrConnect, &grant);
- }
- }
- void ThreadOpenAddedConnections(void* parg)
- {
- RenameThread("ecoin-opencon");
- try
- {
- vnThreadsRunning[THREAD_ADDEDCONNECTIONS]++;
- ThreadOpenAddedConnections2(parg);
- vnThreadsRunning[THREAD_ADDEDCONNECTIONS]--;
- }
- catch (std::exception& e) {
- vnThreadsRunning[THREAD_ADDEDCONNECTIONS]--;
- PrintException(&e, "ThreadOpenAddedConnections()");
- } catch (...) {
- vnThreadsRunning[THREAD_ADDEDCONNECTIONS]--;
- PrintException(NULL, "ThreadOpenAddedConnections()");
- }
- printf("ThreadOpenAddedConnections exited\n");
- }
- void ThreadOpenAddedConnections2(void* parg)
- {
- printf("ThreadOpenAddedConnections started\n");
- if (mapArgs.count("-addnode") == 0)
- return;
- if (HaveNameProxy()) {
- while(!fShutdown) {
- BOOST_FOREACH(string& strAddNode, mapMultiArgs["-addnode"]) {
- CAddress addr;
- CSemaphoreGrant grant(*semOutbound);
- OpenNetworkConnection(addr, &grant, strAddNode.c_str());
- Sleep(500);
- }
- vnThreadsRunning[THREAD_ADDEDCONNECTIONS]--;
- Sleep(120000); // Retry every 2 minutes
- vnThreadsRunning[THREAD_ADDEDCONNECTIONS]++;
- }
- return;
- }
- vector<vector<CService> > vservAddressesToAdd(0);
- BOOST_FOREACH(string& strAddNode, mapMultiArgs["-addnode"])
- {
- vector<CService> vservNode(0);
- if(Lookup(strAddNode.c_str(), vservNode, GetDefaultPort(), fNameLookup, 0))
- {
- vservAddressesToAdd.push_back(vservNode);
- {
- LOCK(cs_setservAddNodeAddresses);
- BOOST_FOREACH(CService& serv, vservNode)
- setservAddNodeAddresses.insert(serv);
- }
- }
- }
- while (true)
- {
- vector<vector<CService> > vservConnectAddresses = vservAddressesToAdd;
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodes)
- for (vector<vector<CService> >::iterator it = vservConnectAddresses.begin(); it != vservConnectAddresses.end(); it++)
- BOOST_FOREACH(CService& addrNode, *(it))
- if (pnode->addr == addrNode)
- {
- it = vservConnectAddresses.erase(it);
- it--;
- break;
- }
- }
- BOOST_FOREACH(vector<CService>& vserv, vservConnectAddresses)
- {
- CSemaphoreGrant grant(*semOutbound);
- OpenNetworkConnection(CAddress(*(vserv.begin())), &grant);
- Sleep(500);
- if (fShutdown)
- return;
- }
- if (fShutdown)
- return;
- vnThreadsRunning[THREAD_ADDEDCONNECTIONS]--;
- Sleep(120000); // Retry every 2 minutes
- vnThreadsRunning[THREAD_ADDEDCONNECTIONS]++;
- if (fShutdown)
- return;
- }
- }
- bool OpenNetworkConnection(const CAddress& addrConnect, CSemaphoreGrant *grantOutbound, const char *strDest, bool fOneShot)
- {
- // Initiate outbound network connection
- if (fShutdown)
- return false;
- if (!strDest)
- if (IsLocal(addrConnect) ||
- FindNode((CNetAddr)addrConnect) || CNode::IsBanned(addrConnect) ||
- FindNode(addrConnect.ToStringIPPort().c_str()))
- return false;
- if (strDest && FindNode(strDest))
- return false;
- vnThreadsRunning[THREAD_OPENCONNECTIONS]--;
- CNode* pnode = ConnectNode(addrConnect, strDest);
- vnThreadsRunning[THREAD_OPENCONNECTIONS]++;
- if (fShutdown)
- return false;
- if (!pnode)
- return false;
- if (grantOutbound)
- grantOutbound->MoveTo(pnode->grantOutbound);
- pnode->fNetworkNode = true;
- if (fOneShot)
- pnode->fOneShot = true;
- return true;
- }
- void ThreadMessageHandler(void* parg)
- {
- // Make this thread recognisable as the message handling thread
- RenameThread("ecoin-msghand");
- try
- {
- vnThreadsRunning[THREAD_MESSAGEHANDLER]++;
- ThreadMessageHandler2(parg);
- vnThreadsRunning[THREAD_MESSAGEHANDLER]--;
- }
- catch (std::exception& e) {
- vnThreadsRunning[THREAD_MESSAGEHANDLER]--;
- PrintException(&e, "ThreadMessageHandler()");
- } catch (...) {
- vnThreadsRunning[THREAD_MESSAGEHANDLER]--;
- PrintException(NULL, "ThreadMessageHandler()");
- }
- printf("ThreadMessageHandler exited\n");
- }
- void ThreadMessageHandler2(void* parg)
- {
- printf("ThreadMessageHandler started\n");
- SetThreadPriority(THREAD_PRIORITY_BELOW_NORMAL);
- while (!fShutdown)
- {
- vector<CNode*> vNodesCopy;
- {
- LOCK(cs_vNodes);
- vNodesCopy = vNodes;
- BOOST_FOREACH(CNode* pnode, vNodesCopy)
- pnode->AddRef();
- }
- // Poll the connected nodes for messages
- CNode* pnodeTrickle = NULL;
- if (!vNodesCopy.empty())
- pnodeTrickle = vNodesCopy[GetRand(vNodesCopy.size())];
- BOOST_FOREACH(CNode* pnode, vNodesCopy)
- {
- // Receive messages
- {
- TRY_LOCK(pnode->cs_vRecv, lockRecv);
- if (lockRecv)
- ProcessMessages(pnode);
- }
- if (fShutdown)
- return;
- // Send messages
- {
- TRY_LOCK(pnode->cs_vSend, lockSend);
- if (lockSend)
- SendMessages(pnode, pnode == pnodeTrickle);
- }
- if (fShutdown)
- return;
- }
- {
- LOCK(cs_vNodes);
- BOOST_FOREACH(CNode* pnode, vNodesCopy)
- pnode->Release();
- }
- vnThreadsRunning[THREAD_MESSAGEHANDLER]--;
- Sleep(100);
- if (fRequestShutdown)
- StartShutdown();
- vnThreadsRunning[THREAD_MESSAGEHANDLER]++;
- if (fShutdown)
- return;
- }
- }
- bool BindListenPort(const CService &addrBind, string& strError)
- {
- strError = "";
- int nOne = 1;
- #ifdef WIN32
- // Initialize Windows Sockets
- WSADATA wsadata;
- int ret = WSAStartup(MAKEWORD(2,2), &wsadata);
- if (ret != NO_ERROR)
- {
- strError = strprintf("Error: TCP/IP socket library failed to start (WSAStartup returned error %d)", ret);
- printf("%s\n", strError.c_str());
- return false;
- }
- #endif
- // Create socket for listening for incoming connections
- #ifdef USE_IPV6
- struct sockaddr_storage sockaddr;
- #else
- struct sockaddr sockaddr;
- #endif
- socklen_t len = sizeof(sockaddr);
- if (!addrBind.GetSockAddr((struct sockaddr*)&sockaddr, &len))
- {
- strError = strprintf("Error: bind address family for %s not supported", addrBind.ToString().c_str());
- printf("%s\n", strError.c_str());
- return false;
- }
- SOCKET hListenSocket = socket(((struct sockaddr*)&sockaddr)->sa_family, SOCK_STREAM, IPPROTO_TCP);
- if (hListenSocket == INVALID_SOCKET)
- {
- strError = strprintf("Error: Couldn't open socket for incoming connections (socket returned error %d)", WSAGetLastError());
- printf("%s\n", strError.c_str());
- return false;
- }
- #ifdef SO_NOSIGPIPE
- // Different way of disabling SIGPIPE on BSD
- setsockopt(hListenSocket, SOL_SOCKET, SO_NOSIGPIPE, (void*)&nOne, sizeof(int));
- #endif
- #ifndef WIN32
- setsockopt(hListenSocket, SOL_SOCKET, SO_REUSEADDR, (void*)&nOne, sizeof(int));
- #endif
- #ifdef WIN32
- // Set to non-blocking, incoming connections will also inherit this
- if (ioctlsocket(hListenSocket, FIONBIO, (u_long*)&nOne) == SOCKET_ERROR)
- #else
- if (fcntl(hListenSocket, F_SETFL, O_NONBLOCK) == SOCKET_ERROR)
- #endif
- {
- strError = strprintf("Error: Couldn't set properties on socket for incoming connections (error %d)", WSAGetLastError());
- printf("%s\n", strError.c_str());
- return false;
- }
- #ifdef USE_IPV6
- if (addrBind.IsIPv6()) {
- #ifdef IPV6_V6ONLY
- #ifdef WIN32
- setsockopt(hListenSocket, IPPROTO_IPV6, IPV6_V6ONLY, (const char*)&nOne, sizeof(int));
- #else
- setsockopt(hListenSocket, IPPROTO_IPV6, IPV6_V6ONLY, (void*)&nOne, sizeof(int));
- #endif
- #endif
- #ifdef WIN32
- int nProtLevel = 10 /* PROTECTION_LEVEL_UNRESTRICTED */;
- int nParameterId = 23 /* IPV6_PROTECTION_LEVEl */;
- // this call is allowed to fail
- setsockopt(hListenSocket, IPPROTO_IPV6, nParameterId, (const char*)&nProtLevel, sizeof(int));
- #endif
- }
- #endif
- if (::bind(hListenSocket, (struct sockaddr*)&sockaddr, len) == SOCKET_ERROR)
- {
- int nErr = WSAGetLastError();
- if (nErr == WSAEADDRINUSE)
- strError = strprintf(_("Unable to bind to %s on this computer. Ecoin is probably already running."), addrBind.ToString().c_str());
- else
- strError = strprintf(_("Unable to bind to %s on this computer (bind returned error %d, %s)"), addrBind.ToString().c_str(), nErr, strerror(nErr));
- printf("%s\n", strError.c_str());
- return false;
- }
- printf("Bound to %s\n", addrBind.ToString().c_str());
- // Listen for incoming connections
- if (listen(hListenSocket, SOMAXCONN) == SOCKET_ERROR)
- {
- strError = strprintf("Error: Listening for incoming connections failed (listen returned error %d)", WSAGetLastError());
- printf("%s\n", strError.c_str());
- return false;
- }
- vhListenSocket.push_back(hListenSocket);
- if (addrBind.IsRoutable() && fDiscover)
- AddLocal(addrBind, LOCAL_BIND);
- return true;
- }
- void static Discover()
- {
- if (!fDiscover)
- return;
- #ifdef WIN32
- // Get local host IP
- char pszHostName[1000] = "";
- if (gethostname(pszHostName, sizeof(pszHostName)) != SOCKET_ERROR)
- {
- vector<CNetAddr> vaddr;
- if (LookupHost(pszHostName, vaddr))
- {
- BOOST_FOREACH (const CNetAddr &addr, vaddr)
- {
- AddLocal(addr, LOCAL_IF);
- }
- }
- }
- #else
- // Get local host ip
- struct ifaddrs* myaddrs;
- if (getifaddrs(&myaddrs) == 0)
- {
- for (struct ifaddrs* ifa = myaddrs; ifa != NULL; ifa = ifa->ifa_next)
- {
- if (ifa->ifa_addr == NULL) continue;
- if ((ifa->ifa_flags & IFF_UP) == 0) continue;
- if (strcmp(ifa->ifa_name, "lo") == 0) continue;
- if (strcmp(ifa->ifa_name, "lo0") == 0) continue;
- if (ifa->ifa_addr->sa_family == AF_INET)
- {
- struct sockaddr_in* s4 = (struct sockaddr_in*)(ifa->ifa_addr);
- CNetAddr addr(s4->sin_addr);
- if (AddLocal(addr, LOCAL_IF))
- printf("IPv4 %s: %s\n", ifa->ifa_name, addr.ToString().c_str());
- }
- #ifdef USE_IPV6
- else if (ifa->ifa_addr->sa_family == AF_INET6)
- {
- struct sockaddr_in6* s6 = (struct sockaddr_in6*)(ifa->ifa_addr);
- CNetAddr addr(s6->sin6_addr);
- if (AddLocal(addr, LOCAL_IF))
- printf("IPv6 %s: %s\n", ifa->ifa_name, addr.ToString().c_str());
- }
- #endif
- }
- freeifaddrs(myaddrs);
- }
- #endif
- // Don't use external IPv4 discovery, when -onlynet="IPv6"
- if (!IsLimited(NET_IPV4))
- NewThread(ThreadGetMyExternalIP, NULL);
- }
- void StartNode(void* parg)
- {
- // Make this thread recognisable as the startup thread
- RenameThread("ecoin-start");
- if (semOutbound == NULL) {
- // initialize semaphore
- int nMaxOutbound = min(MAX_OUTBOUND_CONNECTIONS, (int)GetArg("-maxconnections", 125));
- semOutbound = new CSemaphore(nMaxOutbound);
- }
- if (pnodeLocalHost == NULL)
- pnodeLocalHost = new CNode(INVALID_SOCKET, CAddress(CService("127.0.0.1", 0), nLocalServices));
- Discover();
- // Start threads
- if (!GetBoolArg("-dnsseed", true))
- printf("DNS seeding disabled\n");
- else
- if (!NewThread(ThreadDNSAddressSeed, NULL))
- printf("Error: NewThread(ThreadDNSAddressSeed) failed\n");
- // Map ports with UPnP
- if (fUseUPnP)
- MapPort();
- // Get addresses from IRC and advertise ours
- if (!NewThread(ThreadIRCSeed, NULL))
- printf("Error: NewThread(ThreadIRCSeed) failed\n");
- // Send and receive from sockets, accept connections
- if (!NewThread(ThreadSocketHandler, NULL))
- printf("Error: NewThread(ThreadSocketHandler) failed\n");
- // Initiate outbound connections from -addnode
- if (!NewThread(ThreadOpenAddedConnections, NULL))
- printf("Error: NewThread(ThreadOpenAddedConnections) failed\n");
- // Initiate outbound connections
- if (!NewThread(ThreadOpenConnections, NULL))
- printf("Error: NewThread(ThreadOpenConnections) failed\n");
- // Process messages
- if (!NewThread(ThreadMessageHandler, NULL))
- printf("Error: NewThread(ThreadMessageHandler) failed\n");
- // Dump network addresses
- if (!NewThread(ThreadDumpAddress, NULL))
- printf("Error; NewThread(ThreadDumpAddress) failed\n");
- // ecoin: mint proof-of-stake blocks in the background
- if (!GetBoolArg("-staking", true))
- printf("Staking disabled\n");
- else
- if (!NewThread(ThreadStakeMinter, pwalletMain))
- printf("Error: NewThread(ThreadStakeMinter) failed\n");
- }
- bool StopNode()
- {
- printf("StopNode()\n");
- fShutdown = true;
- nTransactionsUpdated++;
- int64 nStart = GetTime();
- if (semOutbound)
- for (int i=0; i<MAX_OUTBOUND_CONNECTIONS; i++)
- semOutbound->post();
- do
- {
- int nThreadsRunning = 0;
- for (int n = 0; n < THREAD_MAX; n++)
- nThreadsRunning += vnThreadsRunning[n];
- if (nThreadsRunning == 0)
- break;
- if (GetTime() - nStart > 20)
- break;
- Sleep(20);
- } while(true);
- if (vnThreadsRunning[THREAD_SOCKETHANDLER] > 0) printf("ThreadSocketHandler still running\n");
- if (vnThreadsRunning[THREAD_OPENCONNECTIONS] > 0) printf("ThreadOpenConnections still running\n");
- if (vnThreadsRunning[THREAD_MESSAGEHANDLER] > 0) printf("ThreadMessageHandler still running\n");
- if (vnThreadsRunning[THREAD_RPCLISTENER] > 0) printf("ThreadRPCListener still running\n");
- if (vnThreadsRunning[THREAD_RPCHANDLER] > 0) printf("ThreadsRPCServer still running\n");
- #ifdef USE_UPNP
- if (vnThreadsRunning[THREAD_UPNP] > 0) printf("ThreadMapPort still running\n");
- #endif
- if (vnThreadsRunning[THREAD_DNSSEED] > 0) printf("ThreadDNSAddressSeed still running\n");
- if (vnThreadsRunning[THREAD_ADDEDCONNECTIONS] > 0) printf("ThreadOpenAddedConnections still running\n");
- if (vnThreadsRunning[THREAD_DUMPADDRESS] > 0) printf("ThreadDumpAddresses still running\n");
- if (vnThreadsRunning[THREAD_MINTER] > 0) printf("ThreadStakeMinter still running\n");
- while (vnThreadsRunning[THREAD_MESSAGEHANDLER] > 0 || vnThreadsRunning[THREAD_RPCHANDLER] > 0)
- Sleep(20);
- Sleep(50);
- DumpAddresses();
- return true;
- }
- class CNetCleanup
- {
- public:
- CNetCleanup()
- {
- }
- ~CNetCleanup()
- {
- // Close sockets
- BOOST_FOREACH(CNode* pnode, vNodes)
- if (pnode->hSocket != INVALID_SOCKET)
- closesocket(pnode->hSocket);
- BOOST_FOREACH(SOCKET hListenSocket, vhListenSocket)
- if (hListenSocket != INVALID_SOCKET)
- if (closesocket(hListenSocket) == SOCKET_ERROR)
- printf("closesocket(hListenSocket) failed with error %d\n", WSAGetLastError());
- #ifdef WIN32
- // Shutdown Windows Sockets
- WSACleanup();
- #endif
- }
- }
- instance_of_cnetcleanup;
- void RelayTransaction(const CTransaction& tx, const uint256& hash)
- {
- CDataStream ss(SER_NETWORK, PROTOCOL_VERSION);
- ss.reserve(10000);
- ss << tx;
- RelayTransaction(tx, hash, ss);
- }
- void RelayTransaction(const CTransaction& tx, const uint256& hash, const CDataStream& ss)
- {
- CInv inv(MSG_TX, hash);
- {
- LOCK(cs_mapRelay);
- // Expire old relay messages
- while (!vRelayExpiration.empty() && vRelayExpiration.front().first < GetTime())
- {
- mapRelay.erase(vRelayExpiration.front().second);
- vRelayExpiration.pop_front();
- }
- // Save original serialized message so newer versions are preserved
- mapRelay.insert(std::make_pair(inv, ss));
- vRelayExpiration.push_back(std::make_pair(GetTime() + 15 * 60, inv));
- }
- RelayInventory(inv);
- }
|