Merge branch '2.0release' into develop

@@ -754,6 +754,7 @@ vhost hooks.callback.srs.com {
         #           "client_id": 1985,
         #           "ip": "192.168.1.10", "vhost": "video.test.com", "app": "live",
         #           "stream": "livestream",
+        #           "duration": 9.36, // in seconds
         #           "cwd": "/usr/local/srs",
         #           "file": "./objs/nginx/html/live/livestream.1420254068776-100.ts",
         #           "seq_no": 100

@@ -97,6 +97,13 @@
 		3C689F9F1AB6AAC800C9CEEE /* sched.c in Sources */ = {isa = PBXBuildFile; fileRef = 3C689F9B1AB6AAC800C9CEEE /* sched.c */; };
 		3C689FA01AB6AAC800C9CEEE /* stk.c in Sources */ = {isa = PBXBuildFile; fileRef = 3C689F9C1AB6AAC800C9CEEE /* stk.c */; };
 		3C689FA11AB6AAC800C9CEEE /* sync.c in Sources */ = {isa = PBXBuildFile; fileRef = 3C689F9D1AB6AAC800C9CEEE /* sync.c */; };
+		3CC52DD81ACE4023006FEB01 /* srs_utest_amf0.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3CC52DCA1ACE4023006FEB01 /* srs_utest_amf0.cpp */; };
+		3CC52DD91ACE4023006FEB01 /* srs_utest_config.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3CC52DCC1ACE4023006FEB01 /* srs_utest_config.cpp */; };
+		3CC52DDA1ACE4023006FEB01 /* srs_utest_core.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3CC52DCE1ACE4023006FEB01 /* srs_utest_core.cpp */; };
+		3CC52DDB1ACE4023006FEB01 /* srs_utest_kernel.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3CC52DD01ACE4023006FEB01 /* srs_utest_kernel.cpp */; };
+		3CC52DDC1ACE4023006FEB01 /* srs_utest_protocol.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3CC52DD21ACE4023006FEB01 /* srs_utest_protocol.cpp */; };
+		3CC52DDD1ACE4023006FEB01 /* srs_utest_reload.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3CC52DD41ACE4023006FEB01 /* srs_utest_reload.cpp */; };
+		3CC52DDE1ACE4023006FEB01 /* srs_utest.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3CC52DD61ACE4023006FEB01 /* srs_utest.cpp */; };
 		3CD88B3F1ACA9C58000359E0 /* srs_app_async_call.cpp in Sources */ = {isa = PBXBuildFile; fileRef = 3CD88B3D1ACA9C58000359E0 /* srs_app_async_call.cpp */; };
 /* End PBXBuildFile section */
 
@@ -338,6 +345,20 @@
 		3C689F9B1AB6AAC800C9CEEE /* sched.c */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.c; name = sched.c; path = "../../objs/st-1.9/sched.c"; sourceTree = "<group>"; };
 		3C689F9C1AB6AAC800C9CEEE /* stk.c */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.c; name = stk.c; path = "../../objs/st-1.9/stk.c"; sourceTree = "<group>"; };
 		3C689F9D1AB6AAC800C9CEEE /* sync.c */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.c; name = sync.c; path = "../../objs/st-1.9/sync.c"; sourceTree = "<group>"; };
+		3CC52DCA1ACE4023006FEB01 /* srs_utest_amf0.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = srs_utest_amf0.cpp; path = ../../src/utest/srs_utest_amf0.cpp; sourceTree = "<group>"; };
+		3CC52DCB1ACE4023006FEB01 /* srs_utest_amf0.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = srs_utest_amf0.hpp; path = ../../src/utest/srs_utest_amf0.hpp; sourceTree = "<group>"; };
+		3CC52DCC1ACE4023006FEB01 /* srs_utest_config.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = srs_utest_config.cpp; path = ../../src/utest/srs_utest_config.cpp; sourceTree = "<group>"; };
+		3CC52DCD1ACE4023006FEB01 /* srs_utest_config.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = srs_utest_config.hpp; path = ../../src/utest/srs_utest_config.hpp; sourceTree = "<group>"; };
+		3CC52DCE1ACE4023006FEB01 /* srs_utest_core.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = srs_utest_core.cpp; path = ../../src/utest/srs_utest_core.cpp; sourceTree = "<group>"; };
+		3CC52DCF1ACE4023006FEB01 /* srs_utest_core.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = srs_utest_core.hpp; path = ../../src/utest/srs_utest_core.hpp; sourceTree = "<group>"; };
+		3CC52DD01ACE4023006FEB01 /* srs_utest_kernel.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = srs_utest_kernel.cpp; path = ../../src/utest/srs_utest_kernel.cpp; sourceTree = "<group>"; };
+		3CC52DD11ACE4023006FEB01 /* srs_utest_kernel.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = srs_utest_kernel.hpp; path = ../../src/utest/srs_utest_kernel.hpp; sourceTree = "<group>"; };
+		3CC52DD21ACE4023006FEB01 /* srs_utest_protocol.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = srs_utest_protocol.cpp; path = ../../src/utest/srs_utest_protocol.cpp; sourceTree = "<group>"; };
+		3CC52DD31ACE4023006FEB01 /* srs_utest_protocol.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = srs_utest_protocol.hpp; path = ../../src/utest/srs_utest_protocol.hpp; sourceTree = "<group>"; };
+		3CC52DD41ACE4023006FEB01 /* srs_utest_reload.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = srs_utest_reload.cpp; path = ../../src/utest/srs_utest_reload.cpp; sourceTree = "<group>"; };
+		3CC52DD51ACE4023006FEB01 /* srs_utest_reload.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = srs_utest_reload.hpp; path = ../../src/utest/srs_utest_reload.hpp; sourceTree = "<group>"; };
+		3CC52DD61ACE4023006FEB01 /* srs_utest.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = srs_utest.cpp; path = ../../src/utest/srs_utest.cpp; sourceTree = "<group>"; };
+		3CC52DD71ACE4023006FEB01 /* srs_utest.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = srs_utest.hpp; path = ../../src/utest/srs_utest.hpp; sourceTree = "<group>"; };
 		3CD88B3D1ACA9C58000359E0 /* srs_app_async_call.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = srs_app_async_call.cpp; path = ../../../src/app/srs_app_async_call.cpp; sourceTree = "<group>"; };
 		3CD88B3E1ACA9C58000359E0 /* srs_app_async_call.hpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.h; name = srs_app_async_call.hpp; path = ../../../src/app/srs_app_async_call.hpp; sourceTree = "<group>"; };
 /* End PBXFileReference section */
@@ -365,6 +386,7 @@
 				3C1231E61AAE64A400CE8F6C /* Products */,
 				3C1232EE1AAEA71C00CE8F6C /* links */,
 				3C1231E71AAE64A400CE8F6C /* srs_xcode */,
+				3CC52DC91ACE4006006FEB01 /* utest */,
 				3C663F001AB014B500286D8B /* research */,
 			);
 			sourceTree = "<group>";
@@ -735,6 +757,27 @@
 			name = "st-1.9";
 			sourceTree = "<group>";
 		};
+		3CC52DC91ACE4006006FEB01 /* utest */ = {
+			isa = PBXGroup;
+			children = (
+				3CC52DCA1ACE4023006FEB01 /* srs_utest_amf0.cpp */,
+				3CC52DCB1ACE4023006FEB01 /* srs_utest_amf0.hpp */,
+				3CC52DCC1ACE4023006FEB01 /* srs_utest_config.cpp */,
+				3CC52DCD1ACE4023006FEB01 /* srs_utest_config.hpp */,
+				3CC52DCE1ACE4023006FEB01 /* srs_utest_core.cpp */,
+				3CC52DCF1ACE4023006FEB01 /* srs_utest_core.hpp */,
+				3CC52DD01ACE4023006FEB01 /* srs_utest_kernel.cpp */,
+				3CC52DD11ACE4023006FEB01 /* srs_utest_kernel.hpp */,
+				3CC52DD21ACE4023006FEB01 /* srs_utest_protocol.cpp */,
+				3CC52DD31ACE4023006FEB01 /* srs_utest_protocol.hpp */,
+				3CC52DD41ACE4023006FEB01 /* srs_utest_reload.cpp */,
+				3CC52DD51ACE4023006FEB01 /* srs_utest_reload.hpp */,
+				3CC52DD61ACE4023006FEB01 /* srs_utest.cpp */,
+				3CC52DD71ACE4023006FEB01 /* srs_utest.hpp */,
+			);
+			name = utest;
+			sourceTree = "<group>";
+		};
 /* End PBXGroup section */
 
 /* Begin PBXNativeTarget section */
@@ -798,6 +841,7 @@
 				3C1232961AAE81D900CE8F6C /* srs_app_conn.cpp in Sources */,
 				3C12322A1AAE814D00CE8F6C /* srs_kernel_ts.cpp in Sources */,
 				3C12329E1AAE81D900CE8F6C /* srs_app_hls.cpp in Sources */,
+				3CC52DD91ACE4023006FEB01 /* srs_utest_config.cpp in Sources */,
 				3C663F171AB0155100286D8B /* srs_ingest_rtmp.c in Sources */,
 				3C663F131AB0155100286D8B /* srs_flv_injecter.c in Sources */,
 				3C1232971AAE81D900CE8F6C /* srs_app_dvr.cpp in Sources */,
@@ -816,15 +860,18 @@
 				3C1EE6AE1AB1055800576EE9 /* srs_app_hds.cpp in Sources */,
 				3C663F101AB0155100286D8B /* srs_audio_raw_publish.c in Sources */,
 				3C663F111AB0155100286D8B /* srs_bandwidth_check.c in Sources */,
+				3CC52DDE1ACE4023006FEB01 /* srs_utest.cpp in Sources */,
 				3C1232A11AAE81D900CE8F6C /* srs_app_http_conn.cpp in Sources */,
 				3C1232AC1AAE81D900CE8F6C /* srs_app_refer.cpp in Sources */,
 				3C1232991AAE81D900CE8F6C /* srs_app_empty.cpp in Sources */,
+				3CC52DDA1ACE4023006FEB01 /* srs_utest_core.cpp in Sources */,
 				3C36DB5C1ABD1CB90066CCAF /* srs_lib_simple_socket.cpp in Sources */,
 				3C1232201AAE814D00CE8F6C /* srs_kernel_aac.cpp in Sources */,
 				3C1232941AAE81D900CE8F6C /* srs_app_bandwidth.cpp in Sources */,
 				3C1232221AAE814D00CE8F6C /* srs_kernel_codec.cpp in Sources */,
 				3C1232B71AAE81D900CE8F6C /* srs_app_utility.cpp in Sources */,
 				3C1232AB1AAE81D900CE8F6C /* srs_app_recv_thread.cpp in Sources */,
+				3CC52DDC1ACE4023006FEB01 /* srs_utest_protocol.cpp in Sources */,
 				3C663F151AB0155100286D8B /* srs_h264_raw_publish.c in Sources */,
 				3C1231F61AAE652D00CE8F6C /* srs_core_autofree.cpp in Sources */,
 				3C1EE6D71AB1367D00576EE9 /* README.md in Sources */,
@@ -849,7 +896,9 @@
 				3C1232281AAE814D00CE8F6C /* srs_kernel_mp3.cpp in Sources */,
 				3C1232B21AAE81D900CE8F6C /* srs_app_source.cpp in Sources */,
 				3C1231F71AAE652D00CE8F6C /* srs_core_performance.cpp in Sources */,
+				3CC52DD81ACE4023006FEB01 /* srs_utest_amf0.cpp in Sources */,
 				3C1232981AAE81D900CE8F6C /* srs_app_edge.cpp in Sources */,
+				3CC52DDB1ACE4023006FEB01 /* srs_utest_kernel.cpp in Sources */,
 				3C689F9E1AB6AAC800C9CEEE /* md.S in Sources */,
 				3C1232461AAE81A400CE8F6C /* srs_rtmp_msg_array.cpp in Sources */,
 				3C1232A71AAE81D900CE8F6C /* srs_app_listener.cpp in Sources */,
@@ -875,6 +924,7 @@
 				3C12329D1AAE81D900CE8F6C /* srs_app_heartbeat.cpp in Sources */,
 				3C1232231AAE814D00CE8F6C /* srs_kernel_consts.cpp in Sources */,
 				3C1232AF1AAE81D900CE8F6C /* srs_app_rtsp.cpp in Sources */,
+				3CC52DDD1ACE4023006FEB01 /* srs_utest_reload.cpp in Sources */,
 				3C689FA11AB6AAC800C9CEEE /* sync.c in Sources */,
 				3C1232A31AAE81D900CE8F6C /* srs_app_http.cpp in Sources */,
 				3C12329A1AAE81D900CE8F6C /* srs_app_encoder.cpp in Sources */,

@@ -328,8 +328,11 @@ class RESTHls(object):
               {
                   "action": "on_dvr",
                   "client_id": 1985,
-                  "ip": "192.168.1.10", "vhost": "video.test.com", "app": "live",
+                  "ip": "192.168.1.10", 
+                  "vhost": "video.test.com", 
+                  "app": "live",
                   "stream": "livestream",
+                  "duration": 9.68, // in seconds
                   "cwd": "/usr/local/srs",
                   "file": "./objs/nginx/html/live/livestream.1420254068776-100.ts",
                   "seq_no": 100
@@ -368,8 +371,8 @@ class RESTHls(object):
     def __on_hls(self, req):
         code = Error.success
 
-        trace("srs %s: client id=%s, ip=%s, vhost=%s, app=%s, stream=%s, cwd=%s, file=%s, seq_no=%s"%(
-            req["action"], req["client_id"], req["ip"], req["vhost"], req["app"], req["stream"],
+        trace("srs %s: client id=%s, ip=%s, vhost=%s, app=%s, stream=%s, duration=%s, cwd=%s, file=%s, seq_no=%s"%(
+            req["action"], req["client_id"], req["ip"], req["vhost"], req["app"], req["stream"], req["duration"],
             req["cwd"], req["file"], req["seq_no"]
         ))
 

@@ -3414,7 +3414,7 @@ bool SrsConfig::get_hls_cleanup(string vhost)
     
     SrsConfDirective* conf = hls->get("hls_cleanup");
     
-    if (!conf && conf->arg0() != "off") {
+    if (conf && conf->arg0() != "off") {
         return SRS_CONF_DEFAULT_HLS_CLEANUP;
     }
     

@@ -170,11 +170,12 @@ void SrsHlsSegment::update_duration(int64_t current_frame_dts)
     return;
 }
 
-SrsDvrAsyncCallOnHls::SrsDvrAsyncCallOnHls(SrsRequest* r, string p, int s)
+SrsDvrAsyncCallOnHls::SrsDvrAsyncCallOnHls(SrsRequest* r, string p, int s, double d)
 {
     req = r;
     path = p;
     seq_no = s;
+    duration = d;
 }
 
 SrsDvrAsyncCallOnHls::~SrsDvrAsyncCallOnHls()
@@ -199,7 +200,7 @@ int SrsDvrAsyncCallOnHls::call()
         int sn = seq_no;
         for (int i = 0; i < (int)on_hls->args.size(); i++) {
             std::string url = on_hls->args.at(i);
-            if ((ret = SrsHttpHooks::on_hls(url, req, file, sn)) != ERROR_SUCCESS) {
+            if ((ret = SrsHttpHooks::on_hls(url, req, file, sn, duration)) != ERROR_SUCCESS) {
                 srs_error("hook client on_hls failed. url=%s, ret=%d", url.c_str(), ret);
                 return ret;
             }
@@ -581,7 +582,7 @@ int SrsHlsMuxer::segment_close(string log_desc)
         }
         
         // use async to call the http hooks, for it will cause thread switch.
-        if ((ret = async->call(new SrsDvrAsyncCallOnHls(req, current->full_path, current->sequence_no))) != ERROR_SUCCESS) {
+        if ((ret = async->call(new SrsDvrAsyncCallOnHls(req, current->full_path, current->sequence_no, current->duration))) != ERROR_SUCCESS) {
             return ret;
         }
     

@@ -164,8 +164,9 @@ private:
     std::string path;
     int seq_no;
     SrsRequest* req;
+    double duration;
 public:
-    SrsDvrAsyncCallOnHls(SrsRequest* r, std::string p, int s);
+    SrsDvrAsyncCallOnHls(SrsRequest* r, std::string p, int s, double d);
     virtual ~SrsDvrAsyncCallOnHls();
 public:
     virtual int call();

@@ -287,7 +287,7 @@ int SrsHttpHooks::on_dvr(string url, SrsRequest* req, string file)
     return ret;
 }
 
-int SrsHttpHooks::on_hls(string url, SrsRequest* req, string file, int sn)
+int SrsHttpHooks::on_hls(string url, SrsRequest* req, string file, int sn, double duration)
 {
     int ret = ERROR_SUCCESS;
     
@@ -302,6 +302,7 @@ int SrsHttpHooks::on_hls(string url, SrsRequest* req, string file, int sn)
         << SRS_JFIELD_STR("vhost", req->vhost) << SRS_JFIELD_CONT
         << SRS_JFIELD_STR("app", req->app) << SRS_JFIELD_CONT
         << SRS_JFIELD_STR("stream", req->stream) << SRS_JFIELD_CONT
+        << SRS_JFIELD_ORG("duration", duration) << SRS_JFIELD_CONT
         << SRS_JFIELD_STR("cwd", cwd) << SRS_JFIELD_CONT
         << SRS_JFIELD_STR("file", file) << SRS_JFIELD_CONT
         << SRS_JFIELD_ORG("seq_no", sn)

@@ -102,8 +102,9 @@ public:
     *         ignore if empty.
     * @param file the ts file path, can be relative or absolute path.
     * @param sn the seq_no, the sequence number of ts in hls/m3u8.
+    * @param duration the segment duration in seconds.
     */
-    static int on_hls(std::string url, SrsRequest* req, std::string file, int sn);
+    static int on_hls(std::string url, SrsRequest* req, std::string file, int sn, double duration);
 private:
     static int do_post(std::string url, std::string req, int& code, std::string& res);
 };

@@ -348,10 +348,6 @@ int SrsMpegtsOverUdp::on_ts_video(SrsTsMessage* msg, SrsStream* avs)
     u_int32_t dts = msg->dts / 90; 
     u_int32_t pts = msg->dts / 90;
     
-    // the whole ts pes video packet must be a flv frame packet.
-    char* ibpframe = avs->data() + avs->pos();
-    int ibpframe_size = avs->size() - avs->pos();
-    
     // send each frame.
     while (!avs->empty()) {
         char* frame = NULL;
@@ -388,8 +384,6 @@ int SrsMpegtsOverUdp::on_ts_video(SrsTsMessage* msg, SrsStream* avs)
 
         // for pps
         if (avc->is_pps(frame, frame_size)) {
-            got_sps_pps = true;
-            
             std::string pps;
             if ((ret = avc->pps_demux(frame, frame_size, pps)) != ERROR_SUCCESS) {
                 return ret;

@@ -1019,7 +1019,8 @@ int SrsServer::listen_stream_caster()
             return ret;
         }
         
-        if ((ret = listener->listen(port)) != ERROR_SUCCESS) {
+        // TODO: support listen at <[ip:]port>
+        if ((ret = listener->listen("0.0.0.0", port)) != ERROR_SUCCESS) {
             srs_error("StreamCaster listen at port %d failed. ret=%d", port, ret);
             return ret;
         }

@@ -1356,7 +1356,7 @@ VOID TEST(ConfigMainTest, ParseMinConf)
     MockSrsConfig conf;
     EXPECT_TRUE(ERROR_SUCCESS == conf.parse(_MIN_OK_CONF));
     
-    vector<string> listens = conf.get_listen();
+    vector<string> listens = conf.get_listens();
     EXPECT_EQ(1, (int)listens.size());
     EXPECT_STREQ("1935", listens.at(0).c_str());
 }
@@ -1379,7 +1379,7 @@ VOID TEST(ConfigMainTest, ParseFullConf)
     MockSrsConfig conf;
     EXPECT_TRUE(ERROR_SUCCESS == conf.parse(_full_conf));
     
-    vector<string> listens = conf.get_listen();
+    vector<string> listens = conf.get_listens();
     EXPECT_EQ(1, (int)listens.size());
     EXPECT_STREQ("1935", listens.at(0).c_str());
     
@@ -1403,10 +1403,10 @@ VOID TEST(ConfigMainTest, ParseFullConf)
     EXPECT_EQ(4, (int)conf.get_stats_disk_device()->args.size());
     
     EXPECT_TRUE(conf.get_http_api_enabled());
-    EXPECT_EQ(1985, conf.get_http_api_listen());
+    EXPECT_STREQ("1985", conf.get_http_api_listen().c_str());
     
     EXPECT_TRUE(conf.get_http_stream_enabled());
-    EXPECT_EQ(8080, conf.get_http_stream_listen());
+    EXPECT_STREQ("8080", conf.get_http_stream_listen().c_str());
     EXPECT_STREQ("./objs/nginx/html", conf.get_http_stream_dir().c_str());
     
     EXPECT_EQ(10000, conf.get_pithy_print_ms());