Skip to content

Commit

Permalink
Merge pull request #1 from poanetwork/master
Browse files Browse the repository at this point in the history
Migrate from `tokio_core` to `tokio`.
  • Loading branch information
NikVolf authored Aug 28, 2018
2 parents 9a93726 + b4c9d87 commit a607e28
Show file tree
Hide file tree
Showing 2 changed files with 39 additions and 67 deletions.
6 changes: 3 additions & 3 deletions Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "tokio-named-pipes"
version = "0.1.0"
version = "0.2.0"
authors = ["Alex Crichton <alex@alexcrichton.com>"]
license = "MIT/Apache-2.0"
readme = "README.md"
Expand All @@ -12,8 +12,8 @@ Windows named pipe bindings for tokio.
"""

[dependencies]
tokio-core = "0.1"
tokio-io = "0.1"
mio = "0.6"
tokio = "0.1"
mio-named-pipes = { git = "https://github.com/alexcrichton/mio-named-pipes" }
futures = "0.1"
bytes = "0.4"
100 changes: 36 additions & 64 deletions src/lib.rs
Original file line number Diff line number Diff line change
@@ -1,138 +1,110 @@
#![cfg(windows)]

extern crate tokio_core;
extern crate tokio_io;
extern crate tokio;
extern crate bytes;
extern crate mio;
extern crate mio_named_pipes;
extern crate futures;

use std::ffi::OsStr;
use std::fmt;
use std::io::{self, Read, Write};
use std::io::{Read, Write};
use std::os::windows::io::*;

use futures::{Async, Poll};

#[allow(deprecated)]
use tokio_core::io::Io;
use bytes::{BufMut, Buf};

use tokio_core::reactor::{PollEvented, Handle};

use tokio_io::{AsyncRead, AsyncWrite};
use mio::Ready;
use tokio::reactor::{PollEvented2};
use tokio::io::{AsyncRead, AsyncWrite};

pub struct NamedPipe {
io: PollEvented<mio_named_pipes::NamedPipe>,
io: PollEvented2<mio_named_pipes::NamedPipe>,
}

impl NamedPipe {
pub fn new<P: AsRef<OsStr>>(p: P, handle: &Handle) -> io::Result<NamedPipe> {
NamedPipe::_new(p.as_ref(), handle)
pub fn new<P: AsRef<OsStr>>(p: P) -> std::io::Result<NamedPipe> {
NamedPipe::_new(p.as_ref())
}

fn _new(p: &OsStr, handle: &Handle) -> io::Result<NamedPipe> {
fn _new(p: &OsStr) -> std::io::Result<NamedPipe> {
let inner = try!(mio_named_pipes::NamedPipe::new(p));
NamedPipe::from_pipe(inner, handle)
NamedPipe::from_pipe(inner)
}

pub fn from_pipe(pipe: mio_named_pipes::NamedPipe,
handle: &Handle)
-> io::Result<NamedPipe> {
pub fn from_pipe(pipe: mio_named_pipes::NamedPipe)
-> std::io::Result<NamedPipe> {
Ok(NamedPipe {
io: try!(PollEvented::new(pipe, handle)),
io: PollEvented2::new(pipe),
})
}

pub fn connect(&self) -> io::Result<()> {
pub fn connect(&self) -> std::io::Result<()> {
self.io.get_ref().connect()
}

pub fn disconnect(&self) -> io::Result<()> {
pub fn disconnect(&self) -> std::io::Result<()> {
self.io.get_ref().disconnect()
}

pub fn poll_read(&self) -> Async<()> {
self.io.poll_read()
pub fn poll_read_ready_readable(&mut self) -> tokio::io::Result<Async<Ready>> {
self.io.poll_read_ready(Ready::readable())
}

pub fn poll_write(&self) -> Async<()> {
self.io.poll_write()
pub fn poll_write_ready(&mut self) -> tokio::io::Result<Async<Ready>> {
self.io.poll_write_ready()
}

fn io_mut(&mut self) -> &mut PollEvented<mio_named_pipes::NamedPipe> {
fn io_mut(&mut self) -> &mut PollEvented2<mio_named_pipes::NamedPipe> {
&mut self.io
}
}

impl Read for NamedPipe {
fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
self.io.read(buf)
}
}

impl Write for NamedPipe {
fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> {
self.io.write(buf)
}
fn flush(&mut self) -> io::Result<()> {
fn flush(&mut self) -> std::io::Result<()> {
self.io.flush()
}
}

#[allow(deprecated)]
impl Io for NamedPipe {
fn poll_read(&mut self) -> Async<()> {
<NamedPipe>::poll_read(self)
}

fn poll_write(&mut self) -> Async<()> {
<NamedPipe>::poll_write(self)
}
}

impl<'a> Read for &'a NamedPipe {
fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
(&self.io).read(buf)
}
}

impl<'a> Write for &'a NamedPipe {
fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> {
(&self.io).write(buf)
}

fn flush(&mut self) -> io::Result<()> {
fn flush(&mut self) -> std::io::Result<()> {
(&self.io).flush()
}
}

#[allow(deprecated)]
impl<'a> Io for &'a NamedPipe {
fn poll_read(&mut self) -> Async<()> {
<NamedPipe>::poll_read(self)
}

fn poll_write(&mut self) -> Async<()> {
<NamedPipe>::poll_write(self)
}
}


impl AsyncRead for NamedPipe {
unsafe fn prepare_uninitialized_buffer(&self, _: &mut [u8]) -> bool {
false
}

fn read_buf<B: BufMut>(&mut self, buf: &mut B) -> Poll<usize, io::Error> {
if let Async::NotReady = <NamedPipe>::poll_read(self) {
fn read_buf<B: BufMut>(&mut self, buf: &mut B) -> Poll<usize, std::io::Error> {
if let Async::NotReady = self.io.poll_read_ready(Ready::readable())? {
return Ok(Async::NotReady)
}

let mut stack_buf = [0u8; 1024];
let bytes_read = self.io_mut().read(&mut stack_buf);
match bytes_read {
Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => {
self.io_mut().need_read();
Err(ref e) if e.kind() == std::io::ErrorKind::WouldBlock => {
self.io_mut().clear_read_ready(Ready::readable())?;
return Ok(Async::NotReady);
},
Err(e) => Err(e),
Expand All @@ -145,19 +117,19 @@ impl AsyncRead for NamedPipe {
}

impl AsyncWrite for NamedPipe {
fn shutdown(&mut self) -> Poll<(), io::Error> {
fn shutdown(&mut self) -> Poll<(), std::io::Error> {
Ok(().into())
}

fn write_buf<B: Buf>(&mut self, buf: &mut B) -> Poll<usize, io::Error> {
if let Async::NotReady = <NamedPipe>::poll_write(self) {
fn write_buf<B: Buf>(&mut self, buf: &mut B) -> Poll<usize, std::io::Error> {
if let Async::NotReady = self.io.poll_write_ready()? {
return Ok(Async::NotReady)
}

let bytes_wrt = self.io_mut().write(buf.bytes());
match bytes_wrt {
Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => {
self.io_mut().need_write();
Err(ref e) if e.kind() == std::io::ErrorKind::WouldBlock => {
self.io_mut().clear_write_ready()?;
return Ok(Async::NotReady);
},
Err(e) => Err(e),
Expand Down

0 comments on commit a607e28

Please sign in to comment.