mirror of
https://github.com/feschber/lan-mouse.git
synced 2026-03-07 20:09:59 +03:00
committed by
GitHub
parent
5fd3b719d6
commit
460bacade5
1
Cargo.lock
generated
1
Cargo.lock
generated
@@ -1292,6 +1292,7 @@ dependencies = [
|
|||||||
"async-trait",
|
"async-trait",
|
||||||
"clap",
|
"clap",
|
||||||
"core-graphics",
|
"core-graphics",
|
||||||
|
"endi",
|
||||||
"env_logger",
|
"env_logger",
|
||||||
"futures",
|
"futures",
|
||||||
"futures-core",
|
"futures-core",
|
||||||
|
|||||||
@@ -35,6 +35,7 @@ once_cell = "1.19.0"
|
|||||||
num_enum = "0.7.2"
|
num_enum = "0.7.2"
|
||||||
hostname = "0.4.0"
|
hostname = "0.4.0"
|
||||||
slab = "0.4.9"
|
slab = "0.4.9"
|
||||||
|
endi = "1.1.0"
|
||||||
|
|
||||||
[target.'cfg(unix)'.dependencies]
|
[target.'cfg(unix)'.dependencies]
|
||||||
libc = "0.2.148"
|
libc = "0.2.148"
|
||||||
|
|||||||
@@ -11,6 +11,7 @@ use std::{
|
|||||||
use crate::frontend::{gtk::window::Window, FrontendRequest};
|
use crate::frontend::{gtk::window::Window, FrontendRequest};
|
||||||
|
|
||||||
use adw::Application;
|
use adw::Application;
|
||||||
|
use endi::{Endian, ReadBytes};
|
||||||
use gtk::{
|
use gtk::{
|
||||||
gdk::Display, glib::clone, prelude::*, subclass::prelude::ObjectSubclassIsExt, IconTheme,
|
gdk::Display, glib::clone, prelude::*, subclass::prelude::ObjectSubclassIsExt, IconTheme,
|
||||||
};
|
};
|
||||||
@@ -85,16 +86,14 @@ fn build_ui(app: &Application) {
|
|||||||
gio::spawn_blocking(move || {
|
gio::spawn_blocking(move || {
|
||||||
match loop {
|
match loop {
|
||||||
// read length
|
// read length
|
||||||
let mut len = [0u8; 8];
|
let len = match rx.read_u64(Endian::Big) {
|
||||||
match rx.read_exact(&mut len) {
|
Ok(l) => l,
|
||||||
Ok(_) => (),
|
|
||||||
Err(e) if e.kind() == ErrorKind::UnexpectedEof => break Ok(()),
|
Err(e) if e.kind() == ErrorKind::UnexpectedEof => break Ok(()),
|
||||||
Err(e) => break Err(e),
|
Err(e) => break Err(e),
|
||||||
};
|
};
|
||||||
let len = usize::from_be_bytes(len);
|
|
||||||
|
|
||||||
// read payload
|
// read payload
|
||||||
let mut buf = vec![0u8; len];
|
let mut buf = vec![0u8; len as usize];
|
||||||
match rx.read_exact(&mut buf) {
|
match rx.read_exact(&mut buf) {
|
||||||
Ok(_) => (),
|
Ok(_) => (),
|
||||||
Err(e) if e.kind() == ErrorKind::UnexpectedEof => break Ok(()),
|
Err(e) if e.kind() == ErrorKind::UnexpectedEof => break Ok(()),
|
||||||
|
|||||||
@@ -10,6 +10,7 @@ use std::net::TcpStream;
|
|||||||
|
|
||||||
use adw::prelude::*;
|
use adw::prelude::*;
|
||||||
use adw::subclass::prelude::*;
|
use adw::subclass::prelude::*;
|
||||||
|
use endi::{Endian, WriteBytes};
|
||||||
use glib::{clone, Object};
|
use glib::{clone, Object};
|
||||||
use gtk::{
|
use gtk::{
|
||||||
gio,
|
gio,
|
||||||
@@ -265,8 +266,7 @@ impl Window {
|
|||||||
let mut stream = self.imp().stream.borrow_mut();
|
let mut stream = self.imp().stream.borrow_mut();
|
||||||
let stream = stream.as_mut().unwrap();
|
let stream = stream.as_mut().unwrap();
|
||||||
let bytes = json.as_bytes();
|
let bytes = json.as_bytes();
|
||||||
let len = bytes.len().to_be_bytes();
|
if let Err(e) = stream.write_u64(Endian::Big, bytes.len() as u64) {
|
||||||
if let Err(e) = stream.write(&len) {
|
|
||||||
log::error!("error sending message: {e}");
|
log::error!("error sending message: {e}");
|
||||||
};
|
};
|
||||||
if let Err(e) = stream.write(bytes) {
|
if let Err(e) = stream.write(bytes) {
|
||||||
|
|||||||
Reference in New Issue
Block a user