Method Process

src/UploadQueue.cpp:239–286

}

void CUploadQueue::Process()
{
	// Check if someone's waiting, if there is a slot for him,
	// or if we should try to free a slot for him
	uint64 tick = GetTickCount64();
	// Nobody waiting or upload started recently
	// (Actually instead of "empty" it should check for "no HighID clients queued",
	//  but the cost for that outweighs the benefit. As it is, a slot will be freed
	//  even if it can't be taken because all of the queue is LowID. But just one,
	//  and the kicked client will instantly get it back if he has HighID.)
	// Also, if we are running out of sockets, don't add new clients, but also don't kick existing ones,
	// or uploading will cease right away.
#if EXTENDED_UPLOADQUEUE
	if (tick - m_nLastStartUpload < 1000
#else
	if (m_waitinglist.empty() || tick - m_nLastStartUpload < 1000
#endif
		|| theApp->listensocket->TooManySockets()) {
		m_allowKicking = false;
	// Already a slot free, try to fill it
	} else if (m_uploadinglist.size() < GetMaxSlots()) {
		m_allowKicking = false;
		m_nLastStartUpload = tick;
		AddUpNextClient();
	// All slots taken, try to free one
	} else {
		m_allowKicking = true;
	}

	// The loop that feeds the upload slots with data.
	CClientRefList::iterator it = m_uploadinglist.begin();
	while (it != m_uploadinglist.end()) {
		// Get the client. Note! Also updates pos as a side effect.
		CUpDownClient* cur_client = it++->GetClient();

		// It seems chatting or friend slots can get stuck at times in upload.. This needs looked into..
		if (!cur_client->GetSocket()) {
			RemoveFromUploadQueue(cur_client);
			if(cur_client->Disconnected(_T("CUploadQueue::Process"))){
				cur_client->Safe_Delete();
			}
		} else if (cur_client->m_bIOError) {
			// Disk I/O thread signaled an error for this client
			RemoveFromUploadQueue(cur_client);
		} else {
			cur_client->SendBlockData();
		}
	}

	// Save used bandwidth for speed calculations
	uint64 sentBytes = theApp->uploadBandwidthThrottler->GetNumberOfSentBytesSinceLastCallAndReset();