Searched refs:ControlCommand (Results 1 – 9 of 9) sorted by relevance
54 enum ControlCommand { enum88 command_tx: Option<mpsc::UnboundedSender<ControlCommand>>,97 command_rx: mpsc::UnboundedReceiver<ControlCommand>,140 self.command_tx.as_ref().unwrap().send(ControlCommand::CloseConnection)?; in stop()207 command_tx.send(ControlCommand::Stats { resp: resp_tx })?; in request_stats()232 .send(ControlCommand::StatsClearQueries) in stats_clear_queries()252 let (command_tx, command_rx) = mpsc::unbounded_channel::<ControlCommand>(); in init_worker_thread_params()401 ControlCommand::Stats {resp} => { in worker_thread()413 ControlCommand::StatsClearQueries => queries_received = 0, in worker_thread()414 ControlCommand::CloseConnection => { in worker_thread()
297 proto::ControlCommand controlCommand; in applyPipeConfigs()309 proto::ControlCommand controlCommand; in resetPipeConfigs()317 proto::ControlCommand controlCommand; in startPipe()325 proto::ControlCommand controlCommand; in stopPipe()356 proto::ControlCommand controlCommand; in releaseRunner()
112 proto::ControlCommand controlCommand; in startPipeProfiling()123 proto::ControlCommand controlCommand; in stopPipeProfiling()134 proto::ControlCommand controlCommand2; in stopPipeProfiling()174 proto::ControlCommand controlCommand; in releaseDebugger()
45 virtual Status processClientCommand(const proto::ControlCommand& command) = 0;
34 MOCK_METHOD1(processClientCommand, Status(const proto::ControlCommand&));
218 proto::ControlCommand command; in TEST_F()250 proto::ControlCommand command; in TEST_F()
41 message ControlCommand { message
101 Status processClientCommand(const proto::ControlCommand& command) override;
116 Status DefaultEngine::processClientCommand(const proto::ControlCommand& command) { in processClientCommand()