Bug Summary

File:rootdir/src/ServerSocket.cpp
Warning:line 92, column 4
This statement is never executed

Annotated Source Code

Press '?' to see keyboard shortcuts

clang -cc1 -cc1 -triple x86_64-pc-linux-gnu -analyze -disable-free -clear-ast-before-backend -disable-llvm-verifier -discard-value-names -main-file-name ServerSocket.cpp -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=cplusplus -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -setup-static-analyzer -mrelocation-model pic -pic-level 2 -pic-is-pie -mframe-pointer=all -fmath-errno -ffp-contract=on -fno-rounding-math -mconstructor-aliases -funwind-tables=2 -target-cpu x86-64 -tune-cpu generic -debugger-tuning=gdb -fdebug-compilation-dir=/rootdir/src -fcoverage-compilation-dir=/rootdir/src -resource-dir /usr/lib/llvm-19/lib/clang/19 -D HAVE_CONFIG_H -I . -I .. -D USE_WX_EXTENSIONS -I /usr/include/upnp -D ENABLE_UPNP=1 -I /usr/lib/x86_64-linux-gnu/wx/include/gtk3-unicode-3.2 -I /usr/include/wx-3.2 -D _FILE_OFFSET_BITS=64 -D WXUSINGDLL -D __WXGTK__ -D ENABLE_IP2COUNTRY=1 -I ./libs -I libs -I ./include -internal-isystem /usr/lib/gcc/x86_64-linux-gnu/14/../../../../include/c++/14 -internal-isystem /usr/lib/gcc/x86_64-linux-gnu/14/../../../../include/x86_64-linux-gnu/c++/14 -internal-isystem /usr/lib/gcc/x86_64-linux-gnu/14/../../../../include/c++/14/backward -internal-isystem /usr/lib/llvm-19/lib/clang/19/include -internal-isystem /usr/local/include -internal-isystem /usr/lib/gcc/x86_64-linux-gnu/14/../../../../x86_64-linux-gnu/include -internal-externc-isystem /usr/include/x86_64-linux-gnu -internal-externc-isystem /include -internal-externc-isystem /usr/include -Wno-register -fdeprecated-macro -ferror-limit 19 -fgnuc-version=4.2.1 -fskip-odr-check-in-gmf -fcxx-exceptions -fexceptions -analyzer-checker deadcode.DeadStores -analyzer-checker alpha.deadcode.UnreachableCode -analyzer-checker alpha.core.CastSize -analyzer-checker alpha.core.CastToStruct -analyzer-checker alpha.core.IdenticalExpr -analyzer-checker alpha.security.ArrayBoundV2 -analyzer-checker alpha.security.MallocOverflow -analyzer-checker alpha.security.ReturnPtrRange -analyzer-checker alpha.unix.SimpleStream -analyzer-checker alpha.unix.cstring.BufferOverlap -analyzer-checker alpha.unix.cstring.NotNullTerminated -analyzer-checker alpha.unix.cstring.OutOfBounds -analyzer-checker alpha.core.FixedAddr -analyzer-output=html -faddrsig -D__GCC_HAVE_DWARF2_CFI_ASM=1 -o /rootdir/html-report/2025-01-17-081402-14897-1 -x c++ ServerSocket.cpp
1//
2// This file is part of the aMule Project.
3//
4// Copyright (c) 2003-2011 aMule Team ( admin@amule.org / http://www.amule.org )
5// Copyright (c) 2002-2011 Merkur ( devs@emule-project.net / http://www.emule-project.net )
6//
7// Any parts of this program derived from the xMule, lMule or eMule project,
8// or contributed by third-party developers are copyrighted by their
9// respective authors.
10//
11// This program is free software; you can redistribute it and/or modify
12// it under the terms of the GNU General Public License as published by
13// the Free Software Foundation; either version 2 of the License, or
14// (at your option) any later version.
15//
16// This program is distributed in the hope that it will be useful,
17// but WITHOUT ANY WARRANTY; without even the implied warranty of
18// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19// GNU General Public License for more details.
20//
21// You should have received a copy of the GNU General Public License
22// along with this program; if not, write to the Free Software
23// Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
24//
25
26#include "ServerSocket.h" // Interface declarations
27
28#include <protocol/Protocols.h>
29#include <common/EventIDs.h>
30#include <tags/ServerTags.h>
31
32#include <wx/tokenzr.h>
33
34#include "Packet.h" // Needed for CPacket
35#include "updownclient.h" // Needed for CUpDownClient
36#include "ClientList.h" // Needed for CClientList
37#include "MemFile.h" // Needed for CMemFile
38#include "PartFile.h" // Needed for CPartFile
39#include "SearchList.h" // Needed for CSearchList
40#include "Preferences.h" // Needed for CPreferences
41#include "DownloadQueue.h" // Needed for CDownloadQueue
42#include "ServerList.h" // Needed for CServerList
43#include "Server.h" // Needed for CServer
44#include "amule.h" // Needed for theApp
45#include "Statistics.h" // Needed for theStats
46#include "AsyncDNS.h" // Needed for CAsyncDNS
47#include "Logger.h"
48#include <common/Format.h>
49#include "IPFilter.h"
50#include "GuiEvents.h" // Needed for Notify_*
51#ifdef ASIO_SOCKETS
52# include <boost/system/error_code.hpp>
53#endif
54
55
56#ifndef ASIO_SOCKETS
57
58//------------------------------------------------------------------------------
59// CServerSocketHandler
60//------------------------------------------------------------------------------
61
62class CServerSocketHandler: public wxEvtHandler
63{
64public:
65 CServerSocketHandler() {};
66
67public:
68private:
69 void ServerSocketHandler(wxSocketEvent& event);
70 DECLARE_EVENT_TABLE()private: static const wxEventTableEntry sm_eventTableEntries[
]; protected: GCC diagnostic push GCC diagnostic ignored "-Wsuggest-override"
GCC diagnostic push GCC diagnostic ignored "-Winconsistent-missing-override"
const wxEventTable* GetEventTable() const ; wxEventHashTable
& GetEventHashTable() const ; GCC diagnostic pop GCC diagnostic
pop static const wxEventTable sm_eventTable; static wxEventHashTable
sm_eventHashTable;
71};
72
73
74BEGIN_EVENT_TABLE(CServerSocketHandler, wxEvtHandler)const wxEventTable CServerSocketHandler::sm_eventTable = { &
wxEvtHandler::sm_eventTable, &CServerSocketHandler::sm_eventTableEntries
[0] }; const wxEventTable *CServerSocketHandler::GetEventTable
() const { return &CServerSocketHandler::sm_eventTable; }
wxEventHashTable CServerSocketHandler::sm_eventHashTable(CServerSocketHandler
::sm_eventTable); wxEventHashTable &CServerSocketHandler::
GetEventHashTable() const { return CServerSocketHandler::sm_eventHashTable
; } const wxEventTableEntry CServerSocketHandler::sm_eventTableEntries
[] = {
75 EVT_SOCKET(ID_SERVERSOCKET_EVENT, CServerSocketHandler::ServerSocketHandler)wxEventTableEntry(wxEVT_SOCKET, ID_SERVERSOCKET_EVENT, wxID_ANY
, wxNewEventTableFunctor(wxEVT_SOCKET, wxEventFunctionCast(wxPrivate
::DoCast<wxPrivate::EventArgOf<wxSocketEventFunction>
::type>(&CServerSocketHandler::ServerSocketHandler))),
__null),
76END_EVENT_TABLE()wxEventTableEntry(wxEVT_NULL, 0, 0, __null, __null) };
77
78void CServerSocketHandler::ServerSocketHandler(wxSocketEvent& event)
79{
80 CServerSocket *socket = dynamic_cast<CServerSocket *>(event.GetSocket());
81 wxASSERT(socket)do { if ( socket ) { } else if ( wxTheAssertHandler &&
(wxOnAssert("ServerSocket.cpp", 81, __FUNCTION__, "socket", (
const char*)__null), wxTrapInAssert) ) { wxTrapInAssert = false
; asm volatile ("int $3"); } } while ( (void)0, 0 );
82 if (!socket) {
83 return;
84 }
85
86 if (socket->IsDestroying()) {
87 return;
88 }
89
90 switch(event.GetSocketEvent()) {
91 case wxSOCKET_CONNECTION:
92 socket->OnConnect(wxSOCKET_NOERROR);
This statement is never executed
93 break;
94 case wxSOCKET_LOST:
95 socket->OnError(socket->LastError());
96 break;
97 case wxSOCKET_INPUT:
98 socket->OnReceive(wxSOCKET_NOERROR);
99 break;
100 case wxSOCKET_OUTPUT:
101 socket->OnSend(wxSOCKET_NOERROR);
102 break;
103 default:
104 wxFAILdo { if ( wxTheAssertHandler && (wxOnAssert("ServerSocket.cpp"
, 104, __FUNCTION__, "\"Assert failure\"", (const char*)__null
), wxTrapInAssert) ) { wxTrapInAssert = false; asm volatile (
"int $3"); } } while ( (void)0, 0 );
105 break;
106 }
107
108
109}
110
111//
112// There can be only one. :)
113//
114static CServerSocketHandler g_serverSocketHandler;
115
116#endif /* !ASIO_SOCKETS */
117
118
119//------------------------------------------------------------------------------
120// CServerSocket
121//------------------------------------------------------------------------------
122
123CServerSocket::CServerSocket(CServerConnect* in_serverconnect, const CProxyData *ProxyData)
124:
125CEMSocket(ProxyData)
126{
127 serverconnect = in_serverconnect;
128 connectionstate = 0;
129 cur_server = 0;
130 info.Clear();
131 m_bIsDeleting = false;
132
133#ifndef ASIO_SOCKETS
134 SetEventHandler(g_serverSocketHandler, ID_SERVERSOCKET_EVENT);
135
136 SetNotify(
137 wxSOCKET_CONNECTION_FLAG |
138 wxSOCKET_INPUT_FLAG |
139 wxSOCKET_OUTPUT_FLAG |
140 wxSOCKET_LOST_FLAG);
141#endif
142 Notify(true);
143
144 m_dwLastTransmission = 0;
145 m_IsSolving = false;
146 m_bNoCrypt = false;
147}
148
149CServerSocket::~CServerSocket()
150{
151#ifndef ASIO_SOCKETS
152 // remove event handler...
153 SetNotify(0);
154 Notify(FALSE0);
155#endif
156
157 if (cur_server) {
158 delete cur_server;
159 }
160 cur_server = NULL__null;
161}
162
163
164void CServerSocket::OnConnect(int nErrorCode)
165{
166 switch (nErrorCode) {
167#ifdef ASIO_SOCKETS
168 case boost::system::errc::success:
169#else
170 case wxSOCKET_NOERROR:
171#endif
172 if (cur_server->HasDynIP()) {
173 uint32 server_ip = GetPeerInt();
174 cur_server->SetID(server_ip);
175 // GetServerByAddress may return NULL, so we must test!
176 // This was the reason why amule would crash when trying to
177 // connect in wxWidgets 2.5.2
178 CServer *pServer = theApp->serverlist->GetServerByAddress(
179 cur_server->GetAddress(), cur_server->GetPort());
180 if (pServer) {
181 pServer->SetID(server_ip);
182 } else {
183 AddDebugLogLineN(logServer, wxT("theApp->serverlist->GetServerByAddress() returned NULL"))do {} while (false);
184 return;
185 }
186 }
187 SetConnectionState(CS_WAITFORLOGIN3);
188 break;
189
190#ifdef ASIO_SOCKETS
191 case boost::system::errc::address_in_use:
192 case boost::system::errc::address_not_available:
193 case boost::system::errc::bad_address:
194 case boost::system::errc::connection_refused:
195 case boost::system::errc::host_unreachable:
196 case boost::system::errc::invalid_argument:
197 case boost::system::errc::timed_out:
198#else
199 case wxSOCKET_INVADDR:
200 case wxSOCKET_NOHOST:
201 case wxSOCKET_INVPORT:
202 case wxSOCKET_TIMEDOUT:
203#endif
204 m_bIsDeleting = true;
205 SetConnectionState(CS_SERVERDEAD-3);
206 serverconnect->DestroySocket(this);
207 return;
208
209 default:
210 m_bIsDeleting = true;
211 SetConnectionState(CS_FATALERROR-5);
212 serverconnect->DestroySocket(this);
213 return;
214
215 }
216
217}
218
219void CServerSocket::OnReceive(int nErrorCode)
220{
221 if (connectionstate != CS_CONNECTED2 && !serverconnect->IsConnecting()) {
222 serverconnect->DestroySocket(this);
223 return;
224 }
225 CEMSocket::OnReceive(nErrorCode);
226 m_dwLastTransmission = GetTickCount();
227}
228
229bool CServerSocket::ProcessPacket(const uint8_t* packet, uint32 size, int8 opcode)
230{
231 try {
232 AddDebugLogLineN( logServer, wxT("Processing Server Packet: ") )do {} while (false);
233
234 switch(opcode) {
235 case OP_SERVERMESSAGE: {
236 /* Kry import of lugdunum 16.40 new features */
237 AddDebugLogLineN( logServer, wxT("Server: OP_SERVERMESSAGE") )do {} while (false);
238
239 theStats::AddDownOverheadServer(size);
240 char* buffer = new char[size-1];
241 memcpy(buffer,&packet[2],size-2);
242 buffer[size-2] = 0;
243
244 wxString strMessages(char2unicode(buffer));
245
246 delete[] buffer;
247
248 // 16.40 servers do not send separate OP_SERVERMESSAGE packets for each line;
249 // instead of this they are sending all text lines with one OP_SERVERMESSAGE packet.
250
251 wxStringTokenizer token(strMessages,wxT("\r\n")L"\r\n",wxTOKEN_DEFAULT );
252
253 while (token.HasMoreTokens()) {
254 wxString message = token.GetNextToken();
255
256 bool bOutputMessage = true;
257 if (message.StartsWith(wxT("server version")L"server version")) {
258 wxString strVer = message.Mid(15,64); // truncate string to avoid misuse by servers in showing ads
259 strVer.Trim();
260 CServer* eserver = theApp->serverlist->GetServerByAddress(cur_server->GetAddress(),cur_server->GetPort());
261 if (eserver) {
262 eserver->SetVersion(strVer);
263 Notify_ServerRefresh(eserver)MuleNotify::DoNotify(&MuleNotify::ServerRefresh, eserver);
264 }
265 } else if (message.StartsWith(wxT("ERROR")L"ERROR")) {
266 CServer* pServer = theApp->serverlist->GetServerByAddress(cur_server->GetAddress(),cur_server->GetPort());
267 wxString servername;
268 if (pServer) {
269 servername = pServer->GetListName();
270 } else {
271 servername = _("Server")wxGetTranslation(("Server"));
272 }
273 AddLogLineN(CFormat( _("ERROR: %s (%s) - %s") )theLogger.AddLogLine(L"ServerSocket.cpp", 276, false, logStandard
, CFormat( wxGetTranslation(("ERROR: %s (%s) - %s")) ) % servername
% Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server
->GetPort()) % message.Mid(5,message.Len()).Trim(L" :"))
274 % servernametheLogger.AddLogLine(L"ServerSocket.cpp", 276, false, logStandard
, CFormat( wxGetTranslation(("ERROR: %s (%s) - %s")) ) % servername
% Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server
->GetPort()) % message.Mid(5,message.Len()).Trim(L" :"))
275 % Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server->GetPort())theLogger.AddLogLine(L"ServerSocket.cpp", 276, false, logStandard
, CFormat( wxGetTranslation(("ERROR: %s (%s) - %s")) ) % servername
% Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server
->GetPort()) % message.Mid(5,message.Len()).Trim(L" :"))
276 % message.Mid(5,message.Len()).Trim(wxT(" :")))theLogger.AddLogLine(L"ServerSocket.cpp", 276, false, logStandard
, CFormat( wxGetTranslation(("ERROR: %s (%s) - %s")) ) % servername
% Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server
->GetPort()) % message.Mid(5,message.Len()).Trim(L" :"));
277 bOutputMessage = false;
278
279 } else if (message.StartsWith(wxT("WARNING")L"WARNING")) {
280
281 CServer* pServer = theApp->serverlist->GetServerByAddress(cur_server->GetAddress(),cur_server->GetPort());
282 wxString servername;
283 if (pServer) {
284 servername = pServer->GetListName();
285 } else {
286 servername = _("Server")wxGetTranslation(("Server"));
287 }
288 AddLogLineN(CFormat( _("WARNING: %s (%s) - %s") )theLogger.AddLogLine(L"ServerSocket.cpp", 291, false, logStandard
, CFormat( wxGetTranslation(("WARNING: %s (%s) - %s")) ) % servername
% Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server
->GetPort()) % message.Mid(5,message.Len()).Trim(L" :"))
289 % servernametheLogger.AddLogLine(L"ServerSocket.cpp", 291, false, logStandard
, CFormat( wxGetTranslation(("WARNING: %s (%s) - %s")) ) % servername
% Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server
->GetPort()) % message.Mid(5,message.Len()).Trim(L" :"))
290 % Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server->GetPort())theLogger.AddLogLine(L"ServerSocket.cpp", 291, false, logStandard
, CFormat( wxGetTranslation(("WARNING: %s (%s) - %s")) ) % servername
% Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server
->GetPort()) % message.Mid(5,message.Len()).Trim(L" :"))
291 % message.Mid(5,message.Len()).Trim(wxT(" :")))theLogger.AddLogLine(L"ServerSocket.cpp", 291, false, logStandard
, CFormat( wxGetTranslation(("WARNING: %s (%s) - %s")) ) % servername
% Uint32_16toStringIP_Port(cur_server->GetIP(), cur_server
->GetPort()) % message.Mid(5,message.Len()).Trim(L" :"));
292
293 bOutputMessage = false;
294 }
295
296 if (message.Find(wxT("[emDynIP: ")L"[emDynIP: ") != (-1) && message.Find(wxT("]")L"]") != (-1) && message.Find(wxT("[emDynIP: ")L"[emDynIP: ") < message.Find(wxT("]")L"]")){
297 wxString dynip = message.Mid(message.Find(wxT("[emDynIP: ")L"[emDynIP: ")+10,message.Find(wxT("]")L"]") - (message.Find(wxT("[emDynIP: ")L"[emDynIP: ")+10));
298 dynip.Trim(wxT(" ")L" ");
299 if ( dynip.Length() && dynip.Length() < 51){
300 CServer* eserver = theApp->serverlist->GetServerByAddress(cur_server->GetAddress(),cur_server->GetPort());
301 if (eserver){
302 eserver->SetDynIP(dynip);
303 cur_server->SetDynIP(dynip);
304 Notify_ServerRefresh(eserver)MuleNotify::DoNotify(&MuleNotify::ServerRefresh, eserver);
305 }
306 }
307 }
308
309 if (bOutputMessage) {
310 theApp->AddServerMessageLine(message);
311 }
312 }
313 break;
314 }
315 case OP_IDCHANGE: {
316 AddDebugLogLineN(logServer, wxT("Server: OP_IDCHANGE"))do {} while (false);
317
318 theStats::AddDownOverheadServer(size);
319
320 if (size < 4 /* uint32 (ID)*/) {
321 throw wxString(wxT("Corrupt or invalid loginanswer from server received")L"Corrupt or invalid loginanswer from server received");
322 }
323
324 CMemFile data(packet, size);
325
326 uint32 new_id = data.ReadUInt32();
327
328 // save TCP flags in 'cur_server'
329 wxASSERT(cur_server)do { if ( cur_server ) { } else if ( wxTheAssertHandler &&
(wxOnAssert("ServerSocket.cpp", 329, __FUNCTION__, "cur_server"
, (const char*)__null), wxTrapInAssert) ) { wxTrapInAssert = false
; asm volatile ("int $3"); } } while ( (void)0, 0 );
330 CServer* pServer = NULL__null;
331 if (cur_server) {
332 uint32 ConnPort = 0;
333 uint32 rport = cur_server->GetConnPort();
334 pServer = theApp->serverlist->GetServerByAddress(cur_server->GetAddress(), rport);
335 if (size >= 4+4 /* uint32 (ID) + uint32 (TCP flags)*/) {
336 cur_server->SetTCPFlags(data.ReadUInt32());
337 if (size >= 4+4+4 /* uint32 (ID) + uint32 (TCP flags) + uint32 (aux port) */) {
338 // aux port login : we should use the 'standard' port of this server to advertise to other clients
339 ConnPort = data.ReadUInt32();
340 cur_server->SetPort(ConnPort);
341 if (cur_server->GetAuxPortsList().IsEmpty()) {
342 cur_server->SetAuxPortsList(CFormat(wxT("%u")L"%u") % rport);
343 }
344 }
345 } else {
346 cur_server->SetTCPFlags(0);
347 }
348 // copy TCP flags into the server in the server list
349 if (pServer) {
350 pServer->SetTCPFlags(cur_server->GetTCPFlags());
351 if (ConnPort) {
352 pServer->SetPort(ConnPort);
353 if (pServer->GetAuxPortsList().IsEmpty()) {
354 pServer->SetAuxPortsList(CFormat(wxT("%u")L"%u") % pServer->GetConnPort());
355 }
356 Notify_ServerRefresh(pServer)MuleNotify::DoNotify(&MuleNotify::ServerRefresh, pServer);
357 Notify_ServerUpdateED2KInfo()MuleNotify::DoNotify(&MuleNotify::ServerUpdateED2KInfo);
358 }
359 }
360 }
361
362 uint32 dwServerReportedIP = 0;
363 if (size >= 4 + 4 + 4 + 4 + 4 /* All of the above + reported ip + obfuscation port */) {
364 dwServerReportedIP = data.ReadUInt32();
365 if (::IsLowID(dwServerReportedIP)){
366 wxFAILdo { if ( wxTheAssertHandler && (wxOnAssert("ServerSocket.cpp"
, 366, __FUNCTION__, "\"Assert failure\"", (const char*)__null
), wxTrapInAssert) ) { wxTrapInAssert = false; asm volatile (
"int $3"); } } while ( (void)0, 0 );
367 dwServerReportedIP = 0;
368 }
369 wxASSERT( dwServerReportedIP == new_id || ::IsLowID(new_id) )do { if ( dwServerReportedIP == new_id || ::IsLowID(new_id) )
{ } else if ( wxTheAssertHandler && (wxOnAssert("ServerSocket.cpp"
, 369, __FUNCTION__, "dwServerReportedIP == new_id || ::IsLowID(new_id)"
, (const char*)__null), wxTrapInAssert) ) { wxTrapInAssert = false
; asm volatile ("int $3"); } } while ( (void)0, 0 );
370 uint32 dwObfuscationTCPPort = data.ReadUInt32();
371 if (dwObfuscationTCPPort != 0) {
372 if (cur_server != NULL__null) {
373 cur_server->SetObfuscationPortTCP(dwObfuscationTCPPort);
374 }
375 if (pServer != NULL__null) {
376 pServer->SetObfuscationPortTCP(dwObfuscationTCPPort);
377 }
378 }
379 }
380
381 if (new_id == 0) {
382 uint8 state = thePrefs::GetSmartIdState();
383 if ( state > 0 ) {
384 state++;
385 if(state > 3) {
386 thePrefs::SetSmartIdState(0);
387 } else {
388 thePrefs::SetSmartIdState(state);
389 }
390 }
391 break;
392 }
393 if(thePrefs::GetSmartIdCheck()) {
394 if (!IsLowID(new_id)) {
395 thePrefs::SetSmartIdState(1);
396 } else {
397 uint8 state = thePrefs::GetSmartIdState();
398 if ( state > 0 ) {
399 state++;
400 if(state > 3) {
401 thePrefs::SetSmartIdState(0);
402 } else {
403 thePrefs::SetSmartIdState(state);
404 }
405 break;
406 }
407 }
408 }
409
410 // we need to know our client when sending our shared files (done indirectly on SetConnectionState)
411
412 serverconnect->SetClientID(new_id);
413
414 if (::IsLowID(new_id) && dwServerReportedIP != 0) {
415 theApp->SetPublicIP(dwServerReportedIP);
416 }
417
418 if (connectionstate != CS_CONNECTED2) {
419 AddDebugLogLineN(logServer, wxT("Connected"))do {} while (false);
420
421 SetConnectionState(CS_CONNECTED2);
422 theApp->OnlineSig(); // Added By Bouc7
423 }
424
425 theApp->ShowConnectionState();
426
427 AddLogLineN(CFormat(_("New clientid is %u")) % new_id)theLogger.AddLogLine(L"ServerSocket.cpp", 427, false, logStandard
, CFormat(wxGetTranslation(("New clientid is %u"))) % new_id);
428 if (::IsLowID(new_id)) {
429 AddLogLineC(_("WARNING: You have received Low-ID!"))theLogger.AddLogLine(L"ServerSocket.cpp", 429, true, logStandard
, wxGetTranslation(("WARNING: You have received Low-ID!")));
430 AddLogLineN(_("\tMost likely this is because you're behind a firewall or router."))theLogger.AddLogLine(L"ServerSocket.cpp", 430, false, logStandard
, wxGetTranslation(("\tMost likely this is because you're behind a firewall or router."
)));
431 AddLogLineN(_("\tFor more information, please refer to http://wiki.amule.org"))theLogger.AddLogLine(L"ServerSocket.cpp", 431, false, logStandard
, wxGetTranslation(("\tFor more information, please refer to http://wiki.amule.org"
)));
432 }
433
434 theApp->downloadqueue->ResetLocalServerRequests();
435 break;
436 }
437 case OP_SEARCHRESULT: {
438 AddDebugLogLineN(logServer, wxT("Server: OP_SEARCHRESULT"))do {} while (false);
439
440 theStats::AddDownOverheadServer(size);
441 CServer* cur_srv = (serverconnect) ?
442 serverconnect->GetCurrentServer() : NULL__null;
443 theApp->searchlist->ProcessSearchAnswer(
444 packet,
445 size,
446 true /*(cur_srv && cur_srv->GetUnicodeSupport())*/,
447 cur_srv ? cur_srv->GetIP() : 0,
448 cur_srv ? cur_srv->GetPort() : 0);
449 theApp->searchlist->LocalSearchEnd();
450 break;
451 }
452 case OP_FOUNDSOURCES_OBFU:
453 case OP_FOUNDSOURCES: {
454 AddDebugLogLineN(logServer, CFormat(wxT("ServerMsg - OP_FoundSources; sources = %u")) % packet[16])do {} while (false);
455 theStats::AddDownOverheadServer(size);
456 CMemFile sources(packet,size);
457 CMD4Hash fileid = sources.ReadHash();
458 if (CPartFile* file = theApp->downloadqueue->GetFileByID(fileid)) {
459 file->AddSources(sources, cur_server->GetIP(), cur_server->GetPort(), SF_LOCAL_SERVER, (opcode == OP_FOUNDSOURCES_OBFU));
460 } else {
461 AddDebugLogLineN(logServer, wxT("Sources received for unknown file: ") + fileid.Encode())do {} while (false);
462 }
463 break;
464 }
465 case OP_SERVERSTATUS: {
466 AddDebugLogLineN(logServer, wxT("Server: OP_SERVERSTATUS"))do {} while (false);
467 // FIXME some statuspackets have a different size -> why? structure?
468 if (size < 8) {
469 throw wxString(wxT("Invalid server status packet")L"Invalid server status packet");
470 }
471 CServer* update = theApp->serverlist->GetServerByAddress(cur_server->GetAddress(), cur_server->GetPort());
472 if (update) {
473 CMemFile data(packet, size);
474 update->SetUserCount(data.ReadUInt32());
475 update->SetFileCount(data.ReadUInt32());
476 Notify_ServerRefresh( update )MuleNotify::DoNotify(&MuleNotify::ServerRefresh, update);
477 theApp->ShowUserCount();
478 }
479 break;
480 }
481 // Cleaned.
482 case OP_SERVERIDENT: {
483 AddDebugLogLineN(logServer, wxT("Server: OP_SERVERIDENT"))do {} while (false);
484
485 theStats::AddDownOverheadServer(size);
486 if (size<38) {
487 AddLogLineN(_("Unknown server info received! - too short"))theLogger.AddLogLine(L"ServerSocket.cpp", 487, false, logStandard
, wxGetTranslation(("Unknown server info received! - too short"
)));
488 // throw wxString(wxT("Unknown server info received!"));
489 break;
490 }
491 CServer* update = theApp->serverlist->GetServerByAddress(cur_server->GetAddress(),cur_server->GetPort());
492 if (update) {
493 CMemFile data(packet,size);
494 CMD4Hash hash = data.ReadHash();
495 if (RawPeekUInt32(hash.GetHash()) == 0x2A2A2A2A){ // No endian problem here
496 const wxString& rstrVersion = update->GetVersion();
497 if (!rstrVersion.IsEmpty()) {
498 update->SetVersion(wxT("eFarm ")L"eFarm " + rstrVersion);
499 } else {
500 update->SetVersion(wxT("eFarm")L"eFarm");
501 }
502 }
503 // Unused
504 /*uint32 nServerIP = */data.ReadUInt32();
505 /*uint16 nServerPort = */data.ReadUInt16();
506
507 uint32 nTags = data.ReadUInt32();
508 for (uint32 i = 0; i < nTags; i++){
509 CTag tag(data, update->GetUnicodeSupport());
510 if (tag.GetNameID() == ST_SERVERNAME){
511 update->SetListName(tag.GetStr());
512 } else if (tag.GetNameID() == ST_DESCRIPTION){
513 update->SetDescription(tag.GetStr());
514 } // No more known tags from server
515 }
516
517 theApp->ShowConnectionState();
518 Notify_ServerRefresh(update)MuleNotify::DoNotify(&MuleNotify::ServerRefresh, update);
519 }
520 break;
521 }
522 // tecxx 1609 2002 - add server's serverlist to own serverlist
523 case OP_SERVERLIST: {
524 AddDebugLogLineN(logServer, wxT("Server: OP_SERVERLIST"))do {} while (false);
525
526 CMemFile* servers = new CMemFile(packet,size);
527 uint8 count = servers->ReadUInt8();
528 if (((int32)(count*6 + 1) > size)) {
529 count = 0;
530 }
531 int addcount = 0;
532 while(count) {
533 uint32 ip = servers->ReadUInt32();
534 uint16 port = servers->ReadUInt16();
535 CServer* srv = new CServer(
536 port , // Port
537 Uint32toStringIP(ip)); // Ip
538 srv->SetListName(srv->GetFullIP());
539 if (!theApp->AddServer(srv)) {
540 delete srv;
541 } else {
542 addcount++;
543 }
544 count--;
545 }
546 delete servers;
547 if (addcount) {
548 AddLogLineN(CFormat(wxPLURAL("Received %d new server", "Received %d new servers", addcount)) % addcount)theLogger.AddLogLine(L"ServerSocket.cpp", 548, false, logStandard
, CFormat(wxGetTranslation(("Received %d new server"), ("Received %d new servers"
), addcount)) % addcount);
549 }
550 theApp->serverlist->SaveServerMet();
551 AddLogLineN(_("Saving of server-list completed."))theLogger.AddLogLine(L"ServerSocket.cpp", 551, false, logStandard
, wxGetTranslation(("Saving of server-list completed.")));
552 break;
553 }
554 case OP_CALLBACKREQUESTED: {
555 AddDebugLogLineN(logServer, wxT("Server: OP_CALLBACKREQUESTED"))do {} while (false);
556
557 theStats::AddDownOverheadServer(size);
558 if (size >= 6) {
559 CMemFile data(packet,size);
560 uint32 dwIP = data.ReadUInt32();
561 uint16 nPort = data.ReadUInt16();
562
563 uint8 byCryptOptions = 0;
564 CMD4Hash achUserHash;
565 if (size >= 23){
566 byCryptOptions = data.ReadUInt8();;
567 achUserHash = data.ReadHash();
568 }
569
570 CUpDownClient* client = theApp->clientlist->FindClientByIP(dwIP,nPort);
571
572 if (!client) {
573 client = new CUpDownClient(nPort,dwIP,0,0,0, true, true);
574 theApp->clientlist->AddClient(client);
575 }
576 if (size >= 23 && client->HasValidHash()){
577 if (client->GetUserHash() != achUserHash){
578 AddDebugLogLineN(logServer, wxT("Reported Userhash from OP_CALLBACKREQUESTED differs with our stored hash"))do {} while (false);
579 // disable crypt support since we dont know which hash is true
580 client->SetCryptLayerRequest(false);
581 client->SetCryptLayerSupport(false);
582 client->SetCryptLayerRequires(false);
583 } else {
584 client->SetConnectOptions(byCryptOptions, true, false);
585 }
586 } else if (size >= 23) {
587 client->SetUserHash(achUserHash);
588 client->SetConnectOptions(byCryptOptions, true, false);
589 }
590
591 client->TryToConnect();
592 }
593 break;
594 }
595 case OP_CALLBACK_FAIL: {
596 AddDebugLogLineN(logServer, wxT("Server: OP_CALLBACK_FAIL"))do {} while (false);
597 break;
598 }
599 case OP_REJECT: {
600 AddDebugLogLineN(logServer, wxT("Server: OP_REJECT"))do {} while (false);
601 AddLogLineN(_("Server rejected last command"))theLogger.AddLogLine(L"ServerSocket.cpp", 601, false, logStandard
, wxGetTranslation(("Server rejected last command")));
602 break;
603 }
604 default:
605 AddDebugLogLineN(logPacketErrors, CFormat(wxT("Unknown server packet with OPcode %x")) % opcode)do {} while (false);
606 }
607 return true;
608 } catch (const CInvalidPacket& e) {
609 AddLogLineN(CFormat( _("Bogus packet received from server: %s") ) % e.what())theLogger.AddLogLine(L"ServerSocket.cpp", 609, false, logStandard
, CFormat( wxGetTranslation(("Bogus packet received from server: %s"
)) ) % e.what());
610 } catch (const CEOFException& e) {
611 AddLogLineN(CFormat( _("Bogus packet received from server: %s") ) % e.what())theLogger.AddLogLine(L"ServerSocket.cpp", 611, false, logStandard
, CFormat( wxGetTranslation(("Bogus packet received from server: %s"
)) ) % e.what());
612 } catch (const wxString& error) {
613 AddLogLineN(CFormat( _("Unhandled error while processing packet from server: %s") ) % error)theLogger.AddLogLine(L"ServerSocket.cpp", 613, false, logStandard
, CFormat( wxGetTranslation(("Unhandled error while processing packet from server: %s"
)) ) % error);
614 }
615
616 // Don't disconnect because of wrong sources.
617 if (opcode==OP_SEARCHRESULT || opcode==OP_FOUNDSOURCES) {
618 return true;
619 }
620
621 SetConnectionState(CS_DISCONNECTED-4);
622 return false;
623}
624
625void CServerSocket::ConnectToServer(CServer* server, bool bNoCrypt)
626{
627 AddDebugLogLineN(logServer, wxT("Trying to connect"))do {} while (false);
628
629 if (cur_server){
630 wxFAILdo { if ( wxTheAssertHandler && (wxOnAssert("ServerSocket.cpp"
, 630, __FUNCTION__, "\"Assert failure\"", (const char*)__null
), wxTrapInAssert) ) { wxTrapInAssert = false; asm volatile (
"int $3"); } } while ( (void)0, 0 );
631 delete cur_server;
632 cur_server = NULL__null;
633 }
634
635 cur_server = new CServer(server);
636
637 m_bNoCrypt = bNoCrypt;
638
639 SetConnectionState(CS_CONNECTING1);
640
641 info = cur_server->GetListName();
642
643 // This must be used if we want to reverse-check the addr of the server
644 if (cur_server->HasDynIP() || !cur_server->GetIP()) {
645 m_IsSolving = true;
646 // Send it to solving thread.
647 CAsyncDNS* dns = new CAsyncDNS(server->GetAddress(), DNS_SERVER_CONNECT, theApp, this);
648
649 if ( dns->Create() == wxTHREAD_NO_ERROR ) {
650 if ( dns->Run() != wxTHREAD_NO_ERROR ) {
651 dns->Delete();
652 AddLogLineN(CFormat( _("Cannot create DNS solving thread for connecting to %s") ) % cur_server->GetAddress())theLogger.AddLogLine(L"ServerSocket.cpp", 652, false, logStandard
, CFormat( wxGetTranslation(("Cannot create DNS solving thread for connecting to %s"
)) ) % cur_server->GetAddress());
653 }
654 } else {
655 dns->Delete();
656 AddLogLineN(CFormat( _("Cannot create DNS solving thread for connecting to %s") ) % cur_server->GetAddress())theLogger.AddLogLine(L"ServerSocket.cpp", 656, false, logStandard
, CFormat( wxGetTranslation(("Cannot create DNS solving thread for connecting to %s"
)) ) % cur_server->GetAddress());
657 }
658 } else {
659 // Nothing to solve, we already have the IP
660 OnHostnameResolved(cur_server->GetIP());
661 }
662
663}
664
665void CServerSocket::OnError(int DEBUG_ONLY(nErrorCode))
666{
667 AddDebugLogLineN(logServer, CFormat(wxT("Error in serversocket: %s(%s:%i): %u"))do {} while (false)
668 % cur_server->GetListName() % cur_server->GetFullIP() % cur_server->GetPort() % nErrorCode)do {} while (false);
669 SetConnectionState(CS_DISCONNECTED-4);
670}
671
672
673bool CServerSocket::PacketReceived(CPacket* packet)
674{
675 AddDebugLogLineN(logServer, CFormat(wxT("Server: Packet Received: Prot %x, Opcode %x, Length %u")) % packet->GetProtocol() % packet->GetOpCode() % packet->GetPacketSize())do {} while (false);
676
677 if (packet->GetProtocol() == OP_PACKEDPROT) {
678 if (!packet->UnPackPacket(250000)){
679 AddDebugLogLineN(logZLib, CFormat(wxT("Failed to decompress server TCP packet: protocol=0x%02x opcode=0x%02x size=%u"))do {} while (false)
680 % packet->GetProtocol() % packet->GetOpCode() % packet->GetPacketSize())do {} while (false);
681 theStats::AddDownOverheadServer(packet->GetPacketSize());
682 return true;
683 }
684
685 packet->SetProtocol(OP_EDONKEYPROT);
686 }
687
688 if (packet->GetProtocol() == OP_EDONKEYPROT) {
689 ProcessPacket(packet->GetDataBuffer(), packet->GetPacketSize(), packet->GetOpCode());
690 } else {
691 AddDebugLogLineN(logServer, CFormat(wxT("Received server TCP packet with unknown protocol: protocol=0x%02x opcode=0x%02x size=%u"))do {} while (false)
692 % packet->GetProtocol() % packet->GetOpCode() % packet->GetPacketSize())do {} while (false);
693 theStats::AddDownOverheadServer(packet->GetPacketSize());
694 }
695
696 return true;
697}
698
699
700void CServerSocket::OnClose(int WXUNUSED(nErrorCode))
701{
702 CEMSocket::OnClose(0);
703
704 switch (connectionstate) {
705 case CS_WAITFORLOGIN3: SetConnectionState(CS_SERVERFULL-1); break;
706 case CS_CONNECTED2: SetConnectionState(CS_DISCONNECTED-4); break;
707 default: SetConnectionState(CS_NOTCONNECTED0);
708 }
709
710 serverconnect->DestroySocket(this);
711}
712
713void CServerSocket::SetConnectionState(sint8 newstate)
714{
715 connectionstate = newstate;
716 if (newstate < CS_CONNECTING1) {
717 serverconnect->ConnectionFailed(this);
718 } else if (newstate == CS_CONNECTED2 || newstate == CS_WAITFORLOGIN3) {
719 if (serverconnect) {
720 serverconnect->ConnectionEstablished(this);
721 }
722 }
723}
724
725
726void CServerSocket::SendPacket(CPacket* packet, bool delpacket, bool controlpacket, uint32 actualPayloadSize)
727{
728 m_dwLastTransmission = GetTickCount();
729 CEMSocket::SendPacket(packet, delpacket, controlpacket, actualPayloadSize);
730}
731
732
733void CServerSocket::OnHostnameResolved(uint32 ip) {
734
735 m_IsSolving = false;
736 if (ip) {
737 if (theApp->ipfilter->IsFiltered(ip, true)) {
738 AddLogLineC(CFormat( _("Server IP %s (%s) is filtered. Not connecting.") )theLogger.AddLogLine(L"ServerSocket.cpp", 739, true, logStandard
, CFormat( wxGetTranslation(("Server IP %s (%s) is filtered. Not connecting."
)) ) % Uint32toStringIP(ip) % cur_server->GetAddress())
739 % Uint32toStringIP(ip) % cur_server->GetAddress() )theLogger.AddLogLine(L"ServerSocket.cpp", 739, true, logStandard
, CFormat( wxGetTranslation(("Server IP %s (%s) is filtered. Not connecting."
)) ) % Uint32toStringIP(ip) % cur_server->GetAddress());
740#ifdef ASIO_SOCKETS
741 OnConnect(boost::system::errc::invalid_argument);
742#else
743 OnConnect(wxSOCKET_INVADDR);
744#endif
745 } else {
746 amuleIPV4Address addr;
747 addr.Hostname(ip);
748 uint16 nPort = 0;
749 wxString useObfuscation;
750 if ( !m_bNoCrypt && thePrefs::IsServerCryptLayerTCPRequested() && cur_server->GetObfuscationPortTCP() != 0 && cur_server->SupportsObfuscationTCP()){
751 nPort = cur_server->GetObfuscationPortTCP();
752 useObfuscation = _("using protocol obfuscation.")wxGetTranslation(("using protocol obfuscation."));
753 SetConnectionEncryption(true, NULL__null, true);
754 } else {
755 nPort = cur_server->GetConnPort();
756 SetConnectionEncryption(false, NULL__null, true);
757 }
758
759 addr.Service(nPort);
760
761 AddLogLineN(CFormat( _("Connecting to %s (%s - %s:%i) %s") )theLogger.AddLogLine(L"ServerSocket.cpp", 767, false, logStandard
, CFormat( wxGetTranslation(("Connecting to %s (%s - %s:%i) %s"
)) ) % cur_server->GetListName() % cur_server->GetAddress
() % cur_server->GetFullIP() % nPort % useObfuscation)
762 % cur_server->GetListName()theLogger.AddLogLine(L"ServerSocket.cpp", 767, false, logStandard
, CFormat( wxGetTranslation(("Connecting to %s (%s - %s:%i) %s"
)) ) % cur_server->GetListName() % cur_server->GetAddress
() % cur_server->GetFullIP() % nPort % useObfuscation)
763 % cur_server->GetAddress()theLogger.AddLogLine(L"ServerSocket.cpp", 767, false, logStandard
, CFormat( wxGetTranslation(("Connecting to %s (%s - %s:%i) %s"
)) ) % cur_server->GetListName() % cur_server->GetAddress
() % cur_server->GetFullIP() % nPort % useObfuscation)
764 % cur_server->GetFullIP()theLogger.AddLogLine(L"ServerSocket.cpp", 767, false, logStandard
, CFormat( wxGetTranslation(("Connecting to %s (%s - %s:%i) %s"
)) ) % cur_server->GetListName() % cur_server->GetAddress
() % cur_server->GetFullIP() % nPort % useObfuscation)
765 % nPorttheLogger.AddLogLine(L"ServerSocket.cpp", 767, false, logStandard
, CFormat( wxGetTranslation(("Connecting to %s (%s - %s:%i) %s"
)) ) % cur_server->GetListName() % cur_server->GetAddress
() % cur_server->GetFullIP() % nPort % useObfuscation)
766 % useObfuscationtheLogger.AddLogLine(L"ServerSocket.cpp", 767, false, logStandard
, CFormat( wxGetTranslation(("Connecting to %s (%s - %s:%i) %s"
)) ) % cur_server->GetListName() % cur_server->GetAddress
() % cur_server->GetFullIP() % nPort % useObfuscation)
767 )theLogger.AddLogLine(L"ServerSocket.cpp", 767, false, logStandard
, CFormat( wxGetTranslation(("Connecting to %s (%s - %s:%i) %s"
)) ) % cur_server->GetListName() % cur_server->GetAddress
() % cur_server->GetFullIP() % nPort % useObfuscation);
768
769 AddDebugLogLineN(logServer, CFormat(wxT("Server %s(%s) Port %i"))do {} while (false)
770 % cur_server->GetAddress() % Uint32toStringIP(ip) % cur_server->GetConnPort())do {} while (false);
771 Connect(addr, false);
772 }
773 } else {
774 AddLogLineC(CFormat( _("Could not solve dns for server %s: Unable to connect!") )theLogger.AddLogLine(L"ServerSocket.cpp", 775, true, logStandard
, CFormat( wxGetTranslation(("Could not solve dns for server %s: Unable to connect!"
)) ) % cur_server->GetAddress())
775 % cur_server->GetAddress() )theLogger.AddLogLine(L"ServerSocket.cpp", 775, true, logStandard
, CFormat( wxGetTranslation(("Could not solve dns for server %s: Unable to connect!"
)) ) % cur_server->GetAddress());
776#ifdef ASIO_SOCKETS
777 OnConnect(boost::system::errc::host_unreachable);
778#else
779 OnConnect(wxSOCKET_NOHOST);
780#endif
781 }
782
783}
784uint32 CServerSocket::GetServerIP() const
785{
786 return cur_server ? cur_server->GetIP() : 0;
787}
788// File_checked_for_headers