aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSteve Holme <steve_holme@hotmail.com>2011-11-30 18:23:09 +0000
committerDaniel Stenberg <daniel@haxx.se>2011-12-01 00:06:47 +0100
commitbdb647814ebf0b19e9e97507e3f99b3b4bbbf8be (patch)
treea3ac996561c0361c56fffc6c1079733a9310a9a7
parentc92234c3bcbb92579a5adecb25c23810e2bc4c10 (diff)
POP3: fixed escaped dot not being striped out
Changed the eob detection to work across the whole of the buffer so that lines that begin with a dot (which the server will have escaped) are passed to the client application correctly.
-rw-r--r--lib/pop3.c109
1 files changed, 65 insertions, 44 deletions
diff --git a/lib/pop3.c b/lib/pop3.c
index cf439c87a..2252c57f8 100644
--- a/lib/pop3.c
+++ b/lib/pop3.c
@@ -1040,61 +1040,75 @@ CURLcode Curl_pop3_write(struct connectdata *conn,
struct SessionHandle *data = conn->data;
struct SingleRequest *k = &data->req;
- /* Detect the end-of-body marker, which is 5 bytes:
- 0d 0a 2e 0d 0a. This marker can of course be spread out
- over up to 5 different data chunks.
- */
struct pop3_conn *pop3c = &conn->proto.pop3c;
+ bool strip_dot = FALSE;
+ size_t last = 0;
size_t i;
- /* since the EOB string must be within the last 5 bytes, get the index
- position of where to start to scan for it */
- size_t checkstart = (nread>POP3_EOB_LEN)?nread-POP3_EOB_LEN:0;
-
- if(checkstart) {
- /* write out the first piece, if any */
- result = Curl_client_write(conn, CLIENTWRITE_BODY, str, checkstart);
- if(result)
- return result;
- pop3c->eob=0;
- }
-
- for(i=checkstart; i<nread; i++) {
+ /* Search through the buffer looking for the end-of-body marker which is
+ 5 bytes (0d 0a 2e 0d 0a). Note that a line starting with a dot matches
+ the eob so the server will have prefixed it with an extra dot which we
+ need to strip out. Additionally the marker could of course be spread out
+ over 5 different data chunks */
+ for(i = 0; i < nread; i++) {
size_t prev = pop3c->eob;
+
switch(str[i]) {
case 0x0d:
- if((pop3c->eob == 0) || (pop3c->eob == 3))
+ if(pop3c->eob == 0) {
+ pop3c->eob++;
+
+ if(i) {
+ /* Write out the body part that didn't match */
+ result = Curl_client_write(conn, CLIENTWRITE_BODY, &str[last],
+ i - last);
+
+ if(result)
+ return result;
+
+ last = i;
+ }
+ }
+ else if(pop3c->eob == 3)
pop3c->eob++;
else
- /* if it wasn't 0 or 3, it restarts the pattern match again */
- pop3c->eob=1;
+ /* If the character match wasn't at position 0 or 3 then restart the
+ pattern matching */
+ pop3c->eob = 1;
break;
+
case 0x0a:
- if((pop3c->eob == 1) || (pop3c->eob == 4))
+ if(pop3c->eob == 1 || pop3c->eob == 4)
pop3c->eob++;
else
- pop3c->eob=0;
+ /* If the character match wasn't at position 1 or 4 then start the
+ search again */
+ pop3c->eob = 0;
break;
+
case 0x2e:
if(pop3c->eob == 2)
pop3c->eob++;
+ else if(pop3c->eob == 3) {
+ /* We have an extra dot after the CRLF which we need to strip off */
+ strip_dot = TRUE;
+ pop3c->eob = 0;
+ }
else
- pop3c->eob=0;
+ /* If the character match wasn't at position 2 then start the search
+ again */
+ pop3c->eob = 0;
break;
+
default:
- pop3c->eob=0;
- break;
- }
- if(pop3c->eob == POP3_EOB_LEN) {
- /* full match, the transfer is done! */
- k->keepon &= ~KEEP_RECV;
pop3c->eob = 0;
- return CURLE_OK;
+ break;
}
- else if(prev && (prev >= pop3c->eob)) {
- /* strip can only be non-zero for the very first mismatch after CRLF and
- then both prev and strip are equal and nothing will be output
+ /* Did we have a partial match which has subsequently failed? */
+ if(prev && prev >= pop3c->eob) {
+ /* Strip can only be non-zero for the very first mismatch after CRLF
+ and then both prev and strip are equal and nothing will be output
below */
while(prev && pop3c->strip) {
prev--;
@@ -1102,27 +1116,34 @@ CURLcode Curl_pop3_write(struct connectdata *conn,
}
if(prev) {
- /* write out the body part that didn't match */
+ /* If the partial match was the CRLF and dot then only write the CRLF
+ as the server would have inserted the dot */
result = Curl_client_write(conn, CLIENTWRITE_BODY, (char*)POP3_EOB,
- prev);
+ strip_dot ? prev - 1 : prev);
+
if(result)
return result;
+
+ last = i;
+ strip_dot = FALSE;
}
}
}
- if(pop3c->eob)
- /* while EOB is matching, don't output it! */
+ if(pop3c->eob == POP3_EOB_LEN) {
+ /* We have a full match so the transfer is done! */
+ k->keepon &= ~KEEP_RECV;
+ pop3c->eob = 0;
return CURLE_OK;
-
- while(nread && pop3c->strip) {
- nread--;
- pop3c->strip--;
- str++;
}
- if(nread) {
- result = Curl_client_write(conn, CLIENTWRITE_BODY, str, nread);
+ if(pop3c->eob)
+ /* While EOB is matching nothing should be output */
+ return CURLE_OK;
+
+ if(nread - last) {
+ result = Curl_client_write(conn, CLIENTWRITE_BODY, &str[last],
+ nread - last);
}
return result;