use crate::capability::FromClientHook;
use crate::private::capability::{ClientHook, PipelineHook, PipelineOp};
use crate::private::layout::{PointerReader, PointerBuilder};
use crate::traits::{FromPointerReader, FromPointerBuilder, SetPointerBuilder};
use crate::Result;
#[derive(Copy, Clone)]
pub struct Owned(());
impl <'a> crate::traits::Owned<'a> for Owned {
type Reader = Reader<'a>;
type Builder = Builder<'a>;
}
impl crate::traits::Pipelined for Owned {
type Pipeline = Pipeline;
}
#[derive(Copy, Clone)]
pub struct Reader<'a> {
reader: PointerReader<'a>
}
impl <'a> Reader<'a> {
#[inline]
pub fn new<'b>(reader: PointerReader<'b>) -> Reader<'b> {
Reader { reader: reader }
}
#[inline]
pub fn is_null(&self) -> bool {
self.reader.is_null()
}
pub fn target_size(&self) -> Result<crate::MessageSize> {
self.reader.total_size()
}
#[inline]
pub fn get_as<T: FromPointerReader<'a>>(&self) -> Result<T> {
FromPointerReader::get_from_pointer(&self.reader, None)
}
pub fn get_as_capability<T: FromClientHook>(&self) -> Result<T> {
Ok(FromClientHook::new(self.reader.get_capability()?))
}
pub fn get_pipelined_cap(&self, ops: &[PipelineOp]) -> Result<Box<dyn ClientHook>> {
let mut pointer = self.reader;
for op in ops {
match *op {
PipelineOp::Noop => { }
PipelineOp::GetPointerField(idx) => {
pointer = pointer.get_struct(None)?.get_pointer_field(idx as usize);
}
}
}
pointer.get_capability()
}
}
impl <'a> FromPointerReader<'a> for Reader<'a> {
fn get_from_pointer(reader: &PointerReader<'a>, default: Option<&'a [crate::Word]>) -> Result<Reader<'a>> {
if default.is_some() {
panic!("Unsupported: any_pointer with a default value.");
}
Ok(Reader { reader: *reader })
}
}
impl <'a> crate::traits::SetPointerBuilder<Builder<'a>> for Reader<'a> {
fn set_pointer_builder<'b>(mut pointer: crate::private::layout::PointerBuilder<'b>,
value: Reader<'a>,
canonicalize: bool) -> Result<()> {
pointer.copy_from(value.reader, canonicalize)
}
}
impl <'a> crate::traits::Imbue<'a> for Reader<'a> {
fn imbue(&mut self, cap_table: &'a crate::private::layout::CapTable) {
self.reader.imbue(crate::private::layout::CapTableReader::Plain(cap_table));
}
}
pub struct Builder<'a> {
builder: PointerBuilder<'a>
}
impl <'a> Builder<'a> {
#[inline]
pub fn new<'b>(builder: PointerBuilder<'a>) -> Builder<'a> {
Builder { builder: builder }
}
pub fn reborrow<'b>(&'b mut self) -> Builder<'b> {
Builder { builder: self.builder.borrow() }
}
pub fn is_null(&self) -> bool {
self.builder.is_null()
}
pub fn target_size(&self) -> Result<crate::MessageSize> {
self.builder.into_reader().total_size()
}
pub fn get_as<T : FromPointerBuilder<'a>>(self) -> Result<T> {
FromPointerBuilder::get_from_pointer(self.builder, None)
}
pub fn init_as<T : FromPointerBuilder<'a>>(self) -> T {
FromPointerBuilder::init_pointer(self.builder, 0)
}
pub fn initn_as<T: FromPointerBuilder<'a>>(self, size: u32) -> T {
FromPointerBuilder::init_pointer(self.builder, size)
}
pub fn set_as<To, From : SetPointerBuilder<To>>(self, value: From) -> Result<()> {
SetPointerBuilder::<To>::set_pointer_builder(self.builder, value, false)
}
pub fn set_as_capability(&mut self, value: Box<dyn ClientHook>) {
self.builder.set_capability(value);
}
#[inline]
pub fn clear(&mut self) {
self.builder.clear()
}
pub fn into_reader(self) -> Reader<'a> {
Reader { reader: self.builder.into_reader() }
}
}
impl <'a> FromPointerBuilder<'a> for Builder<'a> {
fn init_pointer(mut builder: PointerBuilder<'a>, _len: u32) -> Builder<'a> {
if !builder.is_null() {
builder.clear();
}
Builder { builder: builder }
}
fn get_from_pointer(builder: PointerBuilder<'a>, default: Option<&'a [crate::Word]>) -> Result<Builder<'a>> {
if default.is_some() {
panic!("AnyPointer defaults are unsupported")
}
Ok(Builder { builder: builder })
}
}
impl <'a> crate::traits::ImbueMut<'a> for Builder<'a> {
fn imbue_mut(&mut self, cap_table: &'a mut crate::private::layout::CapTable) {
self.builder.imbue(crate::private::layout::CapTableBuilder::Plain(cap_table));
}
}
pub struct Pipeline {
pub hook: Box<dyn PipelineHook>,
ops: Vec<PipelineOp>,
}
impl Pipeline {
pub fn new(hook: Box<dyn PipelineHook>) -> Pipeline {
Pipeline { hook: hook, ops: Vec::new() }
}
pub fn noop(&self) -> Pipeline {
Pipeline { hook: self.hook.add_ref(), ops: self.ops.clone() }
}
pub fn get_pointer_field(&self, pointer_index: u16) -> Pipeline {
let mut new_ops = Vec::with_capacity(self.ops.len() + 1);
for op in &self.ops {
new_ops.push(*op)
}
new_ops.push(PipelineOp::GetPointerField(pointer_index));
Pipeline { hook : self.hook.add_ref(), ops: new_ops }
}
pub fn as_cap(&self) -> Box<dyn ClientHook> {
self.hook.get_pipelined_cap(&self.ops)
}
}
impl crate::capability::FromTypelessPipeline for Pipeline {
fn new(typeless: Pipeline) -> Pipeline {
typeless
}
}
#[test]
fn init_clears_value() {
let mut message = crate::message::Builder::new_default();
{
let root: crate::any_pointer::Builder = message.init_root();
let mut list: crate::primitive_list::Builder<u16> = root.initn_as(10);
for idx in 0..10 {
list.set(idx, idx as u16);
}
}
{
let root: crate::any_pointer::Builder = message.init_root();
assert!(root.is_null());
}
let mut output: Vec<u8> = Vec::new();
crate::serialize::write_message(&mut output, &mut message).unwrap();
assert_eq!(output.len(), 40);
for byte in &output[8..] {
assert_eq!(*byte, 0u8);
}
}