feedc0de/AsyncTCP
1
0
Fork 0
forked from me-no-dev/AsyncTCP
Code Pull Requests Activity

Fix closed_slots initialization.

Browse Source
This commit is contained in:
Matt
2019-09-23 20:08:33 +01:00
parent 95d6a0a562
commit 15356c3300
1 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/AsyncTCP.cpp
View File

@@ -79,8 +79,8 @@ typedef struct {
static xQueueHandle _async_queue; static xQueueHandle _async_queue;
static TaskHandle_t _async_service_task_handle = NULL; static TaskHandle_t _async_service_task_handle = NULL;
const int _number_of_closed_slots = 16; const int _number_of_closed_slots = 16;
static int _closed_index = 1; static int _closed_index = 0;
static int _closed_slots[_number_of_closed_slots] = { 1,1,1,1,1,1,1,1,1,1,1,1,1,1,1,1 }; static int _closed_slots[_number_of_closed_slots];
static inline bool _init_async_event_queue(){ static inline bool _init_async_event_queue(){
if(!_async_queue){ if(!_async_queue){
@@ -555,6 +555,12 @@ AsyncClient::AsyncClient(tcp_pcb* pcb)
_closed_slot = -1; _closed_slot = -1;
if(_pcb){ if(_pcb){
_closed_slot = 0; _closed_slot = 0;
if (_closed_index == 0) {
_closed_index = 1;
for (int i = 0; i < _number_of_closed_slots; ++ i) {
_closed_slots[i] = 1;
}
} else {
int closed_slot_min_index = _closed_slots[0]; int closed_slot_min_index = _closed_slots[0];
for (int i = 0; i < _number_of_closed_slots; ++ i) { for (int i = 0; i < _number_of_closed_slots; ++ i) {
if (_closed_slots[i] <= closed_slot_min_index && _closed_slots[i] != 0) { if (_closed_slots[i] <= closed_slot_min_index && _closed_slots[i] != 0) {
@@ -562,6 +568,7 @@ AsyncClient::AsyncClient(tcp_pcb* pcb)
_closed_slot = i; _closed_slot = i;
} }
} }
}
_closed_slots[_closed_slot] = 0; _closed_slots[_closed_slot] = 0;
_rx_last_packet = millis(); _rx_last_packet = millis();