http server, draft

README.md

@@ -9,8 +9,10 @@ plan:
 
  2) buffer managment.(done)
 
- 3) socket server based on epoll(done.06/12).
+ 3) socket server based on epoll(done).
 
  4) lock-free loging framework:queue/stack.(done)
 
+ 5) http server (on going)
+
 

net/SocketServer.h

@@ -93,6 +93,10 @@ class SocketServer: public noncopyable
         // to make sure that handler is fast as possible
         void RegisterSocketEventHandler(SocketEventHandler handler);
 
+    public:
+
+        static const int max_conn_id;
+
     private:
 
         ServerImpl* impl_;

net/http/HttpServer.cc

@@ -0,0 +1,90 @@
+#include "HttpServer.h"
+
+#include "net/SocketServer.h"
+
+#include "thread/ITask.h"
+#include "thread/Thread.h"
+#include "misc/LockFreeBuffer.h"
+
+class HttpBuffer:public NonCopyable
+{
+    public:
+
+        HttpBuffer();
+        ~HttpBuffer();
+
+        void  Consume(int sz);
+        void  Append(const char* data);
+        char* Find(char c) const;
+        char* Find(const char* str) const;
+
+    private:
+
+        char* buff_; // allocate from lockfree buffer pool
+        int start_;
+        int end_;
+        int cur_;
+};
+
+class HttpContext: public NonCopyable
+{
+    public:
+
+        HttpContext();
+        ~HttpContext();
+
+        enum
+        {
+            HS_REQUEST_LINE,
+            HS_HEADER,
+            HS_BODY,
+            HS_INVALID
+        };
+
+    private:
+
+        bool keepalive_;
+        char* buff_;
+        int curStage_;
+};
+
+class HttpTask: public ITask
+{
+    public:
+
+        HttpTask();
+        ~HttpTask();
+
+        virtual void Run();
+
+    private:
+
+        HttpContext context_;
+};
+
+class HttpImpl:public ThreadBase
+{
+    public:
+
+        HttpImpl(const char* addr);
+        ~HttpImpl();
+
+        void StartServer();
+        void StopServer();
+
+    protected:
+
+        virtual void Run();
+
+        bool ParseRequestLine(HttpBuffer& buffer);
+        bool ParseHeader(HttpBuffer& buffer, map<string, string>& output);
+        string ParseBody(HttpBuffer& buffer);
+
+    private:
+
+        SocketServer tcpServer_;
+
+        // connection id to index into it
+        HttpTask conn_[];
+};
+

net/http/HttpServer.h

@@ -0,0 +1,24 @@
+#ifndef __HTTP_SERVER_H__
+#define __HTTP_SERVER_H__
+
+#include "misc/NonCopyable.h"
+
+class HttpImpl;
+
+class HttpServer: public NonCopyable
+{
+    public:
+
+        HttpServer(const char* addr);
+        ~HttpServer();
+
+        void StartServer();
+        void StopServer();
+
+    private:
+
+        HttpImpl* impl_;
+};
+
+#endif
+

net/src/SocketServer.cc

@@ -1333,3 +1333,5 @@ int SocketServer::WatchRawSocket(int fd, uintptr_t opaque)
     return impl_->WatchRawSocket(fd, opaque);
 }
 
+const int SocketServer::max_conn_id = MAX_SOCKET;
+