shmem 0.2.0

Shared memory across processes.
Documentation 
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

use std::mem;
use std::ptr;
use std::ops::Deref;
use std::marker::PhantomData;

use libc::{c_void, size_t};

use nix::sys::mman::{mmap, munmap};
use nix::sys::mman::{PROT_READ};
use nix::sys::mman::{MAP_SHARED};

use Safe;
use error::{self, Error};
use object::Object;

/// A mapping from a shared object to a type.
pub struct Reference<'a, T: Safe> {
	object:  &'a Object,
	address: *mut c_void,

	_marker: PhantomData<T>,
}

impl<'a, T: Safe> Reference<'a, T> {
	/// Create a new mapping.
	pub fn new(object: &'a Object) -> error::Result<Reference<'a, T>> {
		let size = mem::size_of::<T>() as isize;

		if size > object.size {
			return Err(Error::WrongSize);
		}

		let address = try!(mmap(ptr::null_mut(), object.size as size_t, PROT_READ, MAP_SHARED, object.fd, 0));

		Ok(Reference {
			object:  object,
			address: address,

			_marker: PhantomData,
		})
	}
}

impl<'a, T: Safe> Deref for Reference<'a, T> {
	type Target = T;

	fn deref(&self) -> &Self::Target {
		unsafe {
			(self.address as *const _ as *const _).as_ref().unwrap()
		}
	}
}

impl<'a, T: Safe> Drop for Reference<'a, T> {
	fn drop(&mut self) {
		munmap(self.address, self.object.size as size_t).unwrap();
	}
}