Method DoUpload

src/Networking/HttpResponder.cpp:1390–1443

This function overrides the one in class NetworkResponder. It tries to process a chunk of uploaded data and changes the state if finished.

// This function overrides the one in class NetworkResponder.
// It tries to process a chunk of uploaded data and changes the state if finished.
void HttpResponder::DoUpload() noexcept
{
	const uint8_t *_ecv_array buffer;
	size_t len;
	if (skt->ReadBuffer(buffer, len))
	{
		size_t bytesWritten = 0;		// don't write than one FS buffer at once, else we may get stuck here with slow cards
		do
		{
			(void)CheckAuthenticated();						// uploading may take a long time, so make sure the requester IP is not timed out
			timer = millis();								// reset the timer

			const bool ok = dummyUpload || fileBeingUploaded.Write(buffer, len);
			skt->Taken(len);
			uploadedBytes += len;
			bytesWritten += len;

			if (!ok)
			{
				uploadError = true;
				GetPlatform().Message(ErrorMessage, "HTTP: could not write upload data\n");
				CancelUpload();
				SendJsonResponse("upload");
				return;
			}
		} while (bytesWritten < FileWriteBufLen && skt->ReadBuffer(buffer, len));
	}
	else if (!skt->CanRead() || millis() - timer >= HttpSessionTimeout)
	{
		// Sometimes uploads can get stuck; make sure they are cancelled when that happens
		ConnectionLost();
		return;
	}

	// See if the upload has finished
	if (uploadedBytes >= postFileLength)
	{
		// Reset POST upload state for this client
		const HttpSessionKey key = GetSessionKey();
		const IPAddress remoteIP = GetRemoteIP();
		for (size_t i = 0; i < numSessions; i++)
		{
			if (sessions[i].ip == remoteIP && sessions[i].key == key && sessions[i].isPostUploading)
			{
				sessions[i].isPostUploading = false;
				sessions[i].lastQueryTime = millis();
				break;
			}
		}

		FinishUpload(postFileLength, fileLastModified, postFileGotCrc, postFileExpectedCrc);
		SendJsonResponse("upload");
	}
}

#endif