mirror/OpenBK7231T_App
3
0
Fork 0
mirror of https://github.com/openshwprojects/OpenBK7231T_App.git synced 2026-02-10 15:45:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

sim: save and load system (stores both device flash image with config and littlefs and the drawn connections)

Browse Source
This commit is contained in:
openshwprojects
2022-11-29 14:22:02 +01:00
parent 78dd12b83f
commit 675948382b
20 changed files with 1068 additions and 118 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
src/httpserver/http_tcp_server_nonblocking.c
View File

@ -24,6 +24,9 @@ int HTTPServer_Start() {
hints.ai_protocol = IPPROTO_TCP;
hints.ai_flags = AI_PASSIVE;
if (ListenSocket != INVALID_SOCKET) {
closesocket(ListenSocket);
}
// Resolve the server address and port
iResult = getaddrinfo(NULL, DEFAULT_PORT, &hints, &result);
if ( iResult != 0 ) {
@ -109,6 +112,17 @@ void HTTPServer_RunQuickTick() {
recvbuf[iResult] = 0;
#if 1
// debug test code, you can disable it but dont remove it
if (1) {
FILE *f;
f = fopen("lastHTTPPacket.txt", "wb");
fwrite(recvbuf, 1, recvbuflen, f);
fclose(f);
}
#endif
request.fd = ClientSocket;
request.received = recvbuf;
request.receivedLen = iResult;
@ -155,14 +169,23 @@ void HTTPServer_RunQuickTick() {
//Sleep(50);
// shutdown the connection since we're done
iResult = shutdown(ClientSocket, SD_SEND);
while (1) {
iResult = recv(ClientSocket, recvbuf, recvbuflen, 0);
if (iResult == 0)
break;
err = WSAGetLastError();
if (err != WSAEWOULDBLOCK) {
break;
}
}
//Sleep(50);
//iResult = closesocket(ClientSocket);
if (iResult == SOCKET_ERROR) {
printf("shutdown failed with error: %d\n", WSAGetLastError());
//if (iResult == SOCKET_ERROR) {
/// printf("shutdown failed with error: %d\n", WSAGetLastError());
closesocket(ClientSocket);
//WSACleanup();
//return 1;
}
//}
}
#endif