gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

window -> window_service

Browse Source
This commit is contained in:
Greg Fitzgerald
2018-09-07 12:18:48 -06:00
parent 9693de1867
commit e9f44b6661
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/retransmit_stage.rs
View File

@ -95,7 +95,7 @@ impl RetransmitStage {
retransmit_receiver, retransmit_receiver,
); );
let (blob_sender, blob_receiver) = channel(); let (blob_sender, blob_receiver) = channel();
let t_window = window::window( let t_window = window::window_service(
crdt.clone(), crdt.clone(),
window, window,
entry_height, entry_height,

10
src/window.rs
View File

@ -600,7 +600,7 @@ pub fn new_window_from_entries(
initialized_window(&node_info, blobs, entry_height) initialized_window(&node_info, blobs, entry_height)
} }
pub fn window( pub fn window_service(
crdt: Arc<RwLock<Crdt>>, crdt: Arc<RwLock<Crdt>>,
window: SharedWindow, window: SharedWindow,
entry_height: u64, entry_height: u64,
@ -690,7 +690,7 @@ mod test {
use streamer::{blob_receiver, receiver, responder, BlobReceiver, PacketReceiver}; use streamer::{blob_receiver, receiver, responder, BlobReceiver, PacketReceiver};
use window::{ use window::{
blob_idx_in_window, calculate_highest_lost_blob_index, default_window, repair_backoff, blob_idx_in_window, calculate_highest_lost_blob_index, default_window, repair_backoff,
window, WINDOW_SIZE, window_service, WINDOW_SIZE,
}; };
fn get_msgs(r: PacketReceiver, num: &mut usize) { fn get_msgs(r: PacketReceiver, num: &mut usize) {
@ -798,7 +798,7 @@ mod test {
let (s_window, r_window) = channel(); let (s_window, r_window) = channel();
let (s_retransmit, r_retransmit) = channel(); let (s_retransmit, r_retransmit) = channel();
let win = default_window(); let win = default_window();
let t_window = window( let t_window = window_service(
subs, subs,
win, win,
0, 0,
@ -868,7 +868,7 @@ mod test {
let (s_window, _r_window) = channel(); let (s_window, _r_window) = channel();
let (s_retransmit, r_retransmit) = channel(); let (s_retransmit, r_retransmit) = channel();
let win = default_window(); let win = default_window();
let t_window = window( let t_window = window_service(
subs.clone(), subs.clone(),
win, win,
0, 0,
@ -931,7 +931,7 @@ mod test {
let (s_window, _r_window) = channel(); let (s_window, _r_window) = channel();
let (s_retransmit, r_retransmit) = channel(); let (s_retransmit, r_retransmit) = channel();
let win = default_window(); let win = default_window();
let t_window = window( let t_window = window_service(
subs.clone(), subs.clone(),
win, win,
0, 0,