From 77a76f0783d36056818b14d870f995722286c127 Mon Sep 17 00:00:00 2001
From: Greg Fitzgerald <garious@gmail.com>
Date: Wed, 9 May 2018 08:11:19 -0600
Subject: [PATCH] Record a batch of events

---
 src/tpu.rs | 17 ++++-------------
 1 file changed, 4 insertions(+), 13 deletions(-)

diff --git a/src/tpu.rs b/src/tpu.rs
index 6da34e1332..19cc1a7960 100644
--- a/src/tpu.rs
+++ b/src/tpu.rs
@@ -367,20 +367,11 @@ impl Tpu {
 
     /// Process the transactions in parallel and then log the successful ones.
     fn process_events(&self, events: Vec<Event>) -> Result<()> {
-        for result in self.acc.lock().unwrap().process_verified_events(events) {
-            if let Ok(event) = result {
-                self.historian_input
-                    .lock()
-                    .unwrap()
-                    .send(Signal::Event(event))?;
-            }
-        }
-
-        // Let validators know they should not attempt to process additional
-        // transactions in parallel.
-        self.historian_input.lock().unwrap().send(Signal::Tick)?;
+        let results = self.acc.lock().unwrap().process_verified_events(events);
+        let events = results.into_iter().filter_map(|x| x.ok()).collect();
+        let sender = self.historian_input.lock().unwrap();
+        sender.send(Signal::Events(events))?;
         debug!("after historian_input");
-
         Ok(())
     }