From 937816e67bb7de564c1e2096a9029f0a241453ef Mon Sep 17 00:00:00 2001
From: Sagar Dhawan <sagar@solana.com>
Date: Wed, 24 Jul 2019 12:46:10 -0700
Subject: [PATCH] Post warning if window service isn't receiving any data
 (#5269)

automerge
---
 core/src/window_service.rs | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/core/src/window_service.rs b/core/src/window_service.rs
index 39796482e6..55514273e1 100644
--- a/core/src/window_service.rs
+++ b/core/src/window_service.rs
@@ -214,6 +214,7 @@ impl WindowService {
                     .num_threads(sys_info::cpu_num().unwrap_or(NUM_THREADS) as usize)
                     .build()
                     .unwrap();
+                let mut now = Instant::now();
                 loop {
                     if exit.load(Ordering::Relaxed) {
                         break;
@@ -237,12 +238,19 @@ impl WindowService {
                     ) {
                         match e {
                             Error::RecvTimeoutError(RecvTimeoutError::Disconnected) => break,
-                            Error::RecvTimeoutError(RecvTimeoutError::Timeout) => (),
+                            Error::RecvTimeoutError(RecvTimeoutError::Timeout) => {
+                                if now.elapsed() > Duration::from_secs(30) {
+                                    warn!("Window does not seem to be receiving data. Ensure port configuration is correct...");
+                                    now = Instant::now();
+                                }
+                            }
                             _ => {
                                 inc_new_counter_error!("streamer-window-error", 1, 1);
                                 error!("window error: {:?}", e);
                             }
                         }
+                    } else {
+                        now = Instant::now();
                     }
                 }
             })