names
This commit is contained in:
parent
3eb005d492
commit
9f2086c772
|
@ -59,7 +59,7 @@ pub fn receiver(
|
||||||
panic!("streamer::receiver set_read_timeout error");
|
panic!("streamer::receiver set_read_timeout error");
|
||||||
}
|
}
|
||||||
Builder::new()
|
Builder::new()
|
||||||
.name("receiver".to_string())
|
.name("solana-receiver".to_string())
|
||||||
.spawn(move || {
|
.spawn(move || {
|
||||||
let _ = recv_loop(&sock, &exit, &recycler, &packet_sender);
|
let _ = recv_loop(&sock, &exit, &recycler, &packet_sender);
|
||||||
()
|
()
|
||||||
|
@ -100,7 +100,7 @@ pub fn responder(
|
||||||
r: BlobReceiver,
|
r: BlobReceiver,
|
||||||
) -> JoinHandle<()> {
|
) -> JoinHandle<()> {
|
||||||
Builder::new()
|
Builder::new()
|
||||||
.name("responder".to_string())
|
.name("solana-responder".to_string())
|
||||||
.spawn(move || loop {
|
.spawn(move || loop {
|
||||||
if recv_send(&sock, &recycler, &r).is_err() && exit.load(Ordering::Relaxed) {
|
if recv_send(&sock, &recycler, &r).is_err() && exit.load(Ordering::Relaxed) {
|
||||||
break;
|
break;
|
||||||
|
@ -131,7 +131,7 @@ pub fn blob_receiver(
|
||||||
let timer = Duration::new(1, 0);
|
let timer = Duration::new(1, 0);
|
||||||
sock.set_read_timeout(Some(timer))?;
|
sock.set_read_timeout(Some(timer))?;
|
||||||
let t = Builder::new()
|
let t = Builder::new()
|
||||||
.name("blob_receiver".to_string())
|
.name("solana-blob_receiver".to_string())
|
||||||
.spawn(move || loop {
|
.spawn(move || loop {
|
||||||
if exit.load(Ordering::Relaxed) {
|
if exit.load(Ordering::Relaxed) {
|
||||||
break;
|
break;
|
||||||
|
@ -330,7 +330,7 @@ pub fn window(
|
||||||
retransmit: BlobSender,
|
retransmit: BlobSender,
|
||||||
) -> JoinHandle<()> {
|
) -> JoinHandle<()> {
|
||||||
Builder::new()
|
Builder::new()
|
||||||
.name("window".to_string())
|
.name("solana-window".to_string())
|
||||||
.spawn(move || {
|
.spawn(move || {
|
||||||
let mut consumed = 0;
|
let mut consumed = 0;
|
||||||
let mut received = 0;
|
let mut received = 0;
|
||||||
|
@ -428,7 +428,7 @@ pub fn broadcaster(
|
||||||
r: BlobReceiver,
|
r: BlobReceiver,
|
||||||
) -> JoinHandle<()> {
|
) -> JoinHandle<()> {
|
||||||
Builder::new()
|
Builder::new()
|
||||||
.name("retransmitter".to_string())
|
.name("solana-broadcaster".to_string())
|
||||||
.spawn(move || {
|
.spawn(move || {
|
||||||
let mut transmit_index = 0;
|
let mut transmit_index = 0;
|
||||||
loop {
|
loop {
|
||||||
|
@ -479,7 +479,7 @@ pub fn retransmitter(
|
||||||
r: BlobReceiver,
|
r: BlobReceiver,
|
||||||
) -> JoinHandle<()> {
|
) -> JoinHandle<()> {
|
||||||
Builder::new()
|
Builder::new()
|
||||||
.name("retransmitter".to_string())
|
.name("solana-retransmitter".to_string())
|
||||||
.spawn(move || {
|
.spawn(move || {
|
||||||
trace!("retransmitter started");
|
trace!("retransmitter started");
|
||||||
loop {
|
loop {
|
||||||
|
|
Loading…
Reference in New Issue