lib-fs: Do not abort parent of parent

diff --git a/src/lib-fs/fs-metawrap.c b/src/lib-fs/fs-metawrap.c
index 481bdcdbeee2818ed83d4d922fcf24ce2ad38392..43bca2bfca3bc27191a037aab24f2f8db66ed62e 100644 (file)
--- a/src/lib-fs/fs-metawrap.c
+++ b/src/lib-fs/fs-metawrap.c
@@ -364,7 +364,7 @@ static int fs_metawrap_write_stream_finish(struct fs_file *_file, bool success)
                if (file->super_output != NULL) {
                        /* no metawrap */
                        i_assert(file->temp_output == NULL);
-                       fs_write_stream_abort_parent(_file->parent, &file->super_output);
+                       fs_write_stream_abort_parent(_file, &file->super_output);
                } else {
                        i_assert(file->temp_output != NULL);
                        o_stream_destroy(&file->temp_output);

diff --git a/src/lib-fs/fs-randomfail.c b/src/lib-fs/fs-randomfail.c
index 24abcc19a9ce92be8d8a1bc180ce039eecb0e874..b2acda24d349d5e269009029cd4230aded1438a0 100644 (file)
--- a/src/lib-fs/fs-randomfail.c
+++ b/src/lib-fs/fs-randomfail.c
@@ -402,7 +402,7 @@ static int fs_randomfail_write_stream_finish(struct fs_file *_file, bool success
                else
                        o_stream_unref(&_file->output);
                if (!success) {
-                       fs_write_stream_abort_parent(_file->parent, &file->super_output);
+                       fs_write_stream_abort_parent(_file, &file->super_output);
                        return -1;
                }
                if (!fs_random_fail(_file->fs, 1, FS_OP_WRITE)) {

diff --git a/src/lib-fs/fs-sis-queue.c b/src/lib-fs/fs-sis-queue.c
index a317a9aa830de3fb09ea3d0f7f1cc1990926aa2e..174420be43dde5c8d5ff546da1effaef9d040a70 100644 (file)
--- a/src/lib-fs/fs-sis-queue.c
+++ b/src/lib-fs/fs-sis-queue.c
@@ -149,7 +149,7 @@ static int fs_sis_queue_write_stream_finish(struct fs_file *_file, bool success)
 
        if (!success) {
                if (_file->parent != NULL)
-                       fs_write_stream_abort_parent(_file->parent, &_file->output);
+                       fs_write_stream_abort_parent(_file, &_file->output);
                return -1;
        }
 

diff --git a/src/lib-fs/fs-sis.c b/src/lib-fs/fs-sis.c
index a806fa5609532eb0f5be0d7ced198a5d2ebc4c91..83783215ba4c6db4536e286fdd072857b3eb5184 100644 (file)
--- a/src/lib-fs/fs-sis.c
+++ b/src/lib-fs/fs-sis.c
@@ -287,7 +287,7 @@ static int fs_sis_write_stream_finish(struct fs_file *_file, bool success)
 
        if (!success) {
                if (_file->parent != NULL)
-                       fs_write_stream_abort_parent(_file->parent, &file->fs_output);
+                       fs_write_stream_abort_parent(_file, &file->fs_output);
                o_stream_unref(&_file->output);
                return -1;
        }
@@ -297,7 +297,7 @@ static int fs_sis_write_stream_finish(struct fs_file *_file, bool success)
            i_stream_is_eof(file->hash_input)) {
                o_stream_unref(&_file->output);
                if (fs_sis_try_link(file)) {
-                       fs_write_stream_abort_parent(_file->parent, &file->fs_output);
+                       fs_write_stream_abort_parent(_file, &file->fs_output);
                        return 1;
                }
        }

diff --git a/src/lib-fs/fs-wrapper.c b/src/lib-fs/fs-wrapper.c
index 2dcfd1bb2a86e8cb48f6a1a6ca228408eb256f45..6c0c63045523089531c4abd9107621659341c990 100644 (file)
--- a/src/lib-fs/fs-wrapper.c
+++ b/src/lib-fs/fs-wrapper.c
@@ -79,7 +79,7 @@ void fs_wrapper_write_stream(struct fs_file *file)
 int fs_wrapper_write_stream_finish(struct fs_file *file, bool success)
 {
        if (!success) {
-               fs_write_stream_abort_parent(file->parent, &file->output);
+               fs_write_stream_abort_parent(file, &file->output);
                return -1;
        }
 

diff --git a/src/plugins/fs-compress/fs-compress.c b/src/plugins/fs-compress/fs-compress.c
index d8fbcd8b6e97528c856cb8e65e39956b10b21274..8f7654224ff907d11563d37d431cda1a43778c59 100644 (file)
--- a/src/plugins/fs-compress/fs-compress.c
+++ b/src/plugins/fs-compress/fs-compress.c
@@ -201,7 +201,7 @@ static int fs_compress_write_stream_finish(struct fs_file *_file, bool success)
                if (file->temp_output != NULL)
                        o_stream_destroy(&file->temp_output);
                if (file->super_output != NULL)
-                       fs_write_stream_abort_parent(_file->parent, &file->super_output);
+                       fs_write_stream_abort_parent(_file, &file->super_output);
                return -1;
        }