Implement grab and ungrab

src/raw_stream.rs

@@ -66,6 +66,7 @@ pub struct RawDevice {
     // ff_stat: Option<FFStatus>,
     supported_snd: Option<AttributeSet<SoundType>>,
     pub(crate) event_buf: Vec<libc::input_event>,
+    grabbed: bool,
 }
 
 #[derive(Debug, Clone)]
@@ -222,6 +223,7 @@ impl RawDevice {
             supported_snd,
             auto_repeat,
             event_buf: Vec::new(),
+            grabbed: false,
         })
     }
 
@@ -588,6 +590,26 @@ impl RawDevice {
     pub fn into_event_stream(self) -> io::Result<EventStream> {
         EventStream::new(self)
     }
+
+    pub fn grab(&mut self) -> io::Result<()> {
+        if !self.grabbed {
+            unsafe {
+                sys::eviocgrab(self.as_raw_fd(), 1)?;
+            }
+            self.grabbed = true;
+        }
+        Ok(())
+    }
+
+    pub fn ungrab(&mut self) -> io::Result<()> {
+        if self.grabbed {
+            unsafe {
+                sys::eviocgrab(self.as_raw_fd(), 0)?;
+            }
+            self.grabbed = false;
+        }
+        Ok(())
+    }
 }
 
 impl AsRawFd for RawDevice {

src/sync_stream.rs

@@ -329,6 +329,19 @@ impl Device {
     pub fn into_event_stream(self) -> io::Result<EventStream> {
         EventStream::new(self)
     }
+
+    /// Grab the device through a kernel syscall.
+    ///
+    /// This prevents other clients (including kernel-internal ones such as rfkill) from receiving
+    /// events from this device.
+    pub fn grab(&mut self) -> io::Result<()> {
+        self.raw.grab()
+    }
+
+    /// Ungrab the device through a kernel syscall.
+    pub fn ungrab(&mut self) -> io::Result<()> {
+        self.raw.ungrab()
+    }
 }
 
 impl AsRawFd for Device {