X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/be7cf844f59fa483423724e8e4b5e663e5b88ddd..16e7c282c6fcec8189425bd15ec9e8a4a0ee857d:/rpc/pollmgr.h

diff --git a/rpc/pollmgr.h b/rpc/pollmgr.h
index a082843..2da3167 100644
--- a/rpc/pollmgr.h
+++ b/rpc/pollmgr.h
@@ -11,75 +11,75 @@
 #define MAX_POLL_FDS 128
 
 typedef enum {
-	CB_NONE = 0x0,
-	CB_RDONLY = 0x1,
-	CB_WRONLY = 0x10,
-	CB_RDWR = 0x11,
-	CB_MASK = ~0x11,
+    CB_NONE = 0x0,
+    CB_RDONLY = 0x1,
+    CB_WRONLY = 0x10,
+    CB_RDWR = 0x11,
+    CB_MASK = ~0x11,
 } poll_flag;
 
 class aio_mgr {
-	public:
-		virtual void watch_fd(int fd, poll_flag flag) = 0;
-		virtual bool unwatch_fd(int fd, poll_flag flag) = 0;
-		virtual bool is_watched(int fd, poll_flag flag) = 0;
-		virtual void wait_ready(vector<int> *readable, vector<int> *writable) = 0;
-		virtual ~aio_mgr() {}
+    public:
+        virtual void watch_fd(int fd, poll_flag flag) = 0;
+        virtual bool unwatch_fd(int fd, poll_flag flag) = 0;
+        virtual bool is_watched(int fd, poll_flag flag) = 0;
+        virtual void wait_ready(vector<int> *readable, vector<int> *writable) = 0;
+        virtual ~aio_mgr() {}
 };
 
 class aio_callback {
-	public:
-		virtual void read_cb(int fd) = 0;
-		virtual void write_cb(int fd) = 0;
-		virtual ~aio_callback() {}
+    public:
+        virtual void read_cb(int fd) = 0;
+        virtual void write_cb(int fd) = 0;
+        virtual ~aio_callback() {}
 };
 
 class PollMgr {
-	public:
-		PollMgr();
-		~PollMgr();
+    public:
+        PollMgr();
+        ~PollMgr();
 
-		static PollMgr *Instance();
-		static PollMgr *CreateInst();
+        static PollMgr *Instance();
+        static PollMgr *CreateInst();
 
-		void add_callback(int fd, poll_flag flag, aio_callback *ch);
-		void del_callback(int fd, poll_flag flag);
-		bool has_callback(int fd, poll_flag flag, aio_callback *ch);
-		void block_remove_fd(int fd);
-		void wait_loop();
+        void add_callback(int fd, poll_flag flag, aio_callback *ch);
+        void del_callback(int fd, poll_flag flag);
+        bool has_callback(int fd, poll_flag flag, aio_callback *ch);
+        void block_remove_fd(int fd);
+        void wait_loop();
 
 
-		static PollMgr *instance;
-		static int useful;
-		static int useless;
+        static PollMgr *instance;
+        static int useful;
+        static int useless;
 
-	private:
+    private:
         mutex m_;
         cond changedone_c_;
         thread th_;
 
-		aio_callback *callbacks_[MAX_POLL_FDS];
-		aio_mgr *aio_;
-		bool pending_change_;
+        aio_callback *callbacks_[MAX_POLL_FDS];
+        aio_mgr *aio_;
+        bool pending_change_;
 
 };
 
 class SelectAIO : public aio_mgr {
-	public :
+    public :
 
-		SelectAIO();
-		~SelectAIO();
-		void watch_fd(int fd, poll_flag flag);
-		bool unwatch_fd(int fd, poll_flag flag);
-		bool is_watched(int fd, poll_flag flag);
-		void wait_ready(vector<int> *readable, vector<int> *writable);
+        SelectAIO();
+        ~SelectAIO();
+        void watch_fd(int fd, poll_flag flag);
+        bool unwatch_fd(int fd, poll_flag flag);
+        bool is_watched(int fd, poll_flag flag);
+        void wait_ready(vector<int> *readable, vector<int> *writable);
 
-	private:
+    private:
 
-		fd_set rfds_;
-		fd_set wfds_;
-		int highfds_;
-		int pipefd_[2];
+        fd_set rfds_;
+        fd_set wfds_;
+        int highfds_;
+        int pipefd_[2];
 
         mutex m_;
 
@@ -87,18 +87,18 @@ class SelectAIO : public aio_mgr {
 
 #ifdef __linux__ 
 class EPollAIO : public aio_mgr {
-	public:
-		EPollAIO();
-		~EPollAIO();
-		void watch_fd(int fd, poll_flag flag);
-		bool unwatch_fd(int fd, poll_flag flag);
-		bool is_watched(int fd, poll_flag flag);
-		void wait_ready(vector<int> *readable, vector<int> *writable);
-
-	private:
-		int pollfd_;
-		struct epoll_event ready_[MAX_POLL_FDS];
-		int fdstatus_[MAX_POLL_FDS];
+    public:
+        EPollAIO();
+        ~EPollAIO();
+        void watch_fd(int fd, poll_flag flag);
+        bool unwatch_fd(int fd, poll_flag flag);
+        bool is_watched(int fd, poll_flag flag);
+        void wait_ready(vector<int> *readable, vector<int> *writable);
+
+    private:
+        int pollfd_;
+        struct epoll_event ready_[MAX_POLL_FDS];
+        int fdstatus_[MAX_POLL_FDS];
 
 };
 #endif /* __linux */