Changeset 18476 for lang/c/mpio/trunk/mp/iothreads.pre.h

Timestamp:

08/30/08 15:15:48 (4 months ago)

Author:

frsyuki

Message:

lang/c/mpio: added mp::iothreads::reader and mp::iothreads::writer

Files:

• lang/c/mpio/trunk/mp/iothreads.pre.h (modified) (3 diffs)

lang/c/mpio/trunk/mp/iothreads.pre.h

@@ -54 +54 @@
 public:
         template <typename ThreadIMPL>
-        static void add_thread();
+        static ThreadIMPL* add_thread();
 MP_ARGS_BEGIN
         template <typename ThreadIMPL, MP_ARGS_TEMPLATE>
-        static void add_thread(MP_ARGS_PARAMS);
+        static ThreadIMPL* add_thread(MP_ARGS_PARAMS);
 MP_ARGS_END
 
@@ -70 +70 @@
 private:
         template <typename ThreadIMPL>
-        void add_thread_impl();
+        ThreadIMPL* add_thread_impl();
 MP_ARGS_BEGIN
         template <typename ThreadIMPL, MP_ARGS_TEMPLATE>
-        void add_thread_impl(MP_ARGS_PARAMS);
+        ThreadIMPL* add_thread_impl(MP_ARGS_PARAMS);
 MP_ARGS_END
 
@@ -145 +145 @@
 
 #include "mp/iothreads_impl.h"
+#include "mp/iothreads/writer.h"
 #include "mp/iothreads/listen.h"
 #include "mp/iothreads/timer.h"
 
-
-/*
-namespace mp {
-
-
-template <typename ThreadTag = main_thread_tag>
-class iothreads {
-public:
-
-        template <typename IMPL>
-        class handler {
-        public:
-                handler(int fd);
-                virtual ~handler();
-        protected:
-                template <typename T>  // fixme
-                void submit(void (*callback)(T* obj, void* user), T* obj, void* user);
-        public:
-                //virtual int read_event() = 0;
-        };
-
-        template <typename IMPL>
-        class stream_handler : public handler {
-        public
-                stream_handler(int fd);  // allocate buffer
-                virtual ~stream_handler();
-        public:
-                int read_event();
-        public:
-                // throw exception to close fd
-                //virtual void receive_data(stream& s) = 0;
-                //virtual void unbind() = 0;
-        };
-
-        template <typename IMPL>
-        class timer : public handler {
-        public:
-                timer(int fd);
-                virtual ~timer();
-        public:
-                static start(double interval);
-        public:
-                //virtual void triger() = 0;
-        };
-
-
-        struct thread {
-                virtual ~thread() {}
-                virtual void run() = 0;
-        };
-
-        class io_thread : public thread {
-        public:
-                io_thread();
-                ~io_thread();
-        public:
-                void run();
-        private:
-                struct cb_t {
-                public:
-                        cb_t();
-                        ~cb_t();
-                public:
-                        short event();
-                        void event(short ev);
-                        handler& handler();
-                        // fixme buffer accessor
-                private:
-                        short m_event;
-                        handler& m_handler;
-                        char* m_wbuffer;  // fixme
-                };
-        private:
-                void close_connection(cb_t& cb);
-                void rswitch(cb_t& cb);
-                void wswitch(cb_t& cb);
-        public:
-                void add(handler* handler);
-                bool have(int fd);
-                void send_data(int fd, char* data, size_t len);  // fixme
-                void send_message(int fd, char* msg, size_t len);  // fixme
-        private:
-                // fixme
-                void msg_add();
-                void msg_send_data();
-                void msg_send_message();
-        };
-
-
-public:
-        static void initialize(unsigned int num_threads);
-        static void destroy();
-        ~buffer();
-
-        template <typename Handler>
-        void add(int fd);
-MP_ARGS_BEGIN
-        template <typename Handler, MP_ARGS_TEMPLATE>
-        inline int add(int fd, MP_ARGS_PARAMS);
-MP_ARGS_END
-
-public:
-        void remove(handler* ctx);
-
-public:
-        void send_data(int fd, const char* data, size_t len);
-        void send_message(int fd, const char* data, size_t len);  // fixme
-
-public:
-        template <typename Thread>
-        void custom_thread();
-MP_ARGS_BEGIN
-        template <typename Thread, MP_ARGS_TEMPLATE>
-        inline int custom_thread(MP_ARGS_PARAMS);
-MP_ARGS_END
-
-public:
-        void run();
-        void end();
-        bool is_end() const;
-
-public:
-        void submit(void* data);  // fixme
-
-private:
-        iothreads(unsigned int num_threads);
-
-private:
-        unsigned int m_num_threads;
-
-private:
-        iothreads(const iothreads&);
-        iothreads();
-};
-
-
-
-}  // namespace mp
-*/
-
-
 #endif /* mp/iothreads.h */