Compare commits
2 Commits
f05e235243
...
b25b62ceb9
Author | SHA1 | Date | |
---|---|---|---|
b25b62ceb9 | |||
35eafc624a |
@ -12,8 +12,8 @@
|
|||||||
"type": "git",
|
"type": "git",
|
||||||
"url": "https://github.com/esphome/ESPAsyncWebServer.git"
|
"url": "https://github.com/esphome/ESPAsyncWebServer.git"
|
||||||
},
|
},
|
||||||
"version": "3.0.0",
|
"version": "3.1.0",
|
||||||
"license": "LGPL-3.0",
|
"license": "LGPL-3.0",
|
||||||
"frameworks": "arduino",
|
"frameworks": "arduino",
|
||||||
"platforms": ["espressif8266", "espressif32", "libretuya"]
|
"platforms": ["espressif8266", "espressif32", "libretiny"]
|
||||||
}
|
}
|
||||||
|
@ -22,7 +22,7 @@
|
|||||||
|
|
||||||
#include <Arduino.h>
|
#include <Arduino.h>
|
||||||
#include <Arduino.h>
|
#include <Arduino.h>
|
||||||
#if defined(ESP32) || defined(LIBRETUYA)
|
#if defined(ESP32) || defined(LIBRETINY)
|
||||||
#include <AsyncTCP.h>
|
#include <AsyncTCP.h>
|
||||||
#else
|
#else
|
||||||
#include <ESPAsyncTCP.h>
|
#include <ESPAsyncTCP.h>
|
||||||
@ -43,7 +43,7 @@
|
|||||||
#endif
|
#endif
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#if defined(ESP32) || defined(LIBRETUYA)
|
#if defined(ESP32) || defined(LIBRETINY)
|
||||||
#define DEFAULT_MAX_SSE_CLIENTS 8
|
#define DEFAULT_MAX_SSE_CLIENTS 8
|
||||||
#else
|
#else
|
||||||
#define DEFAULT_MAX_SSE_CLIENTS 4
|
#define DEFAULT_MAX_SSE_CLIENTS 4
|
||||||
|
@ -102,7 +102,7 @@ size_t webSocketSendFrame(AsyncClient *client, bool final, uint8_t opcode, bool
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
client->send();
|
if (!client->send()) return 0;
|
||||||
return len;
|
return len;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -22,13 +22,17 @@
|
|||||||
#define ASYNCWEBSOCKET_H_
|
#define ASYNCWEBSOCKET_H_
|
||||||
|
|
||||||
#include <Arduino.h>
|
#include <Arduino.h>
|
||||||
#if defined(ESP32) || defined(LIBRETUYA)
|
#if defined(ESP32) || defined(LIBRETINY)
|
||||||
#include <AsyncTCP.h>
|
#include <AsyncTCP.h>
|
||||||
|
#ifndef WS_MAX_QUEUED_MESSAGES
|
||||||
#define WS_MAX_QUEUED_MESSAGES 32
|
#define WS_MAX_QUEUED_MESSAGES 32
|
||||||
|
#endif
|
||||||
#else
|
#else
|
||||||
#include <ESPAsyncTCP.h>
|
#include <ESPAsyncTCP.h>
|
||||||
|
#ifndef WS_MAX_QUEUED_MESSAGES
|
||||||
#define WS_MAX_QUEUED_MESSAGES 8
|
#define WS_MAX_QUEUED_MESSAGES 8
|
||||||
#endif
|
#endif
|
||||||
|
#endif
|
||||||
#include <ESPAsyncWebServer.h>
|
#include <ESPAsyncWebServer.h>
|
||||||
|
|
||||||
#include "AsyncWebSynchronization.h"
|
#include "AsyncWebSynchronization.h"
|
||||||
@ -40,7 +44,7 @@
|
|||||||
#endif
|
#endif
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#if defined(ESP32) || defined(LIBRETUYA)
|
#if defined(ESP32) || defined(LIBRETINY)
|
||||||
#define DEFAULT_MAX_WS_CLIENTS 8
|
#define DEFAULT_MAX_WS_CLIENTS 8
|
||||||
#else
|
#else
|
||||||
#define DEFAULT_MAX_WS_CLIENTS 4
|
#define DEFAULT_MAX_WS_CLIENTS 4
|
||||||
|
@ -5,7 +5,7 @@
|
|||||||
|
|
||||||
#include <ESPAsyncWebServer.h>
|
#include <ESPAsyncWebServer.h>
|
||||||
|
|
||||||
#if defined(ESP32) || (defined(LIBRETUYA) && LT_HAS_FREERTOS)
|
#if defined(ESP32) || (defined(LIBRETINY) && LT_HAS_FREERTOS)
|
||||||
|
|
||||||
// This is the ESP32 version of the Sync Lock, using the FreeRTOS Semaphore
|
// This is the ESP32 version of the Sync Lock, using the FreeRTOS Semaphore
|
||||||
class AsyncWebLock
|
class AsyncWebLock
|
||||||
|
@ -28,7 +28,7 @@
|
|||||||
|
|
||||||
#include "StringArray.h"
|
#include "StringArray.h"
|
||||||
|
|
||||||
#if defined(ESP32) || defined(LIBRETUYA)
|
#if defined(ESP32) || defined(LIBRETINY)
|
||||||
#include <WiFi.h>
|
#include <WiFi.h>
|
||||||
#include <AsyncTCP.h>
|
#include <AsyncTCP.h>
|
||||||
#elif defined(ESP8266)
|
#elif defined(ESP8266)
|
||||||
|
@ -180,12 +180,17 @@ void AsyncWebServerRequest::_onData(void *buf, size_t len){
|
|||||||
|
|
||||||
void AsyncWebServerRequest::_removeNotInterestingHeaders(){
|
void AsyncWebServerRequest::_removeNotInterestingHeaders(){
|
||||||
if (_interestingHeaders.containsIgnoreCase("ANY")) return; // nothing to do
|
if (_interestingHeaders.containsIgnoreCase("ANY")) return; // nothing to do
|
||||||
for(const auto& header: _headers){
|
|
||||||
if(!_interestingHeaders.containsIgnoreCase(header->name().c_str())){
|
auto itr = _headers.begin();
|
||||||
|
while (itr != _headers.end())
|
||||||
|
{
|
||||||
|
const auto header = *itr;
|
||||||
|
++itr; // ++operator before remove(), otherwise itr becomes invalid
|
||||||
|
|
||||||
|
if (!_interestingHeaders.containsIgnoreCase(header->name().c_str()))
|
||||||
_headers.remove(header);
|
_headers.remove(header);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
void AsyncWebServerRequest::_onPoll(){
|
void AsyncWebServerRequest::_onPoll(){
|
||||||
//os_printf("p\n");
|
//os_printf("p\n");
|
||||||
|
Loading…
Reference in New Issue
Block a user