AstralTransRocketries/ClassiCube
1
0
Fork 0
mirror of https://github.com/ClassiCube/ClassiCube.git synced 2025-09-17 03:25:14 -04:00
Code Issues Packages Projects Releases Wiki Activity

Don't try to read data for http error status codes for C client

Browse Source
This commit is contained in:
UnknownShadow200 2018-05-07 23:23:32 +10:00
parent a66e4a7e6a
commit abb6f9796a
4 changed files with 36 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/Client/AsyncDownloader.c
View File

@ -218,7 +218,7 @@ void AsyncDownloader_ProcessRequest(AsyncRequest* request) {
Stopwatch_Start(&stopwatch);
result = Platform_HttpMakeRequest(request, &handle);
elapsedMS = Stopwatch_ElapsedMicroseconds(&stopwatch) / 1000;
Platform_Log2("HTTP get request %i in %i ms", &result, &elapsedMS);
Platform_Log2("HTTP get request: ret code %i, in %i ms", &result, &elapsedMS);
if (!ErrorHandler_Check(result)) return;
void* data = NULL;
@ -226,13 +226,14 @@ void AsyncDownloader_ProcessRequest(AsyncRequest* request) {
Stopwatch_Start(&stopwatch);
result = Platform_HttpGetRequestData(request, handle, &data, &size);
elapsedMS = Stopwatch_ElapsedMicroseconds(&stopwatch) / 1000;
Platform_Log2("HTTP get data %i in %i ms", &result, &elapsedMS);
UInt32 status = request->StatusCode;
Platform_Log3("HTTP get data: ret code %i (http %i), in %i ms", &result, &status, &elapsedMS);
Platform_HttpFreeRequest(handle);
if (!ErrorHandler_Check(result)) return;
if (!ErrorHandler_Check(result) || request->StatusCode != 200) return;
UInt64 addr = (UInt64)data;
Platform_Log2("OK I got the DATA! %x of %i", &addr, &size);
Platform_Log2("OK I got the DATA! %i bytes at %x", &size, &addr);
Stream memStream;
switch (request->RequestType) {

2
src/Client/AsyncDownloader.h
View File

@ -18,7 +18,7 @@ typedef struct AsyncRequest_ {
DateTime TimeAdded;
DateTime TimeDownloaded;
UInt16 ResponseCode;
UInt16 StatusCode;
union {
struct { void* Ptr; UInt32 Size; } ResultData;

8
src/Client/Deflate.c
View File

@ -170,11 +170,11 @@ enum INFLATE_STATE_ {
/* Goes to the next state, after having read data of a block. */
#define Inflate_NextBlockState(state) (state->LastBlock ? INFLATE_STATE_DONE : INFLATE_STATE_HEADER)
/* Goes to the next state, after having finished reading a compressed entry. */
/* The maximum amount of bytes that can be output is 258. */
/* The most input bytes required for huffman codes and extra data is 16 + 5 + 16 + 13 bits. Add 3 extra bytes to account for putting data into the bit buffer. */
#define INFLATE_FASTINF_OUT 258
#define INFLATE_FASTINF_IN 10
#define Inflate_NextCompressState(state) ((state->AvailIn >= INFLATE_FASTINF_IN && state->AvailOut >= INFLATE_FASTINF_OUT) ? INFLATE_STATE_FASTCOMPRESSED : INFLATE_STATE_COMPRESSED_LIT)
/* The maximum amount of bytes that can be output is 258. */
#define INFLATE_FASTINF_OUT 258
/* The most input bytes required for huffman codes and extra data is 16 + 5 + 16 + 13 bits. Add 3 extra bytes to account for putting data into the bit buffer. */
#define INFLATE_FASTINF_IN 10
UInt32 Huffman_ReverseBits(UInt32 n, UInt8 bits) {
n = ((n & 0xAAAA) >> 1) | ((n & 0x5555) << 1);

30
src/Client/WinPlatform.c
View File

@ -609,19 +609,39 @@ ReturnCode Platform_HttpMakeRequest(AsyncRequest* request, void** handle) {
return *handle == NULL ? GetLastError() : 0;
}
/* TODO: May need to rethink this API design a bit - probably want to split parse headers function out */
/* TODO: Test last modified and etag even work */
#define Http_Query(flags, result) HttpQueryInfoA(handle, flags, result, &bufferLen, NULL)
ReturnCode Platform_HttpGetRequestData(AsyncRequest* request, void* handle, void** data, UInt32* size) {
DWORD bufferLen = sizeof(DWORD);
BOOL success = HttpQueryInfoA(handle, HTTP_QUERY_CONTENT_LENGTH | HTTP_QUERY_FLAG_NUMBER, size, &bufferLen, 0);
if (!success) return GetLastError();
if (*size == 0) return 1;
DWORD bufferLen;
UInt32 status;
bufferLen = sizeof(DWORD);
if (!Http_Query(HTTP_QUERY_STATUS_CODE | HTTP_QUERY_FLAG_NUMBER, &status)) return GetLastError();
request->StatusCode = status;
bufferLen = sizeof(DWORD);
if (!Http_Query(HTTP_QUERY_CONTENT_LENGTH | HTTP_QUERY_FLAG_NUMBER, size)) return GetLastError();
SYSTEMTIME lastModified;
bufferLen = sizeof(SYSTEMTIME);
if (Http_Query(HTTP_QUERY_LAST_MODIFIED | HTTP_QUERY_FLAG_SYSTEMTIME, &lastModified)) {
Platform_FromSysTime(&request->LastModified, &lastModified);
}
String etag = String_InitAndClearArray(request->Etag);
bufferLen = etag.capacity;
Http_Query(HTTP_QUERY_ETAG, etag.buffer, &bufferLen);
if (*size == 0) return 1;
*data = Platform_MemAlloc(*size, 1);
if (*data == NULL) ErrorHandler_Fail("Failed to allocate memory for http get data");
UInt8* buffer = *data;
UInt32 left = *size, read;
while (left > 0) {
success = InternetReadFile(handle, buffer, left, &read);
bool success = InternetReadFile(handle, buffer, left, &read);
if (!success) { Platform_MemFree(data); return GetLastError(); }
if (read == 0) break;