📄 listensocket.cpp
字号:
if(client)
{
// start secure identification, if
// - we have received eMule-OP_HELLO (new eMule)
if (client->GetInfoPacketsReceived() == IP_BOTH)
client->InfoPacketsReceived();
}
break;
}
case OP_REQUESTFILENAME:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_FileRequest", client, packet);
theStats.AddDownDataOverheadFileRequest(size);
if (size >= 16)
{
if (!client->GetWaitStartTime())
client->SetWaitStartTime();
CSafeMemFile data_in((BYTE*)packet,size);
uchar reqfilehash[16];
data_in.ReadHash16(reqfilehash);
CKnownFile* reqfile;
if ( (reqfile = theApp.sharedfiles->GetFileByID(reqfilehash)) == NULL ){
if ( !((reqfile = theApp.downloadqueue->GetFileByID(reqfilehash)) != NULL
&& reqfile->GetFileSize() > PARTSIZE ) )
{
client->CheckFailedFileIdReqs(reqfilehash);
break;
}
}
// if we are downloading this file, this could be a new source
// no passive adding of files with only one part
if (reqfile->IsPartFile() && reqfile->GetFileSize() > PARTSIZE)
{
if (thePrefs.GetMaxSourcePerFile() > ((CPartFile*)reqfile)->GetSourceCount())
theApp.downloadqueue->CheckAndAddKnownSource((CPartFile*)reqfile, client, true);
}
// check to see if this is a new file they are asking for
if (md4cmp(client->GetUploadFileID(), reqfilehash) != 0)
client->SetCommentDirty();
client->SetUploadFileID(reqfile);
client->ProcessExtendedInfo(&data_in, reqfile);
// send filename etc
CSafeMemFile data_out(128);
data_out.WriteHash16(reqfile->GetFileHash());
data_out.WriteString(reqfile->GetFileName(), client->GetUnicodeSupport());
Packet* packet = new Packet(&data_out);
packet->opcode = OP_REQFILENAMEANSWER;
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugSend("OP__FileReqAnswer", client, (char*)reqfile->GetFileHash());
theStats.AddUpDataOverheadFileRequest(packet->size);
SendPacket(packet, true);
client->SendCommentInfo(reqfile);
break;
}
throw GetResString(IDS_ERR_WRONGPACKAGESIZE);
break;
}
case OP_SETREQFILEID:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_SetReqFileID", client, (size == 16) ? packet : NULL);
theStats.AddDownDataOverheadFileRequest(size);
if (size == 16){
if (!client->GetWaitStartTime())
client->SetWaitStartTime();
CKnownFile* reqfile;
if ( (reqfile = theApp.sharedfiles->GetFileByID((uchar*)packet)) == NULL ){
if ( !((reqfile = theApp.downloadqueue->GetFileByID((uchar*)packet)) != NULL
&& reqfile->GetFileSize() > PARTSIZE ) )
{
// send file request no such file packet (0x48)
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugSend("OP__FileReqAnsNoFil", client, packet);
Packet* replypacket = new Packet(OP_FILEREQANSNOFIL, 16);
md4cpy(replypacket->pBuffer, packet);
theStats.AddUpDataOverheadFileRequest(replypacket->size);
SendPacket(replypacket, true);
client->CheckFailedFileIdReqs((uchar*)packet);
break;
}
}
// check to see if this is a new file they are asking for
if (md4cmp(client->GetUploadFileID(), packet) != 0)
client->SetCommentDirty();
client->SetUploadFileID(reqfile);
// send filestatus
CSafeMemFile data(16+16);
data.WriteHash16(reqfile->GetFileHash());
if (reqfile->IsPartFile())
((CPartFile*)reqfile)->WritePartStatus(&data);
else
data.WriteUInt16(0);
Packet* packet = new Packet(&data);
packet->opcode = OP_FILESTATUS;
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugSend("OP__FileStatus", client, (char*)reqfile->GetFileHash());
theStats.AddUpDataOverheadFileRequest(packet->size);
SendPacket(packet, true);
break;
}
throw GetResString(IDS_ERR_WRONGPACKAGESIZE);
break;
}
case OP_FILEREQANSNOFIL:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_FileReqAnsNoFil", client, packet);
theStats.AddDownDataOverheadFileRequest(size);
if (size == 16)
{
CPartFile* reqfile = theApp.downloadqueue->GetFileByID((uchar*)packet);
if (!reqfile){
client->CheckFailedFileIdReqs((uchar*)packet);
break;
}
else
reqfile->m_DeadSourceList.AddDeadSource(client);
// if that client does not have my file maybe has another different
// we try to swap to another file ignoring no needed parts files
switch (client->GetDownloadState())
{
case DS_CONNECTED:
case DS_ONQUEUE:
case DS_NONEEDEDPARTS:
client->DontSwapTo(client->GetRequestFile()); // ZZ:DownloadManager
if (!client->SwapToAnotherFile(_T("Source says it doesn't have the file. CClientReqSocket::ProcessPacket()"), true, true, true, NULL, false, false)) { // ZZ:DownloadManager
theApp.downloadqueue->RemoveSource(client);
}
break;
}
break;
}
throw GetResString(IDS_ERR_WRONGPACKAGESIZE);
break;
}
case OP_REQFILENAMEANSWER:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_FileReqAnswer", client, packet);
theStats.AddDownDataOverheadFileRequest(size);
CSafeMemFile data((BYTE*)packet,size);
uchar cfilehash[16];
data.ReadHash16(cfilehash);
CPartFile* file = theApp.downloadqueue->GetFileByID(cfilehash);
if (file == NULL)
client->CheckFailedFileIdReqs(cfilehash);
client->ProcessFileInfo(&data, file);
break;
}
case OP_FILESTATUS:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_FileStatus", client, packet);
theStats.AddDownDataOverheadFileRequest(size);
CSafeMemFile data((BYTE*)packet,size);
uchar cfilehash[16];
data.ReadHash16(cfilehash);
CPartFile* file = theApp.downloadqueue->GetFileByID(cfilehash);
if (file == NULL)
client->CheckFailedFileIdReqs(cfilehash);
client->ProcessFileStatus(false, &data, file);
break;
}
case OP_STARTUPLOADREQ:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_StartUpLoadReq", client);
theStats.AddDownDataOverheadFileRequest(size);
if (!client->CheckHandshakeFinished(OP_EDONKEYPROT, opcode))
break;
if (size == 16)
{
CKnownFile* reqfile = theApp.sharedfiles->GetFileByID((uchar*)packet);
if (reqfile)
{
if (md4cmp(client->GetUploadFileID(), packet) != 0)
client->SetCommentDirty();
client->SetUploadFileID(reqfile);
client->SendCommentInfo(reqfile);
theApp.uploadqueue->AddClientToQueue(client);
}
else
client->CheckFailedFileIdReqs((uchar*)packet);
}
break;
}
case OP_QUEUERANK:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_QueueRank", client);
theStats.AddDownDataOverheadFileRequest(size);
client->ProcessEdonkeyQueueRank(packet, size);
break;
}
case OP_ACCEPTUPLOADREQ:
{
if (thePrefs.GetDebugClientTCPLevel() > 0){
DebugRecv("OP_AcceptUploadReq", client, size >= 16 ? packet : NULL);
if (size > 0)
Debug(_T(" ***NOTE: Packet contains %u additional bytes\n"), size);
Debug(_T(" QR=%d\n"), client->IsRemoteQueueFull() ? (UINT)-1 : (UINT)client->GetRemoteQueueRank());
}
theStats.AddDownDataOverheadFileRequest(size);
client->ProcessAcceptUpload();
break;
}
case OP_REQUESTPARTS:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_RequestParts", client, packet);
theStats.AddDownDataOverheadFileRequest(size);
CSafeMemFile data((BYTE*)packet,size);
uchar reqfilehash[16];
data.ReadHash16(reqfilehash);
uint32 auStartOffsets[3];
auStartOffsets[0] = data.ReadUInt32();
auStartOffsets[1] = data.ReadUInt32();
auStartOffsets[2] = data.ReadUInt32();
uint32 auEndOffsets[3];
auEndOffsets[0] = data.ReadUInt32();
auEndOffsets[1] = data.ReadUInt32();
auEndOffsets[2] = data.ReadUInt32();
if (thePrefs.GetDebugClientTCPLevel() > 0){
Debug(_T(" Start1=%u End1=%u Size=%u\n"), auStartOffsets[0], auEndOffsets[0], auEndOffsets[0] - auStartOffsets[0]);
Debug(_T(" Start2=%u End2=%u Size=%u\n"), auStartOffsets[1], auEndOffsets[1], auEndOffsets[1] - auStartOffsets[1]);
Debug(_T(" Start3=%u End3=%u Size=%u\n"), auStartOffsets[2], auEndOffsets[2], auEndOffsets[2] - auStartOffsets[2]);
}
for (int i = 0; i < ARRSIZE(auStartOffsets); i++)
{
if (auEndOffsets[i] > auStartOffsets[i])
{
Requested_Block_Struct* reqblock = new Requested_Block_Struct;
reqblock->StartOffset = auStartOffsets[i];
reqblock->EndOffset = auEndOffsets[i];
md4cpy(reqblock->FileID, reqfilehash);
reqblock->transferred = 0;
client->AddReqBlock(reqblock);
}
else
{
if (thePrefs.GetVerbose())
{
if (auEndOffsets[i] != 0 || auStartOffsets[i] != 0)
DebugLogWarning(_T("Client requests invalid %u. file block %u-%u (%d bytes): %s"), i, auStartOffsets[i], auEndOffsets[i], auEndOffsets[i] - auStartOffsets[i], client->DbgGetClientInfo());
}
}
}
break;
}
case OP_CANCELTRANSFER:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_CancelTransfer", client);
theStats.AddDownDataOverheadFileRequest(size);
theApp.uploadqueue->RemoveFromUploadQueue(client, _T("Remote client canceled transfer."));
break;
}
case OP_END_OF_DOWNLOAD:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_EndOfDownload", client, packet);
theStats.AddDownDataOverheadFileRequest(size);
if (size>=16 && !md4cmp(client->GetUploadFileID(),packet))
{
theApp.uploadqueue->RemoveFromUploadQueue(client, _T("Remote client ended transfer."));
}
else
client->CheckFailedFileIdReqs((uchar*)packet);
break;
}
case OP_HASHSETREQUEST:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_HashSetReq", client, packet);
theStats.AddDownDataOverheadFileRequest(size);
if (size != 16)
throw GetResString(IDS_ERR_WRONGHPACKAGESIZE);
client->SendHashsetPacket(packet);
break;
}
case OP_HASHSETANSWER:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_HashSetAnswer", client, packet);
theStats.AddDownDataOverheadFileRequest(size);
client->ProcessHashSet(packet,size);
break;
}
case OP_SENDINGPART:
{
if (thePrefs.GetDebugClientTCPLevel() > 1)
DebugRecv("OP_SendingPart", client, packet);
theStats.AddDownDataOverheadFileRequest(24);
if (client->GetRequestFile() && !client->GetRequestFile()->IsStopped() && (client->GetRequestFile()->GetStatus()==PS_READY || client->GetRequestFile()->GetStatus()==PS_EMPTY))
{
client->ProcessBlockPacket(packet,size);
if (client->GetRequestFile()->IsStopped() || client->GetRequestFile()->GetStatus()==PS_PAUSED || client->GetRequestFile()->GetStatus()==PS_ERROR)
{
client->SendCancelTransfer();
client->SetDownloadState(client->GetRequestFile()->IsStopped() ? DS_NONE : DS_ONQUEUE);
}
}
else
{
client->SendCancelTransfer();
client->SetDownloadState((client->GetRequestFile()==NULL || client->GetRequestFile()->IsStopped()) ? DS_NONE : DS_ONQUEUE);
}
break;
}
case OP_OUTOFPARTREQS:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_OutOfPartReqs", client);
theStats.AddDownDataOverheadFileRequest(size);
if (client->GetDownloadState() == DS_DOWNLOADING)
{
client->SetDownloadState(DS_ONQUEUE, _T("The remote client decided to stop/complete the transfer (got OP_OutOfPartReqs)."));
}
break;
}
case OP_CHANGE_CLIENT_ID:
{
if (thePrefs.GetDebugClientTCPLevel() > 0)
DebugRecv("OP_ChangedClientID", client);
theStats.AddDownDataOverheadOther(size);
CSafeMemFile data((BYTE*)packet, size);
uint32 nNewUserID = data.ReadUInt32();
uint32 nNewServerIP = data.ReadUInt32();
if (thePrefs.GetDebugClientTCPLevel() > 0)
Debug(_T(" NewUserID=%u (%08x, %s) NewServerIP=%u (%08x, %s)\n"), nNewUserID, nNewUserID, ipstr(nNewUserID), nNewServerIP, nNewServerIP, ipstr(nNewServerIP));
if (IsLowID(nNewUserID))
{ // client changed server and has a LowID
CServer* pNewServer = theApp.serverlist->GetServerByIP(nNewServerIP);
if (pNewServer != NULL)
{
client->SetUserIDHybrid(nNewUserID); // update UserID only if we know the server
client->SetServerIP(nNewServerIP);
client->SetServerPort(pNewServer->GetPort());
}
}
else if (nNewUserID == client->GetIP())
{ // client changed server and has a HighID(IP)
client->SetUserIDHybrid(ntohl(nNewUserID));
CServer* pNewServer = theApp.serverlist->GetServerByIP(nNewServerIP);
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -