mirror of
https://github.com/logicog/RTLPlayground.git
synced 2026-10-29 17:54:14 +08:00
httpd: clear upload reset intent when the TCP slot is reused
With UIP_CONF_MAX_CONNECTIONS set to one, a verified upload can leave reset intent set when its response is never acknowledged. A subsequent TCP connection reuses that slot, and ACKing its plain GET response can otherwise trigger reset_chip(). This is sequential slot reuse, not concurrent HTTP connections. Store reset intent in the connection appstate and initialize both tstate and fw_reset_pending on every uip_connected() event, regardless of stale appstate contents. Reset only after the verified upload response is fully acknowledged. Exercise the real HTTP callback for all stale tstate bytes, sequential slot reuse and a later GET, partial/final ACKs, abort, timeout and CRC failure. Keep the regression tests in the existing tab-indented style.
This commit is contained in:
1 parent
b28ead65dc
commit
491a919105
3 files changed
+122
-8
No files matched your search
+4
-7
@@ -75,9 +75,6 @@ __xdata uint8_t postbody_endpoint;
|
|||||||
__xdata uint16_t postbody_start;
|
__xdata uint16_t postbody_start;
|
||||||
|
|
||||||
__xdata char passwd[21];
|
__xdata char passwd[21];
|
||||||
// Set when a verified firmware upload awaits its response ACK, after
|
|
||||||
// which the chip resets to apply the staged image
|
|
||||||
__xdata uint8_t fw_reset_pending;
|
|
||||||
__xdata char session_id[SESSION_ID_LENGTH + 1];
|
__xdata char session_id[SESSION_ID_LENGTH + 1];
|
||||||
__xdata uint8_t authenticated;
|
__xdata uint8_t authenticated;
|
||||||
__xdata uint32_t now;
|
__xdata uint32_t now;
|
||||||
@@ -110,7 +107,6 @@ void httpd_init(void) __banked
|
|||||||
// Not through uip_conn: it only points at a connection while uIP is
|
// Not through uip_conn: it only points at a connection while uIP is
|
||||||
// handling one, and nothing has set it yet at init time.
|
// handling one, and nothing has set it yet at init time.
|
||||||
uip_conns[0].appstate.tstate = TSTATE_CLOSED;
|
uip_conns[0].appstate.tstate = TSTATE_CLOSED;
|
||||||
fw_reset_pending = 0; // xdata is not zeroed by the startup code
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@@ -511,7 +507,7 @@ uint8_t stream_upload(void)
|
|||||||
"Content-Type: text/plain\r\n\r\n"
|
"Content-Type: text/plain\r\n\r\n"
|
||||||
"OK: checksum verified, rebooting\n");
|
"OK: checksum verified, rebooting\n");
|
||||||
// Reset once the response is fully ACKed
|
// Reset once the response is fully ACKed
|
||||||
fw_reset_pending = 1;
|
s->fw_reset_pending = 1;
|
||||||
} else {
|
} else {
|
||||||
print_string("Checksum incorrect! Aborting.\n");
|
print_string("Checksum incorrect! Aborting.\n");
|
||||||
slen = strtox(outbuf, "HTTP/1.1 400 Bad Request\r\nContent-Length: 33\r\n"
|
slen = strtox(outbuf, "HTTP/1.1 400 Bad Request\r\nContent-Length: 33\r\n"
|
||||||
@@ -874,9 +870,10 @@ void httpd_appcall(void)
|
|||||||
print_byte(s->tstate);
|
print_byte(s->tstate);
|
||||||
write_char(' ');
|
write_char(' ');
|
||||||
#endif
|
#endif
|
||||||
if(uip_connected() && s->tstate == TSTATE_CLOSED) {
|
if(uip_connected()) {
|
||||||
dbg_string("Connected...\n");
|
dbg_string("Connected...\n");
|
||||||
s->tstate = TSTATE_NONE;
|
s->tstate = TSTATE_NONE;
|
||||||
|
s->fw_reset_pending = 0; // explicitly initialize reused XDATA appstate
|
||||||
} else if (uip_closed()) {
|
} else if (uip_closed()) {
|
||||||
dbg_string("Connection closed\n");
|
dbg_string("Connection closed\n");
|
||||||
s->tstate = TSTATE_CLOSED;
|
s->tstate = TSTATE_CLOSED;
|
||||||
@@ -928,7 +925,7 @@ void httpd_appcall(void)
|
|||||||
cont_len -= slen;
|
cont_len -= slen;
|
||||||
cont_addr += slen;
|
cont_addr += slen;
|
||||||
s->tstate = TSTATE_TX;
|
s->tstate = TSTATE_TX;
|
||||||
} else if (fw_reset_pending) {
|
} else if (s->fw_reset_pending) {
|
||||||
// The upload verdict has been fully ACKed by the client;
|
// The upload verdict has been fully ACKed by the client;
|
||||||
// now it is safe to reset and apply the staged image
|
// now it is safe to reset and apply the staged image
|
||||||
print_string("Resetting to apply update\n");
|
print_string("Resetting to apply update\n");
|
||||||
|
|||||||
@@ -12,6 +12,7 @@
|
|||||||
for each TCP connection. */
|
for each TCP connection. */
|
||||||
typedef struct httpd_state {
|
typedef struct httpd_state {
|
||||||
uint8_t tstate;
|
uint8_t tstate;
|
||||||
|
uint8_t fw_reset_pending;
|
||||||
} uip_tcp_appstate_t;
|
} uip_tcp_appstate_t;
|
||||||
|
|
||||||
/* Finally we define the application function to be called by uIP. */
|
/* Finally we define the application function to be called by uIP. */
|
||||||
|
|||||||
+117
-1
@@ -94,7 +94,8 @@ void flash_sector_erase(void) { }
|
|||||||
void flash_write_bytes(uint8_t *ptr) { (void)ptr; }
|
void flash_write_bytes(uint8_t *ptr) { (void)ptr; }
|
||||||
const char *get_flash_size_str(void) { return "512 kB"; }
|
const char *get_flash_size_str(void) { return "512 kB"; }
|
||||||
void crc16_bank1(uint8_t *v) { (void)v; }
|
void crc16_bank1(uint8_t *v) { (void)v; }
|
||||||
void reset_chip(void) { }
|
static unsigned reset_calls;
|
||||||
|
void reset_chip(void) { reset_calls++; }
|
||||||
void delay(uint16_t t) { (void)t; }
|
void delay(uint16_t t) { (void)t; }
|
||||||
void write_char(char c) { (void)c; }
|
void write_char(char c) { (void)c; }
|
||||||
void write_char_no_syslog(char c) { (void)c; }
|
void write_char_no_syslog(char c) { (void)c; }
|
||||||
@@ -493,6 +494,120 @@ static void scenario_bad_l4_checksum(void)
|
|||||||
"bad checksum control: the file that follows is intact");
|
"bad checksum control: the file that follows is intact");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/* Private HTTP lifecycle values; drive the real callback, not a model. */
|
||||||
|
enum { TSTATE_NONE = 0, TSTATE_TX = 1 };
|
||||||
|
extern uint16_t slen, cont_len, sent_len, bindex, crc_final, write_len;
|
||||||
|
extern uint8_t boundary[], verify_crc, outbuf[];
|
||||||
|
extern struct { uint8_t *p; uint16_t bptr, plen; } upload_settings;
|
||||||
|
extern uint8_t stream_upload(void);
|
||||||
|
|
||||||
|
static void scenario_upload_reset_owner(void)
|
||||||
|
{
|
||||||
|
uint8_t byte = 0;
|
||||||
|
uint8_t get[] = "GET " FILE_NAME " HTTP/1.1\r\nHost: sw\r\n\r\n";
|
||||||
|
int initialized = 1;
|
||||||
|
|
||||||
|
/* The firmware has one TCP slot. Its appstate can contain stale bytes. */
|
||||||
|
uip_conn = &uip_conns[0];
|
||||||
|
reset_calls = 0;
|
||||||
|
for (unsigned state = 0; state <= 0xff; state++) {
|
||||||
|
uip_conn->appstate.tstate = state;
|
||||||
|
uip_conn->appstate.fw_reset_pending = 0xaa;
|
||||||
|
uip_flags = UIP_CONNECTED;
|
||||||
|
httpd_appcall();
|
||||||
|
if (uip_conn->appstate.tstate != TSTATE_NONE
|
||||||
|
|| uip_conn->appstate.fw_reset_pending != 0)
|
||||||
|
initialized = 0;
|
||||||
|
}
|
||||||
|
CHECK(initialized, "connect initializes both fields for every stale state");
|
||||||
|
CHECK(reset_calls == 0, "connection initialization does not reset");
|
||||||
|
|
||||||
|
/* End-of-part verdict with flash/CRC hardware edges mocked. */
|
||||||
|
boundary[0] = 0;
|
||||||
|
bindex = 0;
|
||||||
|
verify_crc = 1;
|
||||||
|
crc_final = 0xb001;
|
||||||
|
write_len = 0;
|
||||||
|
upload_settings.p = &byte;
|
||||||
|
upload_settings.bptr = 0;
|
||||||
|
upload_settings.plen = 1;
|
||||||
|
stream_upload();
|
||||||
|
CHECK(uip_conn->appstate.fw_reset_pending == 1,
|
||||||
|
"verified upload records reset intent in its slot");
|
||||||
|
|
||||||
|
uip_conn->appstate.tstate = TSTATE_TX;
|
||||||
|
uip_conn->mss = MSS_FULL;
|
||||||
|
slen = 10;
|
||||||
|
sent_len = 5;
|
||||||
|
cont_len = 0;
|
||||||
|
uip_flags = UIP_ACKDATA;
|
||||||
|
httpd_appcall();
|
||||||
|
CHECK(reset_calls == 0 && slen == 5 && sent_len == 5,
|
||||||
|
"partial verdict ACK sends the remainder without resetting");
|
||||||
|
uip_flags = UIP_ACKDATA;
|
||||||
|
httpd_appcall();
|
||||||
|
CHECK(reset_calls == 1 && slen == 0,
|
||||||
|
"final verdict ACK resets after all response bytes are acknowledged");
|
||||||
|
|
||||||
|
/* No verdict ACK: a later connection reuses the same slot. */
|
||||||
|
reset_calls = 0;
|
||||||
|
uip_conn->appstate.tstate = TSTATE_TX;
|
||||||
|
uip_conn->appstate.fw_reset_pending = 1;
|
||||||
|
uip_flags = UIP_CONNECTED;
|
||||||
|
httpd_appcall();
|
||||||
|
CHECK(uip_conn->appstate.tstate == TSTATE_NONE
|
||||||
|
&& uip_conn->appstate.fw_reset_pending == 0,
|
||||||
|
"slot reuse clears an unacknowledged upload's reset intent");
|
||||||
|
uip_appdata = get;
|
||||||
|
uip_len = strlen((char *)get);
|
||||||
|
uip_flags = UIP_NEWDATA;
|
||||||
|
httpd_appcall();
|
||||||
|
CHECK(uip_conn->appstate.tstate == TSTATE_TX && slen > 0,
|
||||||
|
"reused slot serves a subsequent plain GET");
|
||||||
|
for (unsigned i = 0; i < 20 && uip_conn->appstate.tstate == TSTATE_TX; i++) {
|
||||||
|
uip_flags = UIP_ACKDATA;
|
||||||
|
httpd_appcall();
|
||||||
|
}
|
||||||
|
CHECK(reset_calls == 0 && slen == 0 && cont_len == 0,
|
||||||
|
"subsequent GET response ACKs cannot inherit reset intent");
|
||||||
|
|
||||||
|
for (unsigned i = 0; i < 2; i++) {
|
||||||
|
uip_conn->appstate.tstate = TSTATE_TX;
|
||||||
|
uip_conn->appstate.fw_reset_pending = 1;
|
||||||
|
reset_calls = 0;
|
||||||
|
uip_flags = i ? UIP_TIMEDOUT : UIP_ABORT;
|
||||||
|
httpd_appcall();
|
||||||
|
CHECK(reset_calls == 0, "abort/timeout does not reset");
|
||||||
|
uip_flags = UIP_CONNECTED;
|
||||||
|
httpd_appcall();
|
||||||
|
CHECK(uip_conn->appstate.tstate == TSTATE_NONE
|
||||||
|
&& uip_conn->appstate.fw_reset_pending == 0,
|
||||||
|
"connect after abort/timeout clears old upload intent");
|
||||||
|
uip_conn->appstate.tstate = TSTATE_TX;
|
||||||
|
slen = 0;
|
||||||
|
cont_len = 0;
|
||||||
|
sent_len = 0;
|
||||||
|
uip_flags = UIP_ACKDATA;
|
||||||
|
httpd_appcall();
|
||||||
|
CHECK(reset_calls == 0, "new connection ACK cannot inherit reset");
|
||||||
|
}
|
||||||
|
|
||||||
|
crc_final = 0;
|
||||||
|
bindex = 0;
|
||||||
|
stream_upload();
|
||||||
|
CHECK(uip_conn->appstate.fw_reset_pending == 0,
|
||||||
|
"failed CRC does not request reset");
|
||||||
|
CHECK(strstr((char *)outbuf, "HTTP/1.1 400 Bad Request") != NULL,
|
||||||
|
"failed CRC returns an error verdict");
|
||||||
|
uip_conn->appstate.tstate = TSTATE_TX;
|
||||||
|
sent_len = slen;
|
||||||
|
cont_len = 0;
|
||||||
|
uip_flags = UIP_ACKDATA;
|
||||||
|
httpd_appcall();
|
||||||
|
CHECK(reset_calls == 0, "failed CRC verdict ACK does not reset");
|
||||||
|
}
|
||||||
|
|
||||||
int main(int argc, char **argv)
|
int main(int argc, char **argv)
|
||||||
{
|
{
|
||||||
if (argc > 1 && !strcmp(argv[1], "-v"))
|
if (argc > 1 && !strcmp(argv[1], "-v"))
|
||||||
@@ -504,6 +619,7 @@ int main(int argc, char **argv)
|
|||||||
scenario_growing_window();
|
scenario_growing_window();
|
||||||
scenario_rexmit_after_shrink();
|
scenario_rexmit_after_shrink();
|
||||||
scenario_bad_l4_checksum();
|
scenario_bad_l4_checksum();
|
||||||
|
scenario_upload_reset_owner();
|
||||||
|
|
||||||
printf("\n%s (%d failure%s)\n",
|
printf("\n%s (%d failure%s)\n",
|
||||||
failures ? "BENCH: FAILURES" : "BENCH: ALL PASS",
|
failures ? "BENCH: FAILURES" : "BENCH: ALL PASS",
|
||||||
|
|||||||
Reference in new issue
Block a user