Lines Matching refs:handler
229 handler: ProxyHandler<S>, field
241 self.handler.0.worker_count.fetch_add(1, Relaxed); in set_available()
246 let count = self.handler.0.worker_count.fetch_sub(1, SeqCst); in set_available()
253 if count == 1 && !self.handler.0.task_queue.is_empty() { in set_available()
254 self.handler.start_worker(None, None); in set_available()
262 self.handler.0.state.handle_worker_error(error); in run()
301 let handler = &self.handler.0; in run_() localVariable
306 } = handler.state.new_store(req_id)?; in run_()
308 let request_timeout = handler.state.request_timeout(); in run_()
309 let idle_instance_timeout = handler.state.idle_instance_timeout(); in run_()
310 let max_instance_reuse_count = handler.state.max_instance_reuse_count(); in run_()
312 handler.state.max_instance_concurrent_reuse_count(); in run_()
314 let proxy = &handler.instance_pre.instantiate_async(&mut store).await?; in run_()
353 let handler = self.handler.clone(); in run_() localVariable
370 handler.0.task_queue.pop() in run_()
631 handler: self.clone(), in start_worker()