1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
extern crate glib;
extern crate glib_sys;
extern crate libc;
mod socket_pair;
use std::io::Error;
use std::marker::PhantomData;
use std::mem::transmute;
use std::ptr::null_mut;
use glib::Continue;
use glib::translate::ToGlib;
use socket_pair::{SocketReceiver, SocketSender, pair};
pub fn channel<T>() -> (Sender<T>, Receiver<T>) {
let (sender_socket, receiver_socket) = pair().unwrap();
let sender = Sender::new(sender_socket);
let receiver = Receiver::new(receiver_socket);
(sender, receiver)
}
pub struct Sender<T> {
socket: SocketSender,
_phantom: PhantomData<T>,
}
impl<T> Sender<T> {
fn new(socket: SocketSender) -> Self {
Sender {
socket: socket,
_phantom: PhantomData,
}
}
pub fn close(&self) -> Result<(), Error> {
self.socket.close()?;
Ok(())
}
pub fn send(&mut self, data: T) {
self.socket.send(data).unwrap();
}
}
pub struct Receiver<T> {
channel: *mut glib_sys::GIOChannel,
_socket: SocketReceiver,
_phantom: PhantomData<T>,
}
impl<T> Receiver<T> {
fn new(socket: SocketReceiver) -> Self {
let channel = socket.to_channel();
Receiver {
channel: channel,
_socket: socket,
_phantom: PhantomData,
}
}
pub fn connect_recv<F: FnMut(T) -> Continue + 'static>(&mut self, callback: F) {
let trampoline: glib_sys::GIOFunc = unsafe { transmute(io_watch_trampoline::<T> as usize) };
let func: Box<Box<FnMut(T) -> Continue + 'static>> = Box::new(Box::new(callback));
let user_data: *mut libc::c_void = Box::into_raw(func) as *mut _;
unsafe { glib_sys::g_io_add_watch(self.channel, glib_sys::G_IO_IN, trampoline, user_data) };
}
}
impl<T> Drop for Receiver<T> {
fn drop(&mut self) {
unsafe { glib_sys::g_io_channel_shutdown(self.channel, 0, null_mut()) };
unsafe { glib_sys::g_io_channel_unref(self.channel) };
}
}
unsafe extern "C" fn io_watch_trampoline<T>(source: *mut glib_sys::GIOChannel, _condition: glib_sys::GIOCondition,
data: *mut libc::c_void) -> libc::c_int
{
let mut buffer = [0u8; 8];
let mut read: usize = 0;
use std::ptr;
let error = ptr::null_mut();
glib_sys::g_io_channel_read_chars(source, buffer.as_mut_ptr(), 8, &mut read, error);
assert!(error.is_null(), "No reading error in glib-itc");
assert_eq!(read, 8, "Unable to read 8 bytes in glib-itc");
let arg: Box<T> = Box::from_raw(transmute(buffer));
let func: &Box<Fn(T) -> Continue + 'static> = &*(data as *const _);
func(*arg).to_glib()
}