diff options
| author | Pierre Krieger <pierre.krieger1708@gmail.com> | 2015-04-03 08:33:51 +0200 | 
|---|---|---|
| committer | Pierre Krieger <pierre.krieger1708@gmail.com> | 2015-04-03 09:42:45 +0200 | 
| commit | 0f7bd9071e9b64acb9f13e253d49c3790e50d560 (patch) | |
| tree | b35fe22f55ef94a02ab01bf6f5271407ce4ad204 /src/x11 | |
| parent | 1c74614c4ace993e655e18dafdeb9d5ceef9ea06 (diff) | |
| download | glutin-0f7bd9071e9b64acb9f13e253d49c3790e50d560.tar.gz glutin-0f7bd9071e9b64acb9f13e253d49c3790e50d560.zip | |
Remove all features for 1.0 beta
Diffstat (limited to 'src/x11')
| -rw-r--r-- | src/x11/window/mod.rs | 53 | 
1 files changed, 24 insertions, 29 deletions
| diff --git a/src/x11/window/mod.rs b/src/x11/window/mod.rs index 0188386..fa8f91c 100644 --- a/src/x11/window/mod.rs +++ b/src/x11/window/mod.rs @@ -8,7 +8,6 @@ use std::sync::atomic::AtomicBool;  use std::collections::VecDeque;  use super::ffi;  use std::sync::{Arc, Mutex, Once, ONCE_INIT, Weak}; -use std::sync::{StaticMutex, MUTEX_INIT};  use Api;  use CursorState; @@ -21,6 +20,11 @@ mod monitor;  static THREAD_INIT: Once = ONCE_INIT; +// XOpenIM doesn't seem to be thread-safe +lazy_static! {      // TODO: use a static mutex when that's possible, and put me back in my function +    static ref GLOBAL_XOPENIM_LOCK: Mutex<()> = Mutex::new(()); +} +  fn x_error_callback(_: *mut ffi::Display, event: *mut ffi::XErrorEvent) -> libc::c_int {      unsafe {          println!("[glutin] x error code={} major={} minor={}!", (*event).error_code, (*event).request_code, (*event).minor_code); @@ -82,30 +86,25 @@ impl Drop for XWindow {  #[derive(Clone)]  pub struct WindowProxy { -    x: Weak<XWindow>, +    x: Arc<XWindow>,  }  impl WindowProxy {      pub fn wakeup_event_loop(&self) { -        match self.x.upgrade() { -            Some(x) => { -                let mut xev = ffi::XClientMessageEvent { -                    type_: ffi::ClientMessage, -                    window: x.window, -                    format: 32, -                    message_type: 0, -                    serial: 0, -                    send_event: 0, -                    display: x.display, -                    l: [0, 0, 0, 0, 0], -                }; +        let mut xev = ffi::XClientMessageEvent { +            type_: ffi::ClientMessage, +            window: self.x.window, +            format: 32, +            message_type: 0, +            serial: 0, +            send_event: 0, +            display: self.x.display, +            l: [0, 0, 0, 0, 0], +        }; -                unsafe { -                    ffi::XSendEvent(x.display, x.window, 0, 0, mem::transmute(&mut xev)); -                    ffi::XFlush(x.display); -                } -            } -            None => {} +        unsafe { +            ffi::XSendEvent(self.x.display, self.x.window, 0, 0, mem::transmute(&mut xev)); +            ffi::XFlush(self.x.display);          }      }  } @@ -118,15 +117,13 @@ impl<'a> Iterator for PollEventsIterator<'a> {      type Item = Event;      fn next(&mut self) -> Option<Event> { -        use std::num::Int; -          if let Some(ev) = self.window.pending_events.lock().unwrap().pop_front() {              return Some(ev);          }          loop {              let mut xev = unsafe { mem::uninitialized() }; -            let res = unsafe { ffi::XCheckMaskEvent(self.window.x.display, Int::max_value(), &mut xev) }; +            let res = unsafe { ffi::XCheckMaskEvent(self.window.x.display, -1, &mut xev) };              if res == 0 {                  let res = unsafe { ffi::XCheckTypedEvent(self.window.x.display, ffi::ClientMessage, &mut xev) }; @@ -192,12 +189,12 @@ impl<'a> Iterator for PollEventsIterator<'a> {                              mem::transmute(buffer.as_mut_ptr()),                              buffer.len() as libc::c_int, ptr::null_mut(), ptr::null_mut()); -                        str::from_utf8(&buffer.as_slice()[..count as usize]).unwrap_or("").to_string() +                        str::from_utf8(&buffer[..count as usize]).unwrap_or("").to_string()                      };                      {                          let mut pending = self.window.pending_events.lock().unwrap(); -                        for chr in written.as_slice().chars() { +                        for chr in written.chars() {                              pending.push_back(ReceivedCharacter(chr));                          }                      } @@ -445,8 +442,6 @@ impl Window {          // creating IM          let im = unsafe { -            // XOpenIM doesn't seem to be thread-safe -            static GLOBAL_XOPENIM_LOCK: StaticMutex = MUTEX_INIT;              let _lock = GLOBAL_XOPENIM_LOCK.lock().unwrap();              let im = ffi::XOpenIM(display, ptr::null(), ptr::null_mut(), ptr::null_mut()); @@ -681,7 +676,7 @@ impl Window {      pub fn create_window_proxy(&self) -> WindowProxy {          WindowProxy { -            x: self.x.downgrade() +            x: self.x.clone()          }      } @@ -828,7 +823,7 @@ impl Window {          1.0      } -    pub fn set_cursor_position(&self, x: i32, y: i32) -> Result<(), ()> { +    pub fn set_cursor_position(&self, _x: i32, _y: i32) -> Result<(), ()> {          unimplemented!();      }  } | 
