diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/basic/iovec-wrapper.h | 4 | ||||
| -rw-r--r-- | src/shared/journal-importer.c | 4 |
2 files changed, 6 insertions, 2 deletions
diff --git a/src/basic/iovec-wrapper.h b/src/basic/iovec-wrapper.h index 0c6d760a73..4754b98fbb 100644 --- a/src/basic/iovec-wrapper.h +++ b/src/basic/iovec-wrapper.h @@ -23,6 +23,10 @@ static inline void iovw_done_free(struct iovec_wrapper *iovw) { iovw_free_contents(iovw, true); } +static inline void iovw_done(struct iovec_wrapper *iovw) { + iovw_free_contents(iovw, false); +} + int iovw_put(struct iovec_wrapper *iovw, void *data, size_t len); static inline int iovw_consume(struct iovec_wrapper *iovw, void *data, size_t len) { /* Move data into iovw or free on error */ diff --git a/src/shared/journal-importer.c b/src/shared/journal-importer.c index 4dc0b8f662..9264638303 100644 --- a/src/shared/journal-importer.c +++ b/src/shared/journal-importer.c @@ -33,7 +33,7 @@ void journal_importer_cleanup(JournalImporter *imp) { free(imp->name); free(imp->buf); - iovw_free_contents(&imp->iovw, false); + iovw_done(&imp->iovw); } static char* realloc_buffer(JournalImporter *imp, size_t size) { @@ -452,7 +452,7 @@ void journal_importer_drop_iovw(JournalImporter *imp) { /* This function drops processed data that along with the iovw that points at it */ - iovw_free_contents(&imp->iovw, false); + iovw_done(&imp->iovw); /* possibly reset buffer position */ remain = imp->filled - imp->offset; |