Skip to content
This repository was archived by the owner on Nov 8, 2023. It is now read-only.

Commit 28ddf1e

Browse files
committed
clean up tx handle when file write failed, #67
1 parent eb8b135 commit 28ddf1e

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/file.rs

+3
Original file line numberDiff line numberDiff line change
@@ -600,7 +600,10 @@ impl Write for File {
600600
None => unreachable!(),
601601
}
602602
.or_else(|err| {
603+
// when write failed the tx has been aborted, so we need to clean up
604+
// writer and tx handle here
603605
self.wtr.take();
606+
self.tx_handle.take();
604607
Err(err)
605608
}))
606609
}

0 commit comments

Comments
 (0)