Method ProcessRequest2

src/ExternalConn.cpp:1726–2313

}

CECPacket *CECServerSocket::ProcessRequest2(const CECPacket *request)
{

	if ( !request ) {
		return 0;
	}

	CECPacket *response = NULL;

	switch (request->GetOpCode()) {
		//
		// Misc commands
		//
		case EC_OP_SHUTDOWN:
			if (!theApp->IsOnShutDown()) {
				response = new CECPacket(EC_OP_NOOP);
				AddLogLineC(_("External Connection: shutdown requested"));
#ifndef AMULE_DAEMON
				{
					wxCloseEvent evt;
					evt.SetCanVeto(false);
					theApp->ShutDown(evt);
				}
#else
				theApp->ExitMainLoop();
#endif
			} else {
				response = new CECPacket(EC_OP_FAILED);
				response->AddTag(CECTag(EC_TAG_STRING, wxTRANSLATE("Already shutting down.")));
			}
			break;
		case EC_OP_ADD_LINK: {
			// Aggregate the per-link results into a single response: until
			// #206 was filed, every iteration overwrote the previous response,
			// so a batch of N-1 successes followed by one failure looked like
			// a total failure to the caller (and vice versa).
			int successCount = 0;
			int failCount = 0;
			for (CECPacket::const_iterator it = request->begin(); it != request->end(); ++it) {
				const CECTag &tag = *it;
				wxString link = tag.GetStringData();
				int category = 0;
				const CECTag *cattag = tag.GetTagByName(EC_TAG_PARTFILE_CAT);
				if (cattag) {
					category = cattag->GetInt();
				}
				AddLogLineC(CFormat(_("ExternalConn: adding link '%s'.")) % link);
				if ( theApp->downloadqueue->AddLink(link, category) ) {
					++successCount;
				} else {
					// Per-link error reasons are already printed by AddLink().
					++failCount;
				}
			}
			if (failCount == 0) {
				response = new CECPacket(EC_OP_NOOP);
			} else if (successCount == 0) {
				response = new CECPacket(EC_OP_FAILED);