Merge commit '22f4d9c303ede1a240538fd105c97047db40dc86'
authorHendrik Leppkes <h.leppkes@gmail.com>
Tue, 27 Oct 2015 11:50:56 +0000 (12:50 +0100)
committerHendrik Leppkes <h.leppkes@gmail.com>
Tue, 27 Oct 2015 11:50:56 +0000 (12:50 +0100)
* commit '22f4d9c303ede1a240538fd105c97047db40dc86':
  img2enc: Make sure the images are atomically written

Merged-by: Hendrik Leppkes <h.leppkes@gmail.com>
libavformat/img2enc.c

index 48454fe1d205984e67099bddb28ec09f9e85e850..efc9304fe0a04b8ebeca3e28fc3ea17c9426ac9f 100644 (file)
@@ -38,6 +38,7 @@ typedef struct VideoMuxData {
     int is_pipe;
     int split_planes;       /**< use independent file for each Y, U, V plane */
     char path[1024];
+    char tmp[1024];
     int update;
     int use_strftime;
     const char *muxer;
@@ -50,6 +51,7 @@ static int write_header(AVFormatContext *s)
     const AVPixFmtDescriptor *desc = av_pix_fmt_desc_get(st->codec->pix_fmt);
 
     av_strlcpy(img->path, s->filename, sizeof(img->path));
+    snprintf(img->tmp, sizeof(img->tmp), "%s.tmp", s->filename);
 
     /* find format */
     if (s->oformat->flags & AVFMT_NOFILE)
@@ -100,9 +102,9 @@ static int write_packet(AVFormatContext *s, AVPacket *pkt)
             return AVERROR(EINVAL);
         }
         for (i = 0; i < 4; i++) {
-            if (avio_open2(&pb[i], filename, AVIO_FLAG_WRITE,
+            if (avio_open2(&pb[i], img->tmp, AVIO_FLAG_WRITE,
                            &s->interrupt_callback, NULL) < 0) {
-                av_log(s, AV_LOG_ERROR, "Could not open file : %s\n", filename);
+                av_log(s, AV_LOG_ERROR, "Could not open file : %s\n", img->tmp);
                 return AVERROR(EIO);
             }
 
@@ -167,6 +169,7 @@ static int write_packet(AVFormatContext *s, AVPacket *pkt)
     avio_flush(pb[0]);
     if (!img->is_pipe) {
         avio_closep(&pb[0]);
+        ff_rename(img->tmp, filename, s);
     }
 
     img->img_number++;