Method AddUpNextClient

src/UploadQueue.cpp:169–237

void CUploadQueue::AddUpNextClient(CUpDownClient* directadd)
{
	CUpDownClient* newclient = NULL;
	CClientRef newClientRef;
	// select next client or use given client
	if (!directadd) {
		SortGetBestClient(&newClientRef);
		newclient = newClientRef.GetClient();
#if EXTENDED_UPLOADQUEUE
		if (!newclient) {
			// Nothing to upload. Try to find something from the sources.
			if (PopulatePossiblyWaitingList() > 0) {
				newClientRef = * m_possiblyWaitingList.begin();
				m_possiblyWaitingList.pop_front();
				newclient = newClientRef.GetClient();
				AddDebugLogLineN( logLocalClient, "Added client from possiblyWaitingList " + newclient->GetFullIP() );
			}
		}
#endif
		if (!newclient) {
			return;
		}
	} else {
		// Check if requested file is suspended or not shared (maybe deleted recently)

		if (IsSuspended(directadd->GetUploadFileID())
			|| !theApp->sharedfiles->GetFileByID(directadd->GetUploadFileID())) {
			return;
		} else {
			newclient = directadd;
		}
	}

	if (IsDownloading(newclient)) {
		return;
	}
	// tell the client that we are now ready to upload
	if (!newclient->IsConnected()) {
		newclient->SetUploadState(US_CONNECTING);
		if (!newclient->TryToConnect(true)) {
			return;
		}
	} else {
		CPacket* packet = new CPacket(OP_ACCEPTUPLOADREQ, 0, OP_EDONKEYPROT);
		theStats::AddUpOverheadFileRequest(packet->GetPacketSize());
		AddDebugLogLineN( logLocalClient, "Local Client: OP_ACCEPTUPLOADREQ to " + newclient->GetFullIP() );
		newclient->SendPacket(packet,true);
		newclient->SetUploadState(US_UPLOADING);
	}
	newclient->SetUpStartTime();
	newclient->ResetSessionUp();

	{
		// Guard against concurrent iteration by the disk I/O thread.
		wxMutexLocker lock(m_uploadingListMutex);
		theApp->uploadBandwidthThrottler->AddToStandardList(m_uploadinglist.size(), newclient->GetSocket());
		m_uploadinglist.push_back(CCLIENTREF(newclient, "CUploadQueue::AddUpNextClient"));
	}