imple server by libev

Author: wuxiang

libev/include/nb_net_tool.h

@@ -19,6 +19,7 @@
 #include <netdb.h>
 #include <ifaddrs.h>
 #include <vector>
+#include <fcntl.h>
 
 //#include <boost/noncopyable.hpp>
 
@@ -117,4 +118,14 @@ inline std::string nb_getifaddr_v4()
     }    
 }
 
+//add by wuxiang
+int setnoblock(int fd)
+{
+    int flags = 0;
+    flags = fcntl(fd, F_GETFL);
+    flags = flags | O_NONBLOCK;
+    return fcntl(fd, F_SETFL, flags);
+}
+
+
 #endif /* _NB_NET_TOOL_H_ */

libev/source/include/configuration.h

@@ -0,0 +1,27 @@
+#ifndef CONFIGURATION_H_
+#define CONFIGURATION_H_
+
+class configuration
+{
+public:
+    configuration& instance();
+    void parse_option(const int ac, const char* argv[]);
+    std::size_t  get_ev_loop_size();
+    void dump();
+
+private:
+    configuration();
+    ~configuration();
+    configuration(const configuration&);
+    configuration operator=(const configuration&);
+
+private:
+    void init_default_options();
+
+    void load_config_file();
+
+private:
+    std::size_t      m_ev_loop_size;
+};
+
+#endif //CONFIGURATION_H_

libev/source/include/io_loop_pool.h

@@ -6,11 +6,16 @@
 class io_loop_pool: public singleton_base<io_loop_pool>
 {
     public:
+        io_loop_pool& instance();
+        io_loop&   get_io_loop();
+        bool  run();
+        bool  stop();
+
+    private:
         io_loop_pool(); 
         io_loop_pool(const std::size_t& size);
         ~io_loop_pool();
 
-        io_loop&   get_io_loop();
 
     private:
         std::size_t  m_size;

libev/source/include/loop.h

@@ -1,5 +1,6 @@
 #ifndef LOOP_H_
 #define LOOP_H_
+#include <ev.h>
 
 class io_loop
 {
@@ -8,6 +9,11 @@ class io_loop
         io_loop(const unsigned size, const std::size_t*  array);
         ~io_loop();
 
+        bool run();
+        bool stop();
+        bool add_service(const ev_io*  service);
+        bool del_service(const ev_io*  service);
+
     private:
         //make it can not be copied
         io_loop(const io_loop&);

libev/source/src/configuration.cpp

@@ -0,0 +1,38 @@
+#include "configuration.h"
+
+configuration& instance()
+{
+    static configuration  cfg;
+    return cfg;
+}
+
+configuration::configuration()
+{
+    init_default_options();
+}
+
+configuration::~configuration()
+{
+}
+
+void configuration::parse_option(const int ac, const char* argv[])
+{
+}
+
+std::size_t  configuration::get_ev_loop_size()
+{
+}
+
+void configuration::dump()
+{
+}
+
+void configuration::init_default_options()
+{
+    m_ev_loop_size = 4;
+}
+
+void configuration::load_config_file()
+{
+}
+

libev/source/src/loop.cpp

@@ -21,3 +21,25 @@ io_loop::~io_loop()
     ev_loop_destroy(loop);
 }
 
+bool io_loop::run()
+{
+    return ev_run(loop, 0);
+}
+
+bool io_loop::stop()
+{
+    return ev_break(loop, EVBREAK_ALL);
+}
+
+bool io_service::add_service(const ev_io*  service)
+{
+    ev_io_start(loop, service);
+    return true;
+}
+
+bool io_service::del_service(const ev_io*  service)
+{
+    ev_io_start(loop, service);
+    return true;
+}
+

libev/test/entry.cpp

@@ -8,53 +8,13 @@
 #include <unistd.h>
 #include <string.h>
 #include <stdlib.h>
-#include <ev.h>
 
 #include "asyn_server.h"
 #include "nb_net_tool.h"
 
-struct ev_loop*  loop = NULL;
-int server = 0;
-int cli_fd = 0;
-
-//void accept_cb(EV_P_ ev_io* p, int enent)
-void accept_cb(struct ev_loop* loop, struct ev_io* io, int event)
-{
-    printf("accept  handler\n");
-    struct sockaddr_in  cli_addr;
-    socklen_t len = sizeof(cli_addr);
-    cli_fd = accept(server, (struct sockaddr*)&cli_addr, &len);
-    if (-1 == cli_fd)
-    {
-        printf("accept failed\n");
-    }
-
-    //ev_io_stop(EV_A_ p);
-    //ev_break(EV_A_ EVBREAK_ONE);
-
-    //p = (ev_io*)malloc(sizeof(ev_io));
-    //ev_io_init(p, accept_cb, 0, EV_READ);
-    //ev_io_start(loop, p);
-}
-
-
-//void cb(EV_P_ ev_io* p, int enent)
-//{
-//    printf("stdin read happen\n");
-//    //ev_io_stop(EV_A_ p);
-//    //ev_break(EV_A_ EVBREAK_ONE);
-//}
-
 int main()
 {
-    // prepare io
-    //struct ev_loop* loop  = EV_DEFAULT;
-    loop  = EV_DEFAULT;
-    ev_io   accept_id;
-    //ev_io   tmp;
-
-    //int server = socket(AF_INET, SOCK_STREAM, 0);
-    server = socket(AF_INET, SOCK_STREAM, 0);
+    int server = socket(AF_INET, SOCK_STREAM, 0);
 
     struct sockaddr_in   serv_addr;
     bzero(&serv_addr, sizeof(struct sockaddr_in));
@@ -78,15 +38,6 @@ int main()
         printf("error happen when use listen\n");
     }
 
-    printf("ev io starting\n");
-    ev_io_init(&accept_id, accept_cb, server, EV_READ);
-    ev_io_start(loop, &accept_id);
-
-    //ev_io_init(&tmp, cb, 0, EV_READ);
-    //ev_io_start(loop, &tmp);
-
-    ev_run(loop, 0);
-    printf("\nev io end\n");
 
     sigset_t    wait_mask;
     sigemptyset(&wait_mask);
@@ -97,11 +48,6 @@ int main()
     int flag = 0;
     sigwait(&wait_mask, &flag);
 
-    printf("ev io stoping\n");
-    //ev_io_stop(EV_A_ &accept_id);
-    //ev_break(EV_A_ EVBREAK_ALL);
-    printf("ev io has stoped\n");
-
     return 0;
 }