File tree Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -234,13 +234,16 @@ pub fn start_clock_runloop(mut slot_time: u64) -> (Receiver<ClockEvent>, Sender<
234234
235235#[ cfg( windows) ]
236236fn start_geyser_runloop (
237- plugin_config_paths : Vec < PathBuf > ,
238- plugin_manager_commands_rx : Receiver < PluginManagerCommand > ,
239- subgraph_commands_tx : Sender < SubgraphCommand > ,
240- simnet_events_tx : Sender < SimnetEvent > ,
241- geyser_events_rx : Receiver < GeyserEvent > ,
237+ _plugin_config_paths : Vec < PathBuf > ,
238+ _plugin_manager_commands_rx : Receiver < PluginManagerCommand > ,
239+ _subgraph_commands_tx : Sender < SubgraphCommand > ,
240+ _simnet_events_tx : Sender < SimnetEvent > ,
241+ _geyser_events_rx : Receiver < GeyserEvent > ,
242242) -> Result < JoinHandle < Result < ( ) , String > > , String > {
243- Ok ( ( ) )
243+ let handle = hiro_system_kit:: thread_named ( "Geyser Plugins Handler" )
244+ . spawn ( move || Ok ( ( ) ) )
245+ . map_err ( |e| format ! ( "Failed to spawn Geyser Plugins Handler thread: {:?}" , e) ) ?;
246+ Ok ( handle)
244247}
245248
246249#[ cfg( not( windows) ) ]
You can’t perform that action at this time.
0 commit comments