4 releases
0.2.1 | Nov 23, 2019 |
---|---|
0.2.0 | Nov 22, 2019 |
0.1.1 | Aug 13, 2019 |
0.1.0 | Aug 13, 2019 |
#9 in #uds
11KB
166 lines
Dusk Unix Domain Sockets
Minimalistic boilerplate for std::os::unix::net::UnixListener
bindings.
Complies with the log facade.
Installation
Add this to your Cargo.toml
:
[dependencies]
dusk-uds = "0.1"
Example
use std::{
future::Future,
io::{Read, Write},
os::unix::net::UnixStream,
pin::Pin,
task::Context,
task::Poll,
};
use dusk_uds::*;
// This structure will handle the incoming sockets
struct MyFuture {
socket: Option<UnixStream>,
}
// Optional implementation of default to facilitate the clone
impl Default for MyFuture {
fn default() -> Self {
MyFuture { socket: None }
}
}
// Clone implementation is mandatory, for this instance will be shared amongst the worker threads
// with provided ownership.
impl Clone for MyFuture {
fn clone(&self) -> Self {
MyFuture::default()
}
}
// Allow the UDS provider to send the socket to the structure before the poll
impl TaskProvider for MyFuture {
fn set_socket(&mut self, socket: UnixStream) {
self.socket.replace(socket);
}
}
// Standard future implementation.
//
// Will read a byte from the socket, multiply it by 2, and write the result.
//
// If the provided byte is 0, will quit
impl Future for MyFuture {
type Output = Message;
fn poll(mut self: Pin<&mut Self>, _cx: &mut Context) -> Poll<Self::Output> {
let mut buffer = [0x00u8];
let socket = self.socket.as_mut().unwrap();
socket.read_exact(&mut buffer).unwrap();
buffer[0] *= 2;
if buffer[0] == 0 {
return Poll::Ready(Message::ShouldQuit);
}
socket.write_all(&buffer).unwrap();
Poll::Ready(Message::Success)
}
}
fn main() {
// The first parameter is the path of the socket
// The second, the options, if there is the need to customize the UDS somehow
// The third, is the Future implementation that will handle the incoming sockets
UnixDomainSocket::new("/tmp/dusk-socket", None, MyFuture::default())
.bind()
.unwrap();
}
Dependencies
~0.7–1MB
~19K SLoC