refine code remove dup api for #742

@@ -43,6 +43,7 @@ using namespace std;
 #include <srs_protocol_amf0.hpp>
 #include <srs_protocol_amf0.hpp>
 #include <srs_kernel_utility.hpp>
 #include <srs_kernel_utility.hpp>
 #include <srs_app_rtmp_conn.hpp>
 #include <srs_app_rtmp_conn.hpp>
+#include <srs_protocol_utility.hpp>
 
 
 #define SRS_HTTP_FLV_STREAM_BUFFER 4096
 #define SRS_HTTP_FLV_STREAM_BUFFER 4096
 
 
@@ -216,7 +217,7 @@ int SrsDynamicHttpConn::do_proxy(ISrsHttpResponseReader* rr, SrsFlvDecoder* dec)
         }
         }
         
         
         SrsSharedPtrMessage* msg = NULL;
         SrsSharedPtrMessage* msg = NULL;
-        if ((ret = sdk->rtmp_create_msg(type, time, data, size, &msg)) != ERROR_SUCCESS) {
+        if ((ret = srs_rtmp_create_msg(type, time, data, size, sdk->sid(), &msg)) != ERROR_SUCCESS) {
             return ret;
             return ret;
         }
         }
         
         

@@ -50,6 +50,7 @@ using namespace std;
 #include <srs_raw_avc.hpp>
 #include <srs_raw_avc.hpp>
 #include <srs_app_pithy_print.hpp>
 #include <srs_app_pithy_print.hpp>
 #include <srs_app_rtmp_conn.hpp>
 #include <srs_app_rtmp_conn.hpp>
+#include <srs_protocol_utility.hpp>
 
 
 SrsMpegtsQueue::SrsMpegtsQueue()
 SrsMpegtsQueue::SrsMpegtsQueue()
 {
 {
@@ -571,7 +572,7 @@ int SrsMpegtsOverUdp::rtmp_write_packet(char type, u_int32_t timestamp, char* da
     
     
     SrsSharedPtrMessage* msg = NULL;
     SrsSharedPtrMessage* msg = NULL;
     
     
-    if ((ret = sdk->rtmp_create_msg(type, timestamp, data, size, &msg)) != ERROR_SUCCESS) {
+    if ((ret = srs_rtmp_create_msg(type, timestamp, data, size, sdk->sid(), &msg)) != ERROR_SUCCESS) {
         srs_error("mpegts: create shared ptr msg failed. ret=%d", ret);
         srs_error("mpegts: create shared ptr msg failed. ret=%d", ret);
         return ret;
         return ret;
     }
     }

@@ -270,20 +270,6 @@ int SrsSimpleRtmpClient::sid()
     return stream_id;
     return stream_id;
 }
 }
 
 
-int SrsSimpleRtmpClient::rtmp_create_msg(char type, u_int32_t timestamp, char* data, int size, SrsSharedPtrMessage** pmsg)
-{
-    *pmsg = NULL;
-    
-    int ret = ERROR_SUCCESS;
-    
-    if ((ret = srs_rtmp_create_msg(type, timestamp, data, size, stream_id, pmsg)) != ERROR_SUCCESS) {
-        srs_error("sdk: create shared ptr msg failed. ret=%d", ret);
-        return ret;
-    }
-    
-    return ret;
-}
-
 int SrsSimpleRtmpClient::recv_message(SrsCommonMessage** pmsg)
 int SrsSimpleRtmpClient::recv_message(SrsCommonMessage** pmsg)
 {
 {
     return client->recv_message(pmsg);
     return client->recv_message(pmsg);

@@ -90,8 +90,6 @@ public:
     virtual void kbps_sample(const char* label, int64_t age, int msgs);
     virtual void kbps_sample(const char* label, int64_t age, int msgs);
     virtual int sid();
     virtual int sid();
 public:
 public:
-    virtual int rtmp_create_msg(char type, u_int32_t timestamp, char* data, int size, SrsSharedPtrMessage** pmsg);
-public:
     virtual int recv_message(SrsCommonMessage** pmsg);
     virtual int recv_message(SrsCommonMessage** pmsg);
     virtual int decode_message(SrsCommonMessage* msg, SrsPacket** ppacket);
     virtual int decode_message(SrsCommonMessage* msg, SrsPacket** ppacket);
     virtual int send_and_free_messages(SrsSharedPtrMessage** msgs, int nb_msgs);
     virtual int send_and_free_messages(SrsSharedPtrMessage** msgs, int nb_msgs);

@@ -43,6 +43,7 @@ using namespace std;
 #include <srs_kernel_codec.hpp>
 #include <srs_kernel_codec.hpp>
 #include <srs_app_pithy_print.hpp>
 #include <srs_app_pithy_print.hpp>
 #include <srs_app_rtmp_conn.hpp>
 #include <srs_app_rtmp_conn.hpp>
+#include <srs_protocol_utility.hpp>
 
 
 #ifdef SRS_AUTO_STREAM_CASTER
 #ifdef SRS_AUTO_STREAM_CASTER
 
 
@@ -624,7 +625,7 @@ int SrsRtspConn::rtmp_write_packet(char type, u_int32_t timestamp, char* data, i
     
     
     SrsSharedPtrMessage* msg = NULL;
     SrsSharedPtrMessage* msg = NULL;
 
 
-    if ((ret = sdk->rtmp_create_msg(type, timestamp, data, size, &msg)) != ERROR_SUCCESS) {
+    if ((ret = srs_rtmp_create_msg(type, timestamp, data, size, sdk->sid(), &msg)) != ERROR_SUCCESS) {
         srs_error("rtsp: create shared ptr msg failed. ret=%d", ret);
         srs_error("rtsp: create shared ptr msg failed. ret=%d", ret);
         return ret;
         return ret;
     }
     }

@@ -48,6 +48,7 @@ using namespace std;
 #include <srs_raw_avc.hpp>
 #include <srs_raw_avc.hpp>
 #include <srs_app_http_conn.hpp>
 #include <srs_app_http_conn.hpp>
 #include <srs_app_rtmp_conn.hpp>
 #include <srs_app_rtmp_conn.hpp>
+#include <srs_protocol_utility.hpp>
 
 
 // pre-declare
 // pre-declare
 int proxy_hls2rtmp(std::string hls, std::string rtmp);
 int proxy_hls2rtmp(std::string hls, std::string rtmp);
@@ -1185,7 +1186,7 @@ int SrsIngestSrsOutput::rtmp_write_packet(char type, u_int32_t timestamp, char*
     
     
     SrsSharedPtrMessage* msg = NULL;
     SrsSharedPtrMessage* msg = NULL;
     
     
-    if ((ret = sdk->rtmp_create_msg(type, timestamp, data, size, &msg)) != ERROR_SUCCESS) {
+    if ((ret = srs_rtmp_create_msg(type, timestamp, data, size, sdk->sid(), &msg)) != ERROR_SUCCESS) {
         srs_error("mpegts: create shared ptr msg failed. ret=%d", ret);
         srs_error("mpegts: create shared ptr msg failed. ret=%d", ret);
         return ret;
         return ret;
     }
     }