Searched refs:recv_pipe (Results 1 – 4 of 4) sorted by relevance
72 if(conn->recv_pipe && conn->recv_pipe->head) { in Curl_pipeline_penalized()73 struct SessionHandle *recv_handle = conn->recv_pipe->head->ptr; in Curl_pipeline_penalized()142 conn->recv_pipe, conn->recv_pipe->tail); in Curl_move_handle_from_send_to_recv_pipe()337 return pipe_head(data, conn->recv_pipe); in Curl_recvpipe_head()427 conn->recv_pipe->size);
1567 Curl_removeHandleFromPipeline(data, data->easy_conn->recv_pipe); in multi_runsingle()1570 if(data->easy_conn->recv_pipe->head) in multi_runsingle()1571 Curl_expire_latest(data->easy_conn->recv_pipe->head->ptr, 1); in multi_runsingle()1634 Curl_removeHandleFromPipeline(data, data->easy_conn->recv_pipe); in multi_runsingle()1711 Curl_removeHandleFromPipeline(data, data->easy_conn->recv_pipe); in multi_runsingle()2048 if(easy_conn->recv_pipe && easy_conn->recv_pipe->size > 1) { in singlesocket()2057 entry->easy = easy_conn->recv_pipe->head->next->ptr; in singlesocket()2059 entry->easy = easy_conn->recv_pipe->head->ptr; in singlesocket()2252 data->easy_conn->recv_pipe && in multi_socket()2253 data->easy_conn->recv_pipe->head) in multi_socket()[all …]
2714 Curl_llist_destroy(conn->recv_pipe, NULL); in conn_free()2717 conn->recv_pipe = NULL; in conn_free()2790 signalPipeClose(conn->recv_pipe, TRUE); in Curl_disconnect()2892 if(Curl_removeHandleFromPipeline(data, conn->recv_pipe) && recv_head) in Curl_getoff_all_pipelines()3027 size_t pipeLen = conn->send_pipe->size + conn->recv_pipe->size; in disconnect_if_dead()3170 pipeLen = check->send_pipe->size + check->recv_pipe->size; in ConnectionExists()3177 struct SessionHandle* rh = gethandleathead(check->recv_pipe); in ConnectionExists()3213 if(check->recv_pipe->size > 0) { in ConnectionExists()3836 conn->recv_pipe = Curl_llist_alloc((curl_llist_dtor) llist_dtor); in allocate_conn()3837 if(!conn->send_pipe || !conn->recv_pipe) in allocate_conn()[all …]
981 struct curl_llist *recv_pipe; /* List of handles waiting to read member