Changeset 18301 for lang/c/mpio/trunk/mp/fdnotify.h

Timestamp:

08/27/08 15:40:53 (4 months ago)

Author:

frsyuki

Message:

lang/c/mpio: re-implemented mp::fdnotify with readv() system call

Files:

• lang/c/mpio/trunk/mp/fdnotify.h (modified) (2 diffs)

lang/c/mpio/trunk/mp/fdnotify.h

@@ -17 +17 @@
 //
 
-#ifndef MP_FD_NOTIFY_H__
-#define MP_FD_NOTIFY_H__
+#ifndef MP_FDNOTIFY_H__
+#define MP_FDNOTIFY_H__
 
+#include <sys/types.h>
+#include <sys/uio.h>
+#include <unistd.h>
 #include <stdexcept>
+
+#ifndef MP_FDNOTIFY_VECTOR_SIZE
+#define MP_FDNOTIFY_VECTOR_SIZE 64
+#endif
 
 namespace mp {
@@ -40 +47 @@
 
 public:
+        int getfd(void) const { return m_pipe[0]; }
         bool try_receive(NotifyObject* result);
-        int getfd(void) const { return m_pipe[PIPE_READ]; }
 
-        inline void send(const NotifyObject& obj);
+        void send(const NotifyObject& obj);
 
 private:
-        enum {
-                PIPE_READ = 0,
-                PIPE_WRITE = 1,
-        };
         int m_pipe[2];
-        char m_buffer[sizeof(NotifyObject)];
-        size_t m_pos;
+        char m_buffer[sizeof(NotifyObject)*MP_FDNOTIFY_VECTOR_SIZE];
+        struct iovec m_iovec[MP_FDNOTIFY_VECTOR_SIZE];
+        struct iovec* m_head;
+        struct iovec* m_tail;
 
 private:
-        void send_all(const char* p, const char* const endp);
+        bool receive_next(NotifyObject* result);
 
 private: