EventSocket: Add new event type pipe support

Signed-off-by: Haomai Wang <haomaiwang@gmail.com>

diff --git a/src/common/event_socket.h b/src/common/event_socket.h
index f2ac92de5b39a57de8ef9f60f726f88eb1d71b57..7bbd7ec33e25f66bcdf0178925d3a84257aa1369 100644 (file)
--- a/src/common/event_socket.h
+++ b/src/common/event_socket.h
@@ -25,17 +25,27 @@ class EventSocket {
   EventSocket(): socket(-1), type(EVENT_SOCKET_TYPE_NONE) {}
   bool is_valid() const { return socket != -1; }
   int init(int fd, int t) {
+    switch (t) {
+      case EVENT_SOCKET_TYPE_PIPE:
 #ifdef HAVE_EVENTFD
-    if (t == EVENT_SOCKET_TYPE_EVENTFD) {
-      socket = fd;
-      type = t;
-      return 0;
-    }
+      case EVENT_SOCKET_TYPE_EVENTFD:
 #endif
+      {
+        socket = fd;
+        type = t;
+        return 0;
+      }
+    }
     return -1;
   }
   int notify() {
     switch (type) {
+      case EVENT_SOCKET_TYPE_PIPE:
+      {
+        char buf[1];
+        buf[0] = 'i';
+        return write(socket, buf, 1);
+      }
       case EVENT_SOCKET_TYPE_EVENTFD:
       {
         uint64_t value = 1;

diff --git a/src/include/event_type.h b/src/include/event_type.h
index adab6907227ab13ab80f4cb39233d69c37b565a1..696e7664b3a18ce53656b394d5a77d9c0ea1f4c2 100644 (file)
--- a/src/include/event_type.h
+++ b/src/include/event_type.h
@@ -16,6 +16,7 @@
 #define CEPH_COMMON_EVENT_TYPE_H
 
 #define EVENT_SOCKET_TYPE_NONE 0
-#define EVENT_SOCKET_TYPE_EVENTFD 1
+#define EVENT_SOCKET_TYPE_PIPE 1
+#define EVENT_SOCKET_TYPE_EVENTFD 2
 
 #endif