#packet #ipc #servo #c

packet-ipc

Share packets between services using servo ipc

9 releases (breaking)

✓ Uses Rust 2018 edition

0.8.0 May 20, 2019
0.6.0 Apr 26, 2019
0.4.0 Mar 22, 2019

#274 in Asynchronous

Download history 18/week @ 2019-10-30 16/week @ 2019-11-06 35/week @ 2019-11-13 29/week @ 2019-11-20 37/week @ 2019-11-27 26/week @ 2019-12-04 575/week @ 2019-12-11 26/week @ 2019-12-18 15/week @ 2019-12-25 21/week @ 2020-01-01 83/week @ 2020-01-08 43/week @ 2020-01-15 8/week @ 2020-01-22 11/week @ 2020-01-29 1/week @ 2020-02-05

327 downloads per month

MIT license

20KB
433 lines

packet-ipc

build status crates.io version docs.rs docs MIT licensed

Library to share packets between processes using servo's ipc-channel.

Attempts to be as efficient as possible while still allowing packets to be used with C FFI.

A packet is defined for this library as any structure which implements AsIpcPacket.

Usage

A server must be created before a client, since the client will use the server's name to connect.

To start, create a server, and accept a connection:

let server = Server::new().expect("Failed to build server");
let server_name = server.name.clone();
let connection = futures::spawn(server.accept()).expect("No connection formed");

Once a server is created, you can then use the server's name to create a client:

let client = Client::new(server_name.clone()).expect("Failed to connect");

At this point, you can send packets to the client:

connection.send(Some(packets)).expect("Failed to send");

or tell the client you are done sending packets:

connection.send(None).expect("Failed to send");

and close the connection:

connection.close();

The client is immediately available for use, and can receive packets using:

let opt_packets = client.receive_packets(size).expect("Failed to receive packets");
if Some(packets) = opt_packets {
    process_packets(packets);
} //else server is closed

Streaming Packets to Client

Once a connection is formed, it can be used with a stream of packets:

let stream_result = packets_stream.transfer_ipc(connection).collect().wait();

Dependencies

~3.5MB
~76K SLoC