Loading lib/transfer.c +1017 −1024 Original line number Diff line number Diff line Loading @@ -377,7 +377,6 @@ CURLcode Curl_readwrite(struct connectdata *conn, return CURLE_SEND_ERROR; } do { /* We go ahead and do a read if we have a readable socket or if the stream was rewound (in which case we have data in a buffer) */ Loading Loading @@ -1415,14 +1414,12 @@ CURLcode Curl_readwrite(struct connectdata *conn, } /* if( read from socket ) */ /* If we still have writing to do, we check if we have a writable socket. */ /* If we still have writing to do, we check if we have a writable socket. */ if((k->keepon & KEEP_WRITE) && (select_res & CURL_CSELECT_OUT)) { /* write */ ssize_t i, si; ssize_t bytes_written; bool writedone=TRUE; if((k->bytecount == 0) && (k->writebytecount == 0)) Curl_pgrsTime(data, TIMER_STARTTRANSFER); Loading Loading @@ -1474,7 +1471,6 @@ CURLcode Curl_readwrite(struct connectdata *conn, else if(nread<=0) { /* done */ k->keepon &= ~KEEP_WRITE; /* we're done writing */ writedone = TRUE; if(conn->bits.rewindaftersend) { result = Curl_readrewind(conn); Loading @@ -1490,10 +1486,11 @@ CURLcode Curl_readwrite(struct connectdata *conn, /* convert LF to CRLF if so asked */ #ifdef CURL_DO_LINEEND_CONV /* always convert if we're FTPing in ASCII mode */ if((data->set.crlf) || (data->set.prefer_ascii)) { if((data->set.crlf) || (data->set.prefer_ascii)) #else if(data->set.crlf) { if(data->set.crlf) #endif /* CURL_DO_LINEEND_CONV */ { if(data->state.scratch == NULL) data->state.scratch = malloc(2*BUFSIZE); if(data->state.scratch == NULL) { Loading Loading @@ -1531,7 +1528,7 @@ CURLcode Curl_readwrite(struct connectdata *conn, data->req.upload_present = nread; } } } } /* if 0 == data->req.upload_present */ else { /* We have a partial buffer left from a previous "round". Use that instead of reading more data */ Loading Loading @@ -1560,8 +1557,6 @@ CURLcode Curl_readwrite(struct connectdata *conn, /* advance the pointer where to find the buffer when the next send is to happen */ data->req.upload_fromhere += bytes_written; writedone = TRUE; /* we are done, stop the loop */ } else { /* we've uploaded that buffer now */ Loading @@ -1571,19 +1566,16 @@ CURLcode Curl_readwrite(struct connectdata *conn, if(k->upload_done) { /* switch off writing, we're done! */ k->keepon &= ~KEEP_WRITE; /* we're done writing */ writedone = TRUE; } } k->writebytecount += bytes_written; Curl_pgrsSetUploadCounter(data, k->writebytecount); } while(!writedone); /* loop until we're done writing! */ } } while(0); /* just to break out from! */ } /* if(something to write) */ k->now = Curl_tvnow(); if(didwhat) { /* Update read/write counters */ Loading Loading @@ -1679,7 +1671,8 @@ CURLcode Curl_readwrite(struct connectdata *conn, } /* Now update the "done" boolean we return */ *done = (bool)(0 == (k->keepon&(KEEP_READ|KEEP_WRITE|KEEP_READ_PAUSE|KEEP_WRITE_PAUSE))); *done = (bool)(0 == (k->keepon&(KEEP_READ|KEEP_WRITE| KEEP_READ_PAUSE|KEEP_WRITE_PAUSE))); return CURLE_OK; } Loading Loading
lib/transfer.c +1017 −1024 Original line number Diff line number Diff line Loading @@ -377,7 +377,6 @@ CURLcode Curl_readwrite(struct connectdata *conn, return CURLE_SEND_ERROR; } do { /* We go ahead and do a read if we have a readable socket or if the stream was rewound (in which case we have data in a buffer) */ Loading Loading @@ -1415,14 +1414,12 @@ CURLcode Curl_readwrite(struct connectdata *conn, } /* if( read from socket ) */ /* If we still have writing to do, we check if we have a writable socket. */ /* If we still have writing to do, we check if we have a writable socket. */ if((k->keepon & KEEP_WRITE) && (select_res & CURL_CSELECT_OUT)) { /* write */ ssize_t i, si; ssize_t bytes_written; bool writedone=TRUE; if((k->bytecount == 0) && (k->writebytecount == 0)) Curl_pgrsTime(data, TIMER_STARTTRANSFER); Loading Loading @@ -1474,7 +1471,6 @@ CURLcode Curl_readwrite(struct connectdata *conn, else if(nread<=0) { /* done */ k->keepon &= ~KEEP_WRITE; /* we're done writing */ writedone = TRUE; if(conn->bits.rewindaftersend) { result = Curl_readrewind(conn); Loading @@ -1490,10 +1486,11 @@ CURLcode Curl_readwrite(struct connectdata *conn, /* convert LF to CRLF if so asked */ #ifdef CURL_DO_LINEEND_CONV /* always convert if we're FTPing in ASCII mode */ if((data->set.crlf) || (data->set.prefer_ascii)) { if((data->set.crlf) || (data->set.prefer_ascii)) #else if(data->set.crlf) { if(data->set.crlf) #endif /* CURL_DO_LINEEND_CONV */ { if(data->state.scratch == NULL) data->state.scratch = malloc(2*BUFSIZE); if(data->state.scratch == NULL) { Loading Loading @@ -1531,7 +1528,7 @@ CURLcode Curl_readwrite(struct connectdata *conn, data->req.upload_present = nread; } } } } /* if 0 == data->req.upload_present */ else { /* We have a partial buffer left from a previous "round". Use that instead of reading more data */ Loading Loading @@ -1560,8 +1557,6 @@ CURLcode Curl_readwrite(struct connectdata *conn, /* advance the pointer where to find the buffer when the next send is to happen */ data->req.upload_fromhere += bytes_written; writedone = TRUE; /* we are done, stop the loop */ } else { /* we've uploaded that buffer now */ Loading @@ -1571,19 +1566,16 @@ CURLcode Curl_readwrite(struct connectdata *conn, if(k->upload_done) { /* switch off writing, we're done! */ k->keepon &= ~KEEP_WRITE; /* we're done writing */ writedone = TRUE; } } k->writebytecount += bytes_written; Curl_pgrsSetUploadCounter(data, k->writebytecount); } while(!writedone); /* loop until we're done writing! */ } } while(0); /* just to break out from! */ } /* if(something to write) */ k->now = Curl_tvnow(); if(didwhat) { /* Update read/write counters */ Loading Loading @@ -1679,7 +1671,8 @@ CURLcode Curl_readwrite(struct connectdata *conn, } /* Now update the "done" boolean we return */ *done = (bool)(0 == (k->keepon&(KEEP_READ|KEEP_WRITE|KEEP_READ_PAUSE|KEEP_WRITE_PAUSE))); *done = (bool)(0 == (k->keepon&(KEEP_READ|KEEP_WRITE| KEEP_READ_PAUSE|KEEP_WRITE_PAUSE))); return CURLE_OK; } Loading