blockworks-foundation
/
solana-with-rpc-optimizations
mirror of https://github.com/blockworks-foundation/solana-with-rpc-optimizations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Cleanup demo

This commit is contained in:
Greg Fitzgerald 2018-02-19 12:25:57 -07:00
parent 0bead4d410
commit 10a70a238b
2 changed files with 18 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
README.md
View File

@ -30,24 +30,23 @@ extern crate silk;
use silk::historian::Historian; use silk::historian::Historian;
use silk::log::{verify_slice, Entry, Event}; use silk::log::{verify_slice, Entry, Event};
use std::{thread, time}; use std::{thread, time};
use std::sync::mpsc::SendError;
fn create_log(hist: &Historian) -> Vec<Entry> { fn create_log(hist: &Historian) -> Result<(), SendError<Event>> {
hist.sender.send(Event::Tick).unwrap(); hist.sender.send(Event::Tick)?;
thread::sleep(time::Duration::new(0, 100_000)); thread::sleep(time::Duration::new(0, 100_000));
hist.sender.send(Event::UserDataKey(0xdeadbeef)).unwrap(); hist.sender.send(Event::UserDataKey(0xdeadbeef))?;
thread::sleep(time::Duration::new(0, 100_000)); thread::sleep(time::Duration::new(0, 100_000));
hist.sender.send(Event::Tick).unwrap(); hist.sender.send(Event::Tick)?;
Ok(())
let entry0 = hist.receiver.recv().unwrap();
let entry1 = hist.receiver.recv().unwrap();
let entry2 = hist.receiver.recv().unwrap();
vec![entry0, entry1, entry2]
} }
fn main() { fn main() {
let seed = 0; let seed = 0;
let hist = Historian::new(seed); let hist = Historian::new(seed);
let entries = create_log(&hist); create_log(&hist).expect("send error");
drop(hist.sender);
let entries: Vec<Entry> = hist.receiver.iter().collect();
for entry in &entries { for entry in &entries {
println!("{:?}", entry); println!("{:?}", entry);
} }

19
src/bin/demo.rs
View File

@ -3,24 +3,23 @@ extern crate silk;
use silk::historian::Historian; use silk::historian::Historian;
use silk::log::{verify_slice, Entry, Event}; use silk::log::{verify_slice, Entry, Event};
use std::{thread, time}; use std::{thread, time};
use std::sync::mpsc::SendError;
fn create_log(hist: &Historian) -> Vec<Entry> { fn create_log(hist: &Historian) -> Result<(), SendError<Event>> {
hist.sender.send(Event::Tick).unwrap(); hist.sender.send(Event::Tick)?;
thread::sleep(time::Duration::new(0, 100_000)); thread::sleep(time::Duration::new(0, 100_000));
hist.sender.send(Event::UserDataKey(0xdeadbeef)).unwrap(); hist.sender.send(Event::UserDataKey(0xdeadbeef))?;
thread::sleep(time::Duration::new(0, 100_000)); thread::sleep(time::Duration::new(0, 100_000));
hist.sender.send(Event::Tick).unwrap(); hist.sender.send(Event::Tick)?;
Ok(())
let entry0 = hist.receiver.recv().unwrap();
let entry1 = hist.receiver.recv().unwrap();
let entry2 = hist.receiver.recv().unwrap();
vec![entry0, entry1, entry2]
} }
fn main() { fn main() {
let seed = 0; let seed = 0;
let hist = Historian::new(seed); let hist = Historian::new(seed);
let entries = create_log(&hist); create_log(&hist).expect("send error");
drop(hist.sender);
let entries: Vec<Entry> = hist.receiver.iter().collect();
for entry in &entries { for entry in &entries {
println!("{:?}", entry); println!("{:?}", entry);
} }