refine consts

@@ -50,6 +50,9 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // for example, libaacplus, aac, fdkaac
 // for example, libaacplus, aac, fdkaac
 #define SRS_ENCODER_ACODEC     "aac"
 #define SRS_ENCODER_ACODEC     "aac"
 
 
+// when error, encoder sleep for a while and retry.
+#define SRS_ENCODER_SLEEP_US (int64_t)(3*1000*1000LL)
+
 // for encoder to detect the dead loop
 // for encoder to detect the dead loop
 static std::vector<std::string> _transcoded_url;
 static std::vector<std::string> _transcoded_url;
 
 

@@ -40,6 +40,9 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #include <srs_protocol_utility.hpp>
 #include <srs_protocol_utility.hpp>
 #include <srs_protocol_rtmp.hpp>
 #include <srs_protocol_rtmp.hpp>
 
 
+// when error, forwarder sleep for a while and retry.
+#define SRS_FORWARDER_SLEEP_US (int64_t)(3*1000*1000LL)
+
 SrsForwarder::SrsForwarder(SrsSource* _source)
 SrsForwarder::SrsForwarder(SrsSource* _source)
 {
 {
     source = _source;
     source = _source;

@@ -25,4 +25,29 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 
 #ifdef SRS_INGEST
 #ifdef SRS_INGEST
 
 
+#include <srs_kernel_error.hpp>
+
+// when error, ingester sleep for a while and retry.
+#define SRS_INGESTER_SLEEP_US (int64_t)(3*1000*1000LL)
+
+SrsIngester::SrsIngester()
+{
+    pthread = new SrsThread(this, SRS_INGESTER_SLEEP_US);
+}
+
+SrsIngester::~SrsIngester()
+{
+    srs_freep(pthread);
+}
+
+int SrsIngester::cycle()
+{
+    int ret = ERROR_SUCCESS;
+    return ret;
+}
+
+void SrsIngester::on_thread_stop()
+{
+}
+
 #endif
 #endif

@@ -31,5 +31,20 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 
 #ifdef SRS_INGEST
 #ifdef SRS_INGEST
 
 
+#include <srs_app_thread.hpp>
+
+class SrsIngester : public ISrsThreadHandler
+{
+private:
+    SrsThread* pthread;
+public:
+    SrsIngester();
+    virtual ~SrsIngester();
+// interface ISrsThreadHandler.
+public:
+    virtual int cycle();
+    virtual void on_thread_stop();
+};
+
 #endif
 #endif
 #endif
 #endif

@@ -43,6 +43,23 @@ using namespace std;
 #include <srs_app_socket.hpp>
 #include <srs_app_socket.hpp>
 #include <srs_app_http_hooks.hpp>
 #include <srs_app_http_hooks.hpp>
 
 
+// when stream is busy, for example, streaming is already
+// publishing, when a new client to request to publish,
+// sleep a while and close the connection.
+#define SRS_STREAM_BUSY_SLEEP_US (int64_t)(3*1000*1000LL)
+
+// the timeout to wait encoder to republish
+// if timeout, close the connection.
+#define SRS_REPUBLISH_SEND_TIMEOUT_US (int64_t)(3*60*1000*1000LL)
+// if timeout, close the connection.
+#define SRS_REPUBLISH_RECV_TIMEOUT_US (int64_t)(3*60*1000*1000LL)
+
+// the timeout to wait client data, when client paused
+// if timeout, close the connection.
+#define SRS_PAUSED_SEND_TIMEOUT_US (int64_t)(30*60*1000*1000LL)
+// if timeout, close the connection.
+#define SRS_PAUSED_RECV_TIMEOUT_US (int64_t)(30*60*1000*1000LL)
+
 SrsRtmpConn::SrsRtmpConn(SrsServer* srs_server, st_netfd_t client_stfd)
 SrsRtmpConn::SrsRtmpConn(SrsServer* srs_server, st_netfd_t client_stfd)
     : SrsConnection(srs_server, client_stfd)
     : SrsConnection(srs_server, client_stfd)
 {
 {

@@ -41,6 +41,9 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #include <srs_app_http_api.hpp>
 #include <srs_app_http_api.hpp>
 #include <srs_app_http_conn.hpp>
 #include <srs_app_http_conn.hpp>
 #include <srs_app_http.hpp>
 #include <srs_app_http.hpp>
+#ifdef SRS_INGEST
+#include <srs_app_ingest.hpp>
+#endif
 
 
 #define SERVER_LISTEN_BACKLOG 512
 #define SERVER_LISTEN_BACKLOG 512
 #define SRS_TIME_RESOLUTION_MS 500
 #define SRS_TIME_RESOLUTION_MS 500

@@ -33,6 +33,10 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 
 using namespace std;
 using namespace std;
 
 
+// when got a messae header, there must be some data,
+// increase recv timeout to got an entire message.
+#define SRS_MIN_RECV_TIMEOUT_US (int64_t)(60*1000*1000LL)
+
 /****************************************************************************
 /****************************************************************************
 *****************************************************************************
 *****************************************************************************
 ****************************************************************************/
 ****************************************************************************/

@@ -35,19 +35,20 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 
 #include <srs_kernel_log.hpp>
 #include <srs_kernel_log.hpp>
 #include <srs_kernel_error.hpp>
 #include <srs_kernel_error.hpp>
+
+class ISrsProtocolReaderWriter;
+class SrsBuffer;
+class SrsPacket;
+class SrsStream;
+class SrsCommonMessage;
+class SrsChunkStream;
+class SrsAmf0Object;
+class SrsAmf0Any;
+class ISrsMessage;
  
  
 // the following is the timeout for rtmp protocol, 
 // the following is the timeout for rtmp protocol, 
 // to avoid death connection.
 // to avoid death connection.
 
 
-// when got a messae header, there must be some data,
-// increase recv timeout to got an entire message.
-#define SRS_MIN_RECV_TIMEOUT_US (int64_t)(60*1000*1000LL)
-
-// the timeout to wait for client control message,
-// if timeout, we generally ignore and send the data to client,
-// generally, it's the pulse time for data seding.
-#define SRS_PULSE_TIMEOUT_US (int64_t)(200*1000LL)
-
 // the timeout to wait client data,
 // the timeout to wait client data,
 // if timeout, close the connection.
 // if timeout, close the connection.
 #define SRS_SEND_TIMEOUT_US (int64_t)(30*1000*1000LL)
 #define SRS_SEND_TIMEOUT_US (int64_t)(30*1000*1000LL)
@@ -56,38 +57,10 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // if timeout, close the connection.
 // if timeout, close the connection.
 #define SRS_RECV_TIMEOUT_US (int64_t)(30*1000*1000LL)
 #define SRS_RECV_TIMEOUT_US (int64_t)(30*1000*1000LL)
 
 
-// the timeout to wait client data, when client paused
-// if timeout, close the connection.
-#define SRS_PAUSED_SEND_TIMEOUT_US (int64_t)(30*60*1000*1000LL)
-// if timeout, close the connection.
-#define SRS_PAUSED_RECV_TIMEOUT_US (int64_t)(30*60*1000*1000LL)
-
-// the timeout to wait encoder to republish
-// if timeout, close the connection.
-#define SRS_REPUBLISH_SEND_TIMEOUT_US (int64_t)(3*60*1000*1000LL)
-// if timeout, close the connection.
-#define SRS_REPUBLISH_RECV_TIMEOUT_US (int64_t)(3*60*1000*1000LL)
-
-// when stream is busy, for example, streaming is already
-// publishing, when a new client to request to publish,
-// sleep a while and close the connection.
-#define SRS_STREAM_BUSY_SLEEP_US (int64_t)(3*1000*1000LL)
-
-// when error, forwarder sleep for a while and retry.
-#define SRS_FORWARDER_SLEEP_US (int64_t)(3*1000*1000LL)
-
-// when error, encoder sleep for a while and retry.
-#define SRS_ENCODER_SLEEP_US (int64_t)(3*1000*1000LL)
-
-class ISrsProtocolReaderWriter;
-class SrsBuffer;
-class SrsPacket;
-class SrsStream;
-class SrsCommonMessage;
-class SrsChunkStream;
-class SrsAmf0Object;
-class SrsAmf0Any;
-class ISrsMessage;
+// the timeout to wait for client control message,
+// if timeout, we generally ignore and send the data to client,
+// generally, it's the pulse time for data seding.
+#define SRS_PULSE_TIMEOUT_US (int64_t)(200*1000LL)
 
 
 // convert class name to string.
 // convert class name to string.
 #define CLASS_NAME_STRING(className) #className
 #define CLASS_NAME_STRING(className) #className