Mirrors/OpenBK7231T_App
2
0
Fork 0
mirror of https://github.com/openshwprojects/OpenBK7231T_App.git synced 2026-03-08 00:07:42 +01:00
Code Issues Packages Projects Releases Wiki Activity

win http server - do not block in rare cases

Browse Source
This commit is contained in:
openshwprojects
2022-12-08 18:11:23 +01:00
parent dd6b89b73a
commit 6684c01d6f
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/httpserver/http_tcp_server_nonblocking.c
View File

@@ -6,6 +6,7 @@
#include "lwip/inet.h"
#include "../logging/logging.h"
#include "new_http.h"
#include <timeapi.h>
SOCKET ListenSocket = INVALID_SOCKET;
@@ -132,7 +133,7 @@ void HTTPServer_RunQuickTick() {
request.replymaxlen = DEFAULT_BUFLEN;
printf("Bytes received: %d \n", iResult);
printf("HTTP Server for Windows: Bytes received: %d \n", iResult);
len = HTTP_ProcessPacket(&request);
if(len > 0) {
@@ -146,7 +147,7 @@ void HTTPServer_RunQuickTick() {
closesocket(ClientSocket);
return 1;
}
printf("Bytes sent: %d\n", iSendResult);
printf("HTTP Server for Windows: Bytes sent: %d\n", iSendResult);
}
break;
}
@@ -169,6 +170,7 @@ void HTTPServer_RunQuickTick() {
//Sleep(50);
// shutdown the connection since we're done
iResult = shutdown(ClientSocket, SD_SEND);
long firstAttempt = timeGetTime();
while (1) {
iResult = recv(ClientSocket, recvbuf, recvbuflen, 0);
if (iResult == 0)
@@ -177,6 +179,12 @@ void HTTPServer_RunQuickTick() {
if (err != WSAEWOULDBLOCK) {
break;
}
long delta = timeGetTime() - firstAttempt;
if (delta > 100) {
printf("HTTP server would freeze to long!\n");
break; // too long freeze!
}
}
//Sleep(50);
//iResult = closesocket(ClientSocket);