1
0
mirror of https://github.com/DCC-EX/CommandStation-EX.git synced 2024-11-23 08:06:13 +01:00

Restartable Wifi interface.

This commit is contained in:
Asbelos 2020-08-20 10:38:59 +01:00
parent 6ad50df2a7
commit 55d175adb0
2 changed files with 242 additions and 215 deletions

View File

@ -1,142 +1,154 @@
/* /*
* © 2020, Chris Harlow. All rights reserved. © 2020, Chris Harlow. All rights reserved.
*
* This file is part of Asbelos DCC API This file is part of Asbelos DCC API
*
* This is free software: you can redistribute it and/or modify This is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version. (at your option) any later version.
*
* It is distributed in the hope that it will be useful, It is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details. GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License You should have received a copy of the GNU General Public License
* along with CommandStation. If not, see <https://www.gnu.org/licenses/>. along with CommandStation. If not, see <https://www.gnu.org/licenses/>.
*/ */
#include "WifiInterface.h" #include "WifiInterface.h"
#include "DIAG.h" #include "DIAG.h"
#include "StringFormatter.h" #include "StringFormatter.h"
#include "WiThrottle.h" #include "WiThrottle.h"
const char PROGMEM READY_SEARCH[] ="\r\nready\r\n"; const char PROGMEM READY_SEARCH[] = "\r\nready\r\n";
const char PROGMEM OK_SEARCH[] ="\r\nOK\r\n"; const char PROGMEM OK_SEARCH[] = "\r\nOK\r\n";
const char PROGMEM END_DETAIL_SEARCH[] ="@ 1000"; const char PROGMEM END_DETAIL_SEARCH[] = "@ 1000";
const char PROGMEM PROMPT_SEARCH[] =">"; const char PROGMEM PROMPT_SEARCH[] = ">";
const char PROGMEM SEND_OK_SEARCH[] ="\r\nSEND OK\r\n"; const char PROGMEM SEND_OK_SEARCH[] = "\r\nSEND OK\r\n";
const unsigned long LOOP_TIMEOUT=2000; const unsigned long LOOP_TIMEOUT = 2000;
bool WifiInterface::connected=false; bool WifiInterface::connected = false;
bool WifiInterface::closeAfter=false; bool WifiInterface::closeAfter = false;
DCCEXParser WifiInterface::parser; DCCEXParser WifiInterface::parser;
byte WifiInterface::loopstate=0; byte WifiInterface::loopstate = 0;
unsigned long WifiInterface::loopTimeoutStart=0; unsigned long WifiInterface::loopTimeoutStart = 0;
int WifiInterface::datalength=0; int WifiInterface::datalength = 0;
int WifiInterface::connectionId; int WifiInterface::connectionId;
byte WifiInterface::buffer[MAX_WIFI_BUFFER]; byte WifiInterface::buffer[MAX_WIFI_BUFFER];
MemStream WifiInterface::streamer(buffer,sizeof(buffer)); MemStream WifiInterface::streamer(buffer, sizeof(buffer));
Stream * WifiInterface::wifiStream=NULL; Stream * WifiInterface::wifiStream = NULL;
HTTP_CALLBACK WifiInterface::httpCallback=0; HTTP_CALLBACK WifiInterface::httpCallback = 0;
void WifiInterface::setup(Stream & setupStream, const __FlashStringHelper* SSid, const __FlashStringHelper* password, void WifiInterface::setup(Stream & setupStream, const __FlashStringHelper* SSid, const __FlashStringHelper* password,
const __FlashStringHelper* hostname, const __FlashStringHelper* servername, int port) { const __FlashStringHelper* hostname, const __FlashStringHelper* servername, int port) {
wifiStream=&setupStream; wifiStream = &setupStream;
DIAG(F("\n++++++ Wifi Setup In Progress ++++++++\n")); DIAG(F("\n++++++ Wifi Setup In Progress ++++++++\n"));
connected=setup2( SSid, password,hostname, servername,port); connected = setup2( SSid, password, hostname, servername, port);
// TODO calloc the buffer and streamer and parser etc DIAG(F("\n++++++ Wifi Setup %S ++++++++\n"), connected ? F("OK") : F("FAILED"));
DIAG(F("\n++++++ Wifi Setup %S ++++++++\n"), connected?F("OK"):F("FAILED"));
} }
bool WifiInterface::setup2(const __FlashStringHelper* SSid, const __FlashStringHelper* password, bool WifiInterface::setup2(const __FlashStringHelper* SSid, const __FlashStringHelper* password,
const __FlashStringHelper* hostname, const __FlashStringHelper* servername, int port) { const __FlashStringHelper* hostname, const __FlashStringHelper* servername, int port) {
int ipOK = 0;
int ipOK=0; StringFormatter::send(wifiStream, F("AT+GMR\r\n")); // request AT version
delay(1000); checkForOK(2000, OK_SEARCH, true, false); // Makes this visible on the console
StringFormatter::send(wifiStream,F("AT+RST\r\n")); // reset module StringFormatter::send(wifiStream, F("AT+CWMODE=1\r\n")); // configure as client
checkForOK(5000,READY_SEARCH,false); // generally not interesting to DCC checkForOK(1000, OK_SEARCH, true); // Not always OK, sometimes "no change"
StringFormatter::send(wifiStream,F("AT+GMR\r\n")); // request AT version delay(8000); // give preconfigured ES8266 a chance to connect
checkForOK(2000,OK_SEARCH,true); // Makes this visible on the console
StringFormatter::send(wifiStream,F("AT+CWMODE=1\r\n")); // configure as client StringFormatter::send(wifiStream, F("AT+CIFSR\r\n"));
checkForOK(1000,OK_SEARCH,true); // Not always OK, sometimes "no change" if (checkForOK(5000, (const char*) F("+CIFSR:STAIP"), true,false))
StringFormatter::send(wifiStream,F("AT+CIFSR\r\n")); if (!checkForOK(1000, (const char*) F("0.0.0.0"), true,false))
if(checkForOK(5000, (const char*) F("+CIFSR:STAIP"),true)) ipOK = 1;
if(!checkForOK(1000, (const char*) F("0.0.0.0"),true))
ipOK=1;
if(!ipOK) { if (!ipOK) {
StringFormatter::send(wifiStream,F("AT+CWMODE=3\r\n")); // configure as server or access point StringFormatter::send(wifiStream, F("AT+CWMODE=3\r\n")); // configure as server or access point
checkForOK(1000,OK_SEARCH,true); // Not always OK, sometimes "no change" checkForOK(1000, OK_SEARCH, true); // Not always OK, sometimes "no change"
// Older ES versions have AT+CWJAP, newer ones have AT+CWJAP_CUR and AT+CWHOSTNAME // Older ES versions have AT+CWJAP, newer ones have AT+CWJAP_CUR and AT+CWHOSTNAME
StringFormatter::send(wifiStream,F("AT+CWJAP?\r\n")); StringFormatter::send(wifiStream, F("AT+CWJAP?\r\n"));
if (checkForOK(2000,OK_SEARCH,true)) { if (checkForOK(2000, OK_SEARCH, true)) {
// early version supports CWJAP // early version supports CWJAP
StringFormatter::send(wifiStream,F("AT+CWJAP=\"%S\",\"%S\"\r\n"),SSid,password); StringFormatter::send(wifiStream, F("AT+CWJAP=\"%S\",\"%S\"\r\n"), SSid, password);
checkForOK(20000,OK_SEARCH,true); // can ignore failure as AP mode may still be ok checkForOK(20000, OK_SEARCH, true); // can ignore failure as AP mode may still be ok
} }
else { else {
// later version supports CWJAP_CUR // later version supports CWJAP_CUR
StringFormatter::send(wifiStream, F("AT+CWHOSTNAME=\"%S\"\r\n"), hostname); // Set Host name for Wifi Client StringFormatter::send(wifiStream, F("AT+CWHOSTNAME=\"%S\"\r\n"), hostname); // Set Host name for Wifi Client
checkForOK(2000, OK_SEARCH, true); // dont care if not supported checkForOK(2000, OK_SEARCH, true); // dont care if not supported
StringFormatter::send(wifiStream,F("AT+CWJAP_CUR=\"%S\",\"%S\"\r\n"),SSid,password); StringFormatter::send(wifiStream, F("AT+CWJAP_CUR=\"%S\",\"%S\"\r\n"), SSid, password);
checkForOK(20000,OK_SEARCH,true); // can ignore failure as AP mode may still be ok checkForOK(20000, OK_SEARCH, true); // can ignore failure as AP mode may still be ok
StringFormatter::send(wifiStream,F("AT+CIPRECVMODE=0\r\n"),port); // make sure transfer mode is correct StringFormatter::send(wifiStream, F("AT+CIPRECVMODE=0\r\n"), port); // make sure transfer mode is correct
checkForOK(2000,OK_SEARCH,true); checkForOK(2000, OK_SEARCH, true);
// StringFormatter::send(wifiStream, F("AT+MDNS=1,\"%S.local\",\"%S.local\",%d\r\n"), hostname, servername, port); // Setup mDNS for Server // StringFormatter::send(wifiStream, F("AT+MDNS=1,\"%S.local\",\"%S.local\",%d\r\n"), hostname, servername, port); // Setup mDNS for Server
// if (!checkForOK(5000, OK_SEARCH, true)) return false; // if (!checkForOK(5000, OK_SEARCH, true)) return false;
(void)servername; // avoid compiler warning from commented out AT_MDNS above (void)servername; // avoid compiler warning from commented out AT_MDNS above
} }
StringFormatter::send(wifiStream,F("AT+CIFSR\r\n")); // get ip address //192.168.4.1 StringFormatter::send(wifiStream, F("AT+CIFSR\r\n")); // get ip address //192.168.4.1
if (!checkForOK(10000,OK_SEARCH,true)) return false; if (!checkForOK(10000, OK_SEARCH, true, false)) return false;
} }
StringFormatter::send(wifiStream,F("AT+CIPMUX=1\r\n")); // configure for multiple connections StringFormatter::send(wifiStream, F("AT+CIPMUX=1\r\n")); // configure for multiple connections
if (!checkForOK(10000,OK_SEARCH,true)) return false; if (!checkForOK(10000, OK_SEARCH, true)) return false;
StringFormatter::send(wifiStream,F("AT+CIPSERVER=1,%d\r\n"),port); // turn on server on port StringFormatter::send(wifiStream, F("AT+CIPSERVER=1,%d\r\n"), port); // turn on server on port
if (!checkForOK(10000,OK_SEARCH,true)) return false; if (!checkForOK(10000, OK_SEARCH, true)) return false;
return true; return true;
} }
// This function is used to allow users to enter <+ commands> through the DCCEXParser
// Once the user has made whatever changes to the AT commands, a <+X> command can be used
// to force on the connectd flag so that the loop will start picking up wifi traffic.
// If the settings are corrupted <+RST> will clear this and then you must restart the arduino.
void WifiInterface::ATCommand(const byte * command) { void WifiInterface::ATCommand(const byte * command) {
StringFormatter:: send(wifiStream,F("AT+%s\r\n"), command+1); if (*command=='X') {
checkForOK(10000,OK_SEARCH,true); connected = true;
DIAG(F("\n++++++ Wifi Connction forced on ++++++++\n"));
}
else {
StringFormatter:: send(wifiStream, F("AT+%s\r\n"), command + 1);
checkForOK(10000, OK_SEARCH, true);
}
} }
void WifiInterface::setHTTPCallback(HTTP_CALLBACK callback) { void WifiInterface::setHTTPCallback(HTTP_CALLBACK callback) {
httpCallback=callback; httpCallback = callback;
} }
bool WifiInterface::checkForOK( const unsigned int timeout, const char * waitfor, bool echo) { bool WifiInterface::checkForOK( const unsigned int timeout, const char * waitfor, bool echo, bool escapeEcho) {
unsigned long startTime = millis(); unsigned long startTime = millis();
char const *locator=waitfor; char const *locator = waitfor;
DIAG(F("\nWifi Check: [%E]"),waitfor); DIAG(F("\nWifi Check: [%E]"), waitfor);
while( millis()-startTime < timeout) { while ( millis() - startTime < timeout) {
while(wifiStream->available()) { while (wifiStream->available()) {
int ch=wifiStream->read(); int ch = wifiStream->read();
if (echo) StringFormatter::printEscape(&DIAGSERIAL,ch); /// THIS IS A DIAG IN DISGUISE if (echo) {
if (ch!=pgm_read_byte_near(locator)) locator=waitfor; if (escapeEcho) StringFormatter::printEscape(&DIAGSERIAL, ch); /// THIS IS A DIAG IN DISGUISE
if (ch==pgm_read_byte_near(locator)) { else DIAG(F("%c"), ch);
}
if (ch != pgm_read_byte_near(locator)) locator = waitfor;
if (ch == pgm_read_byte_near(locator)) {
locator++; locator++;
if (!pgm_read_byte_near(locator)) { if (!pgm_read_byte_near(locator)) {
DIAG(F("\nFound in %dms"),millis()-startTime); DIAG(F("\nFound in %dms"), millis() - startTime);
return true; return true;
} }
} }
} }
} }
DIAG(F("\nTIMEOUT after %dms\n"),timeout); DIAG(F("\nTIMEOUT after %dms\n"), timeout);
return false; return false;
} }
@ -146,15 +158,15 @@ bool WifiInterface::isHTTP() {
// You may think a simple strstr() is better... but not when ram & time is in short supply // You may think a simple strstr() is better... but not when ram & time is in short supply
switch (buffer[0]) { switch (buffer[0]) {
case 'P': case 'P':
if (buffer[1]=='U' && buffer[2]=='T' && buffer[3]==' ' ) return true; if (buffer[1] == 'U' && buffer[2] == 'T' && buffer[3] == ' ' ) return true;
if (buffer[1]=='O' && buffer[2]=='S' && buffer[3]=='T' && buffer[4]==' ') return true; if (buffer[1] == 'O' && buffer[2] == 'S' && buffer[3] == 'T' && buffer[4] == ' ') return true;
if (buffer[1]=='A' && buffer[2]=='T' && buffer[3]=='C' && buffer[4]=='H' && buffer[5]==' ') return true; if (buffer[1] == 'A' && buffer[2] == 'T' && buffer[3] == 'C' && buffer[4] == 'H' && buffer[5] == ' ') return true;
return false; return false;
case 'G': case 'G':
if (buffer[1]=='E' && buffer[2]=='T' && buffer[3]==' ' ) return true; if (buffer[1] == 'E' && buffer[2] == 'T' && buffer[3] == ' ' ) return true;
return false; return false;
case 'D': case 'D':
if (buffer[1]=='E' && buffer[2]=='L' && buffer[3]=='E' && buffer[4]=='T' && buffer[5]=='E' && buffer[6]==' ') return true; if (buffer[1] == 'E' && buffer[2] == 'L' && buffer[3] == 'E' && buffer[4] == 'T' && buffer[5] == 'E' && buffer[6] == ' ') return true;
return false; return false;
default: default:
return false; return false;
@ -167,106 +179,121 @@ void WifiInterface::loop() {
WiThrottle::loop(); // check heartbeats WiThrottle::loop(); // check heartbeats
// read anything into a buffer, collecting info on the way // read anything into a buffer, collecting info on the way
while (loopstate!=99 && wifiStream->available()) { while (loopstate != 99 && wifiStream->available()) {
int ch=wifiStream->read(); int ch = wifiStream->read();
// echo the char to the diagnostic stream in escaped format // echo the char to the diagnostic stream in escaped format
// StringFormatter::printEscape(&DIAGSERIAL,ch); // DIAG in disguise StringFormatter::printEscape(&DIAGSERIAL,ch); // DIAG in disguise
switch (loopstate) { switch (loopstate) {
case 0: // looking for +IPD case 0: // looking for +IPD
connectionId=0; connectionId = 0;
if (ch=='+') loopstate=1; if (ch == '+') loopstate = 1;
break; break;
case 1: // Looking for I in +IPD case 1: // Looking for I in +IPD
loopstate= (ch=='I')?2:0; loopstate = (ch == 'I') ? 2 : 0;
break; break;
case 2: // Looking for P in +IPD case 2: // Looking for P in +IPD
loopstate= (ch=='P')?3:0; loopstate = (ch == 'P') ? 3 : 0;
break; break;
case 3: // Looking for D in +IPD case 3: // Looking for D in +IPD
loopstate= (ch=='D')?4:0; loopstate = (ch == 'D') ? 4 : 0;
break; break;
case 4: // Looking for , After +IPD case 4: // Looking for , After +IPD
loopstate= (ch==',')?5:0; loopstate = (ch == ',') ? 5 : 0;
break; break;
case 5: // reading connection id case 5: // reading connection id
if (ch==',') loopstate=6; if (ch == ',') loopstate = 6;
else connectionId=10*connectionId+(ch-'0'); else connectionId = 10 * connectionId + (ch - '0');
break; break;
case 6: // reading for length case 6: // reading for length
if (ch==':') loopstate=(datalength==0)?99:7; // 99 is getout without reading next char if (ch == ':') loopstate = (datalength == 0) ? 99 : 7; // 99 is getout without reading next char
else datalength=datalength*10 + (ch-'0'); else datalength = datalength * 10 + (ch - '0');
streamer.flush(); // basically sets write point at start of buffer streamer.flush(); // basically sets write point at start of buffer
break; break;
case 7: // reading data case 7: // reading data
streamer.write(ch); streamer.write(ch);
datalength--; datalength--;
if (datalength==0) loopstate=99; if (datalength == 0) loopstate = 99;
break; break;
case 10: // Waiting for > so we can send reply case 10: // Waiting for > so we can send reply
if (millis()-loopTimeoutStart > LOOP_TIMEOUT) { if (millis() - loopTimeoutStart > LOOP_TIMEOUT) {
DIAG(F("\nWifi TIMEOUT on wait for > prompt or ERROR\n")); DIAG(F("\nWifi TIMEOUT on wait for > prompt or ERROR\n"));
loopstate=0; // go back to +IPD loopstate = 0; // go back to +IPD
break; break;
} }
if (ch=='>'){ if (ch == '>') {
// DIAG(F("\n> [%e]\n"),buffer); // DIAG(F("\n> [%e]\n"),buffer);
wifiStream->print((char *) buffer); wifiStream->print((char *) buffer);
loopTimeoutStart=millis(); loopTimeoutStart = millis();
loopstate=closeAfter?11:0; loopstate = closeAfter ? 11 : 0;
break;
}
if (ch == '.') { // busy during send, delay and retry
loopstate = 12; // look for SEND OK finished
break;
} }
break; break;
case 11: // Waiting for SEND OK or ERROR to complete so we can closeAfter case 11: // Waiting for SEND OK or ERROR to complete so we can closeAfter
if (millis()-loopTimeoutStart > LOOP_TIMEOUT) { if (millis() - loopTimeoutStart > LOOP_TIMEOUT) {
DIAG(F("\nWifi TIMEOUT on wait for SEND OK or ERROR\n")); DIAG(F("\nWifi TIMEOUT on wait for SEND OK or ERROR\n"));
loopstate=0; // go back to +IPD loopstate = 0; // go back to +IPD
break; break;
} }
if (ch=='K') { // assume its in SEND OK if (ch == 'K') { // assume its in SEND OK
StringFormatter::send(wifiStream,F("AT+CIPCLOSE=%d\r\n"),connectionId); StringFormatter::send(wifiStream, F("AT+CIPCLOSE=%d\r\n"), connectionId);
loopstate=0; // wait for +IPD loopstate = 0; // wait for +IPD
}
break;
case 12: // Waiting for OK after send busy
if (ch == 'K') { // assume its in SEND OK
DIAG(F("\n\n WIFI BUSY RETRYING SEND \n"));
StringFormatter::send(wifiStream, F("AT+CIPSEND=%d,%d\r\n"), connectionId, streamer.available() - 1);
loopTimeoutStart = millis();
loopstate = 10; // non-blocking loop waits for > before sending
break;
} }
break; break;
} // switch } // switch
} // while } // while
if (loopstate!=99) return; if (loopstate != 99) return;
// AT this point we have read an incoming message into the buffer // AT this point we have read an incoming message into the buffer
streamer.print('\0'); // null the end of the buffer so we can treat it as a string streamer.print('\0'); // null the end of the buffer so we can treat it as a string
DIAG(F("\n%d Wifi(%d)<-[%e]\n"),millis(),connectionId,buffer); DIAG(F("\n%l Wifi(%d)<-[%e]\n"), millis(),connectionId, buffer);
streamer.setBufferContentPosition(0,0); // reset write position to start of buffer streamer.setBufferContentPosition(0, 0); // reset write position to start of buffer
// SIDE EFFECT WARNING::: // SIDE EFFECT WARNING:::
// We know that parser will read the entire buffer before starting to write to it. // We know that parser will read the entire buffer before starting to write to it.
// Otherwise we would have to copy the buffer elsewhere and RAM is in short supply. // Otherwise we would have to copy the buffer elsewhere and RAM is in short supply.
closeAfter=false; closeAfter = false;
// Intercept HTTP requests // Intercept HTTP requests
if (isHTTP()) { if (isHTTP()) {
if (httpCallback) httpCallback(&streamer,buffer); if (httpCallback) httpCallback(&streamer, buffer);
else { else {
StringFormatter::send(streamer,F("HTTP/1.1 404 Not Found\nContent-Type: text/html\nConnnection: close\n\n")); StringFormatter::send(streamer, F("HTTP/1.1 404 Not Found\nContent-Type: text/html\nConnnection: close\n\n"));
StringFormatter::send(streamer,F("<html><body>This is <b>not</b> a web server.<br/></body></html>")); StringFormatter::send(streamer, F("<html><body>This is <b>not</b> a web server.<br/></body></html>"));
} }
closeAfter=true; closeAfter = true;
} }
else if (buffer[0]=='<') parser.parse(&streamer,buffer, true); // tell JMRI parser that ACKS are blocking because we can't handle the async else if (buffer[0] == '<') parser.parse(&streamer, buffer, true); // tell JMRI parser that ACKS are blocking because we can't handle the async
else WiThrottle::getThrottle(connectionId)->parse(streamer, buffer); else WiThrottle::getThrottle(connectionId)->parse(streamer, buffer);
if (streamer.available()==0) { if (streamer.available() == 0) {
// No reply // No reply
if (closeAfter) StringFormatter::send(wifiStream,F("AT+CIPCLOSE=%d\r\n"),connectionId); if (closeAfter) StringFormatter::send(wifiStream, F("AT+CIPCLOSE=%d\r\n"), connectionId);
loopstate=0; // go back to waiting for +IPD loopstate = 0; // go back to waiting for +IPD
return; return;
} }
// prepare to send reply // prepare to send reply
streamer.print('\0'); // null the end of the buffer so we can treat it as a string streamer.print('\0'); // null the end of the buffer so we can treat it as a string
DIAG(F("%d WiFi(%d)->[%e] l(%d)\n"),millis(),connectionId,buffer,streamer.available()-1); DIAG(F("%l WiFi(%d)->[%e] l(%d)\n"), millis(), connectionId, buffer, streamer.available() - 1);
StringFormatter::send(wifiStream,F("AT+CIPSEND=%d,%d\r\n"),connectionId,streamer.available()-1); StringFormatter::send(wifiStream, F("AT+CIPSEND=%d,%d\r\n"), connectionId, streamer.available() - 1);
loopTimeoutStart=millis(); loopTimeoutStart = millis();
loopstate=10; // non-blocking loop waits for > before sending loopstate = 10; // non-blocking loop waits for > before sending
} }

View File

@ -40,7 +40,7 @@ class WifiInterface {
static DCCEXParser parser; static DCCEXParser parser;
static bool setup2( const __FlashStringHelper* SSSid, const __FlashStringHelper* password, static bool setup2( const __FlashStringHelper* SSSid, const __FlashStringHelper* password,
const __FlashStringHelper* hostname, const __FlashStringHelper* servername, int port); const __FlashStringHelper* hostname, const __FlashStringHelper* servername, int port);
static bool checkForOK(const unsigned int timeout, const char* waitfor, bool echo); static bool checkForOK(const unsigned int timeout, const char* waitfor, bool echo, bool escapeEcho=true);
static bool isHTTP(); static bool isHTTP();
static HTTP_CALLBACK httpCallback; static HTTP_CALLBACK httpCallback;
static bool connected; static bool connected;