urbit/shrub
1
1
Fork 0
mirror of https://github.com/urbit/shrub.git synced 2024-12-23 02:41:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

WIP: Switching tasks

Browse Source
This commit is contained in:
Elliot Glaysher 2018-10-31 14:43:16 -07:00
parent 3af6a85052
commit a5ce6d5ead
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
vere/cttp.c
View File

@ -746,6 +746,8 @@ _cttp_creq_on_body(h2o_http1client_t* cli_u, const c3_c* err_c)
h2o_buffer_consume(&cli_u->sock->input, buf_u->size); h2o_buffer_consume(&cli_u->sock->input, buf_u->size);
} }
// We're using the end of stream thing here to queue event to urbit. we'll
// need to separate this into our own timer for partial progress sends.
if ( h2o_http1client_error_is_eos == err_c ) { if ( h2o_http1client_error_is_eos == err_c ) {
_cttp_creq_respond(ceq_u); _cttp_creq_respond(ceq_u);
} }

4
vere/http.c
View File

@ -482,7 +482,7 @@ _http_start_respond(u3_hreq* req_u,
u3_noun data, u3_noun data,
u3_noun complete) u3_noun complete)
{ {
uL(fprintf(uH, "start\n")); /* uL(fprintf(uH, "start\n")); */
if ( u3_rsat_plan != req_u->sat_e ) { if ( u3_rsat_plan != req_u->sat_e ) {
//uL(fprintf(uH, "duplicate response\n")); //uL(fprintf(uH, "duplicate response\n"));
@ -541,7 +541,7 @@ _http_continue_respond(u3_hreq* req_u,
u3_noun data, u3_noun data,
u3_noun complete) u3_noun complete)
{ {
uL(fprintf(uH, "continue\n")); /* uL(fprintf(uH, "continue\n")); */
// XX add sequence numbers for %continue effects? // XX add sequence numbers for %continue effects?
// Arvo does not (currently) guarantee effect idempotence!! // Arvo does not (currently) guarantee effect idempotence!!