Lines Matching defs:easy_conn
110 struct connectdata *easy_conn; /* the "unit's" connection */
241 if(easy->easy_conn) {
244 connectindex = easy->easy_conn->connectindex;
649 bool easy_owns_conn = (easy->easy_conn &&
650 (easy->easy_conn->data == easy->easy_handle)) ?
660 if(easy->easy_conn &&
661 (easy->easy_conn->send_pipe->size +
662 easy->easy_conn->recv_pipe->size > 1) &&
668 easy->easy_conn->bits.close = TRUE;
671 easy->easy_conn->data = easy->easy_handle;
691 if(easy->easy_conn) {
702 (void)Curl_done(&easy->easy_conn, easy->result, premature);
704 if(easy->easy_conn)
707 easy->easy_conn->data = easy->easy_handle;
711 Curl_getoff_all_pipelines(easy->easy_handle, easy->easy_conn);
735 if(easy->easy_conn && easy_owns_conn &&
736 (easy->easy_conn->send_pipe->size +
737 easy->easy_conn->recv_pipe->size == 0))
738 easy->easy_conn->connectindex = -1;
801 one_easy->easy_conn = NULL;
841 if(easy->easy_handle->state.pipe_broke || !easy->easy_conn)
847 easy->easy_conn->data = easy->easy_handle;
868 return Curl_resolver_getsock(easy->easy_conn, socks, numsocks);
871 return Curl_protocol_getsock(easy->easy_conn, socks, numsocks);
875 return Curl_doing_getsock(easy->easy_conn, socks, numsocks);
879 return waitconnect_getsock(easy->easy_conn, socks, numsocks);
882 return domore_getsock(easy->easy_conn, socks, numsocks);
889 return Curl_single_getsock(easy->easy_conn, socks, numsocks);
983 easy->easy_conn = NULL;
987 if(easy->easy_conn && easy->state > CURLM_STATE_CONNECT &&
990 easy->easy_conn->data = data;
992 if(easy->easy_conn &&
1021 easy->easy_conn->bits.close = TRUE;
1045 easy->result = Curl_connect(data, &easy->easy_conn,
1051 easy->easy_conn);
1069 if(easy->easy_conn->bits.tunnel_connecting)
1086 easy->result = Curl_resolver_is_resolved(easy->easy_conn, &dns);
1096 easy->result = Curl_async_resolved(easy->easy_conn,
1102 easy->easy_conn = NULL; /* no more connection */
1111 if(easy->easy_conn->bits.tunnel_connecting)
1131 easy->result = Curl_http_connect(easy->easy_conn, &protocol_connect);
1133 if(easy->easy_conn->bits.proxy_connect_closed) {
1144 if(!easy->easy_conn->bits.tunnel_connecting)
1152 easy->result = Curl_is_connected(easy->easy_conn,
1160 easy->result = Curl_protocol_connect(easy->easy_conn,
1179 if(easy->easy_conn->bits.tunnel_connecting)
1197 easy->result = Curl_protocol_connecting(easy->easy_conn,
1208 Curl_done(&easy->easy_conn, easy->result, TRUE);
1217 easy->easy_conn->connectindex,
1218 easy->easy_conn->send_pipe->size,
1219 easy->easy_conn->writechannel_inuse?1:0,
1221 easy->easy_conn->send_pipe)?1:0);
1223 if(!easy->easy_conn->writechannel_inuse &&
1225 easy->easy_conn->send_pipe)) {
1227 easy->easy_conn->writechannel_inuse = TRUE;
1236 easy->easy_conn->bits.close = FALSE;
1243 easy->result = Curl_do(&easy->easy_conn,
1253 Curl_done(&easy->easy_conn, CURLE_OK, FALSE);
1266 else if(easy->easy_conn->bits.do_more) {
1279 easy->easy_conn->bits.reuse) {
1290 drc = Curl_retry_request(easy->easy_conn, &newurl);
1300 drc = Curl_done(&easy->easy_conn, easy->result, FALSE);
1333 Curl_done(&easy->easy_conn, easy->result, FALSE);
1341 easy->result = Curl_protocol_doing(easy->easy_conn,
1346 multistate(easy, easy->easy_conn->bits.do_more?
1355 Curl_done(&easy->easy_conn, easy->result, FALSE);
1362 easy->result = Curl_is_connected(easy->easy_conn,
1369 easy->result = Curl_do_more(easy->easy_conn);
1381 Curl_done(&easy->easy_conn, easy->result, FALSE);
1389 moveHandleFromSendToRecvPipeline(data, easy->easy_conn);
1391 checkPendPipeline(easy->easy_conn);
1398 if(!easy->easy_conn->readchannel_inuse &&
1400 easy->easy_conn->recv_pipe)) {
1402 easy->easy_conn->readchannel_inuse = TRUE;
1409 easy->easy_conn->connectindex,
1410 easy->easy_conn->recv_pipe->size,
1411 easy->easy_conn->readchannel_inuse?1:0,
1413 easy->easy_conn->recv_pipe)?1:0);
1420 Curl_pgrsUpdate(easy->easy_conn);
1462 easy->result = Curl_readwrite(easy->easy_conn, &done);
1468 easy->easy_conn->readchannel_inuse = FALSE;
1473 easy->easy_conn->writechannel_inuse = FALSE;
1483 if(!(easy->easy_conn->handler->flags & PROTOPT_DUAL))
1484 easy->easy_conn->bits.close = TRUE;
1487 Curl_done(&easy->easy_conn, easy->result, FALSE);
1494 easy->result = Curl_retry_request(easy->easy_conn, &newurl);
1503 easy->easy_conn);
1506 if(easy->easy_conn->recv_pipe->head)
1507 Curl_expire(easy->easy_conn->recv_pipe->head->ptr, 1);
1510 checkPendPipeline(easy->easy_conn);
1524 easy->result = Curl_done(&easy->easy_conn, CURLE_OK, FALSE);
1560 if(easy->easy_conn) {
1564 easy->easy_conn->recv_pipe);
1566 easy->easy_conn->done_pipe);
1568 checkPendPipeline(easy->easy_conn);
1570 if(easy->easy_conn->bits.stream_was_rewound) {
1578 easy->result = Curl_done(&easy->easy_conn, CURLE_OK, FALSE);
1581 * easy_conn to NULL. In such a case, curl_multi_remove_handle() can
1585 if(easy->easy_conn)
1586 easy->easy_conn = NULL;
1613 easy->easy_conn = NULL;
1637 if(easy->easy_conn) {
1639 easy->easy_conn->writechannel_inuse = FALSE;
1640 easy->easy_conn->readchannel_inuse = FALSE;
1642 easy->easy_conn->send_pipe);
1644 easy->easy_conn->recv_pipe);
1646 easy->easy_conn->done_pipe);
1648 checkPendPipeline(easy->easy_conn);
1652 Curl_disconnect(easy->easy_conn, /* dead_connection */ FALSE);
1654 /* This is where we make sure that the easy_conn pointer is reset.
1657 easy->easy_conn = NULL;
1668 else if(easy->easy_conn && Curl_pgrsUpdate(easy->easy_conn)) {
1671 easy->easy_conn->bits.close = TRUE;
1973 struct connectdata *easy_conn;
1976 easy_conn = easy_by_hash->easy_conn;
1977 if(easy_conn) {
1978 if(easy_conn->recv_pipe && easy_conn->recv_pipe->size > 1) {
1986 if(isHandleAtHead(easy->easy_handle, easy_conn->recv_pipe))
1987 entry->easy = easy_conn->recv_pipe->head->next->ptr;
1989 entry->easy = easy_conn->recv_pipe->head->ptr;
1992 if(easy_conn->send_pipe && easy_conn->send_pipe->size > 1) {
2000 if(isHandleAtHead(easy->easy_handle, easy_conn->send_pipe))
2001 entry->easy = easy_conn->send_pipe->head->next->ptr;
2003 entry->easy = easy_conn->send_pipe->head->ptr;
2139 if(data->set.one_easy->easy_conn) {
2141 data->set.one_easy->easy_conn->send_pipe &&
2142 data->set.one_easy->easy_conn->send_pipe->head)
2143 data = data->set.one_easy->easy_conn->send_pipe->head->ptr;
2145 data->set.one_easy->easy_conn->recv_pipe &&
2146 data->set.one_easy->easy_conn->recv_pipe->head)
2147 data = data->set.one_easy->easy_conn->recv_pipe->head->ptr;
2150 if(data->set.one_easy->easy_conn &&
2151 !(data->set.one_easy->easy_conn->handler->flags & PROTOPT_DIRLOCK))
2153 data->set.one_easy->easy_conn->cselect_bits = ev_bitmask;
2159 if(data->set.one_easy->easy_conn &&
2160 !(data->set.one_easy->easy_conn->handler->flags & PROTOPT_DIRLOCK))
2162 data->set.one_easy->easy_conn->cselect_bits = 0;