Searched refs:keepon (Results 1 – 20 of 20) sorted by relevance
1323 bool keepon = TRUE; in telnet_do() local1380 while(keepon) { in telnet_do()1394 keepon = FALSE; in telnet_do()1412 keepon = FALSE; in telnet_do()1422 keepon = FALSE; in telnet_do()1430 keepon = FALSE; in telnet_do()1441 keepon = FALSE; in telnet_do()1448 keepon = FALSE; in telnet_do()1461 keepon = FALSE; in telnet_do()1474 keepon = FALSE; in telnet_do()[all …]
256 k->keepon |= KEEP_SEND_PAUSE; /* mark socket send as paused */ in Curl_fillreadbuffer()500 k->keepon = 0; /* stop sending as well */ in readwrite_data()620 k->keepon &= ~KEEP_RECV; /* read no more */ in readwrite_data()665 k->keepon &= ~KEEP_RECV; /* we're done reading */ in readwrite_data()737 k->keepon |= KEEP_RECV; /* we're not done reading */ in readwrite_data()744 k->keepon &= ~KEEP_RECV; in readwrite_data()747 if((k->keepon & KEEP_RECV_PAUSE) || !(k->keepon & KEEP_RECV)) { in readwrite_data()760 if(((k->keepon & (KEEP_RECV|KEEP_SEND)) == KEEP_SEND) && in readwrite_data()766 k->keepon &= ~KEEP_SEND; /* no writing anymore either */ in readwrite_data()778 k->keepon &= ~KEEP_SEND; /* we're done writing */ in Curl_done_sending()[all …]
77 } keepon; member105 ts->keepon = KEEPON_CONNECT; in tunnel_reinit()167 ts->keepon = KEEPON_CONNECT; in h1_tunnel_go_state()388 while(ts->keepon) { in recv_CONNECT_resp()403 ts->keepon = KEEPON_DONE; in recv_CONNECT_resp()419 ts->keepon = KEEPON_DONE; in recv_CONNECT_resp()423 if(ts->keepon == KEEPON_IGNORE) { in recv_CONNECT_resp()431 ts->keepon = KEEPON_DONE; in recv_CONNECT_resp()448 ts->keepon = KEEPON_DONE; in recv_CONNECT_resp()496 ts->keepon = KEEPON_IGNORE; in recv_CONNECT_resp()[all …]
270 bool keepon = TRUE; in Curl_pp_readresp() local286 (keepon && !result)) { in Curl_pp_readresp()325 keepon = FALSE; in Curl_pp_readresp()328 if(!keepon) in Curl_pp_readresp()331 keepon = FALSE; in Curl_pp_readresp()375 keepon = FALSE; in Curl_pp_readresp()388 if(!keepon && (i != gotbytes)) { in Curl_pp_readresp()399 else if(keepon) { in Curl_pp_readresp()
44 if(data->req.keepon & KEEP_RECV_PAUSE) in Curl_speedcheck()
1078 data->req.keepon &= ~KEEP_SEND_HOLD; in on_stream_frame()1082 if((data->req.keepon & KEEP_SEND_HOLD) && in on_stream_frame()1083 (data->req.keepon & KEEP_SEND)) { in on_stream_frame()1084 data->req.keepon &= ~KEEP_SEND_HOLD; in on_stream_frame()1232 if((data->req.keepon & KEEP_SEND_HOLD) && in on_frame_recv()1233 (data->req.keepon & KEEP_SEND)) { in on_frame_recv()1235 data->req.keepon &= ~KEEP_SEND_HOLD; in on_frame_recv()1357 data_s->req.keepon &= ~KEEP_SEND_HOLD; in on_stream_close()2294 data->req.keepon |= KEEP_SEND_HOLD; in cf_h2_send()2363 if(!(k->keepon & (KEEP_RECV_PAUSE|KEEP_RECV_HOLD))) in cf_h2_get_select_socks()[all …]
1095 oldstate = k->keepon & (KEEP_RECV_PAUSE| KEEP_SEND_PAUSE); in curl_easy_pause()1098 newstate = (k->keepon &~ (KEEP_RECV_PAUSE| KEEP_SEND_PAUSE)) | in curl_easy_pause()1109 if((k->keepon & ~newstate & KEEP_SEND_PAUSE) && in curl_easy_pause()1117 k->keepon = newstate; in curl_easy_pause()
691 if((data->req.keepon & KEEP_SEND_HOLD) && in proxy_h2_on_frame_recv()692 (data->req.keepon & KEEP_SEND)) { in proxy_h2_on_frame_recv()693 data->req.keepon &= ~KEEP_SEND_HOLD; in proxy_h2_on_frame_recv()730 if((data->req.keepon & KEEP_SEND_HOLD) && in proxy_h2_on_frame_recv()731 (data->req.keepon & KEEP_SEND)) { in proxy_h2_on_frame_recv()732 data->req.keepon &= ~KEEP_SEND_HOLD; in proxy_h2_on_frame_recv()
260 k->keepon |= KEEP_RECV_PAUSE; in pausewrite()288 if(data->req.keepon & KEEP_RECV_PAUSE) in chop_write()
3068 k->keepon &= ~KEEP_RECV; in Curl_http_firstwrite()3087 k->keepon &= ~KEEP_RECV; in Curl_http_firstwrite()3422 data->req.keepon &= ~KEEP_SEND; /* we're done writing */ in Curl_http()4124 k->keepon |= KEEP_SEND; in Curl_http_readwrite_headers()4156 k->keepon &= ~KEEP_RECV; /* read no more content */ in Curl_http_readwrite_headers()4332 k->keepon |= KEEP_SEND; in Curl_http_readwrite_headers()4357 k->keepon |= KEEP_SEND; in Curl_http_readwrite_headers()4393 k->keepon &= ~KEEP_RECV; in Curl_http_readwrite_headers()
366 k->keepon |= KEEP_SEND; in Curl_hyper_stream()748 if((data->req.keepon & KEEP_SEND_PAUSE) != KEEP_SEND_PAUSE) in uploadstreamed()
670 k->keepon &= ~KEEP_RECV; in rtsp_rtp_readwrite()
666 int keepon; member
1569 k->keepon &= ~KEEP_RECV; in Curl_pop3_write()
1582 k->keepon |= KEEP_RECV; /* setup to receive! */1780 data->req.keepon &= ~KEEP_SEND;
254 return (data->req.keepon & KEEP_SEND_HOLD); in stream_send_is_suspended()262 if((data->req.keepon & KEEP_SENDBITS) == KEEP_SEND) { in stream_send_suspend()263 data->req.keepon |= KEEP_SEND_HOLD; in stream_send_suspend()279 data->req.keepon &= ~KEEP_SEND_HOLD; in stream_send_resume()337 data->req.keepon &= ~KEEP_SEND_HOLD; in h3_data_done()593 data->req.keepon &= ~KEEP_SEND_HOLD; in h3_process_event()1195 if(((k->keepon & KEEP_SENDBITS) == KEEP_SEND) in cf_quiche_get_select_socks()
1093 if((k->keepon & KEEP_SENDBITS) == KEEP_SEND && in cf_ngtcp2_get_select_socks()1144 data->req.keepon &= ~KEEP_SEND_HOLD; in cb_h3_stream_close()1576 if((data->req.keepon & KEEP_SEND_HOLD) && in cb_h3_acked_req_body()1577 (data->req.keepon & KEEP_SEND)) { in cb_h3_acked_req_body()1578 data->req.keepon &= ~KEEP_SEND_HOLD; in cb_h3_acked_req_body()1871 data->req.keepon |= KEEP_SEND_HOLD; in cf_ngtcp2_send()
700 sshc->orig_waitfor = data->req.keepon; in wssh_statemach_act()1061 data->req.keepon = 0; /* clear all bits */ in wssh_done()
1357 sshc->orig_waitfor = data->req.keepon; in myssh_statemach_act()1867 sshc->orig_waitfor = data->req.keepon; in myssh_statemach_act()2398 data->req.keepon = 0; /* clear all bits */ in myssh_done()
2203 sshc->orig_waitfor = data->req.keepon; in ssh_statemach_act()2761 sshc->orig_waitfor = data->req.keepon; in ssh_statemach_act()3516 data->req.keepon = 0; /* clear all bits */ in ssh_done()