Mercurial > dovecot > core-2.2

changeset 604:b69e50478671 HEAD

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Use blocking output buffers when writing to files.
author Timo Sirainen <tss@iki.fi>
date Wed, 13 Nov 2002 03:36:16 +0200
parents abb584aabe31
children e5ff7ddeb895
files src/lib-index/mbox/mbox-rewrite.c src/lib-storage/index/maildir/maildir-save.c src/lib-storage/index/mbox/mbox-expunge.c src/lib-storage/index/mbox/mbox-save.c
diffstat 4 files changed, 5 insertions(+), 0 deletions(-) [+]
line wrap: on
line diff
--- a/src/lib-index/mbox/mbox-rewrite.c	Wed Nov 13 03:30:27 2002 +0200
+++ b/src/lib-index/mbox/mbox-rewrite.c	Wed Nov 13 03:36:16 2002 +0200
@@ -375,6 +375,7 @@
 	inbuf = i_buffer_create_mmap(in_fd, data_stack_pool,
 				     1024*256, 0, 0, FALSE);
 	outbuf = o_buffer_create_file(out_fd, data_stack_pool, 1024, 0, FALSE);
+	o_buffer_set_blocking(outbuf, 60000, NULL, NULL);
 
 	ret = o_buffer_send_ibuffer(outbuf, inbuf);
 	if (ret < 0)
@@ -468,6 +469,7 @@
 	/* note: we can't use data_stack_pool with outbuf because it's
 	   being written to inside t_push() .. t_pop() calls */
 	outbuf = o_buffer_create_file(tmp_fd, system_pool, 8192, 0, FALSE);
+	o_buffer_set_blocking(outbuf, 60000, NULL, NULL);
 
 	failed = FALSE; seq = 1;
 	rec = index->lookup(index, 1);
--- a/src/lib-storage/index/maildir/maildir-save.c	Wed Nov 13 03:30:27 2002 +0200
+++ b/src/lib-storage/index/maildir/maildir-save.c	Wed Nov 13 03:36:16 2002 +0200
@@ -61,6 +61,7 @@
 	t_push();
 	outbuf = o_buffer_create_file(fd, data_stack_pool, 4096,
 				      IO_PRIORITY_DEFAULT, FALSE);
+	o_buffer_set_blocking(outbuf, 60000, NULL, NULL);
 
 	path = t_strconcat(dir, "/", fname, NULL);
 	if (!index_storage_save(storage, path, buf, outbuf, data_size))
--- a/src/lib-storage/index/mbox/mbox-expunge.c	Wed Nov 13 03:30:27 2002 +0200
+++ b/src/lib-storage/index/mbox/mbox-expunge.c	Wed Nov 13 03:36:16 2002 +0200
@@ -129,6 +129,7 @@
 	t_push();
 	outbuf = o_buffer_create_file(ibox->index->mbox_fd, data_stack_pool,
 				      4096, 0, FALSE);
+	o_buffer_set_blocking(outbuf, 60000, NULL, NULL);
 
 	failed = !expunge_real(ibox, rec, seq, inbuf, outbuf, notify);
 
--- a/src/lib-storage/index/mbox/mbox-save.c	Wed Nov 13 03:30:27 2002 +0200
+++ b/src/lib-storage/index/mbox/mbox-save.c	Wed Nov 13 03:36:16 2002 +0200
@@ -196,6 +196,7 @@
 		outbuf = o_buffer_create_file(index->mbox_fd,
 					      data_stack_pool, 4096,
 					      0, FALSE);
+		o_buffer_set_blocking(outbuf, 60000, NULL, NULL);
 
 		if (!write_from_line(box->storage, outbuf, mbox_path,
 				     internal_date) ||