refine the http code.

@@ -752,7 +752,7 @@ int SrsHlsMuxer::segment_close(string log_desc)
         if (should_write_file) {
         if (should_write_file) {
             unlink(tmp_file.c_str());
             unlink(tmp_file.c_str());
             if (unlink(tmp_file.c_str()) < 0) {
             if (unlink(tmp_file.c_str()) < 0) {
-                srs_warn("drop unlink path failed, file=%s.", tmp_file.c_str());
+                srs_warn("ignore unlink path failed, file=%s.", tmp_file.c_str());
             }
             }
         }
         }
         
         

@@ -1204,25 +1204,27 @@ int SrsHttpConn::process_request(ISrsHttpResponseWriter* w, ISrsHttpMessage* r)
     return ret;
     return ret;
 }
 }
 
 
-SrsStaticHttpConn::SrsStaticHttpConn(IConnectionManager* cm, st_netfd_t fd, ISrsHttpServeMux* m)
+SrsResponseOnlyHttpConn::SrsResponseOnlyHttpConn(IConnectionManager* cm, st_netfd_t fd, ISrsHttpServeMux* m)
     : SrsHttpConn(cm, fd, m)
     : SrsHttpConn(cm, fd, m)
 {
 {
 }
 }
 
 
-SrsStaticHttpConn::~SrsStaticHttpConn()
+SrsResponseOnlyHttpConn::~SrsResponseOnlyHttpConn()
 {
 {
 }
 }
 
 
-int SrsStaticHttpConn::on_got_http_message(ISrsHttpMessage* msg)
+int SrsResponseOnlyHttpConn::on_got_http_message(ISrsHttpMessage* msg)
 {
 {
     int ret = ERROR_SUCCESS;
     int ret = ERROR_SUCCESS;
     
     
-    // TODO: FIXME: use the post body.
-    std::string res;
+    ISrsHttpResponseReader* br = msg->body_reader();
     
     
-    // get response body.
-    if ((ret = msg->body_read_all(res)) != ERROR_SUCCESS) {
-        return ret;
+    // drop all request body.
+    while (!br->eof()) {
+        char body[4096];
+        if ((ret = br->read(body, 4096, NULL)) != ERROR_SUCCESS) {
+            return ret;
+        }
     }
     }
     
     
     return ret;
     return ret;

@@ -394,12 +394,14 @@ private:
     virtual int process_request(ISrsHttpResponseWriter* w, ISrsHttpMessage* r);
     virtual int process_request(ISrsHttpResponseWriter* w, ISrsHttpMessage* r);
 };
 };
 
 
-// TODO: FIXME: rename to SrsResponseOnlyHttpConn.
-class SrsStaticHttpConn : public SrsHttpConn
+/**
+ * drop body of request, only process the response.
+ */
+class SrsResponseOnlyHttpConn : public SrsHttpConn
 {
 {
 public:
 public:
-    SrsStaticHttpConn(IConnectionManager* cm, st_netfd_t fd, ISrsHttpServeMux* m);
-    virtual ~SrsStaticHttpConn();
+    SrsResponseOnlyHttpConn(IConnectionManager* cm, st_netfd_t fd, ISrsHttpServeMux* m);
+    virtual ~SrsResponseOnlyHttpConn();
 public:
 public:
     virtual int on_got_http_message(ISrsHttpMessage* msg);
     virtual int on_got_http_message(ISrsHttpMessage* msg);
 };
 };

@@ -1219,7 +1219,7 @@ int SrsServer::accept_client(SrsListenerType type, st_netfd_t client_stfd)
 #endif
 #endif
     } else if (type == SrsListenerHttpStream) {
     } else if (type == SrsListenerHttpStream) {
 #ifdef SRS_AUTO_HTTP_SERVER
 #ifdef SRS_AUTO_HTTP_SERVER
-        conn = new SrsStaticHttpConn(this, client_stfd, http_server);
+        conn = new SrsResponseOnlyHttpConn(this, client_stfd, http_server);
 #else
 #else
         srs_warn("close http client for server not support http-server");
         srs_warn("close http client for server not support http-server");
         srs_close_stfd(client_stfd);
         srs_close_stfd(client_stfd);