mirror of
https://github.com/feschber/lan-mouse.git
synced 2026-09-17 18:01:11 +03:00
Compare commits
2 Commits
main-b316a
...
main-09889
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
09889cd839 | ||
|
|
c194df791d |
@@ -123,7 +123,6 @@ struct State {
|
|||||||
focused: Option<Arc<Window>>,
|
focused: Option<Arc<Window>>,
|
||||||
global_list: GlobalList,
|
global_list: GlobalList,
|
||||||
globals: Globals,
|
globals: Globals,
|
||||||
wayland_fd: RawFd,
|
|
||||||
read_guard: Option<ReadEventsGuard>,
|
read_guard: Option<ReadEventsGuard>,
|
||||||
qh: QueueHandle<Self>,
|
qh: QueueHandle<Self>,
|
||||||
pending_events: VecDeque<(Position, CaptureEvent)>,
|
pending_events: VecDeque<(Position, CaptureEvent)>,
|
||||||
@@ -138,7 +137,7 @@ struct Inner {
|
|||||||
|
|
||||||
impl AsRawFd for Inner {
|
impl AsRawFd for Inner {
|
||||||
fn as_raw_fd(&self) -> RawFd {
|
fn as_raw_fd(&self) -> RawFd {
|
||||||
self.state.wayland_fd
|
self.queue.as_fd().as_raw_fd()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -332,7 +331,6 @@ impl LayerShellInputCapture {
|
|||||||
active_windows: Vec::new(),
|
active_windows: Vec::new(),
|
||||||
focused: None,
|
focused: None,
|
||||||
qh,
|
qh,
|
||||||
wayland_fd: queue.as_fd().as_raw_fd(),
|
|
||||||
read_guard: None,
|
read_guard: None,
|
||||||
pending_events: VecDeque::new(),
|
pending_events: VecDeque::new(),
|
||||||
outputs: vec![],
|
outputs: vec![],
|
||||||
@@ -548,13 +546,12 @@ impl State {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl Inner {
|
impl Inner {
|
||||||
fn read(&mut self) -> bool {
|
fn read(&mut self) {
|
||||||
match self.state.read_guard.take().unwrap().read() {
|
match self.state.read_guard.take().unwrap().read() {
|
||||||
Ok(_) => true,
|
Ok(_) => {}
|
||||||
Err(WaylandError::Io(e)) if e.kind() == ErrorKind::WouldBlock => false,
|
Err(WaylandError::Io(e)) if e.kind() == ErrorKind::WouldBlock => {}
|
||||||
Err(WaylandError::Io(e)) => {
|
Err(WaylandError::Io(e)) => {
|
||||||
log::error!("error reading from wayland socket: {e}");
|
log::error!("error reading from wayland socket: {e}");
|
||||||
false
|
|
||||||
}
|
}
|
||||||
Err(WaylandError::Protocol(e)) => {
|
Err(WaylandError::Protocol(e)) => {
|
||||||
panic!("wayland protocol violation: {e}")
|
panic!("wayland protocol violation: {e}")
|
||||||
@@ -564,16 +561,11 @@ impl Inner {
|
|||||||
|
|
||||||
fn prepare_read(&mut self) -> io::Result<()> {
|
fn prepare_read(&mut self) -> io::Result<()> {
|
||||||
loop {
|
loop {
|
||||||
match self.queue.prepare_read() {
|
if let Some(guard) = self.queue.prepare_read() {
|
||||||
None => match self.queue.dispatch_pending(&mut self.state) {
|
self.state.read_guard = Some(guard);
|
||||||
Ok(_) => continue,
|
break Ok(());
|
||||||
Err(DispatchError::Backend(WaylandError::Io(e))) => return Err(e),
|
} else {
|
||||||
Err(e) => panic!("failed to dispatch wayland events: {e}"),
|
self.dispatch_events();
|
||||||
},
|
|
||||||
Some(r) => {
|
|
||||||
self.state.read_guard = Some(r);
|
|
||||||
break Ok(());
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -655,13 +647,7 @@ impl Stream for LayerShellInputCapture {
|
|||||||
let inner = guard.get_inner_mut();
|
let inner = guard.get_inner_mut();
|
||||||
|
|
||||||
// read events
|
// read events
|
||||||
while inner.read() {
|
inner.read();
|
||||||
// prepare next read
|
|
||||||
match inner.prepare_read() {
|
|
||||||
Ok(_) => {}
|
|
||||||
Err(e) => return Poll::Ready(Some(Err(e.into()))),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// dispatch the events
|
// dispatch the events
|
||||||
inner.dispatch_events();
|
inner.dispatch_events();
|
||||||
|
|||||||
Reference in New Issue
Block a user