changeset 9316:2fd8d3a2bd52 HEAD

lib-storage: Actually use MAIL_READ_BLOCK_SIZE sized blocks when reading mails.
author Timo Sirainen <tss@iki.fi>
date Thu, 13 Aug 2009 12:24:42 -0400
parents 70593ef74836
children 1e8edebee242
files src/lib-storage/index/cydir/cydir-mail.c src/lib-storage/index/dbox/dbox-file.c src/lib-storage/index/maildir/maildir-mail.c src/lib-storage/index/mbox/mbox-file.c src/lib-storage/index/raw/raw-storage.c
diffstat 5 files changed, 10 insertions(+), 1 deletions(-) [+]
line wrap: on
line diff
--- a/src/lib-storage/index/cydir/cydir-mail.c	Thu Aug 13 12:22:45 2009 -0400
+++ b/src/lib-storage/index/cydir/cydir-mail.c	Thu Aug 13 12:24:42 2009 -0400
@@ -114,6 +114,8 @@
 		}
 		mail->data.stream =
 			i_stream_create_fd(fd, MAIL_READ_BLOCK_SIZE, TRUE);
+		i_stream_set_init_buffer_size(mail->data.stream,
+					      MAIL_READ_BLOCK_SIZE);
 	}
 
 	return index_mail_init_stream(mail, hdr_size, body_size, stream_r);
--- a/src/lib-storage/index/dbox/dbox-file.c	Thu Aug 13 12:22:45 2009 -0400
+++ b/src/lib-storage/index/dbox/dbox-file.c	Thu Aug 13 12:24:42 2009 -0400
@@ -432,6 +432,7 @@
 	}
 
 	file->input = i_stream_create_fd(file->fd, MAIL_READ_BLOCK_SIZE, FALSE);
+	i_stream_set_init_buffer_size(file->input, MAIL_READ_BLOCK_SIZE);
 	return !read_header || file->maildir_file ? 1 :
 		dbox_file_read_header(file);
 }
--- a/src/lib-storage/index/maildir/maildir-mail.c	Thu Aug 13 12:22:45 2009 -0400
+++ b/src/lib-storage/index/maildir/maildir-mail.c	Thu Aug 13 12:24:42 2009 -0400
@@ -45,6 +45,7 @@
 		  bool *deleted_r)
 {
 	struct mail_private *p = (struct mail_private *)mail;
+	struct istream *input;
 	const char *path;
 	int fd = -1;
 
@@ -65,7 +66,9 @@
 		return NULL;
 	}
 
-	return i_stream_create_fd(fd, MAIL_READ_BLOCK_SIZE, TRUE);
+	input = i_stream_create_fd(fd, MAIL_READ_BLOCK_SIZE, TRUE);
+	i_stream_set_init_buffer_size(input, MAIL_READ_BLOCK_SIZE);
+	return input;
 }
 
 static int maildir_mail_stat(struct mail *mail, struct stat *st)
--- a/src/lib-storage/index/mbox/mbox-file.c	Thu Aug 13 12:22:45 2009 -0400
+++ b/src/lib-storage/index/mbox/mbox-file.c	Thu Aug 13 12:24:42 2009 -0400
@@ -79,6 +79,8 @@
 			mbox->mbox_file_stream =
 				i_stream_create_fd(mbox->mbox_fd,
 						   MAIL_READ_BLOCK_SIZE, FALSE);
+			i_stream_set_init_buffer_size(mbox->mbox_file_stream,
+						      MAIL_READ_BLOCK_SIZE);
 		}
 	}
 
--- a/src/lib-storage/index/raw/raw-storage.c	Thu Aug 13 12:22:45 2009 -0400
+++ b/src/lib-storage/index/raw/raw-storage.c	Thu Aug 13 12:24:42 2009 -0400
@@ -124,6 +124,7 @@
 		return -1;
 	}
 	*input_r = i_stream_create_fd(fd, MAIL_READ_BLOCK_SIZE, TRUE);
+	i_stream_set_init_buffer_size(*input_r, MAIL_READ_BLOCK_SIZE);
 	return 0;
 }