Lines Matching defs:conn
94 CURLcode Curl_fillreadbuffer(struct connectdata *conn, int bytes, int *nreadp)
96 struct SessionHandle *data = conn->data;
102 if(conn->handler->protocol&(CURLPROTO_HTTP|CURLPROTO_RTSP)) {
120 nread = (int)conn->fread_func(data->req.upload_fromhere, 1,
121 buffersize, conn->fread_in);
130 if(conn->handler->flags & PROTOPT_NONETWORK) {
249 CURLcode Curl_readrewind(struct connectdata *conn)
251 struct SessionHandle *data = conn->data;
253 conn->bits.rewindaftersend = FALSE; /* we rewind now */
308 static int data_pending(const struct connectdata *conn)
312 return conn->handler->protocol&(CURLPROTO_SCP|CURLPROTO_SFTP) ||
314 Curl_ssl_data_pending(conn, FIRSTSOCKET) ||
318 close, which we emulate it using conn->proto.httpc.closed =
322 ((conn->handler->protocol&CURLPROTO_HTTP) && conn->httpversion == 20 &&
323 conn->proto.httpc.closed);
325 Curl_ssl_data_pending(conn, FIRSTSOCKET);
329 static void read_rewind(struct connectdata *conn,
332 DEBUGASSERT(conn->read_pos >= thismuch);
334 conn->read_pos -= thismuch;
335 conn->bits.stream_was_rewound = TRUE;
342 show = CURLMIN(conn->buf_len - conn->read_pos, sizeof(buf)-1);
343 if(conn->master_buffer) {
344 memcpy(buf, conn->master_buffer + conn->read_pos, show);
351 DEBUGF(infof(conn->data,
353 conn->read_pos, buf));
396 struct connectdata *conn,
426 result = Curl_read(conn, conn->sockfd, k->buf, bytestoread, &nread);
468 if(conn->handler->readwrite) {
469 result = conn->handler->readwrite(data, conn, &nread, &readmore);
482 result = Curl_http_readwrite_headers(data, conn, &nread, &stop_reading);
486 if(conn->handler->readwrite &&
488 result = conn->handler->readwrite(data, conn, &nread, &readmore);
499 if(Curl_multi_pipeline_enabled(conn->data->multi)) {
504 read_rewind(conn, (size_t)nread);
530 if(conn->handler->protocol&(CURLPROTO_HTTP|CURLPROTO_RTSP)) {
534 if(conn->bits.close) {
572 conn->bits.close = TRUE;
587 (size_t)k->hbuflen, conn);
590 k->str, (size_t)nread, conn);
594 k->str, (size_t)nread, conn);
607 Curl_httpchunk_read(conn, k->str, nread, &nread);
628 dataleft = conn->chunk.dataleft;
630 infof(conn->data, "Leftovers after chunking: %zu bytes\n",
632 if(Curl_multi_pipeline_enabled(conn->data->multi)) {
634 infof(conn->data, "Rewinding %zu bytes\n",dataleft);
635 read_rewind(conn, dataleft);
655 if(Curl_multi_pipeline_enabled(conn->data->multi)) {
665 read_rewind(conn, excess);
698 result = Curl_client_write(conn, CLIENTWRITE_BODY,
702 result = Curl_client_write(conn, CLIENTWRITE_BODY,
716 switch (conn->data->set.http_ce_skip ?
726 if(conn->handler->protocol&CURLPROTO_POP3)
727 result = Curl_pop3_write(conn, k->str, nread);
731 result = Curl_client_write(conn, CLIENTWRITE_BODY, k->str,
740 result = Curl_unencode_deflate_write(conn, k, nread);
746 result = Curl_unencode_gzip_write(conn, k, nread);
767 if(conn->handler->readwrite &&
768 (excess > 0 && !conn->bits.stream_was_rewound)) {
773 result = conn->handler->readwrite(data, conn, &nread, &readmore);
788 } while(data_pending(conn));
791 conn->bits.close ) {
806 struct connectdata *conn,
857 if(conn->handler->protocol&(CURLPROTO_HTTP|CURLPROTO_RTSP)) {
866 result = Curl_fillreadbuffer(conn, BUFSIZE, &fillcount);
883 if(conn->bits.rewindaftersend) {
884 result = Curl_readrewind(conn);
895 if(conn->handler->protocol & CURLPROTO_SMTP) {
896 result = Curl_smtp_escape_eob(conn, nread);
954 result = Curl_write(conn,
955 conn->writesockfd, /* socket to send to */
966 (size_t)bytes_written, conn);
1008 CURLcode Curl_readwrite(struct connectdata *conn,
1011 struct SessionHandle *data = conn->data;
1018 int select_res = conn->cselect_bits;
1020 conn->cselect_bits = 0;
1026 fd_read = conn->sockfd;
1031 fd_write = conn->writesockfd;
1048 ((select_res & CURL_CSELECT_IN) || conn->bits.stream_was_rewound)) {
1050 result = readwrite_data(data, conn, k, &didwhat, done);
1059 result = readwrite_upload(data, conn, k, &didwhat);
1098 if(Curl_pgrsUpdate(conn))
1145 (conn->chunk.state != CHUNK_STOP)) {
1151 * conn->proto.http->chunk.datasize != 0 which is true after reading
1158 if(Curl_pgrsUpdate(conn))
1176 int Curl_single_getsock(const struct connectdata *conn,
1181 const struct SessionHandle *data = conn->data;
1185 if(conn->handler->perform_getsock)
1186 return conn->handler->perform_getsock(conn, sock, numsocks);
1195 DEBUGASSERT(conn->sockfd != CURL_SOCKET_BAD);
1198 sock[sockindex] = conn->sockfd;
1204 if((conn->sockfd != conn->writesockfd) ||
1211 DEBUGASSERT(conn->writesockfd != CURL_SOCKET_BAD);
1213 sock[sockindex] = conn->writesockfd;
1810 struct connectdata *conn = *connp;
1811 struct SessionHandle *data = conn->data;
1821 conn->bits.close = TRUE; /* enforce close of this connection */
1822 result = Curl_done(&conn, result, FALSE); /* we are so done with this */
1824 /* conn may no longer be a good pointer, clear it to avoid mistakes by
1844 conn = *connp; /* setup conn to again point to something nice */
1848 result = Curl_resolver_wait_resolv(conn, NULL);
1853 result = Curl_async_resolved(conn, &protocol_done);
1866 CURLcode Curl_retry_request(struct connectdata *conn,
1869 struct SessionHandle *data = conn->data;
1876 !(conn->handler->protocol&(CURLPROTO_HTTP|CURLPROTO_RTSP)))
1882 conn->bits.reuse &&
1889 infof(conn->data, "Connection died, retrying a fresh connect\n");
1890 *url = strdup(conn->data->change.url);
1894 conn->bits.close = TRUE; /* close this connection */
1895 conn->bits.retry = TRUE; /* mark this as a connection we're about
1902 if(conn->handler->protocol&CURLPROTO_HTTP) {
1905 return Curl_readrewind(conn);
1917 struct connectdata *conn, /* connection data */
1930 DEBUGASSERT(conn != NULL);
1932 data = conn->data;
1938 conn->sockfd = sockindex == -1 ?
1939 CURL_SOCKET_BAD : conn->sock[sockindex];
1940 conn->writesockfd = writesockindex == -1 ?
1941 CURL_SOCKET_BAD:conn->sock[writesockindex];
1960 if(conn->sockfd != CURL_SOCKET_BAD)
1963 if(conn->writesockfd != CURL_SOCKET_BAD) {
1975 (conn->handler->protocol&CURLPROTO_HTTP) &&
1994 } /* if(conn->writesockfd != CURL_SOCKET_BAD) */