refine dvr, append file when dvr file exists. 2.0.122.

@@ -530,7 +530,8 @@ Supported operating systems and hardware:
 
 
 ### SRS 2.0 history
 ### SRS 2.0 history
 
 
-* v2.0, 2015-02-19, refine pithy print to more easyer to use 2.0.121.
+* v2.0, 2015-02-19, refine dvr, append file when dvr file exists. 2.0.122.
+* v2.0, 2015-02-19, refine pithy print to more easyer to use. 2.0.121.
 * v2.0, 2015-02-18, fix [#133](https://github.com/winlinvip/simple-rtmp-server/issues/133), support push rtsp to srs. 2.0.120.
 * v2.0, 2015-02-18, fix [#133](https://github.com/winlinvip/simple-rtmp-server/issues/133), support push rtsp to srs. 2.0.120.
 * v2.0, 2015-02-17, the join maybe failed, should use a variable to ensure thread terminated. 2.0.119.
 * v2.0, 2015-02-17, the join maybe failed, should use a variable to ensure thread terminated. 2.0.119.
 * v2.0, 2015-02-15, for [#304](https://github.com/winlinvip/simple-rtmp-server/issues/304), support config default acodec/vcodec. 2.0.118.
 * v2.0, 2015-02-15, for [#304](https://github.com/winlinvip/simple-rtmp-server/issues/304), support config default acodec/vcodec. 2.0.118.

@@ -1227,4 +1227,5 @@ vhost removed.srs.com {
 # config for the pithy print,
 # config for the pithy print,
 # which always print constant message specified by interval,
 # which always print constant message specified by interval,
 # whatever the clients in concurrency.
 # whatever the clients in concurrency.
+# default: 10000
 pithy_print_ms      10000;
 pithy_print_ms      10000;

@@ -369,11 +369,27 @@ int SrsDvrPlan::flv_open(string stream, string path)
     
     
     segment->reset();
     segment->reset();
 
 
-    std::string tmp_file = path + ".tmp";
-    if ((ret = fs->open(tmp_file)) != ERROR_SUCCESS) {
+    if (srs_path_exists(path)) {
+        // when path exists, always append to it.
+        // so we must use the target flv path as output flv.
+        tmp_flv_file = path;
+    } else {
+        // when path not exists, dvr to tmp file.
+        tmp_flv_file = path + ".tmp";
+    }
+    
+    if (srs_path_exists(path)) {
+        if ((ret = fs->open_append(tmp_flv_file)) != ERROR_SUCCESS) {
+            srs_error("append file stream for file %s failed. ret=%d", path.c_str(), ret);
+            return ret;
+        }
+        srs_warn("dvr: always append to when exists, file=%s.", path.c_str());
+    } else {
+        if ((ret = fs->open(tmp_flv_file)) != ERROR_SUCCESS) {
             srs_error("open file stream for file %s failed. ret=%d", path.c_str(), ret);
             srs_error("open file stream for file %s failed. ret=%d", path.c_str(), ret);
             return ret;
             return ret;
         }
         }
+    }
     
     
     if ((ret = enc->initialize(fs)) != ERROR_SUCCESS) {
     if ((ret = enc->initialize(fs)) != ERROR_SUCCESS) {
         srs_error("initialize enc by fs for file %s failed. ret=%d", path.c_str(), ret);
         srs_error("initialize enc by fs for file %s failed. ret=%d", path.c_str(), ret);
@@ -396,13 +412,15 @@ int SrsDvrPlan::flv_close()
     
     
     fs->close();
     fs->close();
     
     
-    std::string tmp_file = segment->path + ".tmp";
-    if (rename(tmp_file.c_str(), segment->path.c_str()) < 0) {
+    // when tmp flv file exists, reap it.
+    if (tmp_flv_file != segment->path) {
+        if (rename(tmp_flv_file.c_str(), segment->path.c_str()) < 0) {
             ret = ERROR_SYSTEM_FILE_RENAME;
             ret = ERROR_SYSTEM_FILE_RENAME;
             srs_error("rename flv file failed, %s => %s. ret=%d", 
             srs_error("rename flv file failed, %s => %s. ret=%d", 
-            tmp_file.c_str(), segment->path.c_str(), ret);
+                tmp_flv_file.c_str(), segment->path.c_str(), ret);
             return ret;
             return ret;
         }
         }
+    }
     
     
 #ifdef SRS_AUTO_HTTP_CALLBACK
 #ifdef SRS_AUTO_HTTP_CALLBACK
     SrsRequest* req = _req;
     SrsRequest* req = _req;

@@ -111,6 +111,8 @@ protected:
     SrsRequest* _req;
     SrsRequest* _req;
     bool dvr_enabled;
     bool dvr_enabled;
     SrsFileWriter* fs;
     SrsFileWriter* fs;
+private:
+    std::string tmp_flv_file;
 public:
 public:
     SrsDvrPlan();
     SrsDvrPlan();
     virtual ~SrsDvrPlan();
     virtual ~SrsDvrPlan();

@@ -294,8 +294,7 @@ int SrsGoHttpFileServer::serve_http(ISrsGoHttpResponseWriter* w, SrsHttpMessage*
     }
     }
     
     
     // stat current dir, if exists, return error.
     // stat current dir, if exists, return error.
-    struct stat st;
-    if (stat(fullpath.c_str(), &st) != 0) {
+    if (!srs_path_exists(fullpath)) {
         srs_warn("http miss file=%s, pattern=%s, upath=%s", 
         srs_warn("http miss file=%s, pattern=%s, upath=%s", 
             fullpath.c_str(), entry->pattern.c_str(), upath.c_str());
             fullpath.c_str(), entry->pattern.c_str(), upath.c_str());
         return SrsGoHttpNotFoundHandler().serve_http(w, r);
         return SrsGoHttpNotFoundHandler().serve_http(w, r);

@@ -31,7 +31,7 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // current release version
 // current release version
 #define VERSION_MAJOR       2
 #define VERSION_MAJOR       2
 #define VERSION_MINOR       0
 #define VERSION_MINOR       0
-#define VERSION_REVISION    121
+#define VERSION_REVISION    122
 
 
 // server info.
 // server info.
 #define RTMP_SIG_SRS_KEY "SRS"
 #define RTMP_SIG_SRS_KEY "SRS"

@@ -69,6 +69,30 @@ int SrsFileWriter::open(string file)
     return ret;
     return ret;
 }
 }
 
 
+int SrsFileWriter::open_append(string file)
+{
+    int ret = ERROR_SUCCESS;
+    
+    if (fd > 0) {
+        ret = ERROR_SYSTEM_FILE_ALREADY_OPENED;
+        srs_error("file %s already opened. ret=%d", _file.c_str(), ret);
+        return ret;
+    }
+    
+    int flags = O_APPEND|O_WRONLY;
+    mode_t mode = S_IRUSR|S_IWUSR|S_IRGRP|S_IWGRP|S_IROTH;
+
+    if ((fd = ::open(file.c_str(), flags, mode)) < 0) {
+        ret = ERROR_SYSTEM_FILE_OPENE;
+        srs_error("open file %s failed. ret=%d", file.c_str(), ret);
+        return ret;
+    }
+    
+    _file = file;
+    
+    return ret;
+}
+
 void SrsFileWriter::close()
 void SrsFileWriter::close()
 {
 {
     int ret = ERROR_SUCCESS;
     int ret = ERROR_SUCCESS;

@@ -47,6 +47,10 @@ public:
     * open file writer, can open then close then open...
     * open file writer, can open then close then open...
     */
     */
     virtual int open(std::string file);
     virtual int open(std::string file);
+    /**
+    * open file writer in append mode.
+    */
+    virtual int open_append(std::string file);
     virtual void close();
     virtual void close();
 public:
 public:
     virtual bool is_open();
     virtual bool is_open();

@@ -230,10 +230,8 @@ int __srs_create_dir_recursively(string dir)
 {
 {
     int ret = ERROR_SUCCESS;
     int ret = ERROR_SUCCESS;
     
     
-    struct stat st;
-    
     // stat current dir, if exists, return error.
     // stat current dir, if exists, return error.
-    if (stat(dir.c_str(), &st) == 0) {
+    if (srs_path_exists(dir)) {
         return ERROR_SYSTEM_DIR_EXISTS;
         return ERROR_SYSTEM_DIR_EXISTS;
     }
     }
     
     
@@ -279,6 +277,18 @@ int srs_create_dir_recursively(string dir)
     return ret;
     return ret;
 }
 }
 
 
+bool srs_path_exists(std::string path)
+{
+    struct stat st;
+    
+    // stat current dir, if exists, return error.
+    if (stat(path.c_str(), &st) == 0) {
+        return true;
+    }
+
+    return false;
+}
+
 bool srs_avc_startswith_annexb(SrsStream* stream, int* pnb_start_code)
 bool srs_avc_startswith_annexb(SrsStream* stream, int* pnb_start_code)
 {
 {
     char* bytes = stream->data() + stream->pos();
     char* bytes = stream->data() + stream->pos();

@@ -64,6 +64,9 @@ extern bool srs_string_ends_with(std::string str, std::string flag);
 // create dir recursively
 // create dir recursively
 extern int srs_create_dir_recursively(std::string dir);
 extern int srs_create_dir_recursively(std::string dir);
 
 
+// whether path exists.
+extern bool srs_path_exists(std::string path);
+
 /**
 /**
 * whether stream starts with the avc NALU in "AnnexB" 
 * whether stream starts with the avc NALU in "AnnexB" 
 * from H.264-AVC-ISO_IEC_14496-10.pdf, page 211.
 * from H.264-AVC-ISO_IEC_14496-10.pdf, page 211.