diff options
| author | Janito Vaqueiro Ferreira Filho <janito@mullvad.net> | 2020-02-19 19:02:39 +0000 |
|---|---|---|
| committer | Janito Vaqueiro Ferreira Filho <janito@mullvad.net> | 2020-02-24 12:45:06 +0000 |
| commit | 35120cb77593edde22d6fa8686c1ba4bf824d91a (patch) | |
| tree | 7e177122e6abe8a2b5240a0f4d07bd24578928cb | |
| parent | 4669724ebd5e46bd5f06437b2e2c4fff8d84c3f1 (diff) | |
| download | mullvadvpn-35120cb77593edde22d6fa8686c1ba4bf824d91a.tar.xz mullvadvpn-35120cb77593edde22d6fa8686c1ba4bf824d91a.zip | |
Rename `ManagementInterfaceEvent` into `Command`
| -rw-r--r-- | mullvad-daemon/src/lib.rs | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/mullvad-daemon/src/lib.rs b/mullvad-daemon/src/lib.rs index 67c6b96231..52ac7d2bdf 100644 --- a/mullvad-daemon/src/lib.rs +++ b/mullvad-daemon/src/lib.rs @@ -219,8 +219,8 @@ pub(crate) enum InternalDaemonEvent { mpsc::Sender<Result<TunnelParameters, ParameterGenerationError>>, u32, ), - /// An event coming from the JSONRPC-2.0 management interface. - ManagementInterfaceEvent(DaemonCommand), + /// A command sent to the daemon. + Command(DaemonCommand), /// Triggered if the server hosting the JSONRPC-2.0 management interface dies unexpectedly. ManagementInterfaceExited, /// Daemon shutdown triggered by a signal, ctrl-c or similar. @@ -249,7 +249,7 @@ impl From<TunnelStateTransition> for InternalDaemonEvent { impl From<DaemonCommand> for InternalDaemonEvent { fn from(command: DaemonCommand) -> Self { - InternalDaemonEvent::ManagementInterfaceEvent(command) + InternalDaemonEvent::Command(command) } } @@ -613,7 +613,7 @@ where GenerateTunnelParameters(tunnel_parameters_tx, retry_attempt) => { self.handle_generate_tunnel_parameters(&tunnel_parameters_tx, retry_attempt) } - ManagementInterfaceEvent(event) => self.handle_management_interface_event(event), + Command(event) => self.handle_management_interface_event(event), ManagementInterfaceExited => { return Err(Error::ManagementInterfaceExited); } @@ -850,12 +850,9 @@ where if let Err(mpsc::RecvTimeoutError::Timeout) = rx.recv_timeout(delay) { debug!("Attempting to reconnect"); - let _ = tunnel_command_tx.unbounded_send( - InternalDaemonEvent::ManagementInterfaceEvent(DaemonCommand::SetTargetState( - result_tx, - TargetState::Secured, - )), - ); + let _ = tunnel_command_tx.unbounded_send(InternalDaemonEvent::Command( + DaemonCommand::SetTargetState(result_tx, TargetState::Secured), + )); } }); } |
